6

おそらく私が見逃している非常に小さなものがありますが、公式の Pyzmq パッケージ ( https://github.com/zeromq/pyzmq ) を使用して Python で動作する単純な pub-sub の例を取得できません。

私は最新の ZeroMQ 安定リリース 4.0.3 を使用しており、c で簡単に動作する簡単な例を得ることができます。Mac と Ubuntu マシンの両方で試しました。これに関する意見をお待ちしております;)

これが私のコードです:

sub.py

import zmq

ctx = zmq.Context()
s = ctx.socket(zmq.SUB)
s.connect("tcp://127.0.0.1:5567")
s.setsockopt(zmq.SUBSCRIBE,'')

while True:
    print 'waiting...'
    msg = s.recv()
    print 'received:', msg

pub.py

import zmq

ctx = zmq.Context()
s = ctx.socket(zmq.PUB)
s.bind("tcp://*:5567")

for i in range(100):
    s.send("test")
4

1 に答える 1