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

概述我有一个基本的ZeroMQ场景,包括两个发布者和一个订阅者.这在本地计算机上运行良好,直到我决定将LAN中不同计算机中的所有进程分开.这就是我创建ZeroMQ套接字(简化的Python代码)的方法：(在IP 192.168.1.52的机器上运行的订户进程)发布商代码(两个发布商通用)：context = zmq.Context() self.pub_sock

我有一个基本的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 1import zmqcontext = zmq.Context()socket = context.socket(zmq.REP)socket.bind("tcp://*:5556")req = socket.recv()socket.send(req) # machine 2import zmqcontext = 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 receiverimport zmqcontext = zmq.Context()socket = context.socket(zmq.PulL)socket.bind("tcp://*:5556")while True:    print socket.recv()# many sendersimport zmqcontext = zmq.Context()socket = context.socket(zmq.PUSH)socket.connect("tcp://192.168.1.52:5556")socket.send("FOO")

总结

以上是内存溢出为你收集整理的python – ZeroMQ：多个远程(LAN)发布者全部内容，希望文章能够帮你解决python – ZeroMQ：多个远程(LAN)发布者所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。