zmq round robin lost messageプッシュ/プル

Question

1つのクライアントから2人のワーカーに10個のメッセージを送信しようとしています。 PUSH/PULLパターンを使用します。

python pull.py 
Received message n°1 
Received message n°4 
Received message n°7 

労働者2：私は2

python push.py 
message n°0 
message n°1 
message n°2 
message n°3 
message n°4 
message n°5 
message n°6 
message n°7 
message n°8 
message n°9 

労働者に1メッセージを失う

プッシュ：

python pull.py 
Received message n°0 
Received message n°3 
Received message n°6 
Received message n°9 

私は、Python 3を使用し、ここに私のコードです。 py

import time 
import zmq 

context = zmq.Context() 
socket = context.socket(zmq.PUSH) 
socket.bind("tcp://127.0.0.1:5557") 

time.sleep(1) 
for i in range(10): 
    message = "message n°%d" % i 
    print(message) 
    socket.send_string(message) 
    time.sleep(1) 
time.sleep(1) 

pull.py

import zmq 

context = zmq.Context() 

socket = context.socket(zmq.PULL) 
socket.connect("tcp://127.0.0.1:5557") 

while True: 
    print("Received %s" % socket.recv_string()) 

は、たぶん私は私のソケットのオプションを失いました。どんな助け？

Answer 1

あなたのコードは私に似ています。私はそれをコピー/ペーストし、問題を再現できませんでした。私はOSX上でPython 2.7.13と3.6.0を試しました。 pyzmqバージョン4.1.2を使用しています。

どのような順序でプロセスを開始していますか？ （それは問題ではありません。）あなたは毎回メッセージ2を失いますか？

これを再現できる場合は、ネットワークスニファを試して、何が起こっているのかを確認する必要があります。