Android:创建ZeroMQ的客户端


这里我们将给出一个subscribe模式的客户端示例程序,如下:

private class ZeroMQMessageTask extends AsyncTask<String, Void, String> {
    private String message = "";

    public ZeroMQMessageTask() {
    }

    @Override
    protected String doInBackground(String... params) {

        ZMQ.Context context = ZMQ.context(1);
        ZMQ.Socket subscriber = context.socket(ZMQ.SUB);
        subscriber.subscribe("");
        subscriber.connect("tcp://x.x.x.x:6666");  // 注意,这里必须是服务器的IP地址或DNS Name
        message = new String(subscriber.recv(0));

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

        return message;
    }

    @Override
    protected void onPostExecute(String result) {
        EditText text = (EditText) myView.findViewById(R.id.message); // 这里替换成对应的UI控件用于显示结果
        searchEditText.setText(result);
    }
}

关于创建ZeroMQ的服务端,请参考这篇文章:

在Ubuntu 11.04上安装ZeroMQ

Ubuntu Server 12.10 上安装 Node.js, ZeroMQ

Linux下ZeroMQ write函数变更

ZeroMQ使用注意点滴

ZeroMQ 的详细介绍:请点这里
ZeroMQ 的下载地址:请点这里

本文永久更新链接地址:

相关内容

    暂无相关文章