3

这是我正在使用的示例代码，但是，我不知道如何从放置或访问队列中获取响应，即消息已发送。

 mqQueue = mqQMgr.AccessQueue("Queue Name", MQC.MQOO_OUTPUT |
 MQC.MQOO_INPUT_SHARED |       MQC.MQOO_INQUIRE); 
 mqQueue.Put(mqMsg, mqPutMsgOpts);

PUT 方法是一个 void 返回类型，例如，如果它是 bool，基于返回值 - true/false，我可以确认，消息已发送到队列，这就是我的问题，我如何取回确认，以便将消息发送到队列。

任何输入都会非常有帮助。

4

2 回答 2

4

根据澄清问题的评论进行更新：

将您PUT包含在 try 块中并捕获MQException. 如果没有MQException抛出，那么PUT工作并且你得到了 RC=0。例如，这是来自示例PUT程序：

    void PutMessages()
    {
        try
        {
            // mq properties
            properties = new Hashtable();
            properties.Add(MQC.TRANSPORT_PROPERTY, MQC.TRANSPORT_MQSERIES_MANAGED);
            properties.Add(MQC.HOST_NAME_PROPERTY, hostName);
            properties.Add(MQC.PORT_PROPERTY, port);
            properties.Add(MQC.CHANNEL_PROPERTY, channelName);

            // display all details
            Console.WriteLine("MQ Parameters");
            Console.WriteLine("1) queueName = " + queueName);
            Console.WriteLine("2) host = " + hostName);
            Console.WriteLine("3) port = " + port);
            Console.WriteLine("4) channel = " + channelName);
            Console.WriteLine("5) numberOfMsgs = " + numberOfMsgs);
            Console.WriteLine("");

            // create connection
            Console.Write("Connecting to queue manager.. ");
            queueManager = new MQQueueManager(queueManagerName, properties);
            Console.WriteLine("done");

            // accessing queue
            Console.Write("Accessing queue " + queueName + ".. ");
            queue = queueManager.AccessQueue(queueName, MQC.MQOO_OUTPUT + MQC.MQOO_FAIL_IF_QUIESCING);
            Console.WriteLine("done");

            // creating a message object
            message = new MQMessage();
            message.WriteString(messageString);

            // putting messages continuously
            for (int i = 1; i <= numberOfMsgs; i++)
            {
                Console.Write("Message " + i + " <" + messageString + ">.. ");
                queue.Put(message);
                Console.WriteLine("put");
            }

            // closing queue
            Console.Write("Closing queue.. ");
            queue.Close();
            Console.WriteLine("done");

            // disconnecting queue manager
            Console.Write("Disconnecting queue manager.. ");
            queueManager.Disconnect();
            Console.WriteLine("done");
        }

        catch (MQException mqe)
        {
            Console.WriteLine("");
            Console.WriteLine("MQException caught: {0} - {1}", mqe.ReasonCode, mqe.Message);
            Console.WriteLine(mqe.StackTrace);
        }
    }

如前所述，这是来自示例代码，并且用于生产的真实程序可能具有更精细的异常处理。也就是说，API 调用要么成功，要么抛出MQException. 确切的行为取决于您的选择。例如，如果您在 a 上请求消息转换，GET则可能会出现转换错误，而作为二进制有效负载检索的完全相同的消息会成功。

以前的回应：

我不确定我是否理解这个问题，但我认为您要问的是如何使用 WebSphere MQ 设计请求/回复程序，这就是我将如何回应的方式。但是，如果您所说的“响应”实际上是指原因和返回代码PUT，请澄清问题，我会更新我的答案。

请求/响应的通常模式是请求程序首先打开回复队列。如果打开的队列的名称是模型队列，则队列管理器创建一个动态队列并返回一个句柄。否则，队列必须是预先存在的本地队列。

一旦应用程序处理了回复队列，它就会打开请求队列并创建一个新的请求消息。本地回复队列的名称用于初始化replyToQueue请求消息的字段。本地队列管理器名称会自动填充到消息的replyToQMgr字段中。然后，应用程序将消息放入回复队列中并等待回复。

如果有多个应用程序实例侦听同一个回复队列，它们通常会为他们想要的特定消息指定一个关联 ID。通常的设计是读取请求消息的服务器将其MQMD.MsgID放入MQMD.CorrelID回复消息的字段中，但有时它会将传入消息 ID 传输到出站消息 ID。

请务必COMMIT在PUT发布之前，GET否则您将永远不会得到答复。

在信息中心主题请求示例程序的设计中有更多关于此的内容，您可以C:\Program Files (x86)\IBM\WebSphere MQ\tools\dotnet在默认的 Windows WMQ 客户端安装中找到示例程序。我鼓励您熟悉这些示例并重用其中的一些代码。如果您实际上没有下载并安装完整的客户端，请在SupportPac MQC75上免费获取一份副本。然后在安装的时候一定要选择安装SDK和示例代码的选项。

于 2013-02-25T23:40:04.517 回答
1

我如何取回确认，以便将消息发送到队列

如果 Put 方法没有抛出异常，那么这就是您确认 MQ 已将消息放入队列。

于 2013-02-26T16:37:08.797 回答