RabbitMQDirectReply-ToUnroutableMessagesDropwithSpringBoot

1. 在Spring Boot应用的配置文件中，添加如下配置：

   spring.rabbitmq.listener.direct.default-requeue-rejected=false

   这个配置的作用是当消息无法路由到目标队列时，不回到原始队列，而是直接丢弃。

2. 创建一个实现了RabbitListenerErrorHandler接口的类，并在其中实现处理消息无法路由的逻辑。示例代码如下：

   @Component public class DirectReplyToErrorHandler implements RabbitListenerErrorHandler {

   @Override
   public Object handleError(Message amqpMessage, org.springframework.messaging.Message<?> message, ListenerExecutionFailedException exception) {
       if (amqpMessage.getMessageProperties().getReplyTo() != null) {
           throw new AmqpRejectAndDontRequeueException("Message cannot be routed to reply-to queue: " + amqpMessage);
       }
       throw exception;
   }
   

   }

   这个实现中，检查消息属性中是否有Reply-To队列的配置，如果没有则继续抛出异常，否则直接抛弃消息并不回到原始队列。

3. 配置监听器工厂（ListenerContainerFactory）时，设置errorHandler属性为上面创建的错误处理类。示例代码如下：

   @Bean public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory, DirectReplyToErrorHandler errorHandler) { SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory(); factory.setConnectionFactory(connectionFactory); factory.setErrorHandler(errorHandler); return factory; }

   这段代码使用了SimpleRabbitListenerContainerFactory创建了一个监听器工厂，设置了连接工厂和错误处理类，并将其返回。

通过以上三个步骤，应用就可以处理RabbitMQ Direct Reply-To Unroutable Messages Drop的问题。