rocketmq顺序消费示例

RocketMQ是一个分布式消息中间件，它支持顺序消费（FIFO，First In First Out）模式。在有序消费中，消费者会按照消息生产时的顺序逐一处理，不会跳过任何一个消息。以下是使用RocketMQ Java客户端进行顺序消费的一个简单示例：

// 引入必要的依赖
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.consumer.MessageExt;

public class OrderlyConsumer {
    private final DefaultMQPushConsumer consumer;
    private static String GROUP_NAME = "orderly_group";

    public OrderlyConsumer() {
        // 创建并初始化消费者
        consumer = new DefaultMQPushConsumer(GROUP_NAME);
        
        // 设置自动订阅策略，这里设置为Topic订阅
        consumer.subscribe("your_topic", "*");
        
        // 开启顺序消费
        consumer.setMessageModel(MessageModel.CLUSTERING); // CLUSTERING模型用于顺序消费

        // 注册监听器处理消息
        consumer.registerMessageListener(new MessageListenerConcurrentMQ() {
            @Override
            public void messageArrived(String topic, int partition, MessageExt msg) {
                System.out.printf("顺序消费消息 %s%n", msg.getBody());
            }

            @Override
            public void exceptionCaught(Throwable e) {
                e.printStackTrace();
            }
        });

        // 启动消费者
        consumer.start();
    }

    public static void main(String[] args) {
        try {
            OrderlyConsumer consumerInstance = new OrderlyConsumer();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

在这个例子中，`GROUP_NAME`应替换为实际的应用组名。消费者会订阅指定的主题，并按照消息到达的顺序依次处理。