Android開發(fā)使用Messenger及Handler進行通信的方法示例

更新時間：2017年12月13日 11:39:03 作者：LovooGod

這篇文章主要介紹了Android開發(fā)使用Messenger及Handler進行通信的方法,結(jié)合實例形式分析了Android使用Messenger及Handler定義客戶端與服務器端實現(xiàn)通信的相關(guān)操作技巧,需要的朋友可以參考下

本文實例講述了Android開發(fā)使用Messenger及Handler進行通信的方法。分享給大家供大家參考，具體如下：

1. 客戶端service

public class MessageService extends Service {
 private static final int MSG_SET_VALUE = 0x110;
 private Handler mHandler = new Handler() {
  public void handleMessage(Message msgFromClient) {
   // 返回給客戶的信息
   Message msgToClient = Message.obtain(msgFromClient);
   switch (msgFromClient.what) {
   // msg 客戶端傳來的消息
   case MSG_SET_VALUE:
    try {
     msgToClient.what = MSG_SET_VALUE;
     SystemClock.sleep(2000);
     msgToClient.arg2 = msgFromClient.arg1 + msgFromClient.arg2;
     //msgFromClient.replyTo.send(msgToClient);
     //得到客戶端的信使對象，并向它發(fā)送消息
     cMessenger = msgFromClient.replyTo;
     cMessenger.send(msgToClient);
    } catch (RemoteException e) {
     e.printStackTrace();
    }
    break;
   default:
    break;
   }
  }
 };
 private Messenger mMessager = new Messenger(mHandler);
 private Messenger cMessenger;
 @Override
 public IBinder onBind(Intent intent) {
  return mMessager.getBinder();
 }
 @Override
 public void onDestroy() {
  cMessenger = null;
  super.onDestroy();
 }
}

2. 服務器端service

public class MessageService extends Service {
 private static final int MSG_SET_VALUE = 0x110;
 private Handler mHandler = new Handler() {
  public void handleMessage(Message msgFromClient) {
   // 返回給客戶的信息
   Message msgToClient = Message.obtain(msgFromClient);
   switch (msgFromClient.what) {
   // msg 客戶端傳來的消息
   case MSG_SET_VALUE:
    try {
     msgToClient.what = MSG_SET_VALUE;
     SystemClock.sleep(2000);
     msgToClient.arg2 = msgFromClient.arg1 + msgFromClient.arg2;
     //msgFromClient.replyTo.send(msgToClient);
     //得到客戶端的信使對象，并向它發(fā)送消息
     cMessenger = msgFromClient.replyTo;
     cMessenger.send(msgToClient);
    } catch (RemoteException e) {
     e.printStackTrace();
    }
    break;
   default:
    break;
   }
  }
 };
 private Messenger mMessager = new Messenger(mHandler);
 private Messenger cMessenger;
 @Override
 public IBinder onBind(Intent intent) {
  return mMessager.getBinder();
 }
 @Override
 public void onDestroy() {
  cMessenger = null;
  super.onDestroy();
 }
}

3. 客戶端使用

public class MainActivity extends Activity {
 private static final int MSG_SET_VALUE = 0x110;
 private TextView mTVStatus; // 連接狀態(tài)
 private LinearLayout mLLContainer;// 用來添加接收到服務器返回的信息
 private Messenger mService; // 客戶端信使
 private boolean isConnecting; // 是否連接
 private Handler mHandler = new Handler() {
  public void handleMessage(Message msgFromServer) {
   switch (msgFromServer.what) {
   case MSG_SET_VALUE:
    TextView tv = (TextView) findViewById(msgFromServer.arg1);
    tv.setText(tv.getText() + "==>" + msgFromServer.arg2);
    break;
   }
   super.handleMessage(msgFromServer);
  };
 };
 private Messenger mMessenger = new Messenger(mHandler);
 @Override
 protected void onCreate(Bundle savedInstanceState) {
  super.onCreate(savedInstanceState);
  setContentView(R.layout.activity_main);
  mTVStatus = (TextView) findViewById(R.id.tv_status);
  mLLContainer = (LinearLayout) findViewById(R.id.ll_container);
 }
 int i = 0;
 public void send(View view){
  try {
   int a = i++;
   int b = (int) (Math.random() * 100);
   //創(chuàng)建一個tv,添加到LinearLayout中
   TextView tv = new TextView(MainActivity.this);
   tv.setText(a + " + " + b + " = caculating ...");
   tv.setId(a);
   mLLContainer.addView(tv);
   Message msgFromClient = Message.obtain(null, MSG_SET_VALUE, a, b);
   msgFromClient.replyTo = mMessenger;
   if (isConnecting) {
    //往服務端發(fā)送消息
    mService.send(msgFromClient);
   }
  } catch (RemoteException e) {
   e.printStackTrace();
  }
 }
 public void bind(View view) {
  Intent service = new Intent();
  service.setAction("android.intent.action.MESSAGE_SERVER");
  bindService(service, conn, Context.BIND_AUTO_CREATE);
 }
 private ServiceConnection conn = new ServiceConnection() {
  @Override
  public void onServiceDisconnected(ComponentName name) {
   mService = null;
   isConnecting = false;
   mTVStatus.setText("已斷開連接！");
  }
  @Override
  public void onServiceConnected(ComponentName name, IBinder service) {
   mService = new Messenger(service);
   isConnecting = true;
   mTVStatus.setText("連接成功！");
  }
 };
 public void unbind(View view) {
  unbindService(conn);
  conn = null;
 }
 @Override
 protected void onDestroy() {
  unbindService(conn);
  conn = null;
  super.onDestroy();
 }
}

更多關(guān)于Android相關(guān)內(nèi)容感興趣的讀者可查看本站專題：《Android通信方式總結(jié)》、《Android開發(fā)入門與進階教程》、《Android調(diào)試技巧與常見問題解決方法匯總》、《Android基本組件用法總結(jié)》、《Android視圖View技巧總結(jié)》、《Android布局layout技巧總結(jié)》及《Android控件用法總結(jié)》

希望本文所述對大家Android程序設(shè)計有所幫助。

您可能感興趣的文章: