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)注意:
虽然看起来这样很美好,不过,潜在着一个巨大的风险:混乱。同一个层级上的路由必须要通过命名来唯一化,以便减少出现混乱的可能性。
(未完待续)