使用DefaultMessageListenerContainer连接到WebSphere MQ会反复抛出“连接关闭”

Question

我需要从运行在WebSphereAS6.1应用服务器上的web应用程序连接到远程WebSphereMQ on z/OS队列。在WebSphere AS上，我配置了QueueConnectionFactory和Queue（一个包含部分远程队列数据的对象），并将大多数设置设置为它们的默认值——我只需要设置队列名称、通道、主机、端口和传输类型，即客户机。我使用JNDI查找将它们注入到下面的Spring 3.2配置中：

    <jee:jndi-lookup id="destination" jndi-name="MyMQQueue" expected-type="javax.jms.Queue" />

    <jee:jndi-lookup id="targetConnectionFactory" jndi-name="MyMQQCF" expected-type="javax.jms.QueueConnectionFactory" />

    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"
      p:connectionFactory-ref="targetConnectionFactory"
      p:defaultDestination-ref="destination" />

    <bean id="simpleMessageListener" class="my.own.SimpleMessageListener"/>

    <bean id="msgListenerContainer"
      class="org.springframework.jms.listener.DefaultMessageListenerContainer">
      <property name="connectionFactory" ref="targetConnectionFactory" />
      <property name="destination" ref="destination" />
      <property name="messageListener" ref="simpleMessageListener" />
      <property name="taskExecutor" ref="managedThreadsTaskExecutor" />
      <property name="receiveTimeout" value="5000" />
      <property name="recoveryInterval" value="5000" />
   </bean>

   <bean id="managedThreadsTaskExecutor" class="org.springframework.scheduling.commonj.WorkManagerTaskExecutor">
      <property name="workManagerName" value="wm/default" />
   </bean>

JmsTemplate正确发送和接收（同步）消息。DefaultMessageListenerContainer是一个异步消息接收器，它在WebSphere AS start期间从MQ队列中读取一些（以前发送的）消息，但很快就会阻塞，并开始反复抛出“连接关闭”异常。每次这样的场合，它都会通知我

DefaultMessag W org.springframework.jms.listener.DefaultMessageListenerContainer handleListenerSetupFailure Setup of JMS message listener invoker failed for destination 'queue://myqueue' - trying to recover. Cause: Connection closed
DefaultMessag I org.springframework.jms.listener.DefaultMessageListenerContainer refreshConnectionUntilSuccessful Successfully refreshed JMS Connection

但停止从队列中删除消息。

深入研究Spring代码，我发现DefaultMessageListenerContainer上的设置

<property name="cacheLevel" value="0"/>

解决了这个问题，因为每次我发送消息时，都会从队列中读取消息。但是，查看到WebSphere MQ的TCP流量，我发现MQCLOSE/MQOPEN命令会重复发送到它，如中所示：

Wireshark捕获流量

这可能意味着连接会持续关闭和重新打开。

有人能建议缓存不能正常工作的原因吗，以及是否有一种相对简单的方法来修改Spring代码（例如扩展DefaultMessageListenerContainer），或者在MQ队列连接工厂/队列上设置一些属性，让它工作？

编辑：

进一步搜索互联网，我发现了以下链接

http://forum.spring.io/forum/spring-projects/integration/jms/89532-defaultmessagelistenercontainer-cachingconnectionfactory-tomcat-and-websphere-mq

这似乎描述了Tomcat上发生的类似问题。解决方案是在DefaultMessageListenerContainer上设置特定的exceptionListener。然而，在WebSphere上尝试这样做会引发异常“javax.jms.IllegalStateException:Method setExceptionListener not Allowed”。根本原因似乎是J2EE 1.4规范禁止在JMS连接上调用setExceptionListener。

https://www.ibm.com/developerworks/library/j-getmess/j-getmess-pdf.pdf

Answer 1

看来设置

<property name="cacheLevel" value="0"/>

在DefaultMessageListenerContainer上，实际上是正确的解决方案。

在本例中，我将Wireshark捕获的TCP流量中看到的MQCLOSE/MQOPEN解释为重量级连接打开，从而误导了自己。

首先，管理控制台WebSphere AS 6.1上新创建的连接html" target="_blank">工厂默认有一个JMS连接池（最大大小为10）。通过调试DefaultMessageListenerContainer的基类AbstractPollingMessageListenerContainer

protected boolean doReceiveAndExecute(
            Object invoker, Session session, MessageConsumer consumer, TransactionStatus status)

）

我们可以看到，创建连接的调用和从连接创建会话的调用都不会生成TCP流量，而TCP流量只能通过创建使用者（如果我理解正确，则被视为“轻量级操作”），尝试从队列接收消息，并关闭使用者来生成。

因此，连接似乎是从各自的池中获取的，并且会话也以某种方式被“缓存”。

因此，这里的缓存似乎是由应用服务器完成的，而不是Spring缓存。