0MQ PUSH/PULL PULLソケットが接続されていない場合は壊れています。

Question

PUSH/PULL0MQ（Python-> C＃）のパターンはPUSHソケットと1つだけPULLソケットです。両方が接続されている限り、作業者がメッセージを処理するのに時間がかかっても、キューに入れられたメッセージの順序は保持されます。

ワーカーがしばらく接続を解除してから再接続すると、PUSHソケットでキューに登録されていても、この期間にキューに入れられたすべてのメッセージがランダムな順序で到着します。この問題に対する組み込みのソリューションはありますか、より高度なパターンを使用すべきですか？

私はPULL側のコードを追加します。

using (var receiver = new PullSocket()) 
      { 
       receiver.Bind("tcp://localhost:5557"); 

       while (true) 
       { 
        var payload = receiver.ReceiveFrameString(); 

        log.Debug($"Payload: {payload}"); 
       } 
      } 

Answer 1

私は0mq PUSH/PULLは配信の順序を保証するものではないことをかなり確信しています。

たぶん、あなたはREQ/REP（またはREQ/ROUTERまたは類似パターン）を行うことができます代わりに - あなたは物事を同期する必要がある場合REQ/REPは非常に便利です。私の頭の上から、メッセージを取り出してREQソケットにプッシュするインプロセスのPUSH/PULLキューを持つことができます。