我正在尝试在使用 python 的 debian/多进程情况下使用 zeromq。我有几个进程解码来自大量传感器的原始数据,并在 zmq 中发布。到目前为止,一切都很好。我有一个计算过程,它订阅 zmq 上的原始数据,并执行一些计算。然后它需要发布它的答案以供其他进程记录和使用。因此,我的计算过程需要在同一个过程中订阅和发布。
import zmq
import json
context = zmq.Context()
sub = context.socket(zmq.SUB)
sub.setsockopt(zmq.SUBSCRIBE, '')
sub.setsockopt(zmq.RCVBUF, 0)
sub.bind("tcp://127.0.0.1:5000")
pub = context.socket(zmq.PUB)
pub.bind("tcp://127.0.0.1:5000")
我尝试了上述方法,但没有运气。它返回一个错误...
File "socket.pyx", line 465, in zmq.core.socket.Socket.bind (zmq/core/socket.c:4749)
zmq.core.error.ZMQError: Address already in use
我阅读了文档、谷歌等,但现在完全卡住了。