pub端输入:
import zmq
import random
import time
import socket
import json
context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://*:5554")
data = [1, 2, 3, 4, 5, 6]
json_str = json.dumps(data)
while True:
print("Sending message: data")
time.sleep(1)
socket.send(b'helloworld')