如何设置 pyzmq 套接字排队超时

Question

我已经连接 zeromq，“msg_in”已经排队。如果在该时间段内没有新消息队列到来，则设置超时。如何设置超时。以下是核心代码

requestDict = {"id":111, "name":"test"}
zmqConn.mSocket.send(json.dumps(requestDict), flags=zmq.NOBLOCK)
msg_in = zmqConn.mSocket.recv()

Answer 1

你应该使用 Poller 来处理超时：

import zmq
p = zmq.Poller()
p.register(zmqConn.mSocket, zmq.POLLIN)

msgs = dict(p.poll(timeout)) 
if zmqConn.mSocket in msgs and msgs[zmqConn.mSocket] == zmq.POLLIN:
   # recv there
else:
   # timeout