大家有没有遇到这个错误,暂时看不到出错环境。集思广益一下为啥报这个错误。 rabbit mq 3.x 版本,haproxy + (普通)clustering consumer 一直报下面的错误,但是有消息可以正常消费 2016-11-03 13:13:45 [INFO] [org.springframework.amq ..

求救,rabbitmq consumer 频繁打印 ShutdownSignalException

本贴最后更新于 1127 天前,其中的信息可能已经天翻地覆

大家有没有遇到这个错误,暂时看不到出错环境。集思广益一下为啥报这个错误。

rabbit mq 3.x 版本,haproxy + (普通)clustering

consumer 一直报下面的错误,但是有消息可以正常消费

2016-11-03 13:13:45 [INFO] [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.run:1234] |Restarting Consumer: tags=[{amq.ctag-OTTQJu3QZKQExp1U-Bm1AA=queue.notify.wallet}], channel=Cached Rabbit Channel: PublisherCallbackChannelImpl: AMQChannel(), acknowledgeMode=AUTO local queue size=0
2016-11-03 13:14:35 [ERROR] [org.springframework.amqp.rabbit.connection.CachingConnectionFactory.shutdownCompleted:281] |Channel shutdown: connection error
2016-11-03 13:14:35 [ERROR] [org.springframework.amqp.rabbit.connection.CachingConnectionFactory.shutdownCompleted:281] |Channel shutdown: connection error
2016-11-03 13:14:35 [ERROR] [org.springframework.amqp.rabbit.connection.CachingConnectionFactory.shutdownCompleted:281] |Channel shutdown: connection error
2016-11-03 13:14:35 [WARN] [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.logConsumerException:1243] |Consumer raised exception, processing can restart if the connection factory supports it
com.rabbitmq.client.ShutdownSignalException: connection error
at com.rabbitmq.client.impl.AMQConnection.startShutdown(AMQConnection.java:719) ~[amqp-client-3.5.1.jar:na]
at com.rabbitmq.client.impl.AMQConnection.shutdown(AMQConnection.java:709) ~[amqp-client-3.5.1.jar:na]
at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:565) ~[amqp-client-3.5.1.jar:na]
at java.lang.Thread.run(Thread.java:745) [na:1.7.0_75]
Caused by: java.io.EOFException: null
at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:290) ~[na:1.7.0_75]
at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:95) ~[amqp-client-3.5.1.jar:na]
at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:139) ~[amqp-client-3.5.1.jar:na]
at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:534) ~[amqp-client-3.5.1.jar:na]
... 1 common frames omitted

  • RabbitMQ

    RabbitMQ 是一个开源的 AMQP 实现,服务器端用 Erlang 语言编写,支持多种语言客户端,如:Python、Ruby、.NET、Java、C、PHP、ActionScript 等。用于在分布式系统中存储转发消息,在易用性、扩展性、高可用性等方面表现不俗。

    35 引用 • 59 回帖 • 567 关注
  • 异常
    17 引用 • 46 回帖
8 回帖
请输入回帖内容...
  • tom

    自己的思路和描述:
    1、没有夸网段、
    2、节点在防火墙之后(这个不知道有没有问题)
    3、集群中各节点都正常运行
    4、打算一次 将 haproxy 改成 单节点 IP 连接测试一下(尚未验证)
    5、还没有想到

  • 88250 1 赞同

    建议先看下 TCP 连接数

    1 回复
  • tom

    谢谢回复,请问可以说的在细一点吗?

    1 回复
  • 88250

    用 netstat/lsof/ss 等命令看下操作系统的 TCP 链接数和状态,客户端和服务端都看一下,先看看是不是程序问题。

    1 回复
  • tom

    虽然还没明白,谢谢回复这么快

    1 回复
  • 88250

    可以找你们运维同学帮忙看看 :)

    1 回复
  • tom

    刚上线的项目数据量很少,目测不是这个问题。是一个思路,在看 ing

  • litterGuy

    博主 问下这问题最后追查出原因是因为什么?

请输入回帖内容 ...