MQQueue get 调用无法从队列中获取消息

Question

MQQueue get 调用无法从队列中检索消息，出现 2033 (07F1) (RC2033)：MQRC_NO_MSG_AVAILABLE 错误。我正在使用以下代码从队列中获取消息：

获取消息：

    byte[] replyMessageBytes = null;
    try {
        this.replyConnection.open();

        MQQueue replyQueue = this.replyConnection.getQueue(CMQC.MQOO_INPUT_AS_Q_DEF);
        if (null == replyQueue) {
            logger.error("Could not create reply queue.");
            throw new PFMCommunicationException("Could not create reply queue.");
        }

        MQMessage replyMessage = new MQMessage();
        MQGetMessageOptions gmo = new MQGetMessageOptions();
        gmo.resolvedQueueName = replyQueue.getResolvedQName();
        if (timeout.length > 0) {
            try {
                gmo.waitInterval = Integer.valueOf("" + timeout[0]);
            } catch (NumberFormatException e) {
            }
        } else {
            gmo.waitInterval = MQConstants.MQWI_UNLIMITED;
        }
        gmo.options = MQConstants.MQGMO_WAIT;
        if (null != correlationId) {
            gmo.matchOptions = MQConstants.MQMO_MATCH_MSG_ID | MQConstants.MQMO_MATCH_CORREL_ID;
            replyMessage.messageId = correlationId.getBytes();
            replyMessage.correlationId = correlationId.getBytes();
        } else {
            gmo.matchOptions = MQConstants.MQMO_NONE;
            replyMessage.messageId = MQConstants.MQMI_NONE;
            replyMessage.correlationId = MQConstants.MQCI_NONE;
        }

        try {
            replyQueue.get(replyMessage, gmo);
            int length = replyMessage.getMessageLength();
            replyMessageBytes = replyMessage.readStringOfByteLength(length).getBytes();
        } catch (MQException e) {
            logger.error("ERROR on receiving reply: CC=" + e.completionCode + " RC=" + e.reasonCode + " "
                    + e.getMessage());
        } catch (IOException e) {
            logger.error("ERROR on receiving reply.", e);
        }

        if (null == replyMessageBytes) {
            logger.error("No reply received.");
        } else {
            logger.debug("Received message: " + new String(replyMessageBytes));
        }
    } catch (MQException e) {
        logger.error("ERROR:", e);
        throw new PFMCommunicationException(e);
    } catch (PFMConnectionException e) {
        logger.error(e.getMessage());
        throw new PFMCommunicationException(e);
    } finally {
        this.replyConnection.close();
        logger.debug("Closed connection with MQ replies.");
    }

我确认消息在 waitInterval 到期之前存在于队列中，并且correlationId 也匹配。事实上，当我运行代码而不尝试匹配correlationId 时，我能够得到消息。我想这意味着响应消息有问题，或者我在正确创建 matchOptions 时出错。

    gmo.matchOptions = MQConstants.MQMO_NONE;
    replyMessage.messageId = MQConstants.MQMI_NONE;
    replyMessage.correlationId = MQConstants.MQCI_NONE;

这是我的响应消息头的样子：

   <Header Origin="DISPUTE1" Addressee="PSXDX2" Date="20180802" Time="123055" Area="QUERY" Content="RAddr" ID="8af3257cf01a4842bf5eec8d" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="cms/customerAccountDetails.xsd">

我尝试在响应标头中放置 CorrelId 而不是 ID，但它仍然相同。有人可以帮我找出问题吗？

Answer 1

if (null != correlationId) {
  gmo.matchOptions = MQConstants.MQMO_MATCH_MSG_ID | MQConstants.MQMO_MATCH_CORREL_ID;
  replyMessage.messageId = correlationId.getBytes();
  replyMessage.correlationId = correlationId.getBytes();
}

好吧，那是你的问题。 MQ 消息在 MsgId 和 CorrelId 字段中具有相同值的情况非常罕见。

如果您收到针对您发送的请求的回复消息，并且您在 MQPUT 之后保存了 请求消息的 MsgId，则代码应为：

if (null != correlationId) {
  gmo.matchOptions = MQConstants.MQMO_MATCH_CORREL_ID;
  replyMessage.correlationId = correlationId.getBytes();
}

注意：您不保存请求（出站）消息的 CorrelId，而是保存 MsgId。处理您的请求的服务器应该将传入的 MsgId 放在回复消息的 CorrelId 中。因此，这就是为什么您只在 CorrelId 上匹配回复消息。