当前位置:首页 > CN2资讯 > 正文内容

我的世界java 开发文档 我的世界java版使用教程

1天前CN2资讯


前言

提起MySQL,其实网上已经有一大把教程了,为什么我还要写这篇文章呢,大概是因为网上很多网站都是比较零散,而且描述不够直观,不能系统对MySQL相关知识有一个系统的学习,导致不能形成知识体系。为此我撰写了这篇文章,试图让这些底层架构相关知识更加直观易懂:

  • 尽量以图文的方式描述技术原理;
  • 涉及到关键的技术,附加官网或者技术书籍来源,方便大家进一步扩展学习;
  • 涉及到的背景知识尽可能做一个交代,比如讨论到log buffer的刷盘方式,延伸一下IO写磁盘相关知识点。

好了,MySQL从不会到精通系列马上就要开始了(看完之后还是不会的话…请忽略这句话)。

1. 消息的可靠性投递

在使用 RabbitMQ 的时候,作为消息发送方希望杜绝任何消息丢失或者投递失败场景。

RabbitMQ 为我们提供了两种方式用来控制消息的投递可靠性模式。

confirm 确认模式:当消息从 producer 发送到 exchange 则会执行 confirmCallback中的confirm方法。

return 退回模式:当消息发送给Exchange后, Exchange将消息路由到queue失败会执行ReturnCallBack。

确认模式会返回{1.相关配置信息, 2.交换机是否成功接收到消息 , true 成功 false失败 3.失败原因 }

回退模式会返回{1.消息对象,2.错误码,3.错误信息,4.交换机名称,5.路由键}

2.Consumer ACK(消费者 ACK)

ack指Acknowledge,确认。 表示消费端收到消息后的确认方式。

RabbitMQ提供三种确认方式:

自动确认: acknowledge=“none” 当消息一旦被Consumer接收到,则自动确认收到,并将相应 message 从 RabbitMQ 的消息缓存中移除。

手动确认: acknowledge=“manual” 如果出现异常,则调用channel.basicNack()方法,让其自动重新发送消息。

根据异常情况确认:acknowledge=“auto”。

3. 消息过期(TTL)

TTL 全称 Time To Live(存活时间/过期时间)。当消息到达存活时间后,还没有被消费,会被自动清除。

RabbitMQ可以对消息设置过期时间,也可以对整个队列(Queue)设置过期时间。

消息过期, 可以让队列统一过期, 也可以让它单独的消息过期。

4. 死信队列

死信队列,英文缩写:DLX 。Dead Letter Exchange(死信交换机),当消息成为Dead message (死信)后,可以被重新发送到另一个交换机,这个交换机就是DLX。

消息成为死信的三种情况:

1.队列消息长度到达限制;

2.消费者拒接消费消息,并且不把消息重新放入原目标队列;

3.原队列存在消息过期设置,消息到达超时时间未被消费;

死信队列和死信交换机:
死信队列和死信交换机与正常的队列和交换机一模一样, 没有任何区别 !!

如何实现队列与死信交换机绑定 , 给队列设置如下参数:

  • x-dead-letter-exchange : 设置死信交换机
  • x-dead-letter-routing-key : 设置死信路由key

5. 延迟队列

消息进入队列后不会立即被消费,只有到达指定时间后,才会被消费。 例如:

延迟队列是一个很强大的功能 , 但是在RabbitMQ中并没有提供延迟队列功能。

可以使用:TTL(消息过期)+死信队列组合实现延迟队列的效果。

实现流程图如下 :

6. 消费端限流

当系统峰值比较高的时候 , 我们我们可以使用RabbitMQ实现削峰填谷, 让我们系统处理的请求更加平稳

实现步骤

  • 设置akc机制为手动确认
  • 配置监听容器
  • 7.RabbitMQ应用问题 (消息补偿机制)

    我们通过之前的消息可靠性投递 , ACK 确认机制 , 以及死信队列 , 基本上已经能够保证消息投递成功了 !

    为什么还要消息补偿机制呢? 难道消息还会丢失,没错,系统是在一个复杂的环境,不要想的太简单了,虽然以上的三种方案,基本可以保证消息的高可用不丢失的问题,但是作为有追求的程序员来讲,要绝对保证我的系统的稳定性,有一种危机意识。

    比如:持久化的消息,保存到硬盘过程中,当前队列节点挂了,存储节点硬盘又坏了,消息丢了,怎么办?

    产线网络环境太复杂,所以不知数太多,所以要做消息补偿机制 !

    消息补偿机制需要建立在业务数据库和MQ数据库的基础之上 , 当我们发送消息时 , 需要同时将消息数据保存在数据库中, 两者的状态必须记录。 然后通过业务数据库和MQ数据库的对比检查消费是否成功,不成功,进行消息补偿措施,重新发送消息处理

    更多:Java进阶核心知识集

    包含:JVM,JAVA集合,网络,JAVA多线程并发,JAVA基础,Spring原理,微服务,Zookeeper,Kafka,RabbitMQ,Hbase,MongoDB,Cassandra,设计模式,负载均衡,数据库,一致性哈希,JAVA算法,数据结构,加密算法,分布式缓存等等

      你可能想看:

      扫描二维码推送至手机访问。

      版权声明:本文由皇冠云发布,如需转载请注明出处。

      本文链接:https://www.idchg.com/info/21634.html

      分享给朋友:

      “我的世界java 开发文档 我的世界java版使用教程” 的相关文章

      如何在Ubuntu上安装BBR Plus以提高网络性能

      在谈论BBR Plus之前,我们得先来了解一下BBR。BBR即“Bottleneck Bandwidth and Round-trip time”的缩写,这是Google推出的一种拥塞控制算法,它被集成在最新的Linux内核中。它的核心理念在于通过更合理的方式来计算网络的瓶颈带宽和往返时间。这种算法...

      VPS是干嘛用的:解析虚拟专用服务器的优势与应用

      在当今互联网的快速发展下,VPS(Virtual Private Server,虚拟专用服务器)逐渐成为了个人和企业首选的主机类型。简单来说,VPS就是一种将物理服务器分割成多个虚拟服务器的技术。每个虚拟服务器都能独立运行操作系统,用户可以自由管理自己的环境,就像拥有一台独立的服务器一样。VPS通过...

      台湾VPS:高效、稳定且安全的虚拟专用服务器解决方案

      台湾VPS,即虚拟专用服务器,是一种通过虚拟化技术将物理服务器划分为多个独立服务器的解决方案。这种服务不仅为用户提供独享的资源和灵活的管理权限,还能够提升性能和效率。在我使用台湾VPS的过程中,它让我深刻体会到这一技术的便利与强大。 台湾VPS的独特之处在于其地理位置和网络基础设施。位于东亚的台湾,...

      IPv6 测速方法与工具:提升网络体验的技巧

      IPv6 测速的基本概念 IPv6,作为互联网协议的最新版本,让我们在网络世界中畅游无阻。它的推出旨在解决IPv4所面临的地址枯竭问题,推进更加广泛的设备连接。简单来说,IPv6提供了更大的地址空间,能够支持越来越多的设备上线。因为万物互联的时代已经来临,我们的手机、电脑、家居设备甚至汽车都需要连接...

      选择无限流量VPS的最佳指南与注意事项

      在当今互联网时代,网站托管和服务器选择变得尤为重要。其中,VPS(虚拟专用服务器)成为许多企业和个人用户的优选。而无限流量VPS则更加受到青睐。简单来说,无限流量VPS是一种提供几乎无限数据传输的虚拟服务器服务。它让用户可以在不必担心流量限制情况下,安心地运行网站、应用或其他网络服务。 无限流量VP...

      选择Cogent VPS的理由:稳定性、灵活性与优质支持

      谈到虚拟专用服务器(VPS),我想很多人可能会对这个概念产生好奇。VPS是一种将物理服务器分割成多个虚拟服务器的技术。每个VPS都有独立的操作系统和资源,这与共享主机有很大不同。共享主机的用户资源是共用的,而VPS用户则有更多的控制权和灵活性。这种架构使得VPS成为中小企业和开发者的理想选择。 接下...