RoctetMQ 如何保证顺序消费
文章目录
1:背景2:发送端3:消费端
1:背景
在一些特殊的场景下,需要保证消息的顺序性,rocketMQ 提供了确实有效的解决方法。需要发送端和消费端同时保证才行。 总结下来,需要满足下面几个条件: 1:同一个Topic 2:同一个Queue 3:发消息的时候用同一个线程发送消息 3:消费消息的时候用同一个线程消费一个 Queue 里面的消息,或者用提供的消息选择器 MessageListenerOrderly
2:发送端
示例代码:
/**
* 发送顺序消息
*/
private static void orderSend(DefaultMQProducer producer) throws Exception {
Message message = new Message("myTopic", "我发送的第一条消息".getBy
共有 0 条评论