下图是RabbitMQ消息的发送过程，在任何环节消息都有可能丢失：
生产者确认机制
开启生产者确认机制
publisher confirm 机制：避免消息发送到MQ过程中丢失 。 消息发送到MQ后 ， 会返回一个结果给发送者，表示消息是否处理成功。（当消息发送到队列后，会返回一个publish-comfirm ack，告诉生产者已经收到消息；）
- 导致消息丢失的原因一：消息发送到交换机会失败，交换机路由消息到队列失败。 - 消息发送到交换机会失败：返回一个publish-confirm的nack- 交换机路由消息到队列失败：返回一个publish-return的ack- 消息发送失败之后如何处理？- 通过回调方法及时重发- 记录日志- 保证到数据库然后定时重发，成功发送后即刻删除表中的数据
开启RabbitMQ的持久化
- 导致消息丢失的原因二：当消息发送到队列中，但MQ宕机了，如何解决： - 开启持久化功能，确保消息未消费前 在队列中 不会丢失-
消费者确认机制
- 导致消息丢失的原因三： 消费者导致消息丢失，如何解决（两种解决方案）： - 开启消费者确认机制为auto，由spring确认消息处理成功后完成ack-
- 开启消费者失败重试机制，多次重试失败后将消息投递到异常交换机，交由人工处理- 
本文转载自: https://blog.csdn.net/m0_61925586/article/details/141592177
版权归原作者 雪球不会消失了 所有， 如有侵权，请联系我们删除。
版权归原作者 雪球不会消失了 所有， 如有侵权，请联系我们删除。