java - Akka ZeroMQExtension 使用一个 zeromq 套接字创建多个连接

Question

是否可以使用 ZeroMQExtensions 创建具有多个传出（传入）连接的套接字？

有关ZeroMQ 指南中的多个连接的更多信息。

upd： 我看不到 ZeroMQExtensions 的等价样本。在 0MQExtensions 文档中，我发现：

newPubSocket(socketParameters: Array[SocketOption]): ActorRef

用于创建表示 ZeroMQ Publisher 套接字的参与者的 Java API 工厂方法。您可以根据需要传入任意数量的配置选项，并且配置选项的顺序无关紧要它们在类型上匹配，并且找到的第一个获胜。

PS：我不知道 scala，刚开始阅读 akka 文档以了解我是否需要 Akka。

Answer 1

我找到了解决方案（它不直观但有效）：

    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"));
    }