[转] RabbitMQ 消息如何保证100%的投递成功

Posted 2020-11-29 eedc

投递主要针对生产端，什么是生产端的可靠性投递？

• 保障消息成功的发出去
• 保证MQ节点成功收到消息
• 发送端收到MQ的确认应答
• 完善的消息补偿机制，只做前三步的时候，也许生产端就失败了

BAT/TMD 互联网大厂解决方案，看具体业务和并发量

• 消息落库，对消息状态进行打标
• 消息的延迟投递，做二次检查，回调检查

细节

消息落库步骤：

1. 写入数据库，可能涉及多个库，业务库，消息库
2. 发送消息
3. 消息确认
4. 更新数据库消息状态
5. 定时任务获取数据库消息状态
6. 重试发送
7. 重试数量大于 3 次，修改状态

延迟投递：

如果再高并发的情况下，消息就不要入库了，延迟投递，可以不保证首次100%的成功，但是一定要保证性能。

1. 首次发送，一定等到业务数据入库之后再发送消息，Upstream serivce上游服务
2. 延迟发送刚发送消息 的 检查消息
3. 当消费者消费消息
4. 消息消费成功之后，发送一个确认消费消息
5. CallBack服务收到消费者的确认消息，消费成功之后，做消息的持久化存储
6. CallBack服务检查，处理第二步发送的检查消息，检查数据库是否有处理成功，如果处理成功了，那么就不用处理任何事情，如果处理失败了，Callback服务再通知Upstream服务再次发送消息。

作者：Real_man
链接：https://www.jianshu.com/p/7944bbd5efc5
来源：简书
著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。

MQ系列整个内容，我们将讨论：

• MQ的使用场景
• 业务系统中投递消息的几种方式？
• 如何确保投递消息一定成功？
• 消息消费的几种方式
• 如何确保消息至少消费一次
• 如何保证消息消费的幂等性