概述
我有一个基本的ZeroMQ场景,包括两个发布者和一个订阅者.这在本地计算机上运行良好,直到我决定将LAN中不同计算机中的所有进程分开.这就是我创建ZeroMQ套接字(简化的Python代码)的方法：
(在IP 192.168.1.52的机器上运行的订户进程)
发布商代码(两个发布商通用)：
context = zmq.Context()
self.pub_socket = context.socket(zmq.PUB)
self.pub_socket.connect("tcp://192.168.1.52:5556")
订户代码：
context = zmq.Context()
self.sub_socket = context.socket(zmq.SUB)
self.sub_socket.bind("tcp://192.168.1.52:5556")
self.sub_socket.setsockopt(zmq.SUBSCRIBE,"")
我已经尝试输入tcp：//127.0.0.1：5556作为绑定地址：订阅者的端口,但没有区别.
首先,我会检查您是否可以在两台机器之间执行简单的req / rep之一：
# machine 1
import zmq
context = zmq.Context()
socket = context.socket(zmq.REP)
socket.bind("tcp://*:5556")
req = socket.recv()
socket.send(req)
# machine 2
import zmq
context = zmq.Context()
socket = context.socket(zmq.REQ)
socket.connect("tcp://192.168.1.52:5556")
socket.send("FOO")
print socket.recv()
如果您遇到问题,那么您可能需要检查这些端口.
其次,您也可以尝试使用以下命令绑定到所有接口：socket.bind(“tcp：// *：5556”)
而对于你的实际目标,如果你需要的只是一个多发送器/单接收器,你可以只使用PUSH / PULL而不是PUB / SUB
# one receiver
import zmq
context = zmq.Context()
socket = context.socket(zmq.PULL)
socket.bind("tcp://*:5556")
while True:
print socket.recv()
# many senders
import zmq
context = zmq.Context()
socket = context.socket(zmq.PUSH)
socket.connect("tcp://192.168.1.52:5556")
socket.send("FOO")
总结
以上是编程之家为你收集整理的python – ZeroMQ：多个远程(LAN)发布者全部内容，希望文章能够帮你解决python – ZeroMQ：多个远程(LAN)发布者所遇到的程序开发问题。
如果您也喜欢它,动动您的小指点个赞吧
602392714
清零编程群