python – ZeroMQ：多个远程(LAN)发布者

我有一个基本的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")