RabbitMQ如何保证消息消费的顺序性？

傷城~ 2023-09-28 18:02 28阅读 0赞

RabbitMQ的queue本身就是队列，是可以保证消息的顺序投递的。

但是消息的顺序消费则是另一回事了，所谓的“顺序消费”意味着是否顺序达到目的地，比如：数据库。

看看如下场景：

一个 queue，多个 consumer。比如，生产者向 RabbitMQ 里发送了三条数据，顺序依次是 data1/data2/data3，压入的是 RabbitMQ 的一个内存队列。有三个消费者分别从 MQ 中消费这三条数据中的一条，结果消费者2先执行完操作，把 data2 存入数据库，然后是 data1/data3。这不明显乱了。

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAamVycnlfZHl5_size_15_color_FFFFFF_t_70_g_se_x_16][]

产生多个consumer去消费一个queue，极有可能是因为：消息消费太慢，所以盲目让多个consumer同时来消费，而忽略了消息消费顺序性。

在某些情况下，消息是需要保证顺序性的，如果上图中的data1, data2, data3 分别意味着对某条数据的增改删，但是如果乱序以后就变成了：删改增。

**解决方案：**

1、拆分多个 queue，每个 queue 一个 consumer。

2、一个 queue，但是对应一个 consumer，然后这个 consumer 内部用内存队列（其实就是List而已）做排队，然后分发给底层不同的thread来处理（此方案可以支持高并发）。

实际consumer的数量是受限的，不会仅仅因为消息消费太慢而去增加consumer实例的数量，所以通过方案2的方式，可以在不增加consumer实例数量的前提下，加快消息消费的速度。

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAamVycnlfZHl5_size_16_color_FFFFFF_t_70_g_se_x_16][]

先自我介绍一下，小编13年上师交大毕业，曾经在小公司待过，去过华为OPPO等大厂，18年进入阿里，直到现在。深知大多数初中级java工程师，想要升技能，往往是需要自己摸索成长或是报班学习，但对于培训机构动则近万元的学费，着实压力不小。自己不成体系的自学效率很低又漫长，而且容易碰到天花板技术停止不前。因此我收集了一份《java开发全套学习资料》送给大家，初衷也很简单，就是希望帮助到想自学又不知道该从何学起的朋友，同时减轻大家的负担。添加下方名片，即可获取全套学习资料哦

[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAamVycnlfZHl5_size_15_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/ebda3708bee546dabc2d4420a4401d23.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAamVycnlfZHl5,size_15,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAamVycnlfZHl5_size_16_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/0850d731da8b45dcb955c8d27912bb1b.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAamVycnlfZHl5,size_16,color_FFFFFF,t_70,g_se,x_16