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

ActiveMQ支持 message groups 从字面上看,这正是你需要的。

你可能想考虑使用 Hazelcast 分布式锁。超级精简,容易和开源。

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

当做,

塔利普

淡褐色石膏 -打开源分布式队列、映射、集、列表、锁

邮件头中是否有类似组ID的内容?如果是这样,消费者可以创建 Selector 按顺序处理组。

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