IBM MQ Connect Factory CLIENTRECONNECTTIMEOUT 不使用 CLIENTRECONNECTOPTIONS答案

【问题标题】：IBM MQ Connect Factory CLIENTRECONNECTTIMEOUT without using CLIENTRECONNECTOPTIONSIBM MQ Connect Factory CLIENTRECONNECTTIMEOUT 不使用 CLIENTRECONNECTOPTIONS
【发布时间】：2019-01-01 21:24:27
【问题描述】：

我使用了没有 CLIENTRECONNECTTIMEOUT 和 CLIENTRECONNECTOPTIONS 的 MQQueueConnectionFactory。使用 Spring JmsTemplate 发送消息。

<bean id="mqCachingConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
    <property name="targetConnectionFactory" ref="mqConnectionFactory" />
    <property name="sessionCacheSize" value="20" /> 
    <property name="reconnectOnException" value="true"/>

未使用以下任何 IBM MQ 连接工厂设置。

firstMQConnectionFactory.setClientReconnectOptions(WMQConstancs.WMQ_CLIENT_RECONNECT;
firstMQConnectionFactory.setClientReconnectTimeout(5);

我让 spring CachingConnectionFactory 检测错误并尝试重新连接。

当队列管理器意外关闭时，问题就出现了。 Spring CachingConnectionFactory 检测到这一点并开始一个新的连接。现在 IBM MQ 连接工厂尝试创建新连接。在放弃 MQRC_HOST_NOT_AVAILABLE 之前，它会等待 30 分钟。堆栈跟踪：

org.springframework.jms.IllegalStateException: JMSWMQ0018: Failed to connect to queue manager 'QMGRID' with connection mode 'Client' and host name 'QMGRHOST(port)'.; nested exception is com.ibm.msg.client.jms.DetailedIllegalStateException: JMSWMQ0018: Failed to connect to queue manager 'QMGR' with connection mode 'Client' and host name 'hostname(62306)'.\nCheck the queue manager is started and if running in client mode, check there is a listener running. Please see the linked exception for more information.; nested exception is com.ibm.mq.MQException: JMSCMQ0001: IBM MQ call failed with compcode '2' ('MQCC_FAILED') reason '2538' ('MQRC_HOST_NOT_AVAILABLE').
Caused by: com.ibm.mq.jmqi.JmqiException: CC=2;RC=2538;AMQ9213: A communications error for 'TCP' occurred. [1=java.net.ConnectException[Connection timed out (Connection timed out)],3=connnectUsingLocalAddress,4=TCP,5=Socket.connect]
java.net.ConnectException: Connection timed out (Connection timed out)
at java.net.PlainSocketImpl.socketConnect(Native Method) ~[?:1.8.0_172]
at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) ~[?:1.8.0_172]
at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) ~[?:1.8.0_172]
at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) ~[?:1.8.0_172]
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) ~[?:1.8.0_172]
at java.net.Socket.connect(Socket.java:589) ~[?:1.8.0_172]
at java.net.Socket.connect(Socket.java:538) ~[?:1.8.0_172]
at com.ibm.mq.jmqi.remote.impl.RemoteTCPConnection$5.run(RemoteTCPConnection.java:825) ~[com.ibm.mq.jmqi-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at com.ibm.mq.jmqi.remote.impl.RemoteTCPConnection$5.run(RemoteTCPConnection.java:816) ~[com.ibm.mq.jmqi-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_172]
at com.ibm.mq.jmqi.remote.impl.RemoteTCPConnection.connnectUsingLocalAddress(RemoteTCPConnection.java:816) ~[com.ibm.mq.jmqi-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at com.ibm.mq.jmqi.remote.impl.RemoteTCPConnection.protocolConnect(RemoteTCPConnection.java:1279) ~[com.ibm.mq.jmqi-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at com.ibm.mq.jmqi.remote.impl.RemoteConnection.connect(RemoteConnection.java:1003) ~[com.ibm.mq.jmqi-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at com.ibm.mq.jmqi.remote.impl.RemoteConnectionSpecification.getSessionFromNewConnection(RemoteConnectionSpecification.java:409) ~[com.ibm.mq.jmqi-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at com.ibm.mq.jmqi.remote.impl.RemoteConnectionSpecification.getSession(RemoteConnectionSpecification.java:305) ~[com.ibm.mq.jmqi-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at com.ibm.mq.jmqi.remote.impl.RemoteConnectionPool.getSession(RemoteConnectionPool.java:155) ~[com.ibm.mq.jmqi-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at com.ibm.mq.jmqi.remote.api.RemoteFAP.jmqiConnect(RemoteFAP.java:1716) ~[com.ibm.mq.jmqi-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at com.ibm.mq.jmqi.remote.api.RemoteFAP.jmqiConnect(RemoteFAP.java:1280) ~[com.ibm.mq.jmqi-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at com.ibm.mq.ese.jmqi.InterceptedJmqiImpl.jmqiConnect(InterceptedJmqiImpl.java:377) ~[com.ibm.mq.jmqi-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at com.ibm.mq.ese.jmqi.ESEJMQI.jmqiConnect(ESEJMQI.java:562) ~[com.ibm.mq.jmqi-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at com.ibm.msg.client.wmq.internal.WMQConnection.< init>(WMQConnection.java:356) ~[com.ibm.mqjms-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at com.ibm.msg.client.wmq.factories.WMQConnectionFactory.createV7ProviderConnection(WMQConnectionFactory.java:8474) ~[com.ibm.mqjms-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at com.ibm.msg.client.wmq.factories.WMQConnectionFactory.createProviderConnection(WMQConnectionFactory.java:7814) ~[com.ibm.mqjms-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at com.ibm.msg.client.jms.admin.JmsConnectionFactoryImpl._createConnection(JmsConnectionFactoryImpl.java:299) ~[com.ibm.mqjms-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at com.ibm.msg.client.jms.admin.JmsConnectionFactoryImpl.createConnection(JmsConnectionFactoryImpl.java:236) ~[com.ibm.mqjms-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at com.ibm.mq.jms.MQConnectionFactory.createCommonConnection(MQConnectionFactory.java:6016) ~[com.ibm.mqjms-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at com.ibm.mq.jms.MQQueueConnectionFactory.createQueueConnection(MQQueueConnectionFactory.java:111) ~[com.ibm.mqjms-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at com.ibm.mq.jms.MQQueueConnectionFactory.createConnection(MQQueueConnectionFactory.java:187) ~[com.ibm.mqjms-9.0.0.3.jar:9.0.0.3 - p900-003-180226]
at org.springframework.jms.connection.SingleConnectionFactory.doCreateConnection(SingleConnectionFactory.java:403) ~[spring-jms-5.0.6.RELEASE.jar:5.0.6.RELEASE]
at org.springframework.jms.connection.SingleConnectionFactory.initConnection(SingleConnectionFactory.java:343) ~[spring-jms-5.0.6.RELEASE.jar:5.0.6.RELEASE]
at org.springframework.jms.connection.SingleConnectionFactory.getConnection(SingleConnectionFactory.java:321) ~[spring-jms-5.0.6.RELEASE.jar:5.0.6.RELEASE]
at org.springframework.jms.connection.SingleConnectionFactory.createConnection(SingleConnectionFactory.java:236) ~[spring-jms-5.0.6.RELEASE.jar:5.0.6.RELEASE]
at org.springframework.jms.support.JmsAccessor.createConnection(JmsAccessor.java:196) ~[spring-jms-5.0.6.RELEASE.jar:5.0.6.RELEASE]
at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:494) ~[spring-jms-5.0.6.RELEASE.jar:5.0.6.RELEASE]
... 67 more\n}

我们可以设置以下设置来限制此连接超时吗？

firstMQConnectionFactory.setClientReconnectTimeout(5);

当 CLIENTRECONNECTOPTIONS 未设置且默认禁用时，此选项是否会生效？

【问题讨论】：

30 分钟后不再尝试重新连接。它在 30 分钟后放弃连接到 mq 主机。我想控制它在放弃之前等待的时间。
是的。连接超时错误需要 30 分钟。用户在浏览器中看到请求旋转。尝试在 5 秒内超时。我们尝试执行的 MQ 操作是可选的。不幸的是，我无法下令删除 qmgr。它只发生在极端情况下。一旦 qmgr 启动，Spring JMS 就会恢复。但是在它下降的同时，试图尽量减少对用户的影响。他们会看到 5 秒的缓慢，但至少不会被阻止。更新了堆栈跟踪超时的问题，显示了它在哪里等待。需要知道此跟踪中是否有任何类使用超时配置。
如果您将配置指向网络上未分配给任何服务器的 IP，您会得到相同的结果吗？
我能够使用随机 IP 地址重现相同的错误。能够使用 System.setProperty('com.ibm.mq.cfg.TCP.Connect_Timeout', '5') 控制超时。谢谢。
@Aladin 我认为您没有线程安全的选项。如果您想让原始海报以外的任何人如此提醒您，您需要像我为您所做的那样@标记他们。

标签： jms ibm-mq spring-jms

【解决方案1】：

根据问题的描述，java 在初始连接上似乎需要 30 分钟才能超时。

MQ 有一个参数可让您调整 TCP 连接超时。

据我所知，如果您不设置参数，它取决于 java 实现和底层操作系统设置超时需要多长时间，在您的情况下，这必须是 30 分钟，但这似乎非常高，例如在 Linux 上，我相信默认值为 93 秒。

有两种方法可以做到这一点：

通过将 java 系统属性 com.ibm.mq.cfg.TCP.Connect_Timeout 设置为您希望连接超时的秒数。这可以通过两种方式完成：
- 以编程方式使用System.setProperty('com.ibm.mq.cfg.TCP.Connect_Timeout', '5')
- 在命令行上通过传递-Dcom.ibm.mq.cfg.TCP.Connect_Timeout=5
您也可以将Connect_Timeout=5 放在mqclient.ini 文件的TCP: 节中，IBM MQ Classes for JMS 将从各种默认位置中选择它。查看我对“Where should MQClient.ini reside for an IIS Application?”的回答，了解 MQ 将在何处查找此文件的信息。请注意，答案是针对 Windows 操作系统编写的，但 IBM 知识中心文档的链接也会向您显示 Unix/Linux 路径。
```
TCP:
   Connect_Timeout=5
```

【讨论】：