如何在 Java SUB 客户端 (ZMQ) 上从 python ZeroMQ PUB 服务器接收数据

Question

我正在与 Pupil Labs 合作，这是一个用于眼睛/瞳孔跟踪的大型开源软件。整个代码是用 Python 编写的。所谓Pupil Remote是基于ZeroMQ的。

如果我开始运行Filter Messages，一切都很好。出于我的目的，我需要将Filter Messages“翻译”成 Java，因为我创建了一个 Android 应用程序，它应该调用一个客户端，该客户端的目的是充当 python 客户端。

这是我到目前为止所做的：

import android.annotation.SuppressLint;
import org.zeromq.ZMQ;
import java.nio.charset.Charset;
import static java.lang.Thread.sleep;

public class ZeroMQClient {
    @SuppressLint("NewApi")
    public static void requestGazeData() {

        ZMQ.Context context = ZMQ.context(1);
        ZMQ.Socket subscriber = context.socket(ZMQ.SUB);

        System.out.println("Connecting to server...");

        subscriber.connect("tcp://xxx.x.x.x:50020");

        System.out.println("Connected");

        String gaze = "gaze";
        subscriber.subscribe(gaze.getBytes(Charset.forName("UTF-8")));

        while (true) {
            String msg = subscriber.recvStr();
            System.out.println(msg);

            subscriber.close();
            context.term();
        }
    }
}

现在正如你所料，为什么我要问你，什么也没发生，我没有从 Pupil Labs 服务器收到任何数据。我把自己定位在this post，但不幸的是，它对我没有用。 IP地址和端口也与服务器上的相同。它既不能在本地工作，也不能在远程工作。

对任何答案都很满意，因为我坚持这一点。

Answer 1

由于我的实现正确建立，实际问题是防火墙，它只是阻止了连接。通过发布我的解决方案，我希望能够帮助这个问题的未来访问者。

Answer 2

在调试了根本原因问题后的最终解决方案如下

---

很高兴有答案，您必须设置订阅政策：

ZeroMQ 希望每个SUB 方首先明确地说，SUB 方希望从 PUB 接收什么>（是的，它要订阅什么）。

就像您的邮箱永远不会收到报纸一样，如果没有先订阅任何报纸。 :o)

所以在订阅者中设置一个空字符串 "" 就完成了：

// String                filterPermitANY = "";        // WAS AN EXAMPLE TO TEST
// subscriber.subscribe( filterPermitANY.getBytes() );//     IF PUB.send()-s ANY
   String                gaze = "gaze";               // WAS ON TOPIC
   subscriber.subscribe( gaze.getBytes() );           //     

瞧。

由于对面运行的 python 版本是零保证的，因此可能会针对字符串表示匹配进行调整...

( 还建议将LINGER 设置为 1，以防止挂起终端
最好是转过程的最佳时机
在软实时维护的事件循环中使用非阻塞.poll() + .recv( ..., ZMQ_DONTWAIT )）

---

[ 1 ] 我们已经确认 Android/ZeroMQ 端工作正常

如果 PUB 端被普通的 python-PUBfinite-sender 模拟并且 Android-SUB 订阅了 String filterPermitANY ="";

这使得上面的claim "It's an issue from the android side" 如果没有误导的话实际上是无效的。

---

[ 2 ] 接下来是为什么它仍然不起作用的问题？

而答案是：由于上面设计的代码没有遵循公布的原则，如何连接和使用Pupil Labs API .

细心的读者会注意到 Pupil Labs API 没有通过 SUB 连接-在端口 :50020 上的一侧（无论是 Android 还是 python 或其他任何此类对等体的实现），但在另一个端口上，首先通过另一个对话询问，通过 REQ/REP-正式沟通原型（lines 13/14/15+19）。

---

结语

敲错门永远不会实现预期的采访。

首先必须询问接下来要敲哪扇门，以便将 Pupil Labs API 放入游戏中。