這邊博客主要記錄一下Android中Messenger的基本原理和用法。
簡單來講，Messenger其實就是Binder通信的包裝器，是一種基于消息傳遞的進程間通信工具。
//Messenger實現了Parcelable接口，因此可以跨進程傳輸public final class Messenger implements Parcelable { ...............} 通常情況下，我們可以在A進程中創建一個Messenger，然后將該Messenger傳遞給B進程。
于是，B進程就可以通過Messenger與A進程通信了。
Messenger通常與Handler一起使用，我們看看對應的源碼：
public final class Messenger implements Parcelable { private final IMessenger mTarget; public Messenger(Handler target) { mTarget = target.getIMessenger(); } ...........}跟進一下Handler的getIMessenger函數：
............. final IMessenger getIMessenger() { synchronized (mQueue) { if (mMessenger != null) { return mMessenger; } //返回的是Handler中定義的MessengerImpl mMessenger = new MessengerImpl(); return mMessenger; } } //此處MessengerImpl繼承自IMessenger.Stub //容易看出MessengerImpl將作為Binder通信的接收端 private final class MessengerImpl extends IMessenger.Stub { public void send(Message msg) { msg.sendingUid = Binder.getCallingUid(); Handler.this.sendMessage(msg); } }從上述代碼可以看出，Messenger實際上作為了一個Binder服務端的wrapper。
當我們在A進程中創建Messenger，然后傳遞給B進程時，Messenger需要執行Parcelable接口定義的操作，于是：
//在A進程中將Binder信息寫入到Parcel中 public void writeToParcel(Parcel out, int flags) { out.writeStrongBinder(mTarget.asBinder()); } public static final Parcelable.Creator<Messenger> CREATOR = new Parcelable.Creator<Messenger>() { //在B進程中，重新創建Binder public Messenger createFromParcel(Parcel in) { IBinder target = in.readStrongBinder(); //調用Messenger的另一個構造函數 return target != null ? new Messenger(target) : null; } public Messenger[] newArray(int size) { return new Messenger[size]; } };跟進一下Messenger的另一個構造函數：
public Messenger(IBinder target) { //得到的是Binder通信的客戶端 mTarget = IMessenger.Stub.asInterface(target);}因此，當Messenger從進程A傳遞到進程B時，它就變為了Binder通信客戶端的wrapper。
當在進程B中使用Messenger的接口時：
public void send(Message message) throws RemoteException { //mTarget為Binder通信的客戶端，將消息發送給服務端的send函數 //即服務端Handler的MessengerImpl的send函數 //上文已經附上了對應代碼，可以看到對應的消息將遞交給Handler處理 mTarget.send(message);} 以上就是Messenger通信的原理，現在實際測試一下。
我們定義一個簡單的demo，包含一個Activity和一個Service，其中Service與Activity處在不同的進程中。
AndroidManifest.xml中的定義如下：
..................... <activity android:name=".MainActivity"> <intent-filter> <action android:name="android.intent.action.MAIN"/> <category android:name="android.intent.category.LAUNCHER"/> </intent-filter> </activity> <service android:name=".RemoteService" android:enabled="true" android:exported="true" <!--指定服務運行在其它進程--> android:process=".remote"> </service> ..............
Activity的界面很簡單，當點擊時就會像Service發送消息，Activity代碼如下：
public class MainActivity extends AppCompatActivity { private Button mButton; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); //打印Activity的pid及所在進程名稱 Log.d("ZJTest", "Activity, pid: " + Process.myPid() + ", name: " + Util.getProcessName(this)); //啟動服務 startService(); //綁定服務 bindService(); mButton = (Button) findViewById(R.id.test_button); mButton.setEnabled(false); //點擊按鍵后，利用Messenger向Service發送消息 mButton.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { if (mMessenger != null) { try { Message msg = Message.obtain(); msg.what = 1; mMessenger.send(msg); } catch (RemoteException e) { Log.d("ZJTest", e.toString()); } } } }); } @Override public void onDestroy() { super.onDestroy(); unBindService(); stopService(); } private Intent mIntent; private void startService() { mIntent = new Intent(this, RemoteService.class); this.startService(mIntent); } private ServiceConnection mServiceConnection; private void bindService() { mServiceConnection = new LocalServiceConnection(); this.bindService(mIntent, mServiceConnection, BIND_AUTO_CREATE); } Messenger mMessenger; private class LocalServiceConnection implements android.content.ServiceConnection { @Override public void onServiceConnected(ComponentName name, IBinder service) { //綁定服務后，獲得Messenger并激活Button mMessenger = new Messenger(service); mButton.setEnabled(true); } @Override public void onServiceDisconnected(ComponentName name) { mButton.setEnabled(false); } } private void stopService() { stopService(mIntent); } private void unBindService() { unbindService(mServiceConnection); }}Service對應的代碼如下：
public class RemoteService extends Service { private Messenger mMessenger; @Override public void onCreate() { super.onCreate(); //同樣打印進程號及名稱 Log.d("ZJTest", "Service, pid: " + Process.myPid() + ", name: " + Util.getProcessName(this)); LocalHandler mHandler = new LocalHandler(); mMessenger = new Messenger(mHandler); } private static class LocalHandler extends Handler{ @Override public void handleMessage(Message msg) { Log.d("ZJTest", "receive msg: " + msg.what); } } @Override public IBinder onBind(Intent intent) { //被綁定時，返回Messenger return mMessenger.getBinder(); }}獲取進程名的代碼如下：
class Util { static String getProcessName(Context context) { int pid = Process.myPid(); ActivityManager am = (ActivityManager) context .getSystemService(Context.ACTIVITY_SERVICE); for (ActivityManager.RunningAppProcessInfo appProcessInfo: am.getRunningAppProcesses()) { if (appProcessInfo.pid == pid) { return appProcessInfo.processName; } } return null; }}上述代碼都是比較簡單的，現在來看看運行結果：
02-20 21:25:15.760 D/ZJTest (30460): Activity, pid: 30460, name: stark.a.is.zhang.messengertest
02-20 21:25:15.769 D/ZJTest (30428): Service, pid: 30428, name: .remote
02-20 21:25:32.111 D/ZJTest (30428): receive msg: 1
從log可以看出，Activity與Servie運行在不同的進程中，Messenger確實可以在不同進程間傳遞消息。
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持VEVB武林網。
新聞熱點
疑難解答
