Skip to content

顺序消费消息 #7

Description

@JamesXiao
  1. 原本在本starter的帮助下,消费者和生产者都能正常工作,不过业务场景需要保证消息的消费顺序。
  2. 经过研究,发现本工程的消费者注解,消费模式默认为并发。
    故而尝试将消费者注解改为顺序模式,即:
    @RocketMQMessageListener(topic = "aaaaa", messageModel = MessageModel.BROADCASTING, consumerGroup = "bbbb", consumeMode = ConsumeMode.ORDERLY)
    之后收不到任何消息。
    PS: 查看rocketmq的控制台,可以确认消息生产者已经成功的把消息发送给了mq。

如果把消费者的模式改回CONCURRENTLY,则又可以收到消息了(但顺序无法保证)。

请问应该如何实现消费者按顺序消费消息?修改注解设置模式为什么就收不到任何消息了,我还缺失了什么关键步骤吗?

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions