如何在使用 SpringBoot 应用程序的 RabbitMQ 连接错误后建立连接

如何解决如何在使用 SpringBoot 应用程序的 RabbitMQ 连接错误后建立连接

将我的 SpringBoot 应用程序重新部署到 TomcatServer 9 后，我遇到了一些奇怪的异常：

MyApplication: 2021-05-17 09:54:39,306 错误 [AMQP 连接主机：端口]

o.s.a.r.c.CachingConnectionFactory:1576 - 通道关闭：连接错误从那以后，我无法从 RabbitMQ 收到任何消息。

如果我重新启动我的应用程序，那么也不例外。

出现这些错误后，我是否需要更改 SpringBoot 应用程序中的某些内容以自动重新连接？

或者我错过了什么？

这是我的 SimpleRabbitListenerContainerFactory 设置：

@Bean
public SimpleRabbitListenerContainerFactory poxStatusFeedbackInterceptContainerFactory(final SimpleRabbitListenerContainerFactoryConfigurer configurer,final ConnectionFactory connectionFactory) {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory() {
        @Override
        protected void initializeContainer(SimpleMessageListenerContainer instance,RabbitListenerEndpoint endpoint) {
            instance.setAfterReceivePostProcessors(new MyPostProcessor()); // this does some prevalidation of messages
            super.initializeContainer(instance,endpoint);
        }
    };
    configurer.configure(factory,connectionFactory);
    return factory;
}

这是 application.yml 设置：

spring:
  rabbitmq:
    host: .......
    port: ....
    virtual-host: myhost
    username: sa
    password: sa
    listener:
      simple:
        retry:
          enabled: true
          initial-interval: 3s
          max-interval: 10s
          multiplier: 2
          max-attempts: 3

解决方法

这将解决问题：

((CachingConnectionFactory) connectionFactory).setRequestedHeartBeat(60);

在这里找到： https://www.rabbitmq.com/heartbeats.html