MQ中如何保证消息的顺序性
# 先说结论
不建议在mq当中使用消息的投递顺序来保证消息的顺序一致性
# 反思为什么需要保留消息的顺序性
日常思维中,顺序大部分情况会和时间关联起来,即时间的先后表示事件的顺序关系。 消息队列中的若干消息如果是对同一个数据进行操作,这些操作具有前后的关系,必须要按前后的顺序执行,否则就会造成数据异常。
其实保证是最终结果的一致性
# 什么情况下会出现消息错乱
同一个消息,有多个消费者,消费时长不同,导致第一个消息未处理完成,第二个已经处理完成了
如图
不同的中间件出现乱序的原因不同
# 简单的解决方案
RocketMQ 中 使用顺序消息
可以考虑用状态机,对于一些状态顺序类的 可以通过状态机进行判断,判断失败的先延时+nack拒绝消费,等待其他消息
上次更新: 2024/11/04, 10:04:09