19

我想使用一个套接字在 Python 中使用 ZeroMQ 订阅多个过滤器。

sock.setsockopt(zmq.SUBSCRIBE, 'first.filter')
sock.setsockopt(zmq.SUBSCRIBE, 'second.filter')

但这不起作用。只考虑第一个。但是,我在zeromq 网站上读到了这个:

多个过滤器可以附加到单个ZMQ_SUB套接字,在这种情况下,如果消息匹配至少一个过滤器,则应接受该消息。

我正在使用 zmq 2.2.0.1。所以,我想知道如何做到这一点。有任何想法吗?

4

1 回答 1

33

这有效:

import time
import zmq

ctx = zmq.Context()
pub = ctx.socket(zmq.PUB)
sub = ctx.socket(zmq.SUB)

url = "tcp://127.0.0.1:5555"
pub.bind(url)
sub.connect(url)

# subscribe to 'a' and 'b'
sub.setsockopt(zmq.SUBSCRIBE, b'a')
sub.setsockopt(zmq.SUBSCRIBE, b'b')

time.sleep(1)

for word in [ 'alpha', 'beta', 'gamma', 'apple', 'carrot', 'bagel']:
    pub.send(word)

time.sleep(1)

for i in range(4):
    print sub.recv(zmq.NOBLOCK)

给出输出:

alpha
beta
apple
bagel

所以这两个订阅都有效。你的确切代码是什么?因为也许这是另一个问题。

于 2012-12-16T21:03:09.880 回答