RabbitMQ:保证消息的顺序性


如何保证消息的顺序性?
数据中台服务器A发送 创建学生信息 与 更新学生信息 两条消息。应用服务器B需要接受服务A的消息。接收到创建学生信息的消息就在表里创建一个学生记录。接受到更新学生的消息就更新学生基本信息。

如果B服务器部署了两台,服务A在很短的时间内发送了两条消息,那么服务B可能有一台做创建学生的操作,另外一台做更新学生的操作。那么就有可能发生,更新学生基本信息的操作早于创建学生基本信息的操作。这样的话更新就会失败。

 

这就牵扯到如何保证消息的顺序性

解决思路

在生产端发送消息的时候,把自己上一条消息ID 记录到放到消息体中。 在消费端接收到消息后,首先检查此消息中的 上一条消息ID属性。如果不存在上一条消息ID属性,那么就正常消费操作。如果成功消费,则将此次消费的消息ID记录到数据库中。  如果存在上一条消息ID属性,那么就先去数据库查看上一条消息是否已经成功被消费。 如果成功被消费,那么就执行正常的业务逻辑。消费并记录本次消息ID。  如果发现上一条消息没有被成功消费,那么可以稍等一下,在程序中执行睡眠X秒的操作。当休眠时间到了以后,再去检查一下上一条消息是否已经被成功消费。如果此时上一条消息仍然没有成功消费,那么就抛出异常,将当前的消息推回原队列,并等待下次重新消费。

 

参考链接:

https://blog.csdn.net/yanluandai1985/article/details/109535600

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM