RabbitMQ Client关闭MessageListener且无法恢复

Question

我使用 RabbitMQ AMQP 2.2.7。我在 2 个 Spring boot 应用程序之间运行 RabbitMQ 集群。一个应用程序向另一个应用程序发送一些消息。它运行良好一段时间，但突然在过去几天，我看到使用消息的应用程序中的 MessageListener 由于某种原因出现故障（可能是主服务器节点出现故障）。

   <dependency>
            <groupId>org.springframework.amqp</groupId>
            <artifactId>spring-rabbit</artifactId>
            <version>2.2.7.RELEASE</version>
   </dependency>

2020-07-22 00:26:33.007 ERROR 24 --- [tContainer#1-15] o.s.a.r.l.SimpleMessageListenerContainer : Stopping container from aborted consumer
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - home node 'rabbit@rad497159-mq-1.node.dc1.a9ssvc' of durable queue 'ORDER' in vhost '/' is down or inaccessible, class-id=50, method-id=10)
Caused by: java.io.IOException: null
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) ~[na:na]
2020-07-22 00:26:33.005 ERROR 24 --- [tContainer#1-15] o.s.a.r.l.SimpleMessageListenerContainer : Consumer threw missing queues exception, fatal=true
at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.initialize(SimpleMessageListenerContainer.java:1350) ~[spring-rabbit-2.2.7.RELEASE.jar:2.2.7.RELEASE]

@Configuration
public class MessageConfiguration {

    public static final String ORDER_QUEUE_NAME = "ORDER";

    public static final String EXCHANGE = "directExchange";

    @Bean
    Queue deadLetterQueue() {
        return QueueBuilder.durable(ORDER_QUEUE_NAME).build();
    }

    @Bean
    public Queue orderQueue(){
        return QueueBuilder.durable(ORDER_QUEUE_NAME)
                .build();
    }

    @Bean
    public DirectExchange directExchange(){
        return new DirectExchange(EXCHANGE,true,false);
    }

    @Bean
    public Binding firstBinding(Queue orderQueue, DirectExchange directExchange){
        return BindingBuilder.bind(orderQueue).to(directExchange).with(ORDER_QUEUE_NAME);
    }
}

@RabbitListener(queues = MessageConfiguration.ORDER_QUEUE_NAME)
public void receiveOrder(final String orderString) {
}

问题是 RabbitMQ 消息监听器无限期关闭，并且没有其他方法可以恢复。重新启动应用程序即可解决该问题。所以我想要以下解决方案之一，但不知道该怎么做

1. 监听 SimpleMessageListener 的关闭通知并重新启动应用程序
2. 让应用程序在关闭侦听器之前重试更多次

有人可以建议一些方法吗？

stackoverflow 中已经存在相同的问题，但没有解决方案（How to避免在发生意外错误时关闭 SimpleMessageListenerContainer？）

Answer 1

home node 'rabbit@rad497159-mq-1.node.dc1.a9ssvc' of durable queue 'ORDER' in vhost '/' is down or inaccessible, class-id=50, method-id=10)

看起来您正在使用集群，但没有使用镜像 (HA) 队列。

在这种情况下，如果队列的主节点出现故障，您将收到该错误。

Consumer threw missing queues exception, fatal=true

如果将容器属性设置missingQueuesFatal为false，容器将继续尝试，直到节点备份。

默认情况下，这是 true，并且容器将在相隔 5 秒的 3 次尝试后停止（默认情况下）。