おそらく私が見逃している非常に小さなものがありますが、公式の 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")