rocketmq 消费者获取消息id

在 RocketMQ 中，消费者消费消息时可以获取消息的唯一标识符 Message ID。可以通过 `MessageExt.getMsgId()` 方法来获取消息的 ID。该方法返回一个字符串，代表消息的唯一标识符。

示例代码如下：

DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("consumerGroup");
consumer.setNamesrvAddr("192.168.0.1:9876");
consumer.subscribe("TopicTest", "*");
consumer.registerMessageListener(new MessageListenerConcurrently() {
    @Override
    public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
        for (MessageExt msg : msgs) {
            String msgId = msg.getMsgId();
            System.out.println("Received message with ID: " + msgId);
        }
        return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
    }
});
consumer.start();

在上述代码中，我们通过 `MessageExt.getMsgId()` 方法获取了消费的消息的 ID，并在控制台输出了该 ID。