Spring Boot和RabbitMQ：如何检测应用程序何时重新连接到代理

问题描述

我有一个Spring Boot应用程序充当生产者并通过RabbitMQ发送消息。 如果代理关闭，是否有某种侦听器将检测代理何时再次启动，以便重试发送失败的消息？

谢谢！

解决方法

如果仅生成消息，则不会。您可以添加一个@Scheduled方法（和@EnableScheduling），这种方法会经常尝试创建一个连接，并且您可以向连接工厂添加一个ConnectionListener，当新连接被建立时将被调用。打开。

由于连接是共享的，因此在连接已打开时运行此计划任务不会对您造成任何伤害。

@Scheduled(fixedDelay = 10000)
public void tryConn() {
    try {
        this.cachingConnectionFactory.createConnection().close();
    }
    catch (Exception e) {
    }
}

在消费者方面，侦听器容器将继续重试。