python_pyzmq.md

Python pyzmq

• 给pyzmq 添加超时时间 详情请见 github

  import sys
  import zmq
  
  # None of these operations will block, regardless of peer:
  context = zmq.Context()
  socket = context.socket(zmq.REQ)
  socket.setsockopt(zmq.LINGER, 0)
  socket.connect("tcp://127.0.0.1:12346")
  socket.send_json({"msg": "testmsg"}) # send can block on other socket types, so keep track
  # use poll for timeouts:
  poller = zmq.Poller()
  poller.register(socket, zmq.POLLIN)
  if poller.poll(10*1000): # 10s timeout in milliseconds
      msg = socket.recv_json()
  else:
      raise IOError("Timeout processing auth request")
  
  # these are not necessary, but still good practice:
  socket.close()
  context.term()
  
  sys.exit(0)