模块集群和 JMS

Question

我有一个模块在JVM（无容器）中独立运行，并通过JMS 与其他模块通信。 我的模块既是一个队列中的生产者，又是另一个队列中的消费者。 然后，出于 HA 原因和工作负载原因，我需要对这个模块进行集群，并且我可能会使用 Terracotta+Hibernate 来集群我的实体。 目前，当我的应用程序启动时，它会启动一个线程（通过Executors.newSingleThreadExecutor()）作为消费者（如果相关和必要，我可以附加实际的代码示例）。

我从这里阅读的问题中了解到，如果我只是在 N 不同的 JVMs 上启动我的模块，那么 N 将创建不同的订阅者并且队列中的每条消息都会到达N订阅者。 我想做的是只让其中一个（让我们目前说哪个不重要）处理该消息，因此实际上使我能够一次处理 N 消息。

如何/应该如何做到这一点？我是不是偏离轨道了？

顺便说一句，我使用 OpenMQ 作为我的实现，但我不知道这是否相关。

感谢您的帮助

Answer 1

集群环境中消息处理的经典案例。这就是我会做的。

使用广播消息（基于频道）代替队列。队列对于点对点通信很有用并不是很有效。设置消息的有效性，直到它被消费者之一消费。这样，其他消费者甚至不会看到消息，只有一个消费者会消费它。

Answer 2

看看JGroups。您可以考虑实现您的模块/订阅者以使用 jgroups 进行所需的同步。 JGroups 提供可靠的多播通信。