19-RabbitMQ应用问题-消息补偿

19-RabbitMQ应用问题-消息补偿

RabbitMQ应用问题

1. 消息可靠性保障

• 消息补偿机制

1. 消息幂等性保障

• 乐观锁解决方案

消息可靠性保障

需求：100%确保消息发送成功

消息可靠性保障--消息补偿

• Producer
  • 1.业务数据入库DB，保证消息持久化
  • 2.发送消息至消费队列Q1（中间有交换机就不写了）
  • 3.延迟发送消息队列Q3（用于后续校验 2.发送的消息）
• Consumer
  • 4.监听队列Q1：如果消费成功，则将消息执行结果写入DB
  • 5.发送确认消息至队列Q2
• 回调检查服务
  • 6.监听 Consumer 发送过来的确认消息
  • 7.当确认消息已消费，则写入第二个数据库实例 MDB
  • 8.监听延迟队列消息 Q3，对比 MDB 数据库的记录，判断是否已经确认消费 Q2 的消息，如果对比结果为 Q2 没有确认消息确认记录，那么则 调用 Producer，重新发送消息。
• 定时检查服务
  • 9.定时对比检查 DB、MBD的数据库记录，当 Producer 发送消息失败（例如网络故障）则 调用 Producer，重新发送消息。

通过以上的机制，基本可以保障消息发送的可靠性。