RabbitMQ消息顺序性保障

2023-12-16 19:03:12

RabbitMQ 没有属性设置消息的顺序性，只能设置消息的优先级，因此消息顺序性保障只能在 consumer 上实现

场景分析：

生产者向 RabbitMQ 里发送了三条数据， 顺序依次是 data1-> data2 -> data3，压入的是一个内存队列。有三个消费者分别从 MQ 中消费这三条数据中的一条，结果消费者2先执行完操作，把 data2 存入数据库，然后是 data1 -> data3，此时发生顺序错乱
场景示意图

解决方案：

  1. 根据业务执行顺序将原先的一个 queue 拆分为多个，每个 queue 配一个 consumer

方案示意图

  1. 依旧是原有的单 queue + 单 consumer ，但 consumer 内部使用内存队列保证消息顺序性（例如 ArrayBlockingQueue），然后分发给底层不同的 worker 来处理

image.png

文章来源:https://blog.csdn.net/weixin_61427900/article/details/135035109
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。