ZeroMQパイプラインパターン

Question

エージェントと呼ばれる外部プログラムがZeroMqプロデューサを介して通信できるメッセージングシステムを実装しています。したがって、関心のあるイベントが発生するたびに、エージェントはメッセージをZeroMqに送信します。

パイプラインパターンを使用してこれを実装することに興味があります。

いくつかの例（Ventilator-Worker-Results Manager）が見つかりましたが、人工呼吸器コンポーネントはワーカーからの接続を受け入れるエンドポイントを作成し、すべてのメッセージを一括して送信します。

私のシナリオは全く異なります。 「エージェント」は、イベントが送信される必要があるたびに接続します。つまり、ワーカーからの接続を待つことはないので、これが可能かどうか疑問です。また、重要な事実は、メッセージが送信される順序で処理されなければならないということです。

Answer 1

あなたのソリューションを実現するために、パターンを混合してください。 REQ エージェントコレクターを実際のREQエージェントにインスタンス化するのはspecialized brokerであるべきだと思います。これらのエージェントコレクタは、システムと通信する前に発注する必要があります。

Answer 2

REQ-REPは、往復を希望する場合です。あなたはPUB-SUBがほしいと思うように聞こえる。よく知られているポートにバインドしてSUBを設定し、クライアントがそのポートに接続してPUBを発行させる。