向 MQ Topic 发布消息时是否可以使用内置关联？

Question

我只是对 WebSphere MQ 7 中主题的使用有点迷失。假设简单的场景：

• 我有一个向主题发布消息的流程。
• 我有零个或多个订阅者接收该消息。
• 任何订阅者都可以决定对收到的消息做出反应=可选的“回复”。 （旁注：最初的决定是也使用主题进行回复，但如有必要，我会将其更改为队列）已发布的消息可以配置 ReplyToQueueName ，也可以是客户端上的系统级配置。
• 响应必须与原始发布的“请求”相关（因为可能有多个发布的请求）。

现在该怎么做呢？我尝试使用 MQ 队列中的常见方法，其中发起者选择：

• 将报告设置为 MQRO_COPY_MSG_ID_TO_CORREL_ID。接收方将从请求中获取消息 ID，并将其作为响应中的相关 ID 传递。
• 将报告设置为 MQRO_PASS_CORREL_ID + 在请求消息中设置相关 ID。接收方将从请求中获取相关 ID，并将其设置为响应消息中的相关 ID。

在这两种情况下，发送方都知道传递给请求的消息 ID 或关联 ID，因此它可以正确关联消息，但这不适用于 MQ 主题。

如果我尝试遵循上述方法，则在发布请求时会立即遇到问题 - 消息 ID 未在发布者端设置（它为空），因此第一种方法是不可能的。如果我尝试在发布者端设置关联 ID，我将在订阅者端得到不同的关联 ID，因此我无法将其用于消息关联（= 第二种方法也不可能）。

以下是使用主题时发生的一些示例（ID 采用 Base64）：

使用 MQRO_COPY_MSG_ID_TO_CORREL_ID 进行测试：

Send request: // After sending message publisher doesn't know its ID!
Message Id:     AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA
Correlation Id: AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA

Received request: // Subscriber gets some ID and correlation ID (but publisher didn't set any)
Message Id:     QU1RIExNLnF1ZXVlLm1hbp2OiU4g6AYH
Correlation Id: QU1RIExNLnF1ZXVlLm1hbp2OiU4g6AYF

Send response:  // Subscriber correctly uses message ID of incoming request
Message Id:     AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA
Correlation Id: QU1RIExNLnF1ZXVlLm1hbp2OiU4g6AYH

Received response: // Publisher gets in response completely different IDs!
Message Id:     QU1RIExNLnF1ZXVlLm1hbp2OiU4g6AYP
Correlation Id: QU1RIExNLnF1ZXVlLm1hbp2OiU4g6AYN

使用 MQRO_PASS_CORREL_ID 进行测试：

Send request: // Publisher doesn't know its ID but it generated some random correlation ID.
Message Id:     AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA
Correlation Id: Chhv8KT+zhTjfAEdzeiB3cizw9vRy9Pf

Received request: // Subscriber got ANOTHER correlation ID!
Message Id:     QU1RIExNLnF1ZXVlLm1hbp2OiU4g6AYY
Correlation Id: QU1RIExNLnF1ZXVlLm1hbp2OiU4g6AYW

Send response:  // Subscriber is using incorrect correlation ID.
Message Id:     AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA
Correlation Id: QU1RIExNLnF1ZXVlLm1hbp2OiU4g6AYW

Received response: // Publisher gets in response completely different IDs!
Message Id:     QU1RIExNLnF1ZXVlLm1hbp2OiU4g6AYg
Correlation Id: QU1RIExNLnF1ZXVlLm1hbp2OiU4g6AYe

如何强制 MQ 不更改我的 ID？我用 Java 和 .NET 编写了测试应用程序，两者的行为方式相同。或者什么是适合我的用例的正确方法？

Answer 1

您是否考虑过使用 JMS（MQ 作为实现）而不是直接使用 MQ api 进行编码？

JMS 已经有了 replyTo< 的概念/a> 在发布的消息中已经有了 a 关联 ID 将消息链接在一起。对于replyTo，发布者可以指定队列或主题，因此您在接收端不会受到任何限制。

Answer 2

消息Id在消息系统中是唯一的。在发布/订阅模式下，消息传递引擎将发布者发送的消息的副本发布给多个（和未知）订阅者。每个消息副本都会有一个不同的消息 ID，因为消息 ID 必须是唯一的。

编辑：

再次通读信息中心，这是我发现的。

您可以使用 MQSO_SET_CORREL_ID 选项强制队列管理器保留应用程序设置的 correlId。

int subOptions = MQC.MQOO_FAIL_IF_QUIESCING | MQC.MQOO_INPUT_SHARED | MQC.MQSO_SET_CORREL_ID;
MQTopic sub = qm.AccessTopic(recvQ, "/TEST/CORRELID", null, subOptions);

必须注意的是，如果您在创建订阅时使用 MQSO_MANAGED 选项，则无法使用 MQSO_SET_CORREL_ID。

发布时将 correlID 设置为

putMsg.CorrelationId = Encoding.ASCII.GetBytes("THISISTHECORRELID");
topicCorrelId.Put(putMsg);

接收发布

gmo.MatchOptions = MQC.MQMO_MATCH_CORREL_ID;
fwdMsg.CorrelationId = Encoding.ASCII.GetBytes("THISISTHECORRELID"); 

sub.Get(fwdMsg, gmo);

时，仅当您使用队列进行多个订阅并且只想获取特定主题的发布时，您才可以使用匹配相关 ID 选项，例如使用 MQMO_MATCH_CORREL_ID。