Java：複数のサーバー間でスレッドを同期する

Question

Windows上のJavaサービスに対して複数の異なるサーバー間で複数のスレッドの処理を同期させる必要があるという問題があります。

このアプリケーションでは、同じJMSキューから複数のコンシューマスレッドpullingsメッセージがあります。メッセージは3つまたは4つのグループに分かれています。各グループのメッセージが完全にシリアルで処理されるようにする必要があります。スレッド1がメッセージをオフにしてから、スレッド2がそのグループから次のメッセージをプルするかどうかを確認するために、何らかの同期メカニズムが必要です。スレッド2はスレッド1の処理が完了する前に処理を完了します。

スレッドの分散同期メカニズムに関する提案はありますか？どんなタイプのソリューションも良いでしょう（JMSソリューション、分散キャッシングなど）

注：使用しているJMSプロバイダはActiveMQです。

Answer 1

ActiveMQはmessage groupsをサポートしています。これはまさに文字通り正確に必要なものです。

Answer 2

メッセージヘッダーにグループIDのようなものはありますか？そうであれば、消費者はグループを順に処理するためにSelectorを作成することができます。

特定のコンシューマにグループを割り当てることは、グループ識別子をハッシュすることによって行うことができます。また、Paxosや仮想同期のようなコンセンサスプロトコルを使用して互いに積極的に調整することもできます（メッセージは別のキューで送信されます） 。

Answer 3

Hazelcast分散ロックを使用することを検討してください。スーパーライト、簡単でオープンソース。

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

よろしく、

-talip

Hazelcast - オープンソースは、私はそれらについて簡単に見てきたキュー、地図、セット、リスト、ロック