5

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

在这个应用程序中，我有多个消费者线程从同一个 JMS 队列中提取消息。消息以 3 或 4 组的形式出现，我需要确保每个组中的消息完全按串行方式处理。我需要某种同步机制来确保线程 1 拉出一条消息，然后线程 2 从该组中拉下一条消息，线程 2 在开始处理它的消息之前等待线程 1 完成处理。

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

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

4

3 回答 3

8

ActiveMQ 支持消息组，从字面上看，这应该正是您所需要的。

于 2009-04-03T21:23:56.777 回答
8

您可能要考虑使用Hazelcast分布式锁。超级精简、简单且开源。

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

问候，

-塔利普

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

于 2009-04-05T19:44:58.947 回答
1

消息头中是否有类似组 ID 的内容？如果是这样，消费者可以创建一个Selector来按顺序处理组。

可以通过对组标识符进行哈希处理来将组分配给特定的消费者，或者它们可以使用诸如 Paxos 或虚拟同步之类的共识协议（通过单独的队列发送消息）来主动相互协调。

于 2009-04-03T21:27:19.497 回答