SpringBoot-RabbitMQ06-持久化和ACK确认机制-阿里云开发者社区

开发者社区> 游客a74jvhcp7vclg> 正文

SpringBoot-RabbitMQ06-持久化和ACK确认机制

简介: 消息的可靠性是 RabbitMQ 的一大特色,那么 RabbitMQ 是如何保证消息可靠性的呢——消息持久化。
+关注继续查看


持久化

 消息的可靠性是 RabbitMQ 的一大特色,那么 RabbitMQ 是如何保证消息可靠性的呢——消息持久化。

创建两个项目

服务消费者

image.png

image.png

服务提供者

image.png

我们在提供者处每隔两秒发送一个消息到交换器中,如下

@RunWith(SpringRunner.class)
@SpringBootTest(classes = RabbitmqDirectProviderApplication.class)
public class RabbitmqDirectProviderApplicationTests {

    @Autowired
    private Sender sender;

    @Test
    public void contextLoads() throws Exception{
        int flag = 0;
        while(true){
            Thread.sleep(2000);
            sender.send("hello .... "+flag++);
        }
    }
}

启动消费者和服务提供者

image.png

当我们在15的时候关闭消费者,然后在启动消费者我们看情况。

image.png

我们会发现在消费者下线的这段时间产生的消息并没有丢失

image.png

autoDelete 属性

@Queue: 当所有消费客户端连接断开后,是否自动删除队列

true:删除 false:不删除

@Exchange:当所有绑定队列都不在使用时,是否自动删除交换器

true:删除 false:不删除

ACK确认机制

1.什么是消息确认ACK?

 如果在处理消息的过程中,消费者的服务器在处理消息时出现异常,那么可能这条正在处理的消息刘没有完成消息消费,数据就会丢失,为了确保数据不会丢失RabbitMQ支持消息确认-ACK

2.ACK的消息确认机制

 ACK机制是消费者从RabbitMQ收到消息并处理完成后,反馈给RabbitMQ的,RabbitMQ收到反馈后才将此消息从队列中删除。

   如果一个消费者在处理消息出现了网络不稳定、服务器异常等现象,会将消息重新放入队列中。

   如果在集群的情况下,RabbitMQ会立即将这个消息推送给这个在线的其他消费者,这种机制保证了在消费者服务端故障的时候,不会丢失任何消息和任务。

   消息永远不会从RabbitMQ中删除:只有当消费者正确发送ACK反馈,RabbitMQ确认收到后,消息才会从RabbitMQ服务器的数据中删除。

   消息的ACK确认机制默认是打开的

演示ACK场景,消费的异常

image.png

image.png

消费者在一直弹出异常信息,说明消息一直被重复的添加到队列中

image.png

3.ACK机制的开发注意事项

 如果忘记ACK,那么后果会很严重,当Consumer退出时,Message会一直重新分发,然后RabbitMQ会占用越来越多的内存,由于RabbitMQ会长时间运行,因此这个“内存泄漏”是致命的。我们可以通过设置重试的次数要防止这个问题

在consumer的application.properties中添加如下配置

spring.rabbitmq.listener.direct.retry.enabled=true
# 重试次数 默认为3次
spring.rabbitmq.listener.direct.retry.max-attempts=5

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
Gear的技术优势
Gear 关键的技术创新在于其新颖的跨合约通信方式。Gear 使用 Actor 通信模型和 WebAssembly VM,支持并行处理,并具有速度快、成本低的优势。 事实证明, WebAssembly VM 比任何其他方案运行速度都要快。使用 WebAssembly 可以让 GEAR 的智能合约直接编译成机器码,运行速度媲美原生。更快的速度意味着更低的交易成本和更高的效率。
9 0
第三期线上 Workshop 回顾
由 GearFans 举办的 “Gear 中文第三期线上 Workshop” 于 2022 年 1 月 18 日通过腾讯会议举行。
11 0
match-trade超高效的交易所撮合引擎
match-trade超高效的交易所撮合引擎
9 0
工商银行实时大数据平台建设历程及展望
中国工商银行大数据平台负责人袁一在 FFA 2021 的分享
239 0
基于交通工具联网的数据分析
截止到2021年年底,包括中国在内的国家和地区超过一半以上的新组装车辆都已配备了互联网接口。当前全球联网车数量已经超过了3亿辆... ...
12 0
Hyperf结合Redis异步队列任务async-queue实现后台操作日志写入
Hyperf结合Redis异步队列任务async-queue实现后台操作日志写入
4 0
MQTT知识大全【科普贴】
MQTT(Message Queuing Telemetry Transport,消息队列遥测传输协议),是一种基于客户端与服务器之间发布/订阅(publish/subscribe)模式的"轻量级"通讯协议。为了保证通讯的安全性和可靠性,该协议基于TCP/IP协议构建。由IBM在1999年发布,最初被用于石油管道传感器与卫星的通讯连接,2014年,它正式成为一个OASIS开放标准并得到了大量开源语言的支持。
10 0
Socket粘包问题终极解决方案—Netty版(2W字)!(4)
Socket粘包问题终极解决方案—Netty版(2W字)!(4)
11 0
完美避坑!记一次Elasticsearch集群迁移架构实战
Elastic自身设计了集群分片的负载平衡机制,当有新数据节点加入集群或者离开集群,集群会自动平衡分片的负载分布。
7 0
+关注
游客a74jvhcp7vclg
10余年开发架构经验,同时乐于技术分享!
332
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
《2021云上架构与运维峰会演讲合集》
立即下载
《零基础CSS入门教程》
立即下载
《零基础HTML入门教程》
立即下载