ZeroMQ：多个远程 (LAN) 发布者答案

【问题标题】：ZeroMQ: multiple remote (LAN) publishersZeroMQ：多个远程 (LAN) 发布者
【发布时间】：2012-11-21 14:15:16
【问题描述】：

我有一个由两个发布者和一个订阅者组成的基本 ZeroMQ 场景。这在本地计算机上一直运行良好，直到我决定在我的局域网内的不同计算机中分离所有进程。这就是我创建 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 作为订阅者的绑定address:port，但这没有区别。

【问题讨论】：

机器之间的端口是否存在防火墙问题？你能在两台机器之间尝试一些更简单的事情吗？比如 req/rep？可能是 ZeroMQ 包中的一个基本回显示例，只是为了确认端口正在通信。
PyZMQ pub/sub examples 可能有助于理解问题。

标签： python zeromq

【解决方案1】：

我怀疑您的问题可能与您的机器之间端口的开放性有关。有些操作系统有自己的软件防火墙，因此您可能需要检查是否需要打开它们。

首先我会检查您是否可以在两台机器之间执行简单的请求/代表之一：

# 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")

【讨论】：

【解决方案2】：

你在ZMQ公会中演练过“Missing Message Problem Solver”吗？

请注意，当使用 PUB/SUB 模式时，会有一个慢加入者综合症，总是会丢失一些消息。如果我们在 SUB 中进行连接并在 PUB 中进行绑定，则可以消除这种综合症；但是，当有多个发布者时，订阅者需要连接到所有发布者。

【讨论】：

【解决方案3】：

谢谢大家的建议。

防火墙确实被禁用了，但最终找到了一台可以接收来自两个发布者的 PC。这似乎是与每台计算机上安装的 ZMQ 版本有关的问题。发送者拥有 v.2.2，而接收者拥有 2.1。这很奇怪，因为我认为 zmq 协议与版本无关。下次需要记住这一点。

再次感谢！

【讨论】：

【解决方案4】：

该协议应该在 2.1 和 2.2 之间工作，但它被 3.1 破坏了。在 3.2 中，我们修复了一些问题以再次使用旧版本。

【讨论】：