使用 Java API 处理 WebSphere MQ 大消息

核心提示：WebSphere MQ 中处理大消息的方法使用过 WebSphere MQ 的读者都知道，WebSphere MQ 对处理的单条消息的大小是有限制的，使用 Java API 处理 WebSphere MQ 大消息，目前支持的最大消息是100M，而且，允许占用大块内存，而且，随着消息大小的增大，WebSphere MQ

WebSphere MQ 中处理大消息的方法

使用过 WebSphere MQ 的读者都知道，WebSphere MQ 对处理的单条消息的大小是有限制的，目前支持的最大消息是100M，而且，随着消息大小的增大，WebSphere MQ 处理的性能也会随之下降。从最佳实践来说，WebSphere MQ 传输大小为几K的消息其效率是最高的。那如何使 WebSphere MQ 能高效的处理大消息呢？

WebSphere MQ 提供了处理大消息的两种方法：消息分片和消息分组。下面我们来看在使用 Java API 编写 WebSphere MQ 程序时如何实现消息分片和分组。

消息分片

消息分片的做法是把应用上一个大的逻辑消息分割成一个一个小的片段，每一个片段作为一个 WebSphere MQ 消息独立传输，通过 MQMD 中 GroupId、 MsgSeqNumber 和 Offset 3 个属性来标识，起始消息的 Offset 值为 0，而最后一个消息则会使用如下标记标识这是最后一个片段：MQMF_LAST_SEGMENT。

具体从实现上来说，消息分片可以细分为两种模式：一是由队列管理器自动实现消息的分片和组装；二是由应用程序来实现消息的分片和组装。下面我们将详细向您介绍这两种实现方式。

队列管理器自动实现的消息分片

顾名思义，队列管理器自动实现的消息分片就是由队列管理器来完成消息的分片和组装。对应用程序来说，不管是发送方还是接收方，它所处理的还是一个完整的大消息，只是在程序中通过设置一些标识来指示队列管理器切分消息后再传输。所以，这种方式适用的场合为，出于传输效率的考虑，WebSphere MQ 不适宜传输大消息，而应用程序可以处理大消息，允许占用大块内存。而且，此种方式对编写应用程序来说也比较简单。