zmqで PUB/SUB してみる - Twisted MindPUSH/PULL はあまり面白く無さそうなので、PUB/SUB を試してみました。 PUB PUB 側が bind します。 SUB は定期的に PUB に接続を見に行くので、少し寝てあげる必要があったりします。 import time import zmq ctx = zmq.Context() sock = ctx.socket(zmq.PUB) sock.bind('tcp://127.0.0.1:5555') time.sleep(1.0) sock.send('hello') SUB SUB が PUB に繋ぎに行きます。今回はルートは空なので FANOUT で、全員に配ります。 普通の MQ でもこれは出来ますね。 import zmq from zmq.eventloop import ioloop loop = ioloop.IOLoop.instance() ctx =
ZMQ で PUSH/PULL を使ってロードバランシングしてみる - Twisted Mind
