今天就跟大家聊聊有關(guān)Messenger如何在Android應(yīng)用中使用,可能很多人都不太了解,為了讓大家更加了解,小編給大家總結(jié)了以下內(nèi)容,希望大家根據(jù)這篇文章可以有所收獲。
站在用戶的角度思考問題,與客戶深入溝通,找到衡南網(wǎng)站設(shè)計(jì)與衡南網(wǎng)站推廣的解決方案,憑借多年的經(jīng)驗(yàn),讓設(shè)計(jì)與互聯(lián)網(wǎng)技術(shù)結(jié)合,創(chuàng)造個性化、用戶體驗(yàn)好的作品,建站類型包括:成都做網(wǎng)站、成都網(wǎng)站建設(shè)、成都外貿(mào)網(wǎng)站建設(shè)、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣、域名注冊、虛擬空間、企業(yè)郵箱。業(yè)務(wù)覆蓋衡南地區(qū)。
Messenger其實(shí)就是Binder通信的包裝器,是一種基于消息傳遞的進(jìn)程間通信工具。
//Messenger實(shí)現(xiàn)了Parcelable接口,因此可以跨進(jìn)程傳輸 public final class Messenger implements Parcelable { ............... }
通常情況下,我們可以在A進(jìn)程中創(chuàng)建一個Messenger,然后將該Messenger傳遞給B進(jìn)程。
于是,B進(jìn)程就可以通過Messenger與A進(jìn)程通信了。
Messenger通常與Handler一起使用,我們看看對應(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í)際上作為了一個Binder服務(wù)端的wrapper。
當(dāng)我們在A進(jìn)程中創(chuàng)建Messenger,然后傳遞給B進(jìn)程時,Messenger需要執(zhí)行Parcelable接口定義的操作,于是:
//在A進(jìn)程中將Binder信息寫入到Parcel中 public void writeToParcel(Parcel out, int flags) { out.writeStrongBinder(mTarget.asBinder()); } public static final Parcelable.CreatorCREATOR = new Parcelable.Creator () { //在B進(jìn)程中,重新創(chuàng)建Binder public Messenger createFromParcel(Parcel in) { IBinder target = in.readStrongBinder(); //調(diào)用Messenger的另一個構(gòu)造函數(shù) return target != null ? new Messenger(target) : null; } public Messenger[] newArray(int size) { return new Messenger[size]; } };
跟進(jìn)一下Messenger的另一個構(gòu)造函數(shù):
public Messenger(IBinder target) { //得到的是Binder通信的客戶端 mTarget = IMessenger.Stub.asInterface(target); }
因此,當(dāng)Messenger從進(jìn)程A傳遞到進(jìn)程B時,它就變?yōu)榱薆inder通信客戶端的wrapper。
當(dāng)在進(jìn)程B中使用Messenger的接口時:
public void send(Message message) throws RemoteException { //mTarget為Binder通信的客戶端,將消息發(fā)送給服務(wù)端的send函數(shù) //即服務(wù)端Handler的MessengerImpl的send函數(shù) //上文已經(jīng)附上了對應(yīng)代碼,可以看到對應(yīng)的消息將遞交給Handler處理 mTarget.send(message); }
以上就是Messenger通信的原理,現(xiàn)在實(shí)際測試一下。
我們定義一個簡單的demo,包含一個Activity和一個Service,其中Service與Activity處在不同的進(jìn)程中。
AndroidManifest.xml中的定義如下:
.....................android:process=".remote"> ..............
Activity的界面很簡單,當(dāng)點(diǎn)擊時就會像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)程名稱 Log.d("ZJTest", "Activity, pid: " + Process.myPid() + ", name: " + Util.getProcessName(this)); //啟動服務(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對應(yīng)的代碼如下:
public class RemoteService extends Service { private Messenger mMessenger; @Override public void onCreate() { super.onCreate(); //同樣打印進(jìn)程號及名稱 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(); } }
獲取進(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; } }
上述代碼都是比較簡單的,現(xiàn)在來看看運(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)程間傳遞消息。
看完上述內(nèi)容,你們對Messenger如何在Android應(yīng)用中使用有進(jìn)一步的了解嗎?如果還想了解更多知識或者相關(guān)內(nèi)容,請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道,感謝大家的支持。