這邊博客主要記錄一下Android中Messenger的基本原理和用法。
簡(jiǎn)單來(lái)講，Messenger其實(shí)就是Binder通信的包裝器，是一種基于消息傳遞的進(jìn)程間通信工具。
//Messenger實(shí)現(xiàn)了Parcelable接口，因此可以跨進(jìn)程傳輸public final class Messenger implements Parcelable { ...............}通常情況下，我們可以在A進(jìn)程中創(chuàng)建一個(gè)Messenger，然后將該Messenger傳遞給B進(jìn)程。
于是，B進(jìn)程就可以通過(guò)Messenger與A進(jìn)程通信了。
Messenger通常與Handler一起使用，我們看看對(duì)應(yīng)的源碼：
public final class Messenger implements Parcelable { private final IMessenger mTarget; public Messenger(Handler target) { mTarget = target.getIMessenger(); } ...........}跟進(jìn)一下Handler的getIMessenger函數(shù)：
............. 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實(shí)際上作為了一個(gè)Binder服務(wù)端的wrapper。
當(dāng)我們?cè)贏進(jìn)程中創(chuàng)建Messenger，然后傳遞給B進(jìn)程時(shí)，Messenger需要執(zhí)行Parcelable接口定義的操作，于是：
//在A進(jìn)程中將Binder信息寫(xiě)入到Parcel中 public void writeToParcel(Parcel out, int flags) { out.writeStrongBinder(mTarget.asBinder()); } public static final Parcelable.Creator<Messenger> CREATOR = new Parcelable.Creator<Messenger>() { //在B進(jìn)程中，重新創(chuàng)建Binder public Messenger createFromParcel(Parcel in) { IBinder target = in.readStrongBinder(); //調(diào)用Messenger的另一個(gè)構(gòu)造函數(shù) return target != null ? new Messenger(target) : null; } public Messenger[] newArray(int size) { return new Messenger[size]; } };跟進(jìn)一下Messenger的另一個(gè)構(gòu)造函數(shù)：
public Messenger(IBinder target) { //得到的是Binder通信的客戶(hù)端 mTarget = IMessenger.Stub.asInterface(target);}因此，當(dāng)Messenger從進(jìn)程A傳遞到進(jìn)程B時(shí)，它就變?yōu)榱薆inder通信客戶(hù)端的wrapper。
當(dāng)在進(jìn)程B中使用Messenger的接口時(shí)：
public void send(Message message) throws RemoteException { //mTarget為Binder通信的客戶(hù)端，將消息發(fā)送給服務(wù)端的send函數(shù) //即服務(wù)端Handler的MessengerImpl的send函數(shù) //上文已經(jīng)附上了對(duì)應(yīng)代碼，可以看到對(duì)應(yīng)的消息將遞交給Handler處理 mTarget.send(message);}以上就是Messenger通信的原理，現(xiàn)在實(shí)際測(cè)試一下。
我們定義一個(gè)簡(jiǎn)單的demo，包含一個(gè)Activity和一個(gè)Service，其中Service與Activity處在不同的進(jìn)程中。
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" <!--指定服務(wù)運(yùn)行在其它進(jìn)程--> android:process=".remote"> </service> ..............
Activity的界面很簡(jiǎn)單，當(dāng)點(diǎn)擊時(shí)就會(huì)像Service發(fā)送消息，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及所在進(jìn)程名稱(chēng) Log.d("ZJTest", "Activity, pid: " + Process.myPid() + ", name: " + Util.getProcessName(this)); //啟動(dòng)服務(wù) startService(); //綁定服務(wù) bindService(); mButton = (Button) findViewById(R.id.test_button); mButton.setEnabled(false); //點(diǎn)擊按鍵后，利用Messenger向Service發(fā)送消息 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) { //綁定服務(wù)后，獲得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對(duì)應(yīng)的代碼如下：
public class RemoteService extends Service { private Messenger mMessenger; @Override public void onCreate() { super.onCreate(); //同樣打印進(jìn)程號(hào)及名稱(chēng) 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) { //被綁定時(shí)，返回Messenger return mMessenger.getBinder(); }}獲取進(jìn)程名的代碼如下：
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; }}上述代碼都是比較簡(jiǎn)單的，現(xiàn)在來(lái)看看運(yùn)行結(jié)果：
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運(yùn)行在不同的進(jìn)程中，Messenger確實(shí)可以在不同進(jìn)程間傳遞消息。
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持武林網(wǎng)。
新聞熱點(diǎn)
疑難解答
圖片精選
網(wǎng)友關(guān)注
