当我的应用程序失去与RabbitMQ的连接时,我将其连接工厂设置为自动尝试重新连接
ConnectionFactory factory = new ConnectionFactory(); factory.setUsername(username); factory.setPassword(password); factory.setRequestedHeartbeat(1); factory.setConnectionTimeout(5000); factory.setAutomaticRecoveryEnabled(true); factory.setTopologyRecoveryEnabled(true);
当它试图重新连接它时,它一旦再次连接就永远不会停止阻塞,我不确定为什么.
我使用的是最新版本的java客户端3.3.4
当我通过rabbitmq管理界面强制断开客户端连接时,似乎也会发生这种情况.
一些进一步的研究看起来像它正试图获得一个频道,但网络界面说有一个频道连接.
把它们包装在一起,这是我的答案.
首先,rabbitmq,或者至少是java客户端,有一些奇怪的默认属性,有时是几秒钟,有时是几毫秒.从我的观点来看,它们的默认值似乎也没有考虑过.例如,connectionTimeout
s默认值为0,表示等待永远.
您还应该networkRecoveryInterval
在您的环境中将属性设置为某个有用的值.
要获得有关导致通道关闭的更多信息,请执行ShutdownListener
- 即使它只是打印异常,它也可以帮助您找出导致错误的原因.
为了测试连接的自动恢复,我在客户端使用了ip tables命令.然后你还可以看到rabbitmq.log中服务器端发生了什么
并且不要忘记调整requestHeartbeet
属性,在我的设置中它总是超过5秒,默认的是在一些客户端实现580秒,这似乎有点奇怪,记住这一点.
无论如何,即使您在群集中运行rabbitmq,它也不能在不可靠的网络上运行良好.也许你对此有更多的兴趣,而不是建议你查看文档.