MQ消息机制如何确认消费了消息?
2024-08-26 15:25:27
消息队列如何保证消息能百分百成功被消费
目前常用的消息队列有很多种,如RabbitMQ,ActiveMQ,Kafka...下面以RabbitMQ为例来讲如何保证消息队列中的信息能百分百被消费掉.
其中消费队列的工作流程如下:
.我们可以再增加一个机制,增加一个确认机制:
流程解释:
1)订单服务生产者再投递消息之前,先把消息持久化到Redis或DB中,建议redis,高性能。消息的状态为发送中。
2)confirm机制监听消息是否发送成功?如ack成功消息,删除redis中此消息。
3)如果nack不成功的消息,这个可以根据自身的业务选择是否重发此消息。也可以删除此消息,由自己的业务决定。
4)这边加了个定时任务,来拉取隔一定时间了,消息状态还是为发送中的,这个状态就表明,订单服务是没有收到ack成功消息。
5)定时任务会作补偿性的投递消息。这个时候如果MQ回调ack成功接收了,再把redis中此消息删除
这种方案其实就是加上一个补偿机制,不管MQ有没有真正的接收到,只要缓存redis中的消息还是发送中的状态,就意味着这个消息没有成功的投递出去,也没有被消费,定时任务启动时就要重新发送.
当然定时任务那边我们还可以加上一个补偿的次数,如果大于3次,还是没有收到ack消息,那就直接把消息的状态设置为【失败】,由人工去排查到底是为什么?
不过这样的方案,就会有可能发送多次相同的消息,很有可能MQ已经收到了消息,就是ack消息回调时出现网络故障,没有让生产者收到。那就要要求消费者一定在消费的时候保障幂等性。
最新文章
- 前端MVC学习总结(一)——MVC概要与angular概要、模板与数据绑定
- [问题2014A01] 复旦高等代数 I(14级)每周一题(第三教学周)
- 1.Mybatis原理
- 将NuGet配置到环境变量中
- 第二百八十八天 how can I坚持
- Dev GridControl 按条件合并相同单元格
- CSS小技巧-图片自动缩放
- 各种ESB产品比较(转)
- node.js零基础详细教程(7):node.js操作mongodb,及操作方法的封装
- spring boot + vue + element-ui全栈开发入门——开篇
- KsUML 免费的类图建模工具
- linux之文件增删改查
- Java实现小学四则运算练习系统(UI)
- 编写自定义Yeoman生成器简述
- 剑指offer十之矩形覆盖
- ispoweroftwo 判断2的次幂
- Codeforces Beta Round #10 D. LCIS 动态规划
- ThinkPHP项目笔记之MVC篇
- SQL server 数据库升级版本问题解决办法
- unittest单元测试框架之测试环境的初始化与还原(fixture)(五)