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

要想保住RabbitMQ消息不丢失，需要从下面几个方面进行完善。

一、消息持久化

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

1、Exchange 设置持久化：durable:true

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

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

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

2、Queue 设置持久化

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

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

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

3、Message持久化发送

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

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

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

MessageProperties的默认发送模式

二、ACK确认机制

1、消息发送确认

ConfirmCallback  只确认消息是否正确到达 Exchange 中。

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

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

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

ReturnCallback 日志

2、消息接收确认

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

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

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

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

3、参考资料

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

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

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

三、设置集群镜像模式

参考https://www.jianshu.com/p/dd706e9ee80d 文章中的《6、HA 镜像模式队列设置》

四、消息补偿机制

在消息发送、接受时记录DB日志，定时轮训DB日志，查明哪些发送消息没有成功消费，启动重新发送消息机制。