如何在 zmq 中处理同一端口上的多个发布者?
How to handle multiple publishers on same port in zmq?
这个问题之前有人问过,here。我有完全一样的问题。我想从一堆不同的进程中发布,并且每次都使用相同的端口。
我尝试了答案中提供的解决方案,但这对我不起作用。我收到错误
File "/usr/local/lib/python2.7/multiprocessing/process.py", line 258, in _bootstrap
self.run()
File "/usr/local/lib/python2.7/multiprocessing/process.py", line 114, in run
self._target(*self._args, **self._kwargs)
File "/home/akay/afk/multi.py", line 18, in to_zmq
socket.connect("tcp://*:%s" % port)
File "zmq/backend/cython/socket.pyx", line 478, in zmq.backend.cython.socket.Socket.connect (zmq/backend/cython/socket.c:4308)
ZMQError: Invalid argument
我的代码是这样的,基本上直接取自 zmq 文档中的示例 here and here:
# Socket to talk to server
port = '5556'
context = zmq.Context()
socket = context.socket(zmq.SUB)
print "Listening for stream...", m
socket.bind("tcp://localhost:%s" % port) #change connect to bind, as per answer above
socket.setsockopt(zmq.SUBSCRIBE, topicfilter)
我正在使用 python 2.7 和最新版本的 zmq。知道我可能做错了什么吗?
嗯,错误很明显:
[...]
socket.connect("tcp://*:%s" % port)
[...]
ZMQError: Invalid argument
您无法连接到*
,您必须指定一个IP地址(服务器IP地址)。如果客户端和服务器 运行 在一台机器上,请尝试使用 localhost
或 127.0.0.1
.
这个问题之前有人问过,here。我有完全一样的问题。我想从一堆不同的进程中发布,并且每次都使用相同的端口。
我尝试了答案中提供的解决方案,但这对我不起作用。我收到错误
File "/usr/local/lib/python2.7/multiprocessing/process.py", line 258, in _bootstrap
self.run()
File "/usr/local/lib/python2.7/multiprocessing/process.py", line 114, in run
self._target(*self._args, **self._kwargs)
File "/home/akay/afk/multi.py", line 18, in to_zmq
socket.connect("tcp://*:%s" % port)
File "zmq/backend/cython/socket.pyx", line 478, in zmq.backend.cython.socket.Socket.connect (zmq/backend/cython/socket.c:4308)
ZMQError: Invalid argument
我的代码是这样的,基本上直接取自 zmq 文档中的示例 here and here:
# Socket to talk to server
port = '5556'
context = zmq.Context()
socket = context.socket(zmq.SUB)
print "Listening for stream...", m
socket.bind("tcp://localhost:%s" % port) #change connect to bind, as per answer above
socket.setsockopt(zmq.SUBSCRIBE, topicfilter)
我正在使用 python 2.7 和最新版本的 zmq。知道我可能做错了什么吗?
嗯,错误很明显:
[...]
socket.connect("tcp://*:%s" % port)
[...]
ZMQError: Invalid argument
您无法连接到*
,您必须指定一个IP地址(服务器IP地址)。如果客户端和服务器 运行 在一台机器上,请尝试使用 localhost
或 127.0.0.1
.