使用spring amqp重新连接

Question

我正在使用org.springframework.amqp.rabbit.connection.CachingConnectionFactory连接到RabbitMQ。但我的应用程序在断开连接后不能自动重新连接到rabbit服务器(因为网络问题)

有没有什么配置可以让CachingConnectionFactory自动重新连接？

Answer 1

对于处理失败和重新连接，您可以直接查看Lyra (而不是spring-amqp)。

Answer 2

考虑对该对象使用setRequestedHeartBeat() (requested-heartbeat)。

根据RabbitMQ Manual的说法

在某些类型的网络故障中，数据包丢失可能意味着操作系统需要一段时间才能检测到中断的

连接。AMQP提供了心跳功能，以确保应用层及时发现中断的连接(以及完全无响应的对等点)。心跳还可以防御某些可能终止“空闲”TCP连接的网络设备。在RabbitMQ版本3.0和更高版本中，代理将尝试在默认情况下协商心跳(尽管客户端仍然可以否决它们)。使用早期版本时，必须将客户端配置为请求心跳。