ZeroMQ.Contextとインスタンスを使用し
て、たとえばセットアップのようなキューのコードの下で.Socketメッセージをプッシュ/プルできます。
ZMQ.Context context = ZMQ.context(1);
// Socket to send messages on
ZMQ.Socket sender = context.socket(ZMQ.PUSH);
sender.bind("tcp://*:5557");
// Send messages
sender.send("0", 0);
ZMQ.Socket receiver = context.socket(ZMQ.PULL);
receiver.connect("tcp://localhost:5557");
// receive messages
String string = new String(receiver.recv(0)).trim();
私の質問は次のとおりです。
Q1: キューにアクティブ/スタンバイ モードを実装するにはどうすればよいですか?
つまり、1 つのホストとポートに対して作成された 2 つのキューがあり、1 つのキュー (アクティブ) が失敗すると、別の (つまりスタンバイ) キューがすぐに開始され、メッセージをリッスン/プルします。
それを実装するための例やガイダンスは、より役に立ちます。
Q2: このタイプのタスクを実行するための組み込みクラスはありますか?