這里我們將給出一個subscribe模式的客戶端示例程序,如下:
1 private class ZeroMQMessageTask extends AsyncTask<String, Void, String> { 2 private String message = ""; 3 4 public ZeroMQMessageTask() { 5 } 6 7 @Override 8 protected String doInBackground(String... params) { 9 10 ZMQ.Context context = ZMQ.context(1); 11 ZMQ.Socket subscriber = context.socket(ZMQ.SUB); 12 subscriber.subscribe(""); 13 subscriber.connect("tcp://x.x.x.x:6666"); // 注意,這里必須是服務器的IP地址或DNS Name 14 message = new String(subscriber.recv(0)); 15 16 subscriber.close(); 17 context.term(); 18 19 return message; 20 } 21 22 @Override 23 protected void onPostExecute(String result) { 24 EditText text = (EditText) myView.findViewById(R.id.message); // 這里替換成對應的UI控件用於顯示結果 25 searchEditText.setText(result); 26 } 27 }
關於創建ZeroMQ的服務端,請參考這篇文章:http://www.cnblogs.com/ilovewindy/p/3984269.html