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 的下载地址：请点这里