0

我正在编写一个接收连续数据流的 Android 应用程序。我已经在一个可运行对象中设置了连接，如下所示：

Runnable runnable = new Runnable()
    {
        public void run()
        {
        ZMQ.Context context = ZMQ.context(1);
        ZMQ.Socket subscriber = context.socket(ZMQ.SUB);
        subscriber.connect("tcp://[IP]:[Port]");
            TextView strDisplay = (TextView) findViewById(R.id.stringDisplay);
            while (!Thread.currentThread ().isInterrupted ())
            {
                // Read message contents
                Log.i("Output", "the while loop ran up to here");
                //*HANGS ON THE LINE BELOW*
                String testcase = subscriber.recvStr(0);
                strDisplay.setText(testcase);
                Log.i("Output", "The while loop completed");
            }

现在，经过大量的互联网搜索，我得出了两个结论：

1) recvStr() 是一个阻塞调用，它一直等到它收到一些东西。所以这意味着它没有正确连接或其他东西

和

2）我可能需要设置某种过滤器？

我不知道接下来我应该做什么。非常感谢有 JeroMQ 或 Android 服务器访问经验的人提供的任何帮助

4

1 回答 1

1

可能，您需要订阅要从发布者那里获得的主题，或者在建立连接后订阅所有主题。

例如订阅单个主题：

subscriber.subscribe("topic_to_get".getBytes());

订阅每个主题：

subscriber.subscribe("".getBytes());
于 2015-08-03T19:41:09.740 回答