ZMQ Pub/Sub Example

demo.sh

python zmq_client_sub.py &
python zmq_client_sub.py &
python zmq_server_pub.py

zmq_client_sub.py

import zmq  # Client
sock = zmq.Context().socket(zmq.SUB)
sock.connect("tcp://127.0.0.1:10000")
sock.setsockopt(zmq.SUBSCRIBE, "")  # All
while True:
    print(sock.recv())

zmq_server_pub.py

import zmq, time  # Server
sock = zmq.Context().socket(zmq.PUB)
sock.bind("tcp://127.0.0.1:10000")
while True:
    sock.send(str(time.time()))
    time.sleep(.1)