5

2つのパブリッシャーと1つのサブスクライバーで構成される基本的なZeroMQシナリオがあります。これは、LAN内の異なるコンピューターのすべてのプロセスを分離することを決定するまで、ローカルコンピューターで正常に機能していました。これが私がZeroMQソケット（簡略化されたPythonコード）を作成する方法です：

（IPを使用するマシンで実行されているサブスクライバープロセス192.168.1.52）

パブリッシャーコード（両方のパブリッシャーに共通）：

context = zmq.Context()
self.pub_socket = context.socket(zmq.PUB)
self.pub_socket.connect("tcp://192.168.1.52:5556")

加入者コード：

context = zmq.Context()
self.sub_socket = context.socket(zmq.SUB)
self.sub_socket.bind("tcp://192.168.1.52:5556")
self.sub_socket.setsockopt(zmq.SUBSCRIBE, "")

サブスクライバーtcp://127.0.0.1:5556のバインディングとして入力しようとしましたが、違いはありません。address:port

4

4 に答える 4

3

あなたの問題は、マシン間のポートの開放性に関連しているのではないかと思います。一部のオペレーティングシステムには独自のソフトウェアファイアウォールがあるため、それらを開く必要があるかどうかを確認する必要がある場合があります。

まず、2台のマシン間で単純なreq/repのいずれかを実行できることを確認します。

# machine 1
import zmq
context = zmq.Context()
socket = context.socket(zmq.REP)
socket.bind("tcp://*:5556")
req = socket.recv()
socket.send(req) 

# machine 2
import zmq
context = zmq.Context()
socket = context.socket(zmq.REQ)
socket.connect("tcp://192.168.1.52:5556")
socket.send("FOO")
print socket.recv()

それで問題が発生した場合は、それらのポートを確認することをお勧めします。

次に、次の方法ですべてのインターフェイスにバインドしようとすることもできます。socket.bind("tcp://*:5556")

実際の目標として、必要なのがマルチセンダー/シングルレシーバーだけの場合は、PUB/SUBの代わりにPUSH/PULLを使用できます。

# one receiver
import zmq
context = zmq.Context()
socket = context.socket(zmq.PULL)
socket.bind("tcp://*:5556")

while True:
    print socket.recv()

# many senders
import zmq
context = zmq.Context()
socket = context.socket(zmq.PUSH)
socket.connect("tcp://192.168.1.52:5556")
socket.send("FOO")
于 2012-11-10T18:22:10.547 に答える
1

ZMQギルドの「MissingMessageProblemSolver」をウォークスルーしましたか？

PUB / SUBパターンを使用する場合、常に一部のメッセージを失うスロージョイナーシンドロームがあることに注意してください。SUBで接続し、PUBでバインドすれば、シンドロームを排除できます。ただし、複数のパブリッシャーがある場合、サブスクライバーはそれらすべてに接続する必要があります。

于 2012-11-12T08:58:46.057 に答える
0

皆さんの提案に感謝します。

ファイアウォールは実際に無効にされていましたが、最終的に両方の発行元から受信できるPCが見つかりました。各コンピュータにインストールされているZMQのバージョンに関連する問題のようです。送信者はv.2.2でしたが、受信者は2.1でした。zmqプロトコルはバージョンに依存しないので、それは奇妙です。次回のためにこれを覚えておく必要があります。

再度、感謝します！

于 2012-11-13T11:01:03.667 に答える
0

プロトコルは2.1から2.2の間で機能するはずですが、3.1で壊れてしまいました。3.2では、古いバージョンで動作するように修正しました。

于 2012-11-21T06:15:16.057 に答える