网站建设 app开发网站牛推网

下图是RabbitMQ消息的发送过程，在任何环节消息都有可能丢失：

 生产者确认机制

开启生产者确认机制，确保生产者的消息能到达队列

RabbitMQ提供了publisher confirm 机制来避免消息发送到MQ过程中丢失 。 消息发送到MQ后 ， 会返回一个结果给发送者，表示消息是否处理成功。

• 当消息发送到队列后，会返回一个publish-comfirm ack，告诉生产者已经收到消息；
  • 导致消息丢失的原因一：在此过程中失败的场景有两个：消息发送到交换机会失败，交换机路由消息到队列失败。
    • 消息发送到交换机会失败：返回一个publish-confirm的nack
    • 交换机路由消息到队列失败：返回一个publish-return的ack
    • 消息发送失败之后如何处理？
      • 通过回调方法即时重发
      • 记录日志
      • 保证到数据库然后定时重发，成功发送后即刻删除表中的数据
• 导致消息丢失的原因二：当消息发送到队列中，但MQ宕机了，如何解决：
  • 开启持久化功能，确保消息未消费前在队列中不会丢失
    •  
• 导致消息丢失的原因三： 消费者导致消息丢失，如何解决（两种解决方案）：
  • 开启消费者确认机制为auto，由spring确认消息处理成功后完成ack
    • 
  • 开启消费者失败重试机制，多次重试失败后将消息投递到异常交换机，交由人工处理
    •