我目前正在尝试使用 0MQ 制作代理。我想订阅不在 0MQ 下运行的发布者。我的意思是我有发送 XML 文件的远程发布者的地址和端口,我想获取这些文件。不幸的是,我没有从发布者那里收到任何消息,但它发送得很好。

我正在做的是(在 Python 中):

context    = zmq.Context(1)
subscriber = context.socket(zmq.SUB)
subscriber.connect(address)
subscriber.setsockopt(zmq.SUBSCRIBE, '') # I want to subscribe any topics

同时,我有一个发布者发送收到的消息(如果发生):
publisher = context.socket (zmq.PUB)
publisher.bind(publishing_address)

最后,
while True:
    data = subscriber.recv()
    print data
    publisher.send(data)

我测试了我的代理,当我将它连接到 0MQ 发布者时它可以工作,但是当我连接到不起作用的非 OMQ 发布者时。

最佳答案

恐怕这无法实现,因为 ØMQ is not a neutral carrier :



换句话说: ØMQ 只能与 ØMQ 对话。

关于python - Pub/Sub - 订阅非 0MQ 发布者,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/16234301/

10-11 06:20