IBM MQ 具有自动客户端重新连接功能,默认超时为 30 分钟。30 分钟后,它停止尝试重新连接(source - p35)。
我想更改超时,以便重试持续更长的时间(例如 2 小时)。我想我可以XMSC.WMQ_CLIENT_RECONNECT_TIMEOUT
为此使用该属性,因为它在 XMSC 类中可用。
测试
我可以通过阻止客户端应用程序连接到 IBM MQ 的端口 1414 来模拟连接失败。出于测试目的,我将超时值降低到 5 分钟(而不是 30 分钟)。
我在日志中看到的是客户端应用程序收到XMSException
原因代码 2544(重新连接):
IBM.XMS.XMSException: MQ delivered an asynchronous event with completion code 1, and reason 2544.
XMSWMQ2014.explanation
XMSWMQ2014.useraction
Linked Exception : CompCode: 1, Reason: 2544
这发生了 30 分钟,之后,我得到一个XMSException
原因代码 2009(连接断开)。并且自动重新连接失败。
XMSException occurred: IBM.XMS.XMSException: MQ delivered an asynchronous event with completion code 2, and reason 2009.
XMSWMQ2014.explanation
XMSWMQ2014.useraction
Linked Exception : CompCode: 2, Reason: 2009
我可以得出结论,更改超时值没有效果......我是否以错误的方式配置了重新连接超时?
下面,有一个代码片段:
XMSFactoryFactory factory = XMSFactoryFactory.GetInstance(XMSC.CT_WMQ);
IConnectionFactory connectionFactory = factory.CreateConnectionFactory();
connectionFactory.SetStringProperty(XMSC.WMQ_HOST_NAME, "hostname");
connectionFactory.SetIntProperty(XMSC.WMQ_PORT, 1414);
connectionFactory.SetStringProperty(XMSC.WMQ_CHANNEL, "channel_name");
connectionFactory.SetIntProperty(XMSC.WMQ_CONNECTION_MODE, XMSC.WMQ_CM_CLIENT_UNMANAGED);
connectionFactory.SetStringProperty(XMSC.WMQ_QUEUE_MANAGER, "*");
connectionFactory.SetIntProperty(XMSC.WMQ_CLIENT_RECONNECT_OPTIONS, XMSC.WMQ_CLIENT_RECONNECT_Q_MGR);
connectionFactory.SetIntProperty(XMSC.WMQ_CLIENT_RECONNECT_TIMEOUT, 300); //300 seconds = 5 minutes
IConnection conn = connectionFactory.CreateConnection();
conn.Start();
IBM MQ 客户端版本:8.0.0.5
笔记
- 如果我及时解除阻塞端口,它可以成功重新连接。
- IBM 官方文档:https ://www.ibm.com/support/knowledgecenter/en/SSFKSJ_8.0.0/com.ibm.mq.msc.doc/xms_automatic_client_reconnection.htm