如何使用 MQ Client 连接到 MQ Server QUEUE MANAGER

Question

我尝试使用 MQ 客户端向 MQ 服务器发送消息

错误是：- 发生 WebSphere MQ 错误：完成代码 2 原因代码 2058.I 知道此原因代码是因为队列管理器名称错误..但队列管理器名称是正确的...

安装 WebSphere MQ 客户端后，我只是运行命令：设置 MQSERVER=QM_ORANGE/TCP/IPADDRESS（端口号）

和运行这个程序 public class MQSample {

  // code identifier
  static final String sccsid = "@(#) MQMBID sn=p750-002-131001_DE su=_FswqMCqGEeOZ3ui-rZDONA pn=MQJavaSamples/wmqjava/MQSample.java";

  // define the name of the QueueManager
  private static final String qManager = "QM_ORANGE";
  // and define the name of the Queue
  private static final String qName = "Q1";

  /**
   * Main entry point
   * 
   * @param args - command line arguments (ignored)
   */
  public static void main(String args[]) {
    try {
      // Create a connection to the QueueManager
      System.out.println("Connecting to queue manager: " + qManager);
      MQQueueManager qMgr = new MQQueueManager(qManager);

      // Set up the options on the queue we wish to open
      //int openOptions = MQConstants.MQOO_INPUT_AS_Q_DEF | MQConstants.MQOO_OUTPUT;
      int openOptions = MQConstants.MQOO_OUTPUT;
     // int openOptions1 = MQConstants.MQOO_INPUT_AS_Q_DEF;
      // Now specify the queue that we wish to open and the open options
      System.out.println("Accessing queue: " + qName);
      MQQueue queue = qMgr.accessQueue(qName, openOptions);
      //MQQueue queue1 = qMgr.accessQueue(qName, openOptions1);
      // Define a simple WebSphere MQ Message ...
      MQMessage msg = new MQMessage();
      // ... and write some text in UTF8 format
      msg.writeUTF("Hello, World!");

      // Specify the default put message options
      MQPutMessageOptions pmo = new MQPutMessageOptions();

      // Put the message to the queue
      System.out.println("Sending a message...");
      queue.put(msg, pmo);


      //



         openOptions = MQC.MQOO_INQUIRE + MQC.MQOO_FAIL_IF_QUIESCING
                + MQC.MQOO_INPUT_SHARED;

         queue = qMgr.accessQueue("QM_APPLE", openOptions,
                null, // default q manager
                null, // no dynamic q name
                null); // no alternate user id

        System.out.println("MQRead v1.0 connected.\n");

        int depth = queue.getCurrentDepth();
        System.out.println("Current depth: " + depth + "\n");
        if (depth == 0) {
            return;
        }

        MQGetMessageOptions getOptions = new MQGetMessageOptions();
        getOptions.options = MQC.MQGMO_NO_WAIT + MQC.MQGMO_FAIL_IF_QUIESCING
                + MQC.MQGMO_CONVERT;
        while (true) {

            MQMessage message = new MQMessage();
            try {
                queue.get(message, getOptions);

                byte[] b = new byte[message.getMessageLength()];
                message.readFully(b);
                System.out.println(new String(b));
                message.clearMessage();
            } catch (IOException e) {
                System.out.println("IOException during GET: " + e.getMessage());
                break;
            } catch (MQException e) {
                if (e.completionCode == 2
                        && e.reasonCode == MQException.MQRC_NO_MSG_AVAILABLE) {
                    if (depth > 0) {
                        System.out.println("All messages read.");
                    }
                } else {
                    System.out.println("GET Exception: " + e);
                }
                break;
            }
        }
        queue.close();
        //_queueManager.disconnect();

      // Disconnect from the QueueManager
      System.out.println("Disconnecting from the Queue Manager");
      qMgr.disconnect();
      System.out.println("Done!");
    }
    catch (MQException ex) {
      System.out.println("A WebSphere MQ Error occured : Completion Code " + ex.completionCode
          + " Reason Code " + ex.reasonCode);
      ex.printStackTrace();
      for (Throwable t = ex.getCause(); t != null; t = t.getCause()) {
        System.out.println("... Caused by ");
        t.printStackTrace();
      }

    }
    catch (java.io.IOException ex) {
      System.out.println("An IOException occured whilst writing to the message buffer: " + ex);
    }
    return;
  }
}

Answer 1

您已设置 MQSERVER 环境变量。 MQ C Client 了解此环境变量并相应地连接到 IP 地址中指定的机器上的队列管理器运行。 MQ Java 的行为方式不同。

在您的应用程序中，您只在 MQQueueManager 构造函数中指定了队列管理器名称。这意味着应用程序想要通过服务器绑定连接连接到同一台机器上的队列管理器运行。

您可以按照以下方式连接到队列管理器：（更改主机、端口、通道和队列管理器名称）。请注意，示例是使用 MQ v8 Java 客户端编写的。

          Hashtable properties = new Hashtable<String, Object>();
          properties.put(MQConstants.HOST_NAME_PROPERTY, "qm.mycomp.com");
          properties.put(MQConstants.PORT_PROPERTY, 1414); 
          properties.put(MQConstants.CHANNEL_PROPERTY, "APP.SVRCONN"); 
          properties.put(MQConstants.USE_MQCSP_AUTHENTICATION_PROPERTY,"true");
          properties.put(MQConstants.USER_ID_PROPERTY, "myuserid");
          properties.put(MQConstants.PASSWORD_PROPERTY, "passw0rd");

          /**
           * Connect to a queue manager 
           */
          MQQueueManager queueManager = new MQQueueManager("QM", properties);

更新

所以您不想在程序中对连接参数进行硬编码？您可以使用它自身的 MQSERVER 环境变量，获取它，解析它和连接参数。您还可以使用配置文件或 LDAP 服务器来拉取连接信息。

更新二

您根本没有阅读 MQ 文档。 MQ 客户端是一组 libraries/jars/.net 程序集等，它们以不同的语言公开 API。您使用这些 API 开发应用程序以与队列管理器通信。这就是您在上面的程序中所做的。如果没有这些库，您将无法连接到队列管理器（许多人将队列管理器视为服务器）。当您的应用程序与队列管理器在同一台机器上运行时，可以通过共享内存与队列管理器进行通信。但是当运行在不同的机器上时，通信结束 TCP/IP （或 SNA）。

希望这能消除困惑。

如何使用 MQ Client 连接到 MQ Server QUEUE MANAGER

How to connect to the MQ Server QUEUE MANAGER using MQ Client

mq

ibm-mq