java - AMQP Channel 关闭但 Consumer 并不总是重新启动

Question

我在 RabbitMQ Java 客户端(我的生产者和消费者相距很远)中经常出现 Channel shutdown: connection error 问题(在 24.133.241:5671 线程下，名称被截断)。大多数时候消费者会自动重新启动，因为我启用了心跳(15秒)。但是，在某些情况下，只有Channel shutdown:连接错误，但没有Consumer引发异常，也没有Restarting Consumer(在cTaskExecutor-4线程下)。

我当前的解决方法是重新启动我的应用程序。任何人都可以阐明这个问题吗？

2017-03-20 12:42:38.856 ERROR 24245 --- [24.133.241:5671] o.s.a.r.c.CachingConnectionFactory
      : Channel shutdown: connection error
2017-03-20 12:42:39.642  WARN 24245 --- [cTaskExecutor-4] o.s.a.r.l.SimpleMessageListenerCont
ainer : Consumer raised exception, processing can restart if the connection factory supports
it
...
2017-03-20 12:42:39.642  INFO 24245 --- [cTaskExecutor-4] o.s.a.r.l.SimpleMessageListenerCont
ainer : Restarting Consumer: tags=[{amq.ctag-4CqrRsUP8plDpLQdNcOjDw=21-05060179}], channel=Ca
ched Rabbit Channel: AMQChannel(amqp://21-05060179@10.24.133.241:5671/,1), conn: Proxy@7ec317
54 Shared Rabbit Connection: SimpleConnection@44bac9ec [delegate=amqp://21-05060179@10.24.133
.241:5671/], acknowledgeMode=NONE local queue size=0

Answer 1

通常，这是由于使用者线程“卡在”用户代码中的某处，因此无法对断开的连接使用react。

如果您遇到网络问题，可能是卡在读取或写入套接字上；确保为任何 I/O 操作设置超时。

下次发生这种情况时，请进行线程转储以查看使用者线程正在做什么。