当使用Spring集成和RabbitMQ时，如何在消费者端处理格式错误的消息

Question

我目前正在从事一个项目，涉及使用来自RabbitMQ Brocker的消息。不过，我对Spring集成、AMQP和RabbitMQ还是个新手。我有一个问题是使用错误的消息格式。当我的使用者接收到一个格式错误的消息时，它将其返回队列，然后RabbitMQ将其返回，这就产生了一个无休止的循环。在Spring Integration文档中，有一些配置可以实现，使得这种消息不会返回到队列中。

class ExceptionHandler {

   public void handle(Throwable e ) { 

     Logger.log("Some log ... we don't give a Sh** ... ") ; 

   } 

}

Answer 1

是的，这是正确的解决方案之一--当您确定消息不应被requeued时，抛出AMQPrejectandDontRequeueException。

在SimpleMessageListenerContainer上还有DefaultRequeuerEjected，默认情况下为True。

您也许应该看看DLX/DLQ解决方案，以免丢失那些格式错误的消息。

请分享困扰你的StackTrace。

SimpleMessageListenerContainer中有这样的代码：

catch (AmqpRejectAndDontRequeueException rejectEx) {
                    /*
                     *  These will normally be wrapped by an LEFE if thrown by the
                     *  listener, but we will also honor it if thrown by an
                     *  error handler.
                     */
                }