Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import zmq
- context = zmq.Context()
- socket2 = context.socket(zmq.SUB)
- socket2.connect("tcp://192.168.0.9:5000")
- socket2.setsockopt_string(zmq.SUBSCRIBE, "Temperature")
- while True:
- print (socket2.recv())
- import zmq
- import time
- import sys
- if __name__ == '__main__':
- HOST, PORT = "192.168.0.9", int(5000)
- context = zmq.Context()
- socket = context.socket(zmq.SUB)
- socket.bind("tcp://127.0.0.1:%i" % PORT)
- socket.setsockopt_string(zmq.SUBSCRIBE, "Temperature")
- while True:
- message = socket.recv_multipart()
- req_id = message[0]
- print("Received request: %s" % message[1:])
- time.sleep(1)
- socket.send_multipart([req_id, "world from %s" % PORT])
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement