rocketmq 获取tag

在 RocketMQ 中，消费者可以根据 tag 来订阅指定类型的消息。消费者可以通过在订阅时指定 tag 的方式来获取相应的消息。

具体来说，在使用 RocketMQ 消费者 API 进行消息订阅时，可以通过调用 `consumer.subscribe(topic, tag)` 方法来指定要订阅的消息的 tag。示例代码如下：

DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("example_group");
consumer.setNamesrvAddr("127.0.0.1:9876");
consumer.subscribe("TopicTest", "TagA || TagB");
consumer.registerMessageListener(new MessageListenerConcurrently() {
    @Override
    public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
        System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs);
        return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
    }
});
consumer.start();

在上述示例中，消费者通过 `consumer.subscribe("TopicTest", "TagA || TagB")` 方法来订阅了 "TopicTest" Topic 下的 "TagA" 或 "TagB" 类型的消息。这样，当生产者发送了带有 "TagA" 或 "TagB" 类型的消息时，消费者就可以接收到这些消息。

需要注意的是，在使用 tag 进行消息订阅时，要确保生产者发送的消息也带有相应的 tag，否则消费者将无法接收到消息。