Java:跨多个服务器同步线程

Question

我有一个问题，我需要为Windows上的Java服务跨多个不同的服务器同步多个线程的处理。

在这个应用程序中，我有多个使用者线程从同一个JMS队列中提取消息。消息以3个或4个为一组进入，我需要确保每个组中的消息都是完全串行处理的。我需要某种同步机制来确保如果thread1拉出一条消息，然后thread2从该组中拉出下一条消息，thread2等待thread1完成处理，然后开始处理它的消息。

对线程的分布式同步机制有什么建议吗？任何类型的解决方案都是好的(JMS解决方案、分布式缓存等)

注意:我们使用的JMS提供者是ActiveMQ。

Answer 1

ActiveMQ支持message groups，从字面上看，这正是您所需要的。

Answer 2

您可能需要考虑使用Hazelcast分布式锁。超级轻量级，简单，开源。

java.util.concurrent.locks.Lock lock = Hazelcast.getLock ("mymonitor");
lock.lock ();
try {
// do your stuff
}finally {
   lock.unlock();
}

致以敬意，

-talip

Hazelcast -开源分布式队列、映射、集合、列表、锁定

Answer 3

邮件头中是否有类似于组ID的内容？如果是这样的话，使用者可以创建一个Selector来按顺序处理该组。

将组分配给特定的使用者可以通过散列组标识符来完成，或者它们可以使用某种共识协议(如Paxos或虚拟同步)主动地相互协调(消息通过单独的队列发送)。