获取Rabbitmq HeartBeat异常

Question

我面临着一个问题，那就是用下面的异常终止连接。

 {"message":"com.rabbitmq.client.AlreadyClosedException: connection is already closed due to connection error; cause: com.rabbitmq.client.MissedHeartbeatException: Heartbeat missing with heartbeat = 60 seconds"}

因此，我使用以下配置：-

1. 在AWSEC2-instance1与t2_small服务器上的Rabbitmq码头。
2. 面临此问题的服务运行在具有T2小服务器的aws ec2-instance2上。
3. 为rabbitmq设置以下配置

Factory.setAutomaticRecoveryEnabled(真)；factory.setNetworkRecoveryInterval(1000)；factory.setRequestedHeartbeat(60)；

我只是不明白为什么会出现这种错误，我们如何解决这个问题。

此外，我还在下面的服务中找到了日志，该服务试图连接rabbitmq。

{“log”：“在连接恢复期间捕获异常！\n”，“流”：“stderr”，"time":"2018-03-22T00:00:00.632851865Z"} {"log":"java.net.NoRouteToHostException: No Method to host\n"，"stream":"stderr"，"time":"2018-03-22T00:00:00.633374123Z"} {“log”{"log":"\u0009at java.net.PlainSocketImpl.socketConnect(原生方法)\n“，”流“：”stderr“，”stderr“，“时间”：“2018-03-22T00:00:00.633666158Z”{"log":"\u0009at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:345)\n"，“流”stderr“，"time":"2018-03-22T00:00:00.633935828Z"} {”log“：”\u0009 03 java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)\n"，“java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)\n”，"stream":"stderr"，“时间”：“2018-03-22T00:00:00.634170787Z”} {"log":"\u0009at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)\n"，“流”stderr“，”time“：”2018-03-22T00:00:00.63440824Z“{”log“：”\u0009 03 java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)\n"，“流：”stderr“，“时间”：“2018-03-22T00:00:00.634625637Z”{"log":"\u0009at java.net.Socket.connect(Socket.java:589)\n"，"stream":"stderr"，"time":"2018-03-22T00:00:00.635038038Z"} {“log”：“\u0009 03 java.net.Socket.connect(Socket.java:589)\n”：“stderr”，“时间”：“2018-03-22T00:00:00.635172903Z”}{“日志”：“\u0009at com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:34)\n"，”流：“stderr”，“时间”：“2018-03-22T00:00:00.635369445Z”}{“日志”：“\u0009 03 com.rabbitmq.client.impl.recovery.AutorecoveringConnection.recoverConnection(AutorecoveringConnection.java:435)\n"，”流：“stderr”，“时间”：“2018-03-22T00:00:00.635639932Z”} {"log":"\u0009at com.rabbitmq.client.impl.recovery.AutorecoveringConnection.beginAutomaticRecovery(AutorecoveringConnection.java:407)\n"，“流：”stderr“，"time":"2018-03-22T00:00:00.63584649Z"} {”log“：”\u0009 03 com.rabbitmq.client.impl.recovery.AutorecoveringConnection.access$000(AutorecoveringConnection.java:53)\n"，“流：”stderr“，“时间”：“2018-03-22T00:00:00.636051142Z”}{“log”：“\u0009 03 com.rabbitmq.client.impl.recovery.AutorecoveringConnection$1.shutdownCompleted(AutorecoveringConnection.java:352)\n"，”流：“stderr”，"time":"2018-03-22T00:00:00.636233667Z"} {“log”：“\u0009 03 com.rabbitmq.client.impl.ShutdownNotifierComponent.notifyListeners(ShutdownNotifierComponent.java:75)\n"，”com.rabbitmq.client.impl.ShutdownNotifierComponent.notifyListeners(ShutdownNotifierComponent.java:75)\n“，"stream":"stderr"，“时间”：“2018-03-22T00:00:00.636899252Z”{"log":"\u0009at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:576)\n"，“流”stderr“，"time":"2018-03-22T00:00:00.637183801Z"}

Answer 1

据我所能找到的搜索，似乎连接可能已经关闭了AWS负载平衡器。您是否可以尝试按以下方式修改您的配置：

factory.setRequestedHeartbeat(30);

看看能不能解决你的问题？