使用 IBM MQ 发送消息，出现 2059 错误或在构建队列管理器时挂起

Question

我的任务是向（目前）未知的 MQ 端点发送测试消息。

我在服务器上安装了 IBM WebSphere MQ (v8.0.0.5) 的试用版，我相信配置正确。

但是，鉴于下面包含的代码，我得到了异常：

An unhandled exception of type 'IBM.WMQ.MQException' occurred in amqmdnet.dll

Additional information: 2059

或者如果我在服务器本身上使用 localhost 而不是远程服务器名称，构造函数行会挂起。

这是 C#：

Hashtable connectionProperties = new Hashtable();

string connectionType = MQC.TRANSPORT_MQSERIES_MANAGED
connectionProperties.Add(MQC.TRANSPORT_PROPERTY, connectionType);

// Set up the rest of the connection properties, based on the
// connection type requested
switch (_connectionType)
{
    case MQC.TRANSPORT_MQSERIES_BINDINGS:
        break;
    case MQC.TRANSPORT_MQSERIES_CLIENT:
    case MQC.TRANSPORT_MQSERIES_XACLIENT:
    case MQC.TRANSPORT_MQSERIES_MANAGED:
        connectionProperties.Add(MQC.HOST_NAME_PROPERTY, "server.com");
        connectionProperties.Add(MQC.CHANNEL_PROPERTY, "SYSTEM.DEF.CLNTCONN");      
        break;
}

MQQueueManager qMgr = new MQQueueManager("test", connectionProperties);
MqClientTest mqClientTest=new MqClientTest("TEST_QM","localhost", "SYSTEM.DEF.CLNTCONN");

我们在这方面有什么遗漏吗？

更新 1：

在 errors 文件夹的 amqerr01.log 文件中，我们现在有文本：

AMQ6183: An internal WebSphere MQ error has occurred.

更新二：

"internal WebSphere MQ error" 可能是由于我探测了 1414 端口以查看该端口是否 "up" 并正在监听。似乎是，它显然不喜欢我那样做。

更新 3：

@Roger 建议我使用 127.0.0.1 和大写字母，我现在已经应用了 - 并更改了上面的示例以反映。

@JoshMc 请指出队列管理器文件夹中的第二个 AMQERR01.LOG 文件。我现在得到错误：

14/11/2017 15:35:08 - Process(336.6) User(xxxx) Program(amqrmppa.exe) Host(xxxx) Installation(xxxx) VRMF(8.0.0.5) QMgr(TEST_QM) AMQ9519: Channel 'SYSTEM.DEF.CLNTCONN' not found.

EXPLANATION: The requested operation failed because the program could not find a definition of channel 'SYSTEM.DEF.CLNTCONN'.

TEST_QM 是我的队列管理器，具有默认（？）通道 SYSTEM.DEF.CLNTCONN

Answer 1

localhost

尝试使用 127.0.0.1 而不是本地主机。

"rx" and "swift_test_tx"

由于您是 MQ 的新手，是时候阅读 MQ 最佳实践了。一项是对 MQ 对象名称使用小写字符不是一个好主意。即队列、通道等...... MQ 将始终将任何不在引号中的名称折叠为大写。所以，名字开头还是大写比较好（以后少出问题）。

接下来，您是否在防火墙中打开了端口 1414？如果没有，则打开 TCP 和 UDP 端口。

下面是一个 C# 程序示例，用于将消息放入远程队列管理器中的队列：

using System;
using System.Collections;
using System.Collections.Generic;
using System.Text;
using IBM.WMQ;

/// <summary> Program Name
/// MQTest51
///
/// Description
/// This C# class will connect to a remote queue manager
/// and put a message to a queue under a managed .NET environment.
///
/// Sample Command Line Parameters
/// -h 127.0.0.1 -p 1414 -c TEST.CHL -m MQWT1 -q TEST.Q1
///
/// </summary>
namespace MQTest51
{
   class MQTest51
   {
      private Hashtable inParms = null;
      private Hashtable qMgrProp = null;
      private System.String qManager;
      private System.String outputQName;

      /*
      * The constructor
      */
      public MQTest51()
         : base()
      {
      }

      /// <summary> Make sure the required parameters are present.</summary>
      /// <returns> true/false
      /// </returns>
      private bool allParamsPresent()
      {
         bool b = inParms.ContainsKey("-h") && inParms.ContainsKey("-p") &&
                  inParms.ContainsKey("-c") && inParms.ContainsKey("-m") &&
                  inParms.ContainsKey("-q");
         if (b)
         {
            try
            {
               System.Int32.Parse((System.String)inParms["-p"]);
            }
            catch (System.FormatException e)
            {
               b = false;
            }
         }

         return b;
      }

      /// <summary> Extract the command-line parameters and initialize the MQ variables.</summary>
      /// <param name="args">
      /// </param>
      /// <throws>  IllegalArgumentException </throws>
      private void init(System.String[] args)
      {
         inParms = Hashtable.Synchronized(new Hashtable());
         if (args.Length > 0 && (args.Length % 2) == 0)
         {
            for (int i = 0; i < args.Length; i += 2)
            {
               inParms[args[i]] = args[i + 1];
            }
         }
         else
         {
            throw new System.ArgumentException();
         }

         if (allParamsPresent())
         {
            qManager = ((System.String)inParms["-m"]);
            outputQName = ((System.String)inParms["-q"]);

            qMgrProp = new Hashtable();

            qMgrProp.Add(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES_MANAGED);

            qMgrProp.Add(MQC.HOST_NAME_PROPERTY, ((System.String)inParms["-h"]));
            qMgrProp.Add(MQC.CHANNEL_PROPERTY, ((System.String)inParms["-c"]));

            try
            {
               qMgrProp.Add(MQC.PORT_PROPERTY, System.Int32.Parse((System.String)inParms["-p"]));
            }
            catch (System.FormatException e)
            {
               qMgrProp.Add(MQC.PORT_PROPERTY, 1414);
            }

            if (inParms.ContainsKey("-u"))
               qMgrProp.Add(MQC.USER_ID_PROPERTY, ((System.String)inParms["-u"]));

            if (inParms.ContainsKey("-x"))
               qMgrProp.Add(MQC.PASSWORD_PROPERTY, ((System.String)inParms["-x"]));

            if ( (inParms.ContainsKey("-u")) && (inParms.ContainsKey("-x")) )
               qMgrProp.Add(MQC.USE_MQCSP_AUTHENTICATION_PROPERTY, true);
         }
         else
         {
            throw new System.ArgumentException();
         }
      }

      /// <summary> Connect, open queue, write a message, close queue and disconnect.
      ///
      /// </summary>
      /// <throws>  MQException </throws>
      private void testSend()
      {
         System.String line;
         int openOptions = MQC.MQOO_OUTPUT + MQC.MQOO_FAIL_IF_QUIESCING;

         try
         {
            MQQueueManager _qMgr = new MQQueueManager(qManager, qMgrProp);
            System.Console.Out.WriteLine("MQTest51 successfully connected to " + qManager);

            MQQueue queue = _qMgr.AccessQueue(outputQName, openOptions, null, null, null); // no alternate user id
            System.Console.Out.WriteLine("MQTest51 successfully opened " + outputQName);

            MQPutMessageOptions pmo = new MQPutMessageOptions();

            // Define a simple MQ message, and write some text in UTF format..
            MQMessage sendmsg = new MQMessage();
            sendmsg.Format = MQC.MQFMT_STRING;
            sendmsg.Feedback = MQC.MQFB_NONE;
            sendmsg.MessageType = MQC.MQMT_DATAGRAM;

            line = "This is a test message embedded in the MQTest51 program.";

            sendmsg.MessageId = MQC.MQMI_NONE;
            sendmsg.CorrelationId = MQC.MQCI_NONE;
            sendmsg.WriteString(line);

            // put the message on the queue

            queue.Put(sendmsg, pmo);
            System.Console.Out.WriteLine("Message Data>>>" + line);

            queue.Close();
            System.Console.Out.WriteLine("MQTest51 closed: " + outputQName);
            _qMgr.Disconnect();
            System.Console.Out.WriteLine("MQTest51 disconnected from " + qManager);
         }
         catch (MQException mqex)
         {
            System.Console.Out.WriteLine("MQTest51 cc=" + mqex.CompletionCode + " : rc=" + mqex.ReasonCode);
         }
         catch (System.IO.IOException ioex)
         {
            System.Console.Out.WriteLine("MQTest51 ioex=" + ioex);
         }
      }

      /// <summary> main line</summary>
      /// <param name="args">
      /// </param>
      //        [STAThread]
      public static void Main(System.String[] args)
      {
         MQTest51 write = new MQTest51();

         try
         {
            write.init(args);
            write.testSend();
         }
         catch (System.ArgumentException e)
         {
            System.Console.Out.WriteLine("Usage: MQTest51 -h host -p port -c channel -m QueueManagerName -q QueueName [-u userID] [-x passwd]");
            System.Environment.Exit(1);
         }
         catch (MQException e)
         {
            System.Console.Out.WriteLine(e);
            System.Environment.Exit(1);
         }

         System.Environment.Exit(0);
      }
   }
}

Answer 2

对于 IBM MQ，总是有一对协同工作的通道。例如，如果一个 MQ 队列管理器需要将消息发送到另一个队列管理器，它通常会定义一个 SDR（发送方）通道，该通道将指向具有相同名称的 RCVR（接收方）通道在另一个队列管理器上。

对于 MQ 客户端连接，通道的客户端应用程序端称为 MQCD，MQ 队列管理器端称为 SVRCONN（服务器连接）通道。客户端 MQCD 可以用几种不同的方式指定。您在发布的示例中演示的方式是以编程方式指定 MQCD 信息（频道名称、主机名等）。

另一种指定信息的方法是指向通常称为通道 Table 的 CCDT（客户端通道定义 Table），这是一个CLNTCONN 频道将被使用，因为您没有使用频道 table 我将继续说明您收到错误的原因，但在此答案的最后我将提供有关频道的更多详细信息Tables.

总之，您的应用程序应该而不是 指定CLNTCONN 频道，因为MQC.CHANNEL_PROPERTY 它应该指向SVRCONN 频道。

需要注意两点：

您不应为此目的使用预定义的 SYSTEM.* 通道（例如 SYSTEM.DEF.SVRCONN），您应该定义一个新通道供您的应用程序使用。默认通道用于保存您希望在创建相同类型的新通道时作为默认值的参数。
MQ v7.1 及更高版本默认启用了一些 CHLAUTH 规则，这些规则将阻止对 SYSTEM.* 通道的访问。

如果要在 Windows 运行上使用命令行程序 runmqsc 定义 SVRCONN 通道，请在 CMD 提示符下执行以下操作：

echo DEFINE CHL(TEST_QM_CHANNEL1) CHLTYPE(SVRCONN)|runmqsc TEST_QM

有关频道 Table 的更多详细信息：

在 MQ v8 之前，唯一支持的生成通道 Table 的方法是在队列管理器上定义 CLNTCONN 通道，该通道在队列管理器名称下创建一个名为 AMQCLCHL.TAB 的文件名为 @ipcc 的目录中的文件夹。队列管理器带有名为 SYSTEM.DEF.CLNTCONN 的通道的原因是在您创建新的 CLNTCONN 通道时提供默认值。使用 v8 及更高版本，您可以仅使用 runmqsc -n 模式创建通道 table，这将直接编辑通道 table 而不是需要在队列管理器上创建 CLNTCONN 通道. v8 及更高版本的 MQ 客户端现在带有客户端版本 runmqsc，可用于创建和更改通道 tables。

应用程序可以通过几种不同的方式指向通道 table 文件，一种常见的方式是设置两个环境变量（MQCHLLIB 和 MQCHLTAB）。然后应用程序在程序中不指定通道名称、主机名等，它只需要指定要连接的队列管理器的名称。

IBM v7.5（或更高版本）知识中心页面“Connecting IBM WebSphere MQ MQI client applications to queue managers”中记录了 MQ 查找连接信息的顺序和位置。请注意，此 link 适用于 MQI 客户端，但同样的基本顺序也适用于 .NET 客户端。

使用 IBM MQ 发送消息，出现 2059 错误或在构建队列管理器时挂起

Sending a message using IBM MQ, getting 2059 error or hang on construction of Queue Manager

c#

ibm-mq