使用 Java API 处理 WebSphere MQ 大消息

程序功能介绍：

（1）QMgrSegSender 程序是构造一个长度为505字节的消息并把它写入队列 TESTQ 中。

为使 MQ 不能传输505字节的消息，可以修改队列 TESTQ 的属性“最大消息长度（MAXMSGL）”为100。

执行结果如下图 1 所示，该消息被队列管理器自动分割成6个片段消息：

图 1 在 WebSphere MQ 资源管理器中浏览分片消息

（2）QMgrSegReceiver 程序是从队列 TESTQ 中读取一个消息。

我们观察执行的结果是它把队列中6个片段消息组成一个完整的大消息取出。

使用队列管理器自动实现消息分片对应用开发人员来讲比较简单，但是需要确保程序在内存使用等方面可以处理完整的大消息。

应用程序实现的消息分片

应用程序实现消息分片是指，在发送方应用程序中事先把大消息切分成多个片段，每一个片段作为一个独立的消息，写入到队列中；在接收方应用程序中，每一个片段作为一个独立的消息被取出，由程序把所有的消息片段组装成一个完整的消息。这种模式适用的场合为，WebSphere MQ 和应用程序两者都不方便处理这么大的单个消息。

一般在发送方程序实现中，我们是把所有的消息片段放在一个同步点中发送，所以需要设置 MQPutMessageOptions 为 MQPMO_SYNCPOINT；同时，我们推荐使用选项 MQPMO_LOGICAL_ORDER，这意味着队列管理器自动维护每个消息片段的偏移量（Offset），否则，需要应用程序自身来设置：

MQPutMessageOptions pmo = new MQPutMessageOptions ();

pmo.options = MQC.MQPMO_LOGICAL_ORDER + MQC.MQPMO_SYNCPOINT;