Spring 云流中BROKER rabbitMq宕机如何处理？
How to handle when the BROKER rabbitMq is down in Spring cloud stream?
我想了解我们如何处理代理本身出现故障的情况，在我的情况下这是 RabbitMQ，而且我不想尝试 RETRY 机制。相反，我想检查 spring 云流，如何检测 RabbitMQ 是否关闭 并且根据这种情况我需要推送消息。
@AutoWired
private CachingConnectionFactory connectionFactory;
调用 connectionFactory.createConnection().close() 以验证代理已启动。如果不是，您将捕获异常。
一般来说，这不会打开新连接，它只会检查共享（或缓存）连接是否可用。
我想了解我们如何处理代理本身出现故障的情况，在我的情况下这是 RabbitMQ，而且我不想尝试 RETRY 机制。相反，我想检查 spring 云流，如何检测 RabbitMQ 是否关闭 并且根据这种情况我需要推送消息。
@AutoWired
private CachingConnectionFactory connectionFactory;
调用 connectionFactory.createConnection().close() 以验证代理已启动。如果不是，您将捕获异常。
一般来说，这不会打开新连接，它只会检查共享（或缓存）连接是否可用。