Flying Rocket是什么网上商城是什么

  看了/p/453c6e7ff81c这篇博客得出顺序消費的结论。“要实现严格的顺序消息简单且可行的办法就是:保证生产者 - MQServer - 消费者是一对一的关系”。

我们下面通过几个实例来学习RocketMQ的顺序消费

//订阅的主题, 以及过滤的标签内容 * 但是也不能保证说一定会顺序消费因为如果master宕机了,导致写入队列的数量上 * 从消费端如果想保证这批消息是M1消费完成再消费M2的话,可以使用MessageListenerOrderly接口但是这样的话会有以下问题: * 1. 遇到消息失败的消息,无法跳过当前队列消费暂停

Consuerm端输出结果:(横向拖到最后看蓝色字体)

 步骤一、我们先改造一下ProducerQueue,在第一个队列下面再加两个队列

从结果中看到两个消费端都是按照队列顺序消费的,并且负载均衡ConsumerQueue1消费了第三个队列,ConsumerQueue2消费了第一个队列和第二个队列

需要注意的一点是,对于顺序消费我们是不能再Consumer端再使用多线程去消费的。这样就破坏了顺序消费的生态环境

我要回帖

更多关于 网上商城是什么 的文章

 

随机推荐