发送者
发送这端利用confirm保证消息可以顺利达到rabbitmq,消息开启持久化(Delivery Mode = 2). 发送者发送一个消息,到达rabbitmq,然后rabbitmq认为此消息需要持久化,经过内存到磁盘的过程,然后把消息返回给发送者端.
消息持久化
申明交换机持久化和队列持久化 rabbitmq接收到消息,会把消息从内存刷到磁盘的存储文件中.
消费者端
设置消息的ack,当消费者消费一个消息的时候,会返回给rabbitmq对应queue一个ack消息,这样就保证了消息消费完成.
转载请注明原文地址: https://ju.6miu.com/read-1124381.html
