RabbitMQ系列-顺序消费模式和迅速消息发送模式

末蓝、 2023-07-07 03:56 62阅读 0赞

MQ使用过程中，有些业务场景需要我们保证顺序消费，而如果一个Producer，一个Queue，多个Consumer的情况下是无法保证顺序的;

举例：

1、业务上产生三条消息，分别是对数据的增加、修改、删除，而如果没有保证顺序消费，结果可能是删除、修改、增加，本来数据最终要删除

、结果变成增加

![format_png][]

2、或者是电商平台，先付钱，然后生成订单，然后通知物流（我对电商不怎么熟悉，这只是个例子而已，可能不太恰当），如果顺序改变了，

客户不付钱了，你却通知物流送货了

所以，这些业务场景下，消息的顺序消费很重要

解决方案：

1、一个Queue对应一下Consumer，把需要保证顺序的message都发送到一个queue当中，关闭autoack，prefetchCount=1，每次只消费

一条信息，处理过后进行手工ack，然后接收下一条message，只是由一个Consumer进行处理

**这里说一下，如果还是多个Consumer，使用同步处理，手工ack是不行的，第一时间每个Consumer都会收到message（如果message数量>**

**consumer数量），剩余的message才会等到ack之后发送过来，所以还是无法保证顺序消费**

2、上面的解决方案只是个人一些简单理解，真正的生产环境的方案很复杂，下面是大神的解决方案

**需要保障以下几点：**

1、发送的顺序消息，必须保证在投递到同一个队列，且这个消费者只能有一个（独占模式）

2、然后同意提交（可以合并一个大消息，或拆分多个消息，最好是拆分），并且所有消息的会话ID一致

3、添加消息属性：顺序表及的序号、本地顺序消息的size属性，进行落库操作

4、并行进行发送给自身的延迟消息（带上关键属性：会话ID、SIZE）进行后续处理消费

5、当收到延迟消息后，根据会话ID、SIZE抽取数据库数据进行处理即可

6、定时轮询补偿机制，对于异常情况

备注：比如生产端消息没有完全投递成功、或者消费端罗渡异常导致消费端落库后缺少消息条目的情况

![format_png 1][]

解释：

左边的步骤和之前讲的批量消息完全相同;

右边步骤：

1、接收到多条消息之后，首先不是进行逻辑处理，而是直接分别入库，把第一条消息入库的同时，发送一个延迟消息（例如5分钟，用来

保障所有的消息都接受到，进行统一处理），监听到延迟消息之后，根据sessionId和size查出一共多少条消息，然后根绝消息顺序去处理（

例如，起一个线程去处理）

PS：接收到消息一定是先进行入库，在经过延迟消息接收过后，再进行处理

个人对这个方案理解不深，可以自行理解。。。

迅速消息发送模式

1、迅速消息是指消息不进行落库，不做可靠性保障

2、适合日志数据、统计分析业务

3、优点就是性能和吞吐量达到最大

图例：

![format_png 2][]

消息不进行落库，Producer不需要Broker进行confirm

[format_png]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9pbWcyMDE4LmNuYmxvZ3MuY29tL2Jsb2cvMTM1MTk5OS8yMDE5MDUvMTM1MTk5OS0yMDE5MDUyNzEwMTU1NjU5NC0yMTQ2MDgxMTE0LnBuZw?x-oss-process=image/format,png
[format_png 1]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9pbWcyMDE4LmNuYmxvZ3MuY29tL2Jsb2cvMTM1MTk5OS8yMDE5MDUvMTM1MTk5OS0yMDE5MDUyNzExMjgyODQ4NS0xNzUzNTE4NjM2LnBuZw?x-oss-process=image/format,png
[format_png 2]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9pbWcyMDE4LmNuYmxvZ3MuY29tL2Jsb2cvMTM1MTk5OS8yMDE5MDUvMTM1MTk5OS0yMDE5MDUyNzEwMjc0NjI5NC0xOTc0NTg5NDI4LnBuZw?x-oss-process=image/format,png

发表评论取消回复

表情：

评论列表（有 0 条评论，62人围观）

还没有评论，来说两句吧...

相关阅读

相关 RabbitMQ消费消息的两种模式：推和拉

前言在rabbitmq中有两种消息处理的模式，一种是推模式/订阅模式/投递模式（也叫push模式），消费者调用channel.basicConsume方法

Dear 丶/ 2023年07月24日 08:24/ 0 赞/ 68 阅读

相关 RabbitMQ系列-顺序消费模式和迅速消息发送模式

MQ使用过程中，有些业务场景需要我们保证顺序消费，而如果一个Producer，一个Queue，多个Consumer的情况下是无法保证顺序的; 举例：　　1、业务上

末蓝、/ 2023年07月07日 03:56/ 0 赞/ 63 阅读

相关 rabbitMQ五种消息发送模式——通配符模式

紧接上一篇：[https://blog.csdn.net/qq\_36357242/article/details/107688368][https_blog.csdn.net

以你之姓@/ 2023年03月03日 06:22/ 0 赞/ 67 阅读

相关 rabbitMQ五种消息发送模式——路由模式

紧接上一篇：[https://blog.csdn.net/qq\_36357242/article/details/107686056][https_blog.csdn.net

青旅半醒/ 2023年03月03日 05:59/ 0 赞/ 84 阅读

相关 rabbitMQ五种消息发送模式——工作模式

接着上一篇：[https://blog.csdn.net/qq\_36357242/article/details/107664806][https_blog.csdn.net

╰+哭是因爲堅強的太久メ/ 2023年03月03日 04:55/ 0 赞/ 23 阅读

相关 rabbitMQ五种消息发送模式——普通模式

写在前面 MQ的应用场景：[https://www.aquestian.cn/article/27][https_www.aquestian.cn_article_27]

雨点打透心脏的1/2处/ 2023年03月02日 13:15/ 0 赞/ 69 阅读

相关 RabbitMQ教程-消息的两种消费模式

echo编辑整理，欢迎转载，转载请声明文章来源。欢迎添加echo微信(微信号：t2421499075) 交流学习。 -------------------- 消费模式

谁借莪１个温暖的怀抱￠/ 2023年01月11日 01:10/ 0 赞/ 267 阅读

相关 RabbitMQ消息发送与消费（三）

发送消息调用Channel的basicPublish方法来发送消息，basicPublish有多个构造方法，其他构造方法都是由下面构造方法缺省某些参数构

分手后的思念是犯贱/ 2022年09月01日 13:58/ 0 赞/ 279 阅读

相关 RabbitMQ 相关问题总结--RabbitMQ 如何确保消息发送和消费？

转载：[https://blog.51cto.com/4925054/2096599][https_blog.51cto.com_4925054_2096599] [![

àì夳堔傛蜴生んèń/ 2022年03月11日 02:12/ 0 赞/ 449 阅读

相关 RabbitMQ 消息重复和消息顺序消费

> RabbitMQ 消息重复和消息顺序消费 1.【消息重复】：要不保证消息幂等性，要不就用map记录任务状态. 首先我们可以确认的是，触发消息重复执行的条件会是

清疚/ 2022年01月26日 09:05/ 0 赞/ 544 阅读