ActiveMQ 5.11.1 不断抛出 EOFException 并且不会发送消息

Posted 2023-03-10

【中文标题】ActiveMQ 5.11.1 不断抛出 EOFException 并且不会发送消息

【英文标题】：ActiveMQ 5.11.1 Constantly throws EOFException and Won't Send Messages

【发布时间】：2015-11-05 03:14:48

【问题描述】：

我有一个 AMQ 5.11.1 实例在几个不同的服务器上运行。它们都配置相同并连接到相同的网关。在一个特定的服务器上，我不断看到这条消息：

2015-08-12 08:53:59,026 | DEBUG | queue://server-01.lookupdata expiring messages .. | org.apache.activemq.broker.region.Queue | ActiveMQ Broker[server-01] Scheduler
2015-08-12 08:53:59,029 | DEBUG | queue://server-01.lookupdata expiring messages done. | org.apache.activemq.broker.region.Queue | ActiveMQ Broker[server-01] Scheduler
2015-08-12 08:54:08,355 | DEBUG | 30000ms elapsed since last read check. | org.apache.activemq.transport.AbstractInactivityMonitor | ActiveMQ InactivityMonitor ReadCheckTimer
2015-08-12 08:54:08,407 | DEBUG | 30000ms elapsed since last read check. | org.apache.activemq.transport.AbstractInactivityMonitor | ActiveMQ InactivityMonitor ReadCheckTimer
2015-08-12 08:54:08,411 | INFO  | Network connection between vm://server-01#2 and tcp://gateway/209.221.27.54:55616@34260 shutdown due to a local error: java.io.EOFException | org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ Transport: tcp://gateway/209.221.27.54:55616@34260
2015-08-12 08:54:08,414 | DEBUG | The local Exception was: java.io.EOFException | org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ Transport: tcp://gateway/209.221.27.54:55616@34260
java.io.EOFException
        at java.io.DataInputStream.readInt(DataInputStream.java:392)[:1.7.0_71]
        at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:258)[activemq-client-5.11.1.jar:5.11.1]
        at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:221)[activemq-client-5.11.1.jar:5.11.1]
        at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:213)[activemq-client-5.11.1.jar:5.11.1]
        at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)[activemq-client-5.11.1.jar:5.11.1]
        at java.lang.Thread.run(Thread.java:745)[:1.7.0_71]
2015-08-12 08:54:08,418 | DEBUG |  stopping server-01 bridge to production | org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ BrokerService[server-01] Task-2
2015-08-12 08:54:08,420 | DEBUG | Unregistering MBean org.apache.activemq:brokerName=server-01,connector=networkConnectors,networkConnectorName=linkToGatewayController1,networkBridge=tcp_//209.221.27.54_55616,type=Broker | org.apache.activemq.broker.jmx.ManagementContext | ActiveMQ BrokerService[server-01] Task-2

调试输出没有帮助，我无法确定导致此连接不断断开的服务器实例之间的差异。

它有足够的内存：

jps -v | grep activemq
40359 activemq.jar -Xmx8G

这是我的 activemq.xml 的一部分：

   <networkConnector name="linkToGateway"
       uri="static:(tcp://gateway:55616)"
       networkTTL="3"
       duplex="false"
       prefetchSize="2"
   >
        <excludedDestinations>
            <queue physicalName=">"/>
        </excludedDestinations>
        <staticallyIncludedDestinations>
            <queue physicalName="server-01.lookupdata" />
        </staticallyIncludedDestinations>
    </networkConnector>

任何帮助将不胜感激！

【问题讨论】：

您是否有防火墙或负载平衡器正在杀死您的连接？

这很好。我现在正在调查。

嗯，我看到了这个确切的问题，但要连接到没有防火墙的 VM 上的环回接口。

【参考方案1】：

首先确保您的连接没有像 Tim Bish 暗示的那样被外部终止。

其次看看下面的thread，它描述了一个与你有类似症状的 ActiveMQ 错误。可能您需要更新 ActiveMQ。

【讨论】：

我使用的是最新版本 5.11.1，所以这不是升级问题。我正在研究防火墙/负载平衡器。

如果您遇到同样的问题，请跟进 JBos-AMQ 错误修复，很明显该修复尚未复制到 Active-MQ 源。该错误已在最近解决，日期为 06/Mar/15

【参考方案2】：

原本我打算将 Tim Bish 的答案标记为正确，但似乎他删除了它。

网络连接是问题所在。某些连接被杀死，在调查和清除这些问题后，事情开始顺利进行。

【参考方案3】：

我也遇到过同样的问题，通过配置 OpenWire 协议解决了。默认 OpenWire 设置预计连接上的流量在 10 秒内，然后在 30 秒内。您将在日志中看到实际使用的值。我通过设置禁用了这个超时（在我的场景中没关系......）：wireFormat.maxInactivityDuration=0

整个网址：

tcp://localhost:61616?connectionTimeout=0&keepAlive=true&useInactivityMonitor=false&wireFormat.maxInactivityDuration=0

或者确保您立即并定期使用该连接。

http://activemq.apache.org/configuring-wire-formats.html