与 QueueManager 断开连接时出现 MQ 错误 2195

Question

从 QueueManager 断开连接时，我收到错误代码 2195 的 MQException。我无法找到原因。如何找出此异常的原因？

我的代码如下所示。最后一行是抛出异常。

        MQQueueManager qMgr = null;
        MQQueue fromQueue = null;

        try
        {
            // mq properties
            Hashtable properties = new Hashtable();
            properties.Add(MQC.HOST_NAME_PROPERTY, _config.HostName);
            properties.Add(MQC.PORT_PROPERTY, _config.Port);
            properties.Add(MQC.CHANNEL_PROPERTY, _config.ChannelName);
            // managed mode
            properties.Add(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES_MANAGED);

            // create connection
            qMgr = new MQQueueManager(_config.QueueManagerName, properties);
            fromQueue = qMgr.AccessQueue(_config.QueueName, MQC.MQOO_INPUT_AS_Q_DEF + MQC.MQOO_FAIL_IF_QUIESCING);

            MQGetMessageOptions gmo = new MQGetMessageOptions();
            gmo.Options = MQC.MQGMO_SYNCPOINT | MQC.MQGMO_FAIL_IF_QUIESCING | MQC.MQGMO_WAIT;
            gmo.WaitInterval = Convert.ToInt32(timeout.TotalMilliseconds % Int32.MaxValue);

            try
            {
                MQMessage message = new MQMessage();
                fromQueue.Get(message, gmo);       //wait for message

                if (message != null && message.MessageLength > 0)
                {
                    string strMsg = message.ReadString(message.MessageLength);
                    ret = true;
                }
            }
            catch (MQException ex)
            {
                if (ex.ReasonCode != MQC.MQRC_NO_MSG_AVAILABLE)                      
                {
                    throw;
                }
            }
        }
        finally
        {
            try
            {
                if (fromQueue != null)
                    fromQueue.Close();
                if (qMgr != null)
                    if(qMgr.IsConnected)
                        qMgr.Disconnect(); 

Answer 1

MQC.MQGMO_SYNCPOINT

您正在创建本地 UOW（工作单元），但您从未提交或退出事务。现在，对于正常断开连接（相对于异常或崩溃），MQ 应该自动提交消息。但是你永远不应该回复 MQ 为你做你的工作。

我建议您使用 MQC.MQGMO_NO_SYNCPOINT，除非您确实希望在 UOW 中检索消息，但您需要添加提交或回退调用。

如果（qMgr.IsConnected）

这个方法调用毫无意义。它所做的只是查看最后一次调用的 CC 和 RC 值来确定是返回 true 还是 false。它实际上并不测试连接。正如我所说，毫无意义。