zeroMQ初体验-20.对答模式进阶(六)-多对多路由模式

zeroMQ初体验-20.应答模式进阶(六)-多对多路由模式
某些时候，为了冗余的需要，可能会有这样的需求：

import?zmqimport?timeimport?zhelperscontext?=?zmq.Context()worker?=?context.socket(zmq.XREP)worker.setsockopt(zmq.IDENTITY,?"WORKER")worker.bind("ipc://rtrouter.ipc")server?=?context.socket(zmq.XREP)server.setsockopt(zmq.IDENTITY,?"SERVER")server.connect("ipc://rtrouter.ipc")time.sleep(1)server.send_multipart(["WORKER",?"",?"send?to?worker"])zhelpers.dump(worker)worker.send_multipart(["SERVER",?"",?"send?to?server"])zhelpers.dump(server)

注意：
虽然看起来这样很美好，不过，潜在着一个巨大的风险：混乱。同一个层级上的路由必须要通过命名来唯一化，以便减少出现混乱的可能性。

（未完待续）

查看更多 下一篇