如何配置一个多PUB/单SUB python ZMQ Ubuntu

Question

我有两个虚拟机(VirtualBOx、Ubuntu 18.04和python-zmq[16.0.2-2build2](在同一台物理机器(Win10(中运行。两台机器都配置为Bridge，可以成功ping 192.168.1.66-192.168.1.55。我已经学习了本教程https://learning-0mq-with-pyzmq.readthedocs.io/en/latest/pyzmq/patterns/pubsub.html.如果PUB(服务器(被配置为，它就会工作

import zmq
import random
import sys
import time
port = "5557"
if len(sys.argv) > 1:
port =  sys.argv[1]
int(port)
context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://*:%s" % port)
while True:
topic = random.randrange(9999,10005)
messagedata = random.randrange(1,215) - 80
print "%d %d" % (topic, messagedata)
socket.send("%d %d" % (topic, messagedata))
time.sleep(1)

SUB(客户端(作为

import sys
import zmq
port = "5557"
if len(sys.argv) > 1:
port =  sys.argv[1]
int(port)

if len(sys.argv) > 2:
port1 =  sys.argv[2]
int(port1)
# Socket to talk to server
context = zmq.Context()
socket = context.socket(zmq.SUB)
print "Collecting updates from weather server..."
socket.connect ("tcp://192.168.1.66:%s" % port)
if len(sys.argv) > 2:
socket.connect ("tcp://localhost:%s" % port1)
# Subscribe to zipcode, default is NYC, 10001
topicfilter = "10001"
socket.setsockopt(zmq.SUBSCRIBE, topicfilter)
# Process 5 updates
total_value = 0
for update_nbr in range (5):
string = socket.recv()
topic, messagedata = string.split()
total_value += int(messagedata)
print topic, messagedata
print "Average messagedata value for topic '%s' was %dF" % (topicfilter, total_value / update_nbr)

由于我想要一个具有多个服务器(PUB(的单个客户端(SUB(，其中它们可以是数百甚至数千个，因此为每个PUB配置单个IP是不可行的。有没有一种方法可以在不指定IP的情况下进行订阅？或者至少是一个广播节目。我已经尝试在客户端socket.connect ("tcp://IP:%s" % port):中进行配置

">

给出错误：

Traceback (most recent call last):
File "sub_client.py", line 18, in <module>
socket.connect ("tcp://*:%s" % port)
File "zmq/backend/cython/socket.pyx", line 528, in zmq.backend.cython.socket.Socket.connect (zmq/backend/cython/socket.c:5980)
File "zmq/backend/cython/checkrc.pxd", line 25, in zmq.backend.cython.checkrc._check_rc (zmq/backend/cython/socket.c:8400)
zmq.error.ZMQError: Invalid argument

192.168.1.1(GW(，192.168.1.255(广播(，localhost/127.0.0.1及其IP(192.168.1.55(->不接收消息

192.168.1.66(服务器的IP(->确实接收消息，但在大型系统中不实用

有什么办法解决这个问题吗？

Answer 1

Q：有什么方法可以解决这个问题吗

避免违背任何API文档化的属性。虽然tcp://-传输类的.bind()-方法可以尝试绑定到任何localhost侧IP地址，但.connect()-方法显然不能。

如ZMQError:中所述

socket.connect ("tcp://*:%s" % port)
zmq.error.zmq错误：无效参数

更正IP地址目标，
.connect( "tcp://{0:}:{1:}".format( IP, PORT ) )-方法应尝试在何处"以获得连接"；。