Python ZeroMQ pub/sub example

zeromq_demo_publisher.py

'''
测试环境:
  python3.6
  pyzmq==17.0.0
'''
import time
import zmq
context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind('tcp://127.0.0.1:2000')

# Allow clients to connect before sending data

for i in range(1,100):
  socket.send_pyobj({i:[1,2,3]})
  time.sleep(1)

zeromq_demo_subscriber.py

import zmq
context = zmq.Context()
socket = context.socket(zmq.SUB)
# We can connect to several endpoints if we desire, and receive from all.
socket.connect('tcp://127.0.0.1:2000')

# We must declare the socket as of type SUBSCRIBER, and pass a prefix filter.
# Here, the filter is the empty string, wich means we receive all messages.
# We may subscribe to several filters, thus receiving from all.
# socket.setsockopt(zmq.SUBSCRIBE, '')
while True:
  socket.setsockopt_string(zmq.SUBSCRIBE, '')
  message = socket.recv_pyobj()
  print(str(message))