我有一个基本的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作为绑定地址：订阅者的端口,但没有区别.
最佳答案
我怀疑你的问题可能与机器之间端口的开放性有关.某些操作系统有自己的软件防火墙,因此您可能需要检查是否需要打开它们.
原文链接：https://www.f2er.com/python/439413.html首先,我会检查您是否可以在两台机器之间执行简单的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")