如何在 Java 中的 IBM MQ 中实现逻辑排序？

Question

我们有一个用例，即放置一组具有相同 groupId 但 MessageSequenceNumber 不同的消息。这用于对消息进行分组以进行逻辑排序，以便在接收方，接收方可以根据组顺序对所有消息进行分组。我关注的是 IBM MQ v7.5 知识中心页面“Message groups”。

我编写了一个代码来放置消息：-

public boolean writeMessage(String[] messages, String queueName) {          

                Session session = getQueueConnection().createSession(true,
                    Session.AUTO_ACKNOWLEDGE);


            Destination destination = session.createQueue(queueName);
            messageProducer = session.createProducer(destination);
            for (int i = 0; i < messages.length; i++) {
                TextMessage message = session.createTextMessage(messages[i]);
                messageProducer.send(message);
            }

            // Commit the send (Actually put messages to Queue)
            session.commit();
            return true;
}

现在，我想为数组内的所有消息添加一个唯一的 groupID 并添加一个序列号(msgSeqNum) (1,2,3..) 。我怎样才能通过 JMS API 做到这一点？我正在 IBM IIB v8 知识中心页面“Sending messages in a WebSphere MQ message group”上寻找代码的 JMS 版本。

Answer 1

David Currie 在 2006 年写了一篇很好的 IBM developerWorks 博客，标题为“使用 WebSphere MQ Java 和 JMS API 对消息进行分组”，描述了如何按照您的要求进行操作，但它似乎最近被 IBM 删除了。

---

Wayback Machine link to "Grouping messages using the WebSphere MQ Java and JMS APIs"

---

以下是 David 在帖子中提供的信息，与 get 逻辑相比，put 逻辑实现起来要简单得多。我只在此处包含放置逻辑代码，因为这是您询问的内容。我通过电子邮件联系了 David，询问是否会重新发布此博客。

发送消息组

让我们从查看发送应用程序开始。正如刚才提到的， put 消息选项 MQPMO_LOGICAL_ORDER 只是一个指令 到队列管理器自动分配消息组 标识符和序列号。下面清单 3 中的示例 演示了如何在 JMS API 中没有此选项的情况下，我们可以 明确设置这些属性。

清单 3. 使用 WebSphere MQ JMS API 发送消息组

MQConnectionFactory factory = new MQConnectionFactory();
factory.setQueueManager("QM_host")
MQQueue destination = new MQQueue("default");
destination.setTargetClient(JMSC.MQJMS_CLIENT_NONJMS_MQ);
Connection connection = factory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer producer = session.createProducer(destination);
 
String groupId = "ID:" + new BigInteger(24 * 8, new Random()).toString(16);
 
for (int i = 1; i <= 5; i++) {
 
    TextMessage message = session.createTextMessage();
    message.setStringProperty("JMSXGroupID", groupId);
    message.setIntProperty("JMSXGroupSeq", i);
 
    if (i == 5) {
        message.setBooleanProperty("JMS_IBM_Last_Msg_In_Group", true);
    }
 
    message.setText("Message " + i);
    producer.send(message);
 
}
 
connection.close();