0

ZeroMQExtensions を使用して複数の送信 (受信) 接続を持つソケットを作成することは可能ですか?

複数の接続の詳細については、ZeroMQ ガイド を参照してください。

upd: ZeroMQExtensions と同等のサンプルが見当たりません。0MQExtensions ドキュメントで見つけた:

newPubSocket(socketParameters: Array[SocketOption]): ActorRef

ZeroMQ パブリッシャー ソケットを表すアクターを作成するための Java API ファクトリ メソッド。必要な数の構成オプションを渡すことができ、構成オプションの順序は関係ありません。それらはタイプで一致し、最初に見つかったものが優先されます。

PS: 私は scala を知らず、Akka が必要かどうかを理解するために akka のドキュメントを読み始めました。

4

1 に答える 1

0

解決策を見つけました（直感的ではありませんでしたが機能します）：

    ActorRef subSocket = ZeroMQExtension.get(getContext().system())
            .newSubSocket(null, new Listener(getSelf()), new Subscribe("health"));

    @Override
    public void preStart() {
        super.preStart();

        subSocket.tell(new Connect("tcp://127.0.0.1:1237"));
        subSocket.tell(new Connect("tcp://127.0.0.1:1238"));
    }
于 2012-08-30T12:16:18.313 に答える