使用pyzmq广播到子网地址

作者: 敢嫁就敢娶
发布时间: 2024-10-12 03:11:09 (20天前)
转自：

2 条回复

0#
回复此人
只怕再见是故人 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 假设你有三个 <EM> 机器（M1，M2，M3） </EM> 具有相同子网和定义端口的三个不同IP地址。我们希望在每个订阅者（M1，M2）上发布消息（来自M1），因此我们将使用以下代码段： </p> <H1> 发布者（Machine1）： </H1> <pre> <code> import zmq import time context = zmq.Context() socket = context.socket(zmq.PUB) socket.bind("tcp://*:9999") # Note. while True: socket.send_string('hello-all') time.sleep(1) </code> </pre> <HR /> <H1> 订户（Machine2）： </H1> <pre> <code> context = zmq.Context() sub=context.socket(zmq.SUB) sub.setsockopt(zmq.SUBSCRIBE, b"") sub.connect('tcp://Machine1_IP:9999') # Note while True: print(sub.recv()) </code> </pre> <HR /> <H1> 订阅者（Machine3）： </H1> <pre> <code> context = zmq.Context() sub=context.socket(zmq.SUB) sub.setsockopt(zmq.SUBSCRIBE, b"") sub.connect('tcp://Machine1_IP:9999') # Note while True: print(sub.recv()) </code> </pre> </DIV>

编辑

登录后才能参与评论