Android中Messenger原理及基本用法详解

2024-02-27 10:45:03 49

这边博客主要记录一下Android中Messenger的基本原理和用法。

简单来讲，Messenger其实就是Binder通信的包装器，是一种基于消息传递的进程间通信工具。

//Messenger实现了Parcelable接口，因此可以跨进程传输
publicfinalclassMessengerimplementsParcelable{
...............
}

通常情况下，我们可以在A进程中创建一个Messenger，然后将该Messenger传递给B进程。
于是，B进程就可以通过Messenger与A进程通信了。

Messenger通常与Handler一起使用，我们看看对应的源码：

publicfinalclassMessengerimplementsParcelable{
privatefinalIMessengermTarget;

publicMessenger(Handlertarget){
mTarget=target.getIMessenger();
}
...........
}

跟进一下Handler的getIMessenger函数：

.............
finalIMessengergetIMessenger(){
synchronized(mQueue){
if(mMessenger!=null){
returnmMessenger;
}
//返回的是Handler中定义的MessengerImpl
mMessenger=newMessengerImpl();
returnmMessenger;
}
}

//此处MessengerImpl继承自IMessenger.Stub
//容易看出MessengerImpl将作为Binder通信的接收端
privatefinalclassMessengerImplextendsIMessenger.Stub{
publicvoidsend(Messagemsg){
msg.sendingUid=Binder.getCallingUid();
Handler.this.sendMessage(msg);
}
}

从上述代码可以看出，Messenger实际上作为了一个Binder服务端的wrapper。

当我们在A进程中创建Messenger，然后传递给B进程时，Messenger需要执行Parcelable接口定义的操作，于是：

//在A进程中将Binder信息写入到Parcel中
publicvoidwriteToParcel(Parcelout,intflags){
out.writeStrongBinder(mTarget.asBinder());
}

publicstaticfinalParcelable.CreatorCREATOR
=newParcelable.Creator(){
//在B进程中，重新创建Binder
publicMessengercreateFromParcel(Parcelin){
IBindertarget=in.readStrongBinder();

//调用Messenger的另一个构造函数
returntarget!=null?newMessenger(target):null;
}

publicMessenger[]newArray(intsize){
returnnewMessenger[size];
}
};

跟进一下Messenger的另一个构造函数：

publicMessenger(IBindertarget){
//得到的是Binder通信的客户端
mTarget=IMessenger.Stub.asInterface(target);
}

因此，当Messenger从进程A传递到进程B时，它就变为了Binder通信客户端的wrapper。

当在进程B中使用Messenger的接口时：

publicvoidsend(Messagemessage)throwsRemoteException{
//mTarget为Binder通信的客户端，将消息发送给服务端的send函数
//即服务端Handler的MessengerImpl的send函数
//上文已经附上了对应代码，可以看到对应的消息将递交给Handler处理
mTarget.send(message);
}

以上就是Messenger通信的原理，现在实际测试一下。
我们定义一个简单的demo，包含一个Activity和一个Service，其中Service与Activity处在不同的进程中。

AndroidManifest.xml中的定义如下：

.....................









android:process=".remote">

..............

Activity的界面很简单，当点击时就会像Service发送消息，Activity代码如下：

publicclassMainActivityextendsAppCompatActivity{
privateButtonmButton;

@Override
protectedvoidonCreate(BundlesavedInstanceState){
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(newView.OnClickListener(){
@Override
publicvoidonClick(Viewv){
if(mMessenger!=null){
try{
Messagemsg=Message.obtain();
msg.what=1;
mMessenger.send(msg);
}catch(RemoteExceptione){
Log.d("ZJTest",e.toString());
}
}
}
});
}

@Override
publicvoidonDestroy(){
super.onDestroy();
unBindService();
stopService();
}

privateIntentmIntent;
privatevoidstartService(){
mIntent=newIntent(this,RemoteService.class);
this.startService(mIntent);
}

privateServiceConnectionmServiceConnection;
privatevoidbindService(){
mServiceConnection=newLocalServiceConnection();
this.bindService(mIntent,mServiceConnection,BIND_AUTO_CREATE);
}

MessengermMessenger;
privateclassLocalServiceConnectionimplementsandroid.content.ServiceConnection{
@Override
publicvoidonServiceConnected(ComponentNamename,IBinderservice){
//绑定服务后，获得Messenger并激活Button
mMessenger=newMessenger(service);
mButton.setEnabled(true);
}

@Override
publicvoidonServiceDisconnected(ComponentNamename){
mButton.setEnabled(false);
}
}

privatevoidstopService(){
stopService(mIntent);
}

privatevoidunBindService(){
unbindService(mServiceConnection);
}
}

Service对应的代码如下：

publicclassRemoteServiceextendsService{
privateMessengermMessenger;

@Override
publicvoidonCreate(){
super.onCreate();

//同样打印进程号及名称
Log.d("ZJTest","Service,pid:"+Process.myPid()
+",name:"+Util.getProcessName(this));

LocalHandlermHandler=newLocalHandler();

mMessenger=newMessenger(mHandler);
}

privatestaticclassLocalHandlerextendsHandler{
@Override
publicvoidhandleMessage(Messagemsg){
Log.d("ZJTest","receivemsg:"+msg.what);
}
}

@Override
publicIBinderonBind(Intentintent){
//被绑定时，返回Messenger
returnmMessenger.getBinder();
}
}

获取进程名的代码如下：

classUtil{
staticStringgetProcessName(Contextcontext){
intpid=Process.myPid();
ActivityManageram=(ActivityManager)context
.getSystemService(Context.ACTIVITY_SERVICE);

for(ActivityManager.RunningAppProcessInfoappProcessInfo:
am.getRunningAppProcesses()){
if(appProcessInfo.pid==pid){
returnappProcessInfo.processName;
}
}

returnnull;
}
}

上述代码都是比较简单的，现在来看看运行结果：

02-2021:25:15.760D/ZJTest (30460):Activity,pid:30460,name:stark.a.is.zhang.messengertest
02-2021:25:15.769D/ZJTest (30428):Service,pid:30428,name:.remote
02-2021:25:32.111D/ZJTest (30428):receivemsg:1

从log可以看出，Activity与Servie运行在不同的进程中，Messenger确实可以在不同进程间传递消息。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

Android中Messenger原理及基本用法详解

热门推荐

随机推荐