C#.Net多线程IBM MQ连接异常：部分请求失败（错误码2009）

问题现象 #

• 单线程运行时，所有请求均可正常连接IBM MQ并发送消息
• 线程数设置为2或3时，部分请求失败，返回错误码2009 MQRC_CONNECTION_BROKEN

代码问题分析 #

从提供的PutMessageOnQueue_Inward方法来看，主要存在以下问题：

1. 每次请求新建连接：每个线程都创建独立的MQQueueManager实例，频繁的连接创建/销毁会触发MQ服务器的连接限制，或因资源竞争导致连接中断
2. 冗余的手动资源释放：在using块内手动调用objMQQueue.Close()和objMQQueueManager.Disconnect()，using会自动处理资源释放，手动操作可能导致资源状态异常
3. 异常信息缺失：捕获MQException后仅清空message，未记录错误码、具体异常信息，无法定位失败原因

解决方案 #

1. 启用IBM MQ连接池复用连接

通过配置连接池属性，让多线程复用MQQueueManager实例，避免频繁创建连接：

Hashtable properties = new Hashtable();
// 基础连接属性
properties.Add(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES_MANAGED);
properties.Add(MQC.HOST_NAME_PROPERTY, Common.FTS_MQ_HostName);
properties.Add(MQC.CHANNEL_PROPERTY, Common.QUEUE_CHANNEL);
properties.Add(MQC.PORT_PROPERTY, Common.FTS_MQ_Port);
properties.Add(MQC.USER_ID_PROPERTY, Common.FTS_MQ_UserId);
properties.Add(MQC.PASSWORD_PROPERTY, Common.FTS_MQ_Password);
properties.Add(MQC.USE_MQCSP_AUTHENTICATION_PROPERTY, true);

// 启用连接池
properties.Add(MQC.CONNECTION_POOLING_PROPERTY, true);
// 设置连接池最大容量
properties.Add(MQC.MAX_CONNECTIONS_PROPERTY, 10);
// 设置连接空闲超时（毫秒）
properties.Add(MQC.CONNECTION_IDLE_TIMEOUT_PROPERTY, 30000);

2. 修正资源释放逻辑

移除using块内的手动关闭/断开操作，让using自动管理资源生命周期：

public string PutMessageOnQueue_Inward(string message, string strMessageID)
{
    string writeQueueName = Common.WRITE_MESSAGE_QUEUENAME_INWARD;
    try
    {
        Hashtable properties = new Hashtable();
        // 配置连接属性（包含连接池设置）
        properties.Add(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES_MANAGED);
        properties.Add(MQC.HOST_NAME_PROPERTY, Common.FTS_MQ_HostName);
        properties.Add(MQC.CHANNEL_PROPERTY, Common.QUEUE_CHANNEL);
        properties.Add(MQC.PORT_PROPERTY, Common.FTS_MQ_Port);
        properties.Add(MQC.USER_ID_PROPERTY, Common.FTS_MQ_UserId);
        properties.Add(MQC.PASSWORD_PROPERTY, Common.FTS_MQ_Password);
        properties.Add(MQC.USE_MQCSP_AUTHENTICATION_PROPERTY, true);
        properties.Add(MQC.CONNECTION_POOLING_PROPERTY, true);
        properties.Add(MQC.MAX_CONNECTIONS_PROPERTY, 10);
        properties.Add(MQC.CONNECTION_IDLE_TIMEOUT_PROPERTY, 30000);

        using (var objMQQueueManager = new MQQueueManager(Common.QUEUEMANAGER_NAME, properties))
        {
            using (var objMQQueue = objMQQueueManager.AccessQueue(writeQueueName, MQC.MQOO_OUTPUT + MQC.MQOO_FAIL_IF_QUIESCING))
            {
                var objPutMQMessage = new MQMessage
                {
                    CharacterSet = 1208,
                    Format = MQC.MQFMT_STRING,
                    MessageType = MQC.MQMT_DATAGRAM,
                    Report = MQC.MQRO_NONE,                            
                };

                objPutMQMessage.WriteString(message);
                objMQQueue.Put(objPutMQMessage);
                objMQQueueManager.Commit();
            }
        } 
        return message;
    }
    catch (MQException mqEx)
    {
        // 记录详细异常信息，便于排查
        Common.WriteFTSLog($"MQ发送失败，错误码:{mqEx.ReasonCode}，消息:{mqEx.Message}，堆栈:{mqEx.StackTrace}");
        return null;
    }
    catch (Exception ex)
    {
        Common.WriteFTSLog($"发送消息异常:{ex.Message}，堆栈:{ex.StackTrace}");
        return null;
    }
}

3. 检查MQ服务器配置

• 确认队列管理器的最大连接数设置（可通过MQ Explorer查看Maximum connections属性），确保允许足够的并发连接
• 检查MQ通道的最大实例数，避免通道实例被耗尽

4. 线程安全验证

确认ProcessQueue的实现是线程安全的，避免多线程同时操作共享资源引发异常

内容的提问来源于stack exchange，提问作者Pradeep Kumar