如何保证RabbitMQ消息顺序消费

问题分析

所谓顺序消费，即保证消息的发送顺序要与消息的消费顺序保持一致。比如数据库对一条数据依次进行了

插入->更新->删除

操作，这个顺序必须是这样，如果在同步过程中，消息的顺序变成了

删除->插入->更新

，那么原本应该被删除的数据，就没有被删除，造成数据的不一致问题。

错误场景1

①一个

queue

，有多个

consumer

去消费，这样就会造成顺序的错误，

consumer

从

MQ

里面读取数据是有序的，但是每个

consumer

的执行时间是不固定的，无法保证先读到消息的

consumer

一定先完成操作，这样就会出现消息并没有按照顺序执行，造成数据顺序错误。

错误场景2

一个

queue

对应一个

consumer

，但是

consumer

里面进行了多线程消费，这样也会造成消息消费顺序错误。

解决方案

队列与消费者一对一

将原来的一个queue拆分成多个

queue

，然后保证每个

queue对应

一个

consumer

，就是多一些

queue

而已，确实是麻烦点；这样也会造成吞吐量下降，可以在消费者内部采用多线程的方式取消费。

消费者使用内存队列

还是一个

queue，

但是也只对应一个

consumer

，然后这个

consumer

内部用内存队列做排队，然后分发给底层不同的

worker

来处理 。