- 原本在本starter的帮助下,消费者和生产者都能正常工作,不过业务场景需要保证消息的消费顺序。
- 经过研究,发现本工程的消费者注解,消费模式默认为并发。
故而尝试将消费者注解改为顺序模式,即:
@RocketMQMessageListener(topic = "aaaaa", messageModel = MessageModel.BROADCASTING, consumerGroup = "bbbb", consumeMode = ConsumeMode.ORDERLY)
之后收不到任何消息。
PS: 查看rocketmq的控制台,可以确认消息生产者已经成功的把消息发送给了mq。
如果把消费者的模式改回CONCURRENTLY,则又可以收到消息了(但顺序无法保证)。
请问应该如何实现消费者按顺序消费消息?修改注解设置模式为什么就收不到任何消息了,我还缺失了什么关键步骤吗?
故而尝试将消费者注解改为顺序模式,即:
@RocketMQMessageListener(topic = "aaaaa", messageModel = MessageModel.BROADCASTING, consumerGroup = "bbbb", consumeMode = ConsumeMode.ORDERLY)
之后收不到任何消息。
PS: 查看rocketmq的控制台,可以确认消息生产者已经成功的把消息发送给了mq。
如果把消费者的模式改回CONCURRENTLY,则又可以收到消息了(但顺序无法保证)。
请问应该如何实现消费者按顺序消费消息?修改注解设置模式为什么就收不到任何消息了,我还缺失了什么关键步骤吗?