在Java中如何使用RabbitTemplate 消费特定Tag的消息

在使用 RabbitTemplate 消费特定 Tag 的消息时，需要结合 RabbitMQ 的消息确认机制来实现。下面是一个简单的 Java 代码示例：

public class RabbitMQConsumer {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @PostConstruct
    public void consume() {
        String queueName = "myQueue";
        String routingKey = "myRoutingKey";
        String consumerTag = "myConsumerTag";

        SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
        container.setConnectionFactory(rabbitTemplate.getConnectionFactory());
        container.setQueueNames(queueName);
        container.setMessageListener((ChannelAwareMessageListener) (message, channel) -> {
            // 消费消息
            System.out.println("Received message: " + new String(message.getBody()));
            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
        });
        container.setConsumerTagStrategy(queue -> consumerTag);
        container.setAcknowledgeMode(AcknowledgeMode.MANUAL);
        container.start();

        rabbitTemplate.convertAndSend(queueName, routingKey, "Hello RabbitMQ!");
    }
}

上述代码中，我们定义了一个 RabbitTemplate 对象，并使用 @Autowired 注解将其注入到 RabbitMQConsumer 类中。然后，在 consume() 方法中，我们定义了要消费的队列名称、路由键和消费者标签。

接着，我们创建了一个 SimpleMessageListenerContainer 对象，设置了它的连接工厂、队列名称、消息监听器等属性。在消息监听器中，我们使用了 ChannelAwareMessageListener 接口，它可以让我们在消费消息时手动确认消息，从而实现对特定 Tag 的消息进行消费。

最后，我们调用了 container.start() 方法启动消息消费者，并使用 rabbitTemplate.convertAndSend() 方法向队列发送了一条消息。当消费者收到消息后，会输出 Received message: Hello RabbitMQ! 的信息。如果要消费多个 Tag 的消息，只需要在消息监听器中判断消息的 Tag，然后进行相应的处理即可。