如何保证消息消费顺序呢？

通过分区规则可以实现同类消息在rocketmq上的顺序存储。但是对于消费端来说，如何保证消费的顺序？

我们前面写的消息消费代码使用的是MessageListenerConcurrently并发监听，也就是基于多个线程并行来消费消息。这个无法保证消息消费的顺序。RocketMQ中提供了MessageListenerOrderly 一个类来实现顺序消费，

consumer.subscribe("store_topic_test","*"); consumer.registerMessageListener((MessageListenerOrderly) (list,
consumeOrderlyContext) -> {
list.stream().forEach(messageExt -> System.out.println(new
String(messageExt.getBody())));
return ConsumeOrderlyStatus.SUCCESS;
});

顺序消费会带来一些问题，

1. 遇到消息失败的消息，无法跳过，当前队列消费暂停

2. 降低了消息处理的性能

如何保证消息消费顺序呢？相关推荐

多线程顺序消费MySQL数据_关于MQ的几件小事（五）如何保证消息按顺序执行
1.为什么要保证顺序消息队列中的若干消息如果是对同一个数据进行操作,这些操作具有前后的关系,必须要按前后的顺序执行,否则就会造成数据异常.举例: 比如通过mysql binlog进行两个数据库的数据 ...
【重难点】【RabbitMQ 02】如何避免消息重复投递和消息重复消费、如何防止消息丢失、如何保证消息的顺序性、如何保证消息队列的可用性
[重难点][RabbitMQ 02]如何避免消息重复投递和消息重复消费.如何防止消息丢失.如何保证消息的顺序性.如何保证消息队列的可用性文章目录 [重难点][RabbitMQ 02]如何避免消息重复 ...
kafka的消费顺序_Kafka如何保证消息的顺序性
1. 问题比如说我们建了一个 topic,有三个 partition.生产者在写的时候,其实可以指定一个 key,比如说我们指定了某个订单 id 作为 key,那么这个订单相关的数据,一定会被分发到 ...
消息队列面试 - 如何保证消息不被重复消费？或者说，如何保证消息消费的幂等性？
消息队列面试 - 如何保证消息不被重复消费? 面试题如何保证消息不被重复消费?或者说,如何保证消息消费的幂等性? 面试官心理分析其实这是很常见的一个问题,这俩问题基本可以连起来问.既然是消费消息, ...
消息队列面试 - 如何保证消息的顺序性？
消息队列面试 - 如何保证消息的顺序性? 面试题如何保证消息的顺序性? 面试官心理分析其实这个也是用 MQ 的时候必问的话题,第一看看你了不了解顺序这个事儿?第二看看你有没有办法保证消息是有顺序的 ...
java 如何判定消息已在队列_【05期】消息队列中，如何保证消息的顺序性？
本文选自:advanced-java 作者:yanglbme 问:如何保证消息的顺序性? 面试官心理分析其实这个也是用 MQ 的时候必问的话题,第一看看你了不了解顺序这个事儿?第二看看你有没有办法保 ...
消息中间件(五)——如何保证消息的顺序性
当我们的系统中引入了MQ之后,不得不考虑的一个问题是如何保证消息的顺序性,这是一个至关重要的事情,如果顺序错乱了,就会导致数据的不一致. 比如:业务场景是这样的:我们需要根据mysql的binlog日 ...
RabbitMQ如何保证消息的顺序性【重点】
1.1 保证顺序性的意义消息队列中的若干消息如果是对同一个数据进行操作,这些操作具有前后的关系,必须要按前后的顺序执行,否则就会造成数据异常. 举例: 比如通过mysql binlog进行两个数 ...
如何保证消息不被重复消费啊（如何保证消息消费时的幂等性）？
1.面试题如何保证消息不被重复消费啊(如何保证消息消费时的幂等性)? 2.面试官心里分析其实这个很常见的一个问题,这俩问题基本可以连起来问.既然是消费消息,那肯定要考虑考虑会不会重复消费?能不能避 ...

如何保证消息消费顺序呢？

如何保证消息消费顺序呢？相关推荐

最新文章

热门文章