RabbitMQ如何保证消息的顺序性【重点】

怼烎@ 2023-09-28 18:02 14阅读 0赞

## 1.1 保证顺序性的意义 ##

**消息队列中的若干消息如果是对同一个数据进行操作，这些操作具有前后的关系，必须要按前后的顺序执行，否则就会造成数据异常**。

举例：  
比如通过`mysql binlog`进行两个数据库的数据同步，由于对数据库的数据操作是具有顺序性的，如果操作顺序搞反，就会造成不可估量的错误。比如数据库对一条数据依次进行了 `插入->更新->删除`操作，这个顺序必须是这样，如果在同步过程中，消息的顺序变成了`删除->插入->更新`，那么原本应该被删除的数据，就没有被删除，造成数据的不一致问题。

## 1.2 出现顺序错乱的场景 ##

我们还是以RabbitMQ为例，后续会陆续更新更多的MQ的解决方案。

### 1.2.1 错乱场景一 ###

①一个`queue`，有多个`consumer`去消费，这样就会造成顺序的错误，`consumer`从`MQ`里面读取数据是有序的，但是每个`consumer`的执行时间是不固定的，无法保证先读到消息的`consumer`一定先完成操作，这样就会出现消息并没有按照顺序执行，造成数据顺序错误。

![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAX1_lpYvmlpfnmoTljaHljaE_size_20_color_FFFFFF_t_70_g_se_x_16_pic_center]

### 1.2.2 错乱场景二 ###

一个`queue`对应一个`consumer`，但是`consumer`里面进行了多线程消费，这样也会造成消息消费顺序错误。  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAX1_lpYvmlpfnmoTljaHljaE_size_20_color_FFFFFF_t_70_g_se_x_16_pic_center 1]

## 1.3 保证消息的消费顺序 ##

### 1.3.1 解决方案一 ###

拆分成多个`queue`，每个`queue`一个`consumer`，就是多一些`queue`而已，确实是麻烦点；这样也会造成吞吐量下降，可以在消费者内部采用多线程的方式取消费。  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAX1_lpYvmlpfnmoTljaHljaE_size_20_color_FFFFFF_t_70_g_se_x_16_pic_center 2]

### 1.3.2 解决方案二 ###

或者就一个`queue`但是对应一个`consumer`，然后这个`consumer`内部用内存队列做排队，然后分发给底层不同的`worker`来处理

![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAX1_lpYvmlpfnmoTljaHljaE_size_20_color_FFFFFF_t_70_g_se_x_16_pic_center 3]

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

[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAX1_lpYvmlpfnmoTljaHljaE_size_20_color_FFFFFF_t_70_g_se_x_16_pic_center]: https://img-blog.csdnimg.cn/1987253ef53349b7b527590cb7626e7f.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAX1_lpYvmlpfnmoTljaHljaE=,size_20,color_FFFFFF,t_70,g_se,x_16#pic_center
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAX1_lpYvmlpfnmoTljaHljaE_size_20_color_FFFFFF_t_70_g_se_x_16_pic_center 1]: https://img-blog.csdnimg.cn/ce3d601b398849e2a194fa30a32e1cfe.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAX1_lpYvmlpfnmoTljaHljaE=,size_20,color_FFFFFF,t_70,g_se,x_16#pic_center
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAX1_lpYvmlpfnmoTljaHljaE_size_20_color_FFFFFF_t_70_g_se_x_16_pic_center 2]: https://img-blog.csdnimg.cn/1f8da5f220ba47adb978c77cfe254b7f.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAX1_lpYvmlpfnmoTljaHljaE=,size_20,color_FFFFFF,t_70,g_se,x_16#pic_center
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAX1_lpYvmlpfnmoTljaHljaE_size_20_color_FFFFFF_t_70_g_se_x_16_pic_center 3]: https://img-blog.csdnimg.cn/1561bedd3ed444fd989867674384e8f3.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAX1_lpYvmlpfnmoTljaHljaE=,size_20,color_FFFFFF,t_70,g_se,x_16#pic_center