java - ZMQ を使用した均等分散

Question

Centos で Zmq を使用しています。私の仕事は、1 つのプロデューサーと複数のコンシューマーを持つ ZMQ を使用して Java プログラムを作成することです。プロデューサが 100 メッセージを送信し、4 つのコンシューマがある場合、すべてのコンシューマはそれぞれ 25 メッセージを共有する必要があります。これどうやってするの。

Answer 1

これはもっと簡単にできます。Socket タイプにラウンドロビン (PUSH、REQ、DEALER) の発信戦略がある場合、すべてのエンドポイントが接続されている場合、作業が均等に分散されると想定できます。そのように選択した場合は、ブローカーの使用を避けることができます。

Answer 2

私自身が道を見つけました。これを解決するにはブローカーを使用する必要があり、ブローカーにはフロントエンドとバックエンドの接続用に 2 つのソケットが必要です。次に、ストリーマー、キュー、フォワーダーなど、ZMQ で利用できるいくつかのクラスがあります。コンテキスト、フロントエンド、バックエンドをコンストラクターのパラメーターとして渡すことで、このクラスのオブジェクトを作成できます。run メソッドを呼び出してブローカーを待機させるだけです。