Advertisement
Guest User

Untitled

a guest
Oct 23rd, 2016
91
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.70 KB | None | 0 0
  1. import zmq
  2.  
  3. context = zmq.Context()
  4. socket2 = context.socket(zmq.SUB)
  5. socket2.connect("tcp://192.168.0.9:5000")
  6. socket2.setsockopt_string(zmq.SUBSCRIBE, "Temperature")
  7.  
  8. while True:
  9. print (socket2.recv())
  10.  
  11. import zmq
  12. import time
  13. import sys
  14.  
  15.  
  16. if __name__ == '__main__':
  17.  
  18. HOST, PORT = "192.168.0.9", int(5000)
  19.  
  20. context = zmq.Context()
  21. socket = context.socket(zmq.SUB)
  22. socket.bind("tcp://127.0.0.1:%i" % PORT)
  23. socket.setsockopt_string(zmq.SUBSCRIBE, "Temperature")
  24.  
  25. while True:
  26. message = socket.recv_multipart()
  27. req_id = message[0]
  28. print("Received request: %s" % message[1:])
  29. time.sleep(1)
  30. socket.send_multipart([req_id, "world from %s" % PORT])
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement