如何保证RabbitMQ消息顺序消费

Posted 2023-03-09 不平衡的叉叉树

问题分析

所谓顺序消费，即保证消息的发送顺序要与消息的消费顺序保持一致。比如数据库对一条数据依次进行了 插入->更新->删除操作，这个顺序必须是这样，如果在同步过程中，消息的顺序变成了删除->插入->更新，那么原本应该被删除的数据，就没有被删除，造成数据的不一致问题。

错误场景1

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

 

错误场景2

一个queue对应一个consumer，但是consumer里面进行了多线程消费，这样也会造成消息消费顺序错误。

解决方案

队列与消费者一对一 

将原来的一个queue拆分成多个queue，然后保证每个queue对应一个consumer，就是多一些queue而已，确实是麻烦点；这样也会造成吞吐量下降，可以在消费者内部采用多线程的方式取消费。

消费者使用内存队列

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