3

我需要根据队列的相关 ID 从队列中获取特定消息。

有没有一种方法可以让我们获取对应相关 ID 的消息，并仅从队列中删除该消息而不删除其他消息。

我尝试过的选项是检索消息，但在查找我的消息时也会从队列中删除其他消息

浏览队列时，我在 accessQueue 方法中使用了以下 openOptions

MQC.MQOQ_INPUT_SHARED | MQC.MQOO_FAIL_IF_QUIESCING | MQC_MQOO_INQUIRE | MQC.MQOOBROWSE

以及以下选项来获取消息

    String correlation ID = <correlationID>

    MQMessage respMessage = new MQMessage();

    respMessage.correlationId = correlation ID.getBytes();

    MQGetMessageOptions msg = new MqGetMessageOptions();    
    msg.options = MQC.MQGMO_NO_WAIT + MQC.MQGMO_FAIL_IF_QUIESCING + MQC.MQGMO_CONVERT + MQC.MQGMO_BROWSE_NEXT

        msg.matchOptions = MQC.MQMO_MATCH_MSG_ID

msg.waitInterval = 2000;

queue.get(respMessage, msg);
4

1 回答 1

2

您的代码有很多问题。

(1) 正如莫拉格所说，如果你想从队列中删除消息（即破坏性获取），请删除 MQGMO_BROWSE_NEXT 选项。

respMessage.correlationId = correlation ID.getBytes();
msg.matchOptions = MQC.MQMO_MATCH_MSG_ID

(2) 您正在设置 CorrelId，但随后请求匹配 MsgId。那是行不通的。您将获得 MQRC_NO_MSG_AVAILABLE (2033) 的原因代码。

(3) MsgIds 和/或 CorrelIds 永远不应转换为字符串或以字符串开头。MsgIds 和/或 CorrelIds 将包含二进制数据。因此，MsgIds 和 CorrelIds 应该始终是一个字节数组。即字节[]

这是消息的 MsgId 和 CorrelId 的屏幕截图：

MQ 可视化编辑显示消息 MQMD 字段

(4) 您有 MQGMO_NO_WAIT 选项，但您将 waitInterval 设置为 2000。如果您想等待长达 2 秒的消息到达，那么您需要使用 MQGMO_WAIT 选项。

MQGetMessageOptions msg = new MqGetMessageOptions();

(5) “msg”是一个可怕的变量名。它只会让人们感到困惑，因为他们会认为它引用了一条信息。即 MQMessage 类。将变量称为“gmo”要好得多。

IE

MQGetMessageOptions gmo = new MqGetMessageOptions();
gmo.options = CMQC.MQGMO_WAIT + CMQC.MQGMO_FAIL_IF_QUIESCING + CMQC.MQGMO_CONVERT;
gmo.waitInterval = 2000;
gmo.matchOptions = CMQC.MQMO_MATCH_CORREL_ID;
于 2019-07-09T16:11:06.147 回答