rocketmq顺序消费模式代码

下面是一个简单的示例代码，展示如何在 RocketMQ 中进行顺序消费：

// 创建一个消费者实例
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("example_group");

// 指定 Namesrv 地址
consumer.setNamesrvAddr("localhost:9876");

// 订阅一个 Topic，并指定 Tag
consumer.subscribe("example_topic", "example_tag");

// 注册一个消息监听器，用于处理消费消息
consumer.registerMessageListener(new MessageListenerOrderly() {
    @Override
    public ConsumeOrderlyStatus consumeMessage(List<MessageExt> msgs, ConsumeOrderlyContext context) {
        for (MessageExt msg : msgs) {
            // 处理消息
            System.out.println(new String(msg.getBody()));
        }

        // 返回消费状态
        return ConsumeOrderlyStatus.SUCCESS;
    }
});

// 启动 Consumer 实例
consumer.start();

在上面的代码中，我们创建了一个 `DefaultMQPushConsumer` 实例，配置了 Namesrv 地址，并订阅了一个 Topic 和 Tag。接着，我们注册了一个 `MessageListenerOrderly` 消息监听器，用于处理消费消息。最后，我们启动了 Consumer 实例，开始消费消息。当消息到达时，RocketMQ 会调用我们的消息监听器对消息进行处理。

注意，在使用顺序消费模式时，必须确保生产者向同一个队列发送的消息具有相同的 HashKey，这样才能保证消息被消费的顺序。此外，也可以在消费者端设置 MessageListenerOrderly 的 ConsumeOrderlyContext 中的属性来控制消费顺序。但是，在性能方面要略逊于在生产者端设置的顺序消费。