android开发AIDL跨进程通信：AIDL中RemoteCallbackList的使用及权限验证方式详解
业务场景：
现在要实现每新增一个员工，就通知相应的部门人员
1、提供一个aidl接口，由于aidl中无法使用普通接口，所以提供一个aidl接口
// ionnewpersonarrivedlistener.aidl
package com.wuc.aidltest;
// declare any non-default types here with import statements
import com.wuc.aidltest.person;
// 当服务端有新人加入时，就通知每一个已经申请提醒功能的用户，由于aidl中无法使用普通接口，所以提供一个aidl接口
interface ionnewpersonarrivedlistener {
void onnewpersonarrived(in person person);
}
2、 修改icalculateinterface代码，新增注册与注销监听器代码
// icalculateinterface.aidl
package com.wuc.aidltest;
// declare any non-default types here with import statements
import com.wuc.aidltest.person;
import com.wuc.aidltest.ionnewpersonarrivedlistener;
interface icalculateinterface {
//计算两个数的和
int addnum(int num1,int num2);
//除了基本数据类型，其他类型的参数都需要标上方向类型：in(输入), out(输出), inout(输入输出)
list addperson(in person person);
void registerlistener(ionnewpersonarrivedlistener listener);
void unregisterlistener(ionnewpersonarrivedlistener listener);
}
iremoteservice代码
package com.wuc.aidltest;
public class iremoteservice extends service {
private static final string tag = "iremoteservice";
//存储注册监听客户端集合
private final copyonwritearraylist mlistenerlist = new copyonwritearraylist <>();
/**
* copyonwritearraylist支持并发读写，aidl方法是在服务端的binder线程池中执行的，因此当多个客户端同时连接的时候，
* 会存在多个线程同时访问的情形，所以我们要在aidl方法中处理线程同步，这里使用copyonwritearraylist来进行自动的线程同步
*
* 因为aidl中所支持的是抽象的list，二list只是一个接口，因此虽然服务端返回的是copyonwritearraylist，但是在binder中
* 会按照list的规范去访问数据并最终形成一个新的arraylist传递给客户端，所以采用copyonwritearraylist是可以的，类似的
* 还有concurrenthashmap
*/
private copyonwritearraylist mpersonlist;
private atomicboolean misservicedestoryed = new atomicboolean(false);
private ibinder mibinder = new icalculateinterface.stub() {
@override
public int addnum(int num1, int num2) throws remoteexception {
return num1 + num2;
}
@override
public list addperson(person person) throws remoteexception {
mpersonlist.add(person);
return mpersonlist;
}
@suppresslint("newapi")
@override
public void registerlistener(ionnewpersonarrivedlistener listener) throws remoteexception {
if (!mlistenerlist.contains(listener)) {
mlistenerlist.add(listener);//添加监听
} else {
log.d(tag, "already exists.");
}
log.d(tag, "registerlistener，size：" + mlistenerlist.size());
}
@suppresslint("newapi")
@override
public void unregisterlistener(ionnewpersonarrivedlistener listener) throws remoteexception {
if (mlistenerlist.contains(listener)) {
mlistenerlist.remove(listener);//移除监听
log.d(tag, "unregister listener succeed.");
} else {
log.d(tag, "not found,can not unregister.");
}
log.d(tag, "unregisterlistener，current size：" + mlistenerlist.size());
}
};
@override
public void oncreate() {
super.oncreate();
new thread(new serviceworker()).start();
}
@override
public void ondestroy() {
misservicedestoryed.set(true);
super.ondestroy();
}
@nullable
@override
public ibinder onbind(intent intent) {
mpersonlist = new copyonwritearraylist<>();
return mibinder;
}
private void onnewpersonarrived(person person) throws remoteexception {
mpersonlist.add(person);
log.d(tag, "onnewpersonarrived, notify listener:" + mlistenerlist.size());
for (int i = 0; i < mlistenerlist.size(); i++) {
ionnewpersonarrivedlistener listener = mlistenerlist.get(i);
log.d(tag, "onnewpersonarrived, notify listener:" + listener);
listener.onnewpersonarrived(person);
}
}
/**
* 每个5秒增加一个新人，并通知所有感兴趣的员工
*/
private class serviceworker implements runnable {
@override
public void run() {
while (!misservicedestoryed.get()) {
try {
thread.sleep(5000);
} catch (interruptedexception e) {
e.printstacktrace();
}
person person = new person("new person name：" + 2, 22);
try {
onnewpersonarrived(person);
} catch (remoteexception e) {
e.printstacktrace();
}
}
}
}
}
mainactivity代码
package com.wuc.aidlclient;
public class mainactivity extends appcompatactivity {
private static final string tag = "mainactivity";
private static final int message_new_person_arrived = 1;
private appcompatedittext medt_num1;
private appcompatedittext medt_num2;
private appcompatbutton mbtn_calculate;
private appcompattextview mtxt_result;
private icalculateinterface micalculateinterface;
private ibinder.deathrecipient mdeathrecipient = new ibinder.deathrecipient() {
@override
public void binderdied() {
if (micalculateinterface == null) {
return;
}
//移除之前绑定的代理并重新绑定远程服务
micalculateinterface.asbinder().unlinktodeath(mdeathrecipient, 0);
micalculateinterface = null;
bindservice();
}
};
private clienthandler mhandler = new clienthandler();
/**
* 当客户端发起远程请求时，由于当前线程会被挂起直至服务端进程返回数据，所以如果一个远程方法是很耗时的，
* 则不能在ui 线程中发起此远程请求，为了避免阻塞ui 线程出现anr
* 由于服务端的binder 方法运行在 binder 的线程池中，所以 binder 方法不管是否耗时都应该采用同步的方式去实现，
* 因为它已经运行在一个线程中了
*/
private ionnewpersonarrivedlistener monnewpersonarrivedlistener = new ionnewpersonarrivedlistener.stub() {
@override
public void onnewpersonarrived(person person) throws remoteexception {
mhandler.obtainmessage(message_new_person_arrived, person).sendtotarget();
}
};
private serviceconnection conn = new serviceconnection() {
@override
public void onserviceconnected(componentname name, ibinder service) {
//判断binder是否死忙
//boolean binderalive = service.isbinderalive();
//用于将服务端的binder对象转换为客户端需要的aidl接口类型的对象
micalculateinterface = icalculateinterface.stub.asinterface(service);
try {
micalculateinterface.registerlistener(monnewpersonarrivedlistener);
//给binder设置死忙代理，当binder死忙时就可以收到通知
service.linktodeath(mdeathrecipient, 0);
} catch (remoteexception e) {
e.printstacktrace();
}
}
@override
public void onservicedisconnected(componentname name) {
//连接断开，释放aidl binder对象
micalculateinterface = null;
log.d(tag, "binder died");
}
};
@suppresslint("cutpasteid")
@override
protected void oncreate(bundle savedinstancestate) {
super.oncreate(savedinstancestate);
setcontentview(r.layout.activity_main);
medt_num1 = findviewbyid(r.id.edt_num1);
medt_num2 = findviewbyid(r.id.edt_num2);
mtxt_result = findviewbyid(r.id.txt_result);
mbtn_calculate = findviewbyid(r.id.btn_calculate);
mbtn_calculate.setonclicklistener(new view.onclicklistener() {
@suppresslint("settexti18n")
@override
public void onclick(view v) {
int num1 = integer.parseint(medt_num1.gettext().tostring());
int num2 = integer.parseint(medt_num2.gettext().tostring());
try {
int num = micalculateinterface.addnum(num1, num2);
mtxt_result.settext("结果：" + num);
} catch (remoteexception e) {
e.printstacktrace();
mtxt_result.settext("计算错误");
}
try {
list personlist = micalculateinterface.addperson(new person("wuc", 22));
log.d("aidl", personlist.tostring());
} catch (remoteexception e) {
e.printstacktrace();
}
}
});
bindservice();
}
private void bindservice() {
intent intent = new intent();
intent.setcomponent(new componentname("com.wuc.aidltest",
"com.wuc.aidltest.iremoteservice"));
bindservice(intent, conn, context.bind_auto_create);
}
@override
protected void ondestroy() {
//如果连接持续，并且binder未死亡
if (micalculateinterface != null && micalculateinterface.asbinder().isbinderalive()) {
try {
log.d(tag, "unregister listener : " + monnewpersonarrivedlistener);
micalculateinterface.unregisterlistener(monnewpersonarrivedlistener);
} catch (remoteexception e) {
e.printstacktrace();
}
}
unbindservice(conn);
super.ondestroy();
}
/**
* 防止handler泄漏
*/
private static class clienthandler extends handler {
@override
public void handlemessage(message msg) {
switch (msg.what) {
case message_new_person_arrived:
log.d(tag, "receive new person : " + msg.obj);
break;
default:
super.handlemessage(msg);
break;
}
}
}
}
log日志
服务端（iremoteservice）
从日志中可以看出，在解注册的过程中，服务端找不到之前注册的listener；
原因
binder 会把客户端传递过来的对象重新转化并生成一个新的对象，虽然我们在注册和解注册过程中使用的是同一个客户端，但是通过 binder 传递到服务端后，却会产生两个全新的对象。而对象是不能跨进程传输的，对象的跨进程传输本质上都是反序列化的过程，这就是为什么 aidl 中的自定义对象都必须要实现 parcelable 接口的原因
解决办法
用remotecallbacklist，remotecallbacklist 是专门提供的用于删除跨进程 listener 的类，remotecallbacklist 是一个泛型，支持管理任意的 aidl 接口，从它的声明可以看出，因为所有的 aidl 接口都继承自 iinteface 接口
修改后的iremoteservice
package com.wuc.aidltest;
public class iremoteservice extends service {
private static final string tag = "iremoteservice";
//存储注册监听客户端集合
private final remotecallbacklist mlistenerlist = new remotecallbacklist<>();
/**
* copyonwritearraylist支持并发读写，aidl方法是在服务端的binder线程池中执行的，因此当多个客户端同时连接的时候，
* 会存在多个线程同时访问的情形，所以我们要在aidl方法中处理线程同步，这里使用copyonwritearraylist来进行自动的线程同步
*
* 因为aidl中所支持的是抽象的list，二list只是一个接口，因此虽然服务端返回的是copyonwritearraylist，但是在binder中
* 会按照list的规范去访问数据并最终形成一个新的arraylist传递给客户端，所以采用copyonwritearraylist是可以的，类似的
* 还有concurrenthashmap
*/
private copyonwritearraylist mpersonlist;
private atomicboolean misservicedestoryed = new atomicboolean(false);
private ibinder mibinder = new icalculateinterface.stub() {
@override
public int addnum(int num1, int num2) throws remoteexception {
return num1 + num2;
}
@override
public list addperson(person person) throws remoteexception {
mpersonlist.add(person);
return mpersonlist;
}
@suppresslint("newapi")
@override
public void registerlistener(ionnewpersonarrivedlistener listener) throws remoteexception {
mlistenerlist.register(listener);
/* if (!mlistenerlist.contains(listener)) {
mlistenerlist.add(listener);
} else {
log.d(tag, "already exists.");
}*/
log.d(tag, "registerlistener，size：" + mlistenerlist.getregisteredcallbackcount());
}
@suppresslint("newapi")
@override
public void unregisterlistener(ionnewpersonarrivedlistener listener) throws remoteexception {
mlistenerlist.unregister(listener);
/* if (mlistenerlist.contains(listener)) {
mlistenerlist.remove(listener);
log.d(tag, "unregister listener succeed.");
} else {
log.d(tag, "not found,can not unregister.");
}*/
log.d(tag, "unregisterlistener，current size：" + mlistenerlist.getregisteredcallbackcount());
}
};
@override
public void oncreate() {
super.oncreate();
new thread(new serviceworker()).start();
}
@override
public void ondestroy() {
misservicedestoryed.set(true);
super.ondestroy();
}
@nullable
@override
public ibinder onbind(intent intent) {
mpersonlist = new copyonwritearraylist<>();
int check = checkcallingorselfpermission("com.wuc.aidlservice.permission.access_service");
if (check == packagemanager.permission_denied) {
return null;
}
return mibinder;
}
private void onnewpersonarrived(person person) throws remoteexception {
mpersonlist.add(person);
/*log.d(tag, "onnewpersonarrived, notify listener:" + mlistenerlist.size());
for (int i = 0; i < mlistenerlist.size(); i++) {
ionnewpersonarrivedlistener listener = mlistenerlist.get(i);
log.d(tag, "onnewpersonarrived, notify listener:" + listener);
listener.onnewpersonarrived(person);
}*/
synchronized (mlistenerlist) {
int n = mlistenerlist.beginbroadcast();
try {
for (int i = 0; i < n; i++) {
ionnewpersonarrivedlistener listener = mlistenerlist.getbroadcastitem(i);
if (listener != null) {
listener.onnewpersonarrived(person);
}
}
} catch (remoteexception e) {
e.printstacktrace();
}
mlistenerlist.finishbroadcast();
}
}
/**
* 每个5秒增加一个新人，并通知所有感兴趣的员工
*/
private class serviceworker implements runnable {
@override
public void run() {
while (!misservicedestoryed.get()) {
try {
thread.sleep(5000);
} catch (interruptedexception e) {
e.printstacktrace();
}
person person = new person("new person name：" + 2, 22);
try {
onnewpersonarrived(person);
} catch (remoteexception e) {
e.printstacktrace();
}
}
}
}
}
注： remotecallbacklist 并不是一个list ，不能像 list 一样去操作它，遍历remotecallbacklist 必须要以下面的方式进行，其中 beginbroadcast 和 finishbroadcast 必须配套使用，哪怕我们仅仅是想要获取 remotecallbacklist 中的元素个数
int n = mlistenerlist.beginbroadcast();
try {
for (int i = 0; i < n; i++) {
ionnewpersonarrivedlistener listener = mlistenerlist.getbroadcastitem(i);
if (listener != null) {
listener.onnewpersonarrived(person);
}
}
} catch (remoteexception e) {
e.printstacktrace();
}
mlistenerlist.finishbroadcast();
注：
客户端远程调用服务端的方法，被调用的方法运行在服务端的 binder 线程池中，同时客户端线程会被挂起，此时如果服务端方法执行比较耗时，则会导致客户端线程长时间阻塞在这里，如果此时客户端线程是 ui 线程，则会导致客户端anr ，因此如果我们明确知道某个远程方法是耗时的，则要避免在客户端的 ui 线程中去访问远程方法。
由于客户端的 onserviceconnected 和 onservicedisconnected 方法运行在 ui线程中，故也不可以在他们里面直接调用服务端的耗时方法。
服务端方法本身就运行在服务端的binder 线程池中，故服务端的方法本身就可以进行大量的耗时操作，此时切记不要在服务端开线程去进行异步任务，除非你明确知道自己在干什么，否则不建议这么做
同理，当远程服务端需要调用客户端的 listener 中的方法时，被调用的方法运行在客户端的 binder 池中，故我们同样不可以在服务端调用客户端耗时方法，比如针对 iremoteservice 的 onnewpersonarrived 方法，在它内部调用了客户端的 ionnewpersonarrivedlistener 中的 onnewpersonarrived 方法，如果客户端的这个 onnewpersonarrived 方法比较耗时的话，确保 iremoteservice 的onnewpersonarrived 运行在非 ui 线程中，否则将导致服务端无法响应
同时由于客户端的 ionnewbookarrivedlistener 中的 onnewbookarrived 方法运行在客户端的 binder 池中，故不能在里面访问ui相关的内容，如要访问，请用handler 切换到主线程
binder是可能意外死亡的，这往往是由于服务端进程意外停止导致的，此时我们需要重新连接服务。
1、给binder 设置deathrecipient 监听，当binder 死亡时，我们会收到 binderdied 方法的回调，在 binderdied 方法中我们可以重新绑定远程服务
2、在onservicedisconnected 中重连远程服务
这两种方法的区别在于：onservicedisconnected 在客户端的 ui 线程中被回调，而 binderdied 在客户端的binder 线程池中被回调，即在binderdied 方法中我们不能访问 ui
如何在 aidl 中使用权限验证功能？
在onbind 中进行验证，验证不通过直接返回null ，这样验证失败的客户端直接无法绑定服务，至于验证方式有很多种，比如使用permission 验证，使用这种验证方式，我们需要先在 androidmenifest 中声明所需的权限，比如：
定义权限后，在iremoteservice的onbinder中做权限验证
@nullable
@override
public ibinder onbind(intent intent) {
int check = checkcallingorselfpermission("com.wuc.aidlservice.permission.access_service");
if (check == packagemanager.permission_denied) {
return null;
}
return mibinder;
}
一个应用来绑定我们的服务时，会验证这个应用的权限，如果他没有使用这个权限，则onbind 方法就会直接返回 null，最终这个应用无法绑定到我们的服务，这样就达到了权限验证的效果，这种方法同样适用于 messenger中。
如果我们自己内部的应用想要绑定到我们的服务中，只需在它的 androidmenifest 文件中采用如下方式使用 permission 即可
上一篇： Android IPC机制之AIDL解析