想当初在第一次拜读《Android艺术开发探索》时,深感真的是一本很“艺术”的书(由于当初菜的看不懂..),随着本身的成长和屡次阅读,从开始的彻底不懂到如今的有所理解、使用和总结,才体会到其中探索的奥妙,如今跟着安卓高级开发的学习路线,进一步学习、总结和梳理知识。java
多进程做为Android开发者迈向高级开发者的第一关,也使许多初级开发者望而却步,这也是每一个开发者必经阶段,正好笔者在公司的开发项目中也一直使用了多进程,以前只是在使用阶段、和平时零散的知识点,而对Binder的原理和理解并不深刻,本文结合最近所看的文章和实际使用,从开发者的角度总结多进程和Binder的使用,即为本身梳理知识也但愿帮助有须要的人。android
android:process=":consume"
android:process="com.alex.kotlin.myapplication.consume"
复制代码
关于进程间的通讯首先想到的是Binder机制,固然开发中若是使用多进程,那Binder自当是首当其冲要了解和学习的,下文也会重点介绍Binder,在此以前来看看咱们实际开发中使用的、或者能够跨进程通讯的机制git
public class Book implements Serializable {
private static final long serialVersionUID = 871136882801008L;
String name;
int age;
public Book(String name, int age) {
this.name = name;
this.age = age;
}
}
复制代码
在储存数据时只需将对象序列化在磁盘中,在须要使用的地方反序列化便可获取Java实例,使用过程以下:github
//序列化
val book = Book("Android",20)
val file = File(cacheDir,"f.txt")
val out = ObjectOutputStream(FileOutputStream(file))
out.writeObject(book)
out.close()
//反序列化
val file = File(cacheDir,"f.txt")
val input = ObjectInputStream(FileInputStream(file))
val book: Book = input.readObject() as Book
input.close()
复制代码
针对上面的serialVersionUID可能有的认为不设置也可使用,但若是不设置serialVersionUID值,Java对象一样能够序列化,可是当Java类改变时,这时若是去反序列化的化就会报错,由于serialVersionUID是辅助序列化和反序列化的,只有二者的serialVersionUID一致才可实现反序列化,因此你不指定serialVersionUID时,系统会默认使用当前类的Hash值,当java对象改变时其Hash值也改变了,因此反序列化时就找不到对应的Java类了。面试
对于Parcelable和Serializable的选择使用:Serializable是Java的序列化接口,使用时开销大,须要大量的IO操做,Parcelable是Android提供的序列化接口,适合Android效率更高,对于二者的选择,若是只是在内存上序列化使用Parcelable,若是须要在磁盘上序列化使用Serializable便可。bash
在网上看了需对关于Binder的文章,有的深刻Binder源码和底层去分析Binder的源码和实现,固然这里面的代码我是看不懂,本文主要从Android开发的角度,对Binder的通讯的模型和方式作一个介绍,多线程
当Binder收到A进程的请求后,Binder驱动并不会真的把 object 返回给 A,而是返回了一个跟 object 看起来如出一辙的代理对象 objectProxy,这个 objectProxy 具备和 object 一摸同样的方法,可是这些方法并无 B 进程中 object 对象那些方法的能力,这些方法只须要把把请求参数交给驱动便可;app
而对于进程A却傻傻不知道它觉得拿到了B 进程中 object 对象,因此直接调用了Object的方法,当 Binder 驱动接收到 A 进程的消息后,发现这是个 objectProxy 就去查询本身维护的表单,一查发现这是 B 进程 object 的代理对象。因而就会去通知 B 进程调用 object 的方法,并要求 B 进程把返回结果发给本身。当驱动拿到 B 进程的返回结果后就会转发给 A 进程,一次通讯就完成了,因此中间的代理就只是一个面具和传输的媒介。框架
public Messenger(Handler target) {
mTarget = target.getIMessenger();
}
public Messenger(IBinder target) {
mTarget = IMessenger.Stub.asInterface(target);
}
复制代码
实现一个Messenger分为两步,即服务端和客户端的实现ide
//建立Handler
class HandlerService : Handler() {
override fun handleMessage(msg: Message?) {
when (msg?.what) {
MSG_WHAT -> {
Log.e("MyService", "MyServer")
}
else -> super.handleMessage(msg)
}
}
}
//使用Handler实例建立Messenger实例
private val messenger = Messenger(HandlerService())
//服务经过 onBind() 使其返回客户端
override fun onBind(intent: Intent): IBinder {
return messenger.binder
}
复制代码
private var messenger: Messenger? = null
private val serviceConnection = object : ServiceConnection {
override fun onServiceConnected(p0: ComponentName?, iBinder: IBinder?) {
messenger = Messenger(iBinder) // 绑定service后初始化 Messenger
}
override fun onServiceDisconnected(p0: ComponentName?) {
messenger = null
}
}
var message = Message.obtain(null, MSG_WHAT, 100,0) // 建立Message
messenger?.send(message) // 发送Message
//输出结果
07-24 14:00:38.604 18962-18962/com.example.administrator.memory E/MyService:MyServer 100
复制代码
若服务端想回应客户端,那客户端就要像服务端同样建立一个接受信息的Handler和Messenger实例,在发送Message时使用msg.replyTo将Messenger实例发送给服务端,服务端就可使用此实例回应客户端信息;
//客户端发送Messenger到Service
msg.replyTo = mGetReplyMessenger;
// 在Service端接收客户端的Messenger
Messenger msg = msg.replyTo;
复制代码
AIDL 对于进程通讯来讲,可能实际在项目中使用的可能更多的仍是AIDL,因此做为本文的最后也是重点讲解,并结合实际的代码分析多进程的使用,Aidl支持的数据类型:
AIDL的使用分为三步:AIDL接口建立、服务端、客户端实现,下面实际代码分析,咱们作一个简单的Demo,在主进程中输入帐户密码,而后在服务进程中验证登录,并将结果返回调用进程;
import com.alex.kotlin.myapplication.User;
interface ILoginBinder {
void login(String name ,String pasd);
boolean isLogin();
User getUser();
}
复制代码
上面的Aidl文件中使用了User类,因此在Java代码中建立User类,但初次以外也要建立User.aidl文件且包名要和Java中的同样,并在ILoginBinder中导入User文件的包;
package com.alex.kotlin.myapplication;
parcelable User ;
复制代码
此时点击MakePeoject系统会自动编译出AIDL文件对应的java代码 ILoginBinder类,能够在build包相应的路径下能够查看此类,代码结构以下:
public interface ILoginBinder extends android.os.IInterface{
.....
public static abstract class Stub extends android.os.Binder implements com.alex.kotlin.myapplication.binder.ILoginBinder{
......
private static class Proxy implements com.alex.kotlin.myapplication.binder.ILoginBinder{
.....
}
......
}
复制代码
class LoginBinder : ILoginBinder.Stub() {
override fun login(name: String?, pasd: String?) {
Log.e("======","name = $name ; pasd = $pasd")
user = User(name)
}
override fun isLogin(): Boolean {
return user != null
}
override fun getUser(): User? {
return user
}
}
复制代码
class BinderMangerService : Service() {
val binder = LoginBinder()
override fun onBind(intent: Intent) : IBinder?{
return binder
}
}
复制代码
设置Service的进程
<service
android:name=".binder.BinderMangerService"
android:process=":service">
</service>
复制代码
runOnThread {
val intent = Intent(contextWrapper, BinderMangerService::class.java)
contextWrapper.bindService(intent, serviceConnect,Context.BIND_AUTO_CREATE)
binderSuccessCallback?.success()
}
......
override fun onServiceConnected(name: ComponentName?, service: IBinder?) {
iBinderManger = IBinderManger.Stub.asInterface(service)
}
复制代码
此时获取到IBinderManger的代理类后便可调用方法,下面咱们调用login()方法登录,查看输出信息:
2018-12-08 22:24:26.675 349-363/com.alex.kotlin.myapplication:service E/======: name = AAAAA ; pasd = 11111
复制代码
此时在service进程中收到了默认进成发送的登录信息,即两者之间的通讯完成,但服务的链接会在某个时机由于某种缘由时断开,为了获取断开的时间或保持链接的稳定性Android提供了Binder链接的死亡监听类IBinder.DeathRecipient,在绑定成功时给获取的Ibinder绑定IBinder.DeathRecipient实例,在链接断开时会收到死亡回调,咱们能够断开链接后继续重连,使用以下:
//建立IBinder.DeathRecipient实例
var deathRecipient : IBinder.DeathRecipient? = null
deathRecipient = IBinder.DeathRecipient {
//断开链接
iBinderManger?.asBinder()?.unlinkToDeath(deathRecipient,0)
iBinderManger = null
//从新链接
}
override fun onServiceConnected(name: ComponentName?, service: IBinder?) {
iBinderManger = IBinderManger.Stub.asInterface(service)
//设置死亡监听
service?.linkToDeath(deathRecipient,0)
countDownLatch.countDown()
}
复制代码
但此时的通讯是单向的,若是想在登录成功或失败的时候通知默认进程,即进程间的回调,觉得两者处于不一样进程间,因此普通的接口回调不能知足,此时的接口也必须是跨进程的AIDl接口,因此建立ILoginCallback文件:
interface ILoginCallback {
void loginSuccess();
void loginFailed();
}
复制代码
在ILoginBinder的文件中添加注册和解除监听的方法:
void registerListener(ILoginCallback iLoginCallback);
void unregisterListener(ILoginCallback iLoginCallback);
复制代码
在ILoginBinder的实现类中实现这两个方法,这里须要说明的是Android为多进程中的接口注册问题提供了专门的类:RemoteCallbackList,因此在Stub的实现类中建立RemoteCallbackList,并在两个方法中添加和删除ILoginCallback的实例
private val remoteCallbackList = RemoteCallbackList<ILoginCallback>()
override fun registerListener(iLoginCallback: ILoginCallback?) {
remoteCallbackList.register(iLoginCallback)
}
override fun unregisterListener(iLoginCallback: ILoginCallback?) {
remoteCallbackList.unregister(iLoginCallback)
}
复制代码
对于RemoteCallbackList的遍历也有所不一样,必须beginBroadcast()和finishBroadcast()的成对使用,下面在登录成功或失败后回调接口:
f (name != null && pasd != null){
user = User(name)
val number = remoteCallbackList.beginBroadcast()
for (i in 0 until number){
remoteCallbackList.getBroadcastItem(i).loginSuccess()
}
remoteCallbackList.finishBroadcast()
}else{
val number = remoteCallbackList.beginBroadcast()
for (i in 0 until number){
remoteCallbackList.getBroadcastItem(i).loginFailed()
}
remoteCallbackList.finishBroadcast()
}
复制代码
在LoginActivity中建立ILoginCallback.Stub的子类,并调用方法注册接口,
private val loginCallback = object : ILoginCallback.Stub(){
override fun loginSuccess() {
Log.e("======","登录成功")
}
override fun loginFailed() {
}
}
loginBinder?.registerListener(loginCallback)
复制代码
此时再次运行结果:
2018-12-08 22:46:48.366 792-810/com.alex.kotlin.myapplication:service E/======: name = AAAAA ; pasd = 11111
2018-12-08 22:46:48.367 747-747/com.alex.kotlin.myapplication:login E/======: 登录成功
复制代码
到这里进程间的相互通讯已经完成了,如今能够在两者之间实现数据或逻辑的相互调用,是否是很happy,可是你能够调用别人也能够调用,那怎么让只有本身才能调用呢?那就用到最后的一点就是Binder的权限验证
默认状况下远程服务任何人均可以链接,权限验证也就是阻拦那些不想让他链接的人,验证的地方有两处:
验证的方式也有两种:
下面分别使用二者进行服务端的验证,首先在清单文件中添加自定义权限,并默认声明此权限
<uses-permission android:name="com.alex.kotlin.myapplication.permissions.BINDER_SERVICE"/>
<permission android:name="com.alex.kotlin.myapplication.permissions.BINDER_SERVICE"
android:protectionLevel="normal"/>
复制代码
在onBind()中判断此权限,若是经过则返回Binder实例,不然返回null
override fun onBind(intent: Intent) : IBinder?{
val check = checkCallingOrSelfPermission("com.alex.kotlin.myapplication.permissions.BINDER_SERVICE")
if (check == PackageManager.PERMISSION_DENIED){
return null
}
return binder
}
复制代码
另外一中就是在服务端的onTransact()中验证权限和包名,只有两者都经过返回true,不然返回false
override fun onTransact(code: Int, data: Parcel, reply: Parcel?, flags: Int): Boolean {
val check = checkCallingOrSelfPermission("com.alex.kotlin.myapplication.permissions.BINDER_SERVICE")
if (check == PackageManager.PERMISSION_DENIED){
return false
}
val packages = packageManager.getPackagesForUid(Binder.getCallingUid())
if (packages != null && !packages.isEmpty()){
val packageName = packages[0]
if (!packageName.startsWith("com.alex")){
return false
}
}
return super.onTransact(code, data, reply, flags)
}
复制代码
到此本文的全部内容都介绍完毕了,从安卓开发和使用来讲已能知足工做中的需求,文末附上一个Aidl的Demo,以商店购买商品为例,使用Binder链接池实现登录、售货员、商店、和消费者四个进程的通讯;
<activity android:name=".ConsumeActivity"
android:process=":consume">
</activity>
<activity
android:name=".LoginActivity"
android:process=":login">
</activity>
<service
android:name=".binder.BinderMangerService"
android:process=":service">
</service>
<activity
android:name=".ProfuctActivity"
android:process=":product">
</activity>
复制代码