5

我有一个基本的 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，但这没有区别。

4

4 回答 4

3

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

首先，我会检查您是否可以在两台机器之间执行简单的 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")
于 2012-11-10T18:22:10.547 回答
1

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

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

于 2012-11-12T08:58:46.057 回答
0

谢谢你们的建议。

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

再次感谢！

于 2012-11-13T11:01:03.667 回答
0

The protocol should work between 2.1 and 2.2, but it got broken by 3.1. In 3.2 we fixed things to work with older versions again.

于 2012-11-21T06:15:16.057 回答