RabbitMQ的消息丢失解决方案

要想做到消息持久化，必须满足以下三个条件，缺一不可。

new TopicExchange("amq.topic")创建的Exchange就是持久化的。

org.springframework.amqp.core.AbstractExchange构造方法如下：

通过spring-rabbit创建Exchange

通过RabbitMQ的web后台管理界面创建Exchange

new Queue(queueName)创建的Queue就是持久化的。

org.springframework.amqp.core.Queue构造方法如下：

通过spring-rabbit创建Queue

通过 RabbitMQ的web后台管理界面创建Queue

发送消息设置发送模式deliveryMode=2代表持久化消息

org.springframework.amqp.rabbit.core.RabbitTemplate默认情况下发送模式为deliveryMode=2

org.springframework.amqp.core.MessageProperties的默认发送模式：

MessageProperties的默认发送模式

/confirm/iCallback  只确认消息是否正确到达 Exchange 中。

ReturnCallback   消息没有正确到达队列时触发回调，如果正确到达队列不执行。

github上面的代码：https://github.com/wuzhong290/rabbitmq.git

执行com.demo.message.TestReturnCallback方法testReturnCallback能够看效果。

ReturnCallback 日志

默认情况下消息消费者是自动 ack （确认）消息的，需要设置为手动确认，原因是：自动确认会在消息发送给消费者后立即确认，这样存在丢失消息的可能。

github上面的代码：https://github.com/wuzhong290/rabbitmq.git

执行com.demo.message.TestManualAcks方法testMQ能够看效果。

com.demo.message.example.NoticeHandlerACK演示了手动确认消费者的实现。

参考https://www.jianshu.com/p/2c5eebfd0e95

上面文章的消息发送确认ReturnCallback部分需要完善一下：

return-callback="returnCallback" mandatory="true"同时设置了才有效。和rabbit:connection-factory 的publisher-returns="true"没有关系。

作者：静夜明灯
链接：https://www.jianshu.com/p/19e0927315da