在Java中如何使用RabbitTemplate 消费特定Tag的消息，跳过未匹配的Tag，但不能丢失消息

在RabbitMQ中，消费者可以通过指定routing key来接收特定的消息。在Java中，可以通过RabbitTemplate设置MessageListenerAdapter来实现消费指定tag的消息。

以下是一个示例代码：

import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class RabbitMQConsumer {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void consume(String queueName, String routingKey) {
        MessageListenerAdapter messageListenerAdapter = new MessageListenerAdapter(new MessageListener() {
            @Override
            public void onMessage(Message message) {
                // 处理接收到的消息
            }
        });
        messageListenerAdapter.setDefaultListenerMethod("onMessage");
        messageListenerAdapter.setMessageConverter(rabbitTemplate.getMessageConverter());
        rabbitTemplate.setMessageListener(messageListenerAdapter);
        rabbitTemplate.setQueue(queueName);
        rabbitTemplate.setRoutingKey(routingKey);
        rabbitTemplate.receiveAndReply();
    }

}

在上面的代码中，我们设置了一个MessageListenerAdapter，并将其注册到RabbitTemplate中。MessageListenerAdapter会调用onMessage方法来处理接收到的消息。我们通过setDefaultListenerMethod设置了默认的方法名，并设置了messageConverter。接着，我们设置了queueName和routingKey，并调用receiveAndReply方法来开始监听消息。

需要注意的是，如果有消息的routing key与指定的routing key不匹配，RabbitTemplate并不会丢弃消息，而是将其存储在队列中等待后续消费者处理。