Wildfly JMS：当消息存在时，MDB bean 空闲

Question

我在 Wildfly 8.1 (HornetQ) 上使用捆绑的 JMS 实现对大量文档进行 OCR。

我希望拥有一个由 3 个 MDB 组成的池，这些 MDB 使用一个队列的消息，其中包含要 OCRed 的文档。每个 MDB 使用 Apache commons-exec 启动一个进程并阻塞直到该进程退出。

在我的测试中，我有 50 条 JMS 消息（每条代表一个要进行 OCRed 处理的文档），它们在测试开始时加载到队列中。当处理开始时，在任何给定时间我都可以看到有 3 个 CPU 密集型 OCR 进程，每个 MDB 启动并阻止一个。在某个时间点，大约 20 分钟后，其中一个 OCR 进程消失了，在任何给定时间只有 2 个还活着。当剩余 10 条左右的 JMS 消息时，另一个 OCR 进程停止，并且在任何给定时间都只有 1 条。

最后，所有 50 个文档都已被 OCR，任何 OCR 进程或我的应用程序都没有抛出异常。

我觉得这种行为很奇怪，因为我预计在任何时间点都会有 3 个 OCR 进程在消耗 JMS 消息的时间（当然最后除外）。如果 JMS 消息在进入队列时被“分配”给 MDB 实例，而不是实时的，则可以解释这种行为。例如，如果每个 MDB 分配了大约 17 条消息。根据文档大小，一些 MDB 实例可能会提前完成并保持空闲状态而不消耗任何其他消息，而其他 MDB 实例仍然可以使用消息。

这是怎么回事？如果是，有没有办法改变这一点，以便在 MDB 实例完成处理消息时将消息分配给 MDB 实例？

@MessageDriven(activationConfig = {
        @ActivationConfigProperty(propertyName = "destinationLookup", propertyValue = "queue/csrOcrQueue"),
        @ActivationConfigProperty(propertyName = "minSession", propertyValue = "3"),
        @ActivationConfigProperty(propertyName = "maxSession", propertyValue = "3")
})
@TransactionAttribute(TransactionAttributeType.NOT_SUPPORTED)
public class OcrMessageListener implements MessageListener {

Answer 1

这与客户端 (MDB) 上的 JMS 消息缓冲有关。默认情况下，消息缓冲是打开的，以避免网络延迟。但是，对于我的客户端速度较慢的情况，这不是问题。

这是来自HornetQ documentation：

11.1.39。没有消费者缓冲

默认情况下，HornetQ 消费者缓存来自服务器的消息在一个 在客户端实际接收它们之前的客户端缓冲区 边。这可以提高性能，因为否则每次您调用 receive() 或已处理 MessageListener 中的最后一条消息 onMessage() 方法，HornetQ 客户端必须去服务器 请求下一条消息，然后将其发送给客户端 一边，如果有的话。

这将涉及每条消息的网络往返，并减少 表现。因此，默认情况下，HornetQ 将消息预取到 每个消费者的缓冲区。

在某些情况下缓冲是不可取的，HornetQ 允许它 关闭。这个例子证明了这一点。

Github 中有一个示例项目作为文档的一部分，其中消费者缓冲已关闭：link