zmq Poller

1.注册socket到poller中

poller = zmq.Poller()
poller.register(frontend, zmq.POLLIN) # receive worker message
poller.register(receiver, zmq.POLLIN) # put message to client

 

 

2.接受消息时依据socket标识来判断是该哪个socket接受消息

while True:
    if socks.get(frontend) == zmq.POLLIN:
        frontend.recv_multipart()

    if socks.get(receiver) == zmq.POLLIN:
        receiver.recv_multipart()