WebSphere_MQ_Java

转自 http://www.zuoyefeng.com/html/2006-09/212.htm

本文介绍了 WebSphere MQ 中的消息组支持，以及如何利用该支持来提供逻辑消

息排序和支持相关消息分组。并演示了如何使用 WebSphere MQ Java 类进行分组

操作，和如何使用 JMS API 实现与此相同的功能。随后，本文还给出了一个建议

解决方案，并说明了如何在 WebSphere Application Server 或其他 J2EE 应用服务器

中异步接收消息组时如何应用此解决方案。

消息组介绍

IBM® WebSphere® MQ 并不能始终保证发送和接收应用程序间的消息的正确顺序。

开始）。然后，接收应用程序可以指定希望按照此逻辑顺序接收消息（与消息到达

目的地的实际顺序相对）。现在，即使消息 B 或 C 首先到达，也不会将其立即传

递给应用程序，因为它们的序列号不为 1。

消息组还可用于另一个目的。有时候消息顺序可能并不重要，但可能要求将一个消

息集合一起处理（在空间上和时间上）。例如，假定有一个应用程序在每次向在线

购物车添加了物品后都会发送一条消息。购物车中的物品可能需要一起处理，或许

要将其聚合到单个订单消息中。可以通过将消息放入到消息组中对此聚合进行管理。

消息的接收者可以指定，在所有消息到达目的地之前，不希望接收组中的任何消息。

在此场景中，在同一个位置接收所有消息也很重要。如果出于可伸缩性方面的原因，

目的地有多个使用者，则务必将表示相同订单中的物品的所有消息发送到相同的使

发送和接收消息组的实际操作。

发送消息组

下面的清单 1 给出了使用 WebSphere MQ Java API 将包含五条消息的组发送到队列

管理器 QM_host 上的队列 default 所需的代码：

清单 1. 使用 WebSphere MQ Java API 发送消息组

MQQueueManager queueManager = new MQQueueManager("QM_host");

MQQueue queue = queueManager.accessQueue("default", MQC.MQOO_OUTPUT);

MQPutMessageOptions pmo = new MQPutMessageOptions();

pmo.options = MQC.MQPMO_LOGICAL_ORDER;

for (int i = 1; i <= 5; i++) {

MQMessage message = new MQMessage();

}

queue.put(message, pmo);

}

queue.close();

queueManager.disconnect();

该示例首先连接到队列管理器，并打开用于进行输出的队列句柄。从消息组的角度

而言，要注意的第一个重要方面是向 put 消息选项添加了约束

MQPMO_LOGICAL_ORDER。此值告知队列管理器，应用程序将把组中的每个消

息按照序列顺序放入队列中，客户机在处理任何后续消息前会将一个组中的所有消

息放置到其上。