ActiveMQ：“通道处于非活动状态时间过长”异常停止代理消息传递

Question

我的系统有以下几个部分:

• ActiveMQ代理在tcp上暴露，端口61616
• 3个存在于自己的Tomcat服务器中的Grails/Spring战争，它们向JMS代理发布和使用消息
• n次带有JMS侦听器组件的远程客户端系统接收客户端特定消息，使用主机名和端口61616通过VPN连接到JMS代理

到目前为止，在整个开发、测试和生产环境中，所有工作都很好。

我们刚刚在生产中连接了一个新的客户端系统，我们注意到它的日志开始报告“通道不活动时间太长”异常并中断连接。令人担忧的是，这一个客户端的总体效果是，它停止了代理上的所有消息消费，从而使整个系统停止。

这个客户端监听器（使用Spring缓存连接工厂）似乎连接到JMS代理ok，处理一些消息，然后3分钟报告异常。在ActiveMQ中打开调试并获得大量输出，但几乎没有任何提示代理在同一时间出现警告或错误。

相信ActiveMQ有一些内部保持活动状态，即使处于非活动状态的时间超过默认的30秒，也应该保持连接。

基础设施人员已经监控了该客户端的VPN，并确认它始终保持连接和连接。

不要认为是代码或Spring配置有问题，因为我们在不同的客户机中有许多监听器的其他实例，它们都表现良好。

假设我真的有两个问题：

1. 是什么导致“通道不活动”异常
2. 为什么单个客户端中的此异常会阻止ActiveMQ工作

编辑-添加异常堆栈跟踪：

2013-04-24 14:02:06,359 WARN  - Encountered a JMSException - resetting the underlying JMS Connection (org.springframework.jms.connection.CachingConnectionFactory)
javax.jms.JMSException: Channel was inactive for too (>30000) long: jmsserver/xxx.xx.xx.xxx:61616
    at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:49)
    at org.apache.activemq.ActiveMQConnection.onAsyncException(ActiveMQConnection.java:1833)
    at org.apache.activemq.ActiveMQConnection.onException(ActiveMQConnection.java:1850)
    at org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:101)
    at org.apache.activemq.transport.ResponseCorrelator.onException(ResponseCorrelator.java:126)
    at org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:101)
    at org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:101)
    at org.apache.activemq.transport.WireFormatNegotiator.onException(WireFormatNegotiator.java:160)
    at org.apache.activemq.transport.InactivityMonitor.onException(InactivityMonitor.java:266)
    at org.apache.activemq.transport.InactivityMonitor$4.run(InactivityMonitor.java:186)
    at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:693)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:719)
    at java.lang.Thread.run(Thread.java:813)
Caused by: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too (>30000) long: jmsserver/xxx.xx.xx.xxx:61616
    ... 4 more

Answer 1

您只需要更改activemq。xml（配置文件）：

>

transportConnectors部分：

transportConnector name="ws" uri="ws://0.0.0.0:61614"

变化

transportConnector name="ws" uri="tcp://0.0.0.0:61614"

它适用于我的windows和linux虚拟机

Answer 2

您是否尝试过以下操作：

>

禁用InactivityMonitor<代码>线格式。maxInactivityDuration=0。

URL:< code > TCP://localhost:61616？wire format . maxinactivityduration = 0

如果您不想禁用，是否尝试将其设置为一个较高的数字，例如:URL:< code > TCP://localhost:61616？wire format . maxinactivityduration = 5000000(只是一个例子-使用您自己的时间，单位为毫秒)

此外，确保jar文件对于客户端和服务器都是相同的版本。

希望有帮助