RabbitMQ Spring中的建议链不工作

Question

我想实现重试功能（当消费者出现问题时）3次，然后消息应该转到另一个队列（死信交换）。我已按如下方式配置队列/交换

常规邮件交换名称：test\u exchange邮件队列：test\u queue test\u queue绑定到具有路由密钥的test\u exchange test\u queue

死信交换名称：test_dlq_exchange死消息队列：test_dlq_queuetest_dlq_queue用路由密钥绑定test_dlq_exchangetest_dlq_queue

在RabbitMQ UI控制台中，我将“x-dead-letter-exchange”配置为“test\u exchange”

下面是SimpleMessageListenerContainer的代码

  @Bean 
    SimpleMessageListenerContainer getMessageListenerContainer(){
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
    container.setConnectionFactory(connectionFactory);
    container.setQueueNames("test_queue");

    MessageListenerAdapter adapter = new MessageListenerAdapter();
     //configured my message listener class 
     //configured Jackson2JsonMessageConverter as converter
     container.setMessageListener(adapter);
     container.setAdviceChain(new Advice[] {retryAdvice()}
     return container;
    }

    //configuration for retryAdvice

     @Bean 
     public MethodInterceptor retryAdvice{

        ExponentialBackOffPolicy backoffPolicy = new ExponentialBackOffPolicy();
        backoffPolicy.setInitialInterval(10);
        backoffPolicy.setMaxInterval(1000);
        backoffPolicy.setMultiplier(2);
        RabbitTemplate retryTemplate = new RabbitTemplate(connectionFactory());
        retryTemplate.setQueue("test_dl_queue");
        return RetryInterceptorBuilder
                    .stateful()
                    .backOffPolicy(backoffPolicy)
                    .maxAttempts(3)
                    .recoverer(
                       new RepublishMessageRecoverer
                       (retryTemplate,"test_dl_exchange","test_queue")).build();
    }  

我的自定义消息侦听器是消息驱动的POJO，它只有我的MessageObject。

由于我使用的是stateful，所以我启用了createMessageId（true）。在消息侦听器中，我再次调用targetobject的方法。启动容器后，流量循环

i、 e将消息发布到队列-

在日志中，我看到如下内容

      o.s.r.i.StatefulRetryOperationsInterceptor - Executing proxied method in stateful retry public abstract void org.springframework.amqp.rabbitlistener.SimpleMessageListenerContainer$ContainerDelegate.invokeListener(Channel,Message) throws java.lang.Exception(55435ee)

有人能帮我解决这个问题吗？

Answer 1

由于您使用的是RePublishMessageRecoverer，因此在代理上配置DLX/DLQ不会做任何事情。为了路由到DLQ，您需要RejectAndDontRequest eueRecover-当重试耗尽时，消息将被发送到DLX/DLQ。

看起来您正在重新发布到同一队列

(retryTemplate,"test_dl_exchange","test_queue"))

因此产生了无限循环。