1

私はこのコードを持っています

context = zmq.Context()

app_worker = context.socket(zmq.PUSH)
app_worker.bind("tcp://127.0.0.1:9005")

app_sub = context.socket(zmq.SUB)
app_sub.connect("tcp://127.0.0.1:9004")
app_sub.setsockopt(zmq.SUBSCRIBE,'sometopic')

while True:
    msg = app_sub.recv()
    msg_data = msg.split(' ',1)
    app_worker.send_json(msg_data[1])
    print msg_data[1]

しかし、これを実行すると、発行者からメッセージを受け取ることができませんが、この行にコメントすると

app_worker = context.socket(zmq.PUSH)
app_worker.bind("tcp://127.0.0.1:9005")

それは突然機能します。これが可能であることは、zeromq ガイドの第 5 章のブラック ボックス パターンに記載されています。もしそうなら、私はここで何が間違っていますか?

4

2 に答える 2