Android进程通信之Messenger和AIDL使用详解

Android进程通信之Messenger和AIDL使用详解,第1张

概述1.前言提到的进程通信(IPC:Inter-ProcessCommunication),在Android系统中,一个进程是不能直接访问另一个进程的内存的,需要提供一些机制在不同的进程之间进行通信,Android官方推出了AIDL(AndroidInterfaceD

1. 前言

提到的进程间通信(IPC:Inter-Process Communication),在AndroID系统中,一个进程是不能直接访问另一个进程的内存的,需要提供一些机制在不同的进程之间进行通信,AndroID官方推出了AIDL(AndroID Interface DeFinition Language),它是基于Binder机制的。

上篇提到组件在与Service通信方法有三种。

实现IBinder Messenger AIDL

后面两种可以跨进程通信,是基于Binder机制的通信方式。

2. 使用时机

在确定使用什么机制之前,首先了解应用场景。AndroID系统中,如果组件与服务通信是在同一进程,就使用第一种方式;如果是跨进程通信,使用第二种和第三种,两者不同在于,Messenger不能处理多线程并发请求。

3. AIDL使用

AIDL是可以处理多线程访问的请求的,所以实现AIDL首先要保证线程安全。

创建.aIDl文件,定义接口 在代码中实现接口,AndroID SDK会根据aIDl文件,生成接口,接口内部有一个名为Stub内部抽象类,这个类用于继承了Binder类并实现aIDl文件中定义的接口,我们需要拓展Stub类并实现里面的抽象方法 复写Service的onBind(),返回Stub类的实现

3.1 创建.aIDl文件

在AndroID Studio中工程目录下,反键new -> AIDL -> AIDL file,可以新建aIDl文件,编译器会自动在app(壳工程)/src/main/目录下新建aIDl文件,同时也会新建文件夹,默认以工程包名作为aIDl文件所在的目录。

目录结构如下:

图-1 aIDl文件目录结构

也可以手动创建,aIDl接口定义的包名也可以和工程包名不同,aIDl文件语法和Java语法相似,aIDl定义的接口名必须和文件名一致,而且支持传递自定义的数据类型,需要实现parcelable接口。

IRemoteService.aIDl

package com.demo.aIDl;import com.demo.aIDl.ParcelableData;interface IRemoteService { /** * 获取当前进程的pID */ int getPID(); /** * 获取当前服务名称 */ String getServicename(); /** * 处理客户端传过来的数据 */ voID handleData(in ParcelableData data);}

ParcelableData.aIDl

package com.demo.aIDl;/** * 声明支持传递的类 */parcelable ParcelableData;

IRemoteServiceCallBack.aIDl

package com.demo.aIDl;oneway interface IRemoteServiceCallBack { voID valueChanged(int value);}

aIDl文件定义的接口支持的数据类型如下:

Java的八种基本数据类型(byte,int,short,long,float,double,char,boolean) String CharSequence List,List中所有的元素必须是aIDl文件支持的数据类型,例如,List< String > Map,Map中所有的元素必须是aIDl文件支持的数据类型, 其他aIDl定义的接口,要手动添加import 其他aIDl文件中申明的类,要手动添加import

aIDl文件中定义的方法接受的参数,除了Java的基本数据类型和aIDl定义的接口之外,其他参数都需要标记数据的走向,in/out/inout,基本数据类型和aIDl定义的接口作为参数,默认是in。

in表示输入参数,客户端把参数传递给服务端使用。 out表示输出参数,客户端将参数传递给服务端填充,然后自己使用处理。 inout标书输入输出参数,传送相应的值并接收返回。

关键字oneway表示用户请求相应功能时不需要等待响应可直接调用返回,非阻塞效果,该关键字可以用来声明接口或者声明方法,如果接口声明中用到了oneway关键字,则该接口声明的所有方法都采用oneway方式

新建完毕aIDl文件后,rebuild工程或者使用gradle assembleDeBUG(或gradle assembleRelease)指令编译工程,生成具体的java代码,在壳工程/build/generated/aIDl/目录下的deBUG或者release文件夹下,根据build的类型而定,如图:

图-2 adil生成代码目录图

AIDL接口首次公布后对其的任何修改都必须保持向后兼容性,避免中断客户端对服务的使用,因为需要将.aIDl文件复制给其他应用,才能使其他应用能够访问服务,所以必须保持对原始接口的支持。

3.2 实现接口

AndroID SDK会根据.aIDl文件生成同名.java文件,生成的接口中有一个Stub的抽象子类,这个类实现(implements)aIDl定义的接口,同时继承了Binder。

具体代码如下:

private final IRemoteService.Stub mBinder = new IRemoteService.Stub() { @OverrIDe public int getPID() throws remoteexception { return Process.myPID(); } @OverrIDe public String getServicename() throws remoteexception { return RemoteService.this.getClass().getSimplename(); } @OverrIDe public voID handleData(ParcelableData data) throws remoteexception { Toast.makeText(RemoteService.this,"num is " + data.num,Toast.LENGTH_SHORT).show(); } @OverrIDe public voID registerCallback(IRemoteServiceCallBack cb) throws remoteexception { if(cb != null) { mCallBacks.register(cb); } } @OverrIDe public voID unregisterCallback(IRemoteServiceCallBack cb) throws remoteexception { if(cb != null) { mCallBacks.unregister(cb); } }};

现在mBinder是Stub类的一个实例,同时也是一个Binder,用于服务定义的RPC服务,作为onBind()方法的返回对象实例。

实现AIDL接口注意事项:

因为AIDL可以处理多线程并发,在实现过程中要保证线程安全 默认情况下,RPC调用是同步的,但是服务端可能有耗时 *** 作,客户端最好不要在主线程调用服务 服务端引发的任何异常不会返回给客户端

3.3 向客户端暴露接口

实现接口后,需要向客户端将接口暴露出来,以便客户端使用。将Stub的实例化对象作为Service中onBind()方法的返回对象。

public class RemoteService extends Service { /** * 回调容器 */ private final RemoteCallbackList<IRemoteServiceCallBack> mCallBacks = new RemoteCallbackList<>(); /** * aIDl接口具体实现 */ private final IRemoteService.Stub mBinder = new IRemoteService.Stub() { @OverrIDe public int getPID() throws remoteexception { return Process.myPID(); } @OverrIDe public String getServicename() throws remoteexception { return RemoteService.this.getClass().getSimplename(); } @OverrIDe public voID handleData(ParcelableData data) throws remoteexception { Toast.makeText(RemoteService.this,Toast.LENGTH_SHORT).show(); } @OverrIDe public voID registerCallback(IRemoteServiceCallBack cb) throws remoteexception { if(cb != null) { mCallBacks.register(cb); } } @OverrIDe public voID unregisterCallback(IRemoteServiceCallBack cb) throws remoteexception { if(cb != null) { mCallBacks.unregister(cb); } } }; @Nullable @OverrIDe public IBinder onBind(Intent intent) { return mBinder; } @OverrIDe public voID onDestroy() { // 注销所有回调 mCallBacks.kill(); }}

3.4 客户端调用

服务提供给第三方应用使用,其他应用就必须要有接口类,在客户端创建相同的aIDl文件(可以直接拷贝过去)。

核心连接远端服务的代码:

/** * 远端服务 */private IRemoteService mService;private ServiceConnection mConnection = new ServiceConnection() { /** * 连接服务器成功回调 *  * @param classname * @param service */ public voID onServiceConnected(Componentname classname,IBinder service) { mService = IRemoteService.Stub.asInterface(service); } /** * 服务器因为一场情况断开连接时候回调 *  * @param classname */ public voID onServicedisconnected(Componentname classname) { mService = null; }};/** * 绑定服务 */private voID dobindService() { isBound = true; Intent intent = new Intent(BindRemoteServiceActivity.this,RemoteService.class); bindService(intent,mConnection,Context.BIND_auto_CREATE);}/** * 解除绑定 */private voID doUnbindService() { if(isBound && mService != null) { isBound = false; try { mService.unregisterCallback(mCallback); } catch (remoteexception e) { e.printstacktrace(); } unbindService(mConnection); }}/** * 向服务端发送信息 */private voID doSendMsg() { if(!isBound || mService == null) { return; } ParcelableData data = new ParcelableData(1); try { mService.handleData(data); } catch (remoteexception e) { e.printstacktrace(); }}/** * 调用服务端方法获取信息 */private voID doGetServiceInfo() { if(!isBound || mService == null) { return; } try { String info = mService.getServicename(); mInfoTv.setText("Service info :" + info); } catch (remoteexception e) { e.printstacktrace(); }}

详情代码贴上来比较长,贴上工程地址,点我呀!!!

4. Messenger的使用

Messenger的使用相对于AIDL方便好多,因为Messenger是AndroID系统中自带的类,服务端和客户端都不用创建AIDL文件。

Messenger会持有一个Handler,这个Handler用于处理接受到的信息,在服务端和乘客通过Messenger实现双方通信。

4.1 服务端

代码实例:

public class MessengerService extends Service { public static final int MSG_REGISTER_CLIENT = 0X001; public static final int MSG_UNREGISTER_CLIENT = 0X010; public static final int MSG_HANDLE = 0X100; private ArrayList<Messenger> mClIEnts = new ArrayList<>(); private final Messenger mMessenger = new Messenger(new IncomingHandler()); @Nullable @OverrIDe public IBinder onBind(Intent intent) { return mMessenger.getBinder(); } @OverrIDe public voID onDestroy() { Toast.makeText(this,"Remote Service Destroy",Toast.LENGTH_SHORT).show(); } private class IncomingHandler extends Handler { @OverrIDe public voID handleMessage(Message msg) { switch (msg.what) { case MSG_REGISTER_CLIENT:  mClIEnts.add(msg.replyTo);  break; case MSG_UNREGISTER_CLIENT:  mClIEnts.remove(msg.replyTo);  break; case MSG_HANDLE:  for (Messenger mClIEnt : mClIEnts) {  try {  mClIEnt.send(Message.obtain(null,MSG_HANDLE,msg.arg1,0));  } catch (remoteexception e) {  e.printstacktrace();  mClIEnts.remove(mClIEnt);  }  }  break; default:  super.handleMessage(msg); } } };}

4.2 客户端

核心代码:

/** * 关联远端服务的messenger */private Messenger mServiceWrapper;/** * 用于处理服务端发送的信息 */final Messenger mMessenger = new Messenger(new IncomingHandler());private ServiceConnection mConnection = new ServiceConnection() { @OverrIDe public voID onServiceConnected(Componentname name,IBinder service) { mServiceWrapper = new Messenger(service); mInfoTv.setText("Connected Service"); try { // 添加监听注册 Message msg = Message.obtain(null,MessengerService.MSG_REGISTER_CLIENT); msg.replyTo = mMessenger; mServiceWrapper.send(msg); } catch (remoteexception e) { e.printstacktrace(); } } @OverrIDe public voID onServicedisconnected(Componentname name) { mServiceWrapper = null; mInfoTv.setText("disconnected"); }};/** * 绑定服务 */private voID dobindService() { if(!isBound) { bindService(new Intent(this,MessengerService.class),Context.BIND_auto_CREATE); isBound = true; mInfoTv.setText("Binding..."); }}/** * 移除监听并解绑服务 */private voID doUnbindService() { if(isBound) { if(mServiceWrapper != null) { try { Message msg = Message.obtain(null,MessengerService.MSG_UNREGISTER_CLIENT); msg.replyTo = mMessenger; mServiceWrapper.send(msg); } catch (remoteexception e) { e.printstacktrace(); } } unbindService(mConnection); isBound = false; mInfoTv.setText("Unbinding..."); }}/** * 向服务端发送信息 */private voID doSendMsg() { if(mServiceWrapper != null) { try { Message msg = Message.obtain(null,MessengerService.MSG_HANDLE,this.hashCode(),0); mServiceWrapper.send(msg); } catch (remoteexception e) { e.printstacktrace(); } }}

4.3 客户端发送信息

使用Messenger向服务端发送信息,使用的是Messenger.send(Message)方法,这个方法具体实现如下:

public voID send(Message message) throws remoteexception { mTarget.send(message);}

方法内部调用mTarget.send(Message)方法,在Messenger中,mTarget是在构造方法里面被赋值的,有两个构造函数。

public Messenger(Handler target) { mTarget = target.getIMessenger();}public Messenger(IBinder target) { mTarget = IMessenger.Stub.asInterface(target);}

第一个构造函数好理解,mTarget.send(Message)实际上是将Message加入了构造函数传入的Handler的消息队列,Demo工程中服务端向乘客端发送信息就是使用的这种方法

第二个构造函数是不是很眼熟,这不就是获取AIDL定义的接口嘛!!!转了一圈回到了上面的AIDL,客户端向服务端发送信息实际上还是通过AIDL,只不过AndroID系统帮我们做了一层封装。

最后附上demo:demo

5. 总结

到此,AndroID中常用的进程通信都已经总结完毕,算是一个完结,撒花!!希望对大家的学习有所帮助,也希望大家多多支持编程小技巧。

总结

以上是内存溢出为你收集整理的Android进程通信之Messenger和AIDL使用详解全部内容,希望文章能够帮你解决Android进程通信之Messenger和AIDL使用详解所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。

欢迎分享,转载请注明来源:内存溢出

原文地址:https://54852.com/web/1147373.html

(0)
打赏 微信扫一扫微信扫一扫 支付宝扫一扫支付宝扫一扫
上一篇 2022-05-31
下一篇2022-05-31

发表评论

登录后才能评论

评论列表(0条)

    保存