☰

Python の ZeroMQ と複数のサブスクライブ フィルター 質問する

tag-icon • tag-icon python sockets zeromq
Python の ZeroMQ と複数のサブスクライブ フィルター 質問する

1 つのソケットを使用して、Python で ZeroMQ を使用して複数のフィルターをサブスクライブしたいと思います。

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

しかし、これはうまくいきません。最初のものだけが考慮されるのです。しかし、私はこれを読みましたzeromq サイト:

複数のフィルターを 1 つのソケットに接続できますZMQ_SUB。その場合、メッセージが少なくとも 1 つのフィルターに一致すると、そのメッセージは受け入れられます。

私は zmq 2.2.0.1 を使用しています。どうすればいいか知りたいです。何かアイデアはありますか?

ベストアンサー1

これは機能します:

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

つまり、両方のサブスクリプションは機能します。正確なコードは何ですか? 別の問題である可能性があります。

おすすめ記事