Java: синхронизация потоков через несколько серверов

Есть ли что-нибудь как идентификатор группы в заголовках сообщения? Если так, потребитель мог создать a Selector обработать группу в последовательности.

Присвоение группы конкретному потребителю могло быть сделано путем хеширования идентификатора группы, или они могли активно скоординировать друг с другом использующим некоторый протокол согласия как Паксос или виртуальную синхронию (при этом сообщения были отправлены по отдельной очереди).

Вы могли бы хотеть рассмотреть использование распределенных блокировок Hazelcast. Супер облегченный, легкий и с открытым исходным кодом.

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

С уважением,

- talip

Hazelcast - Распределенная очередь с открытым исходным кодом, карта, набор, список, блокировка