Android基于Binder自行实现跨进程通信逻辑

   <p>大家都知道在Android系统中跨进程通信是件很重要的事，app跟系统重要的系统服务进行交互都要进行跨进程通信，例如开启一个新的Activity、获取定位信息等。跨进程间通信方式有着不同实现方式，Android采用的是Binder方式进行处理的，为什么会选择Binder以及Binder实现机制，网上已经有不少文章进行了深度分析，这里就不浪费笔墨了。除了与重要的系统服务需要进行跨进程通信。在我们的app里如果有remote service，app其他组件与这个service进行交互时，也是需要通过使用Binder进行消息通讯的。 一般情况我们用的是AIDL进行处理的。 不知道AIDL怎么使用的同学可以随手Google下，这里也不在赘述了（不过大家如果想了解这块内容也可以留言，有时间可以把AIDL相关的东西整理下给大家看一下）。现在换一种做法，直接使用Binder的接口来实现一下跨进程通讯。这里可能需要有一点的预备知识，就是了解一下这个Binder基本的接口是什么样的，简单来说是Client端调用一下transact函数，然后Service端会在onTransact函数中收到相关参数然后进行处理，处理完成之后将结果返回到Client端。</p>    <p>首先看下Service端代码：</p>    <pre>  <code class="language-java">public class BinderService extends Service {  @Nullable   @Override   public IBinder onBind(Intent intent) {  return new TestBinder();  }  //实际执行的业务逻辑   public String testStart(String tag, int data) {  Log.i("TestFlag", "--------Test testStart-------::" + tag + " " + data);  return "back from service is " + tag + ":" + data;  }  //Binder，大家可以对比思考想一下，使用AIDL时是怎样处理的   class TestBinder extends Binder {  /** * 接收客户端的请求，解析然后进行处理 */   protected boolean onTransact(int code, Parcel data, Parcel reply,int flags) throws RemoteException {  //根据不同code，进行不同方法处理，例如一个Service可能实现不同功能，每个功能可以对应一个code   switch (code)   {  //其中一个分支   case 1001: {  //按顺序读取，client发送过来的内容   String testStr = data.readString();  int testInt = data.readInt();  String result = testStart(testStr, testInt);  //将返回的结果发送回去  reply.writeNoException();  reply.writeString(result);  return true;  }  }  return super.onTransact(code, data, reply, flags);  }  }  }</code></pre>    <p>了解过Binder基本机制的同学都清楚，Binder会是一个client调用transact方法，服务端接收onTransact的过程，那看下客户端的代码：</p>    <pre>  <code class="language-java">private IBinder clientBinder;  //首先绑定Service，获取Service Binder的BinderProxy  Intent intent = new Intent(AActivity.this, BinderService.class);  bindService(intent, new ServiceConnection() {  @Override   public void onServiceConnected(ComponentName name, IBinder service) {  clientBinder = service;  }  @Override   public void onServiceDisconnected(ComponentName name) {  }  }, Context.BIND_AUTO_CREATE);</code></pre>    <p>现在我想调用BinderService的testStart功能，那客户端的实现如此：</p>    <pre>  <code class="language-java">Parcel data = Parcel.obtain();  //按约定顺序组织参数  data.writeString("testflag");  data.writeInt(10);  Parcel reply = Parcel.obtain();  try {  //testStart的code为1001，reply负责接收service返回的数据   clientBinder.transact(1001, data, reply, 0);  reply.readException();  Log.i("TestFlag", reply.readString());  }   catch (RemoteException e) {  e.printStackTrace();  }</code></pre>    <p>这就完成了客户端调用Service端的过程，大家有兴趣看下AIDL生成的类，其实帮大家做了一些事情，把接口映射成不同的code，不同的接口参数按照顺序进行组织，节省了大家的时间，并且减少了出错的可能性。</p>    <p>这是基本的跨进程调用过程，我们利用接口自行搞了一个简单的轮子处理了下相关功能。但是不知道大家有没有这样的需求或者疑问，上边的实现方式本质为客户端调用服务端，然后服务端接着返回结果到客户端的模式。但是我们可能有这样的需求，客户端调用服务端一个需求后，服务端可能要执行一个耗时操作，再结束之后再将结果推送回客户端的需求呢。当然实现这个一个方式，系统已经给我们提供了一个很好的实现，也就是Messenger，对于Messenger实现有疑问的同学搜索下吧。这里还是用自己使用Binder来造轮子，来理解系统的实现。</p>    <p>首先先想下客户端向服务端发送消息时，我们在绑定Service的时候，能拿到Service在客户端的BinderProxy，然后调用transact，即可以实现调用。而服务端向客户端发消息的难点就在于服务端如何难道客户端Binder的BinderProxy，所以问题的解决在于如何将Binder从客户端传递到服务端。不废话上代码：</p>    <p>首先看Service端代码，与上边类似，多加了一个方法：</p>    <pre>  <code class="language-java">package launchmode.test.com.testlaunchmode;  import android.app.Service;  import android.content.Intent;  import android.os.Binder;  import android.os.IBinder;  import android.os.IInterface;  import android.os.Parcel;  import android.os.RemoteException;  import android.support.annotation.Nullable;  import android.util.Log;  public class BinderService extends Service {  @Nullable   @Override public IBinder onBind(Intent intent) {  return new TestBinder();}  //实际执行的业务逻辑   public String testStart(String tag, int data) {  Log.i("TestFlag", "--------Test testStart-------::" + tag + " " + data);  return "back from service is " + tag + ":" + data;  }  public void runTask(final IBinder binder){  new Thread(){  public void run(){  //模拟耗时操作   try {Thread.sleep(1000);}   catch (InterruptedException e)   {e.printStackTrace();}  Parcel data = Parcel.obtain();  Parcel reply = Parcel.obtain();  try {  binder.transact(1001,data,reply,0);  }   catch (RemoteException e) {  e.printStackTrace();  }  }  }.start();  }  //Binder   class TestBinder extends Binder {  /** * 接收客户端的请求，解析然后进行处理 */   protected boolean onTransact(int code, Parcel data, Parcel reply,int flags) throws RemoteException {  //根据不同code，进行不同方法处理，例如一个Service可能实现不同功能，每个功能可以对应一个code   switch (code) {  //其中一个分支   case 1001: {  //按顺序读取，client发送过来的内容   String testStr = data.readString();  int testInt = data.readInt();  String result = testStart(testStr, testInt);  //将返回的结果发送回去   reply.writeNoException();  reply.writeString(result);  return true;  }  case 1002:  //获取客户端的Binder   IBinder binder=data.readStrongBinder();  runTask(binder);  int result=1;  //将返回的结果发送回去   reply.writeNoException();  reply.writeInt(result);  return true;  }  return super.onTransact(code, data, reply, flags);  }  }  }</code></pre>    <p>客户端代码：</p>    <p>1:客户端Binder</p>    <pre>  <code class="language-java">//Binder  static class ClientBinder extends Binder {  /** * 接收客户端的请求，解析然后进行处理 */   protected boolean onTransact(int code, Parcel data, Parcel reply,int flags) throws RemoteException {  switch (code) {  case 1001: {  Log.i("TestFlag","-------Client Client------------");  return true;  }  }  return super.onTransact(code, data, reply, flags);  }  }</code></pre>    <p>2:客户端调用地方</p>    <pre>  <code class="language-java">Parcel data = Parcel.obtain();  data.writeStrongBinder(new ClientBinder());  Parcel reply = Parcel.obtain();  try {   clientBinder.transact(1002, data, reply, 0);  reply.readException();  Parcel data = Parcel.obtain();  data.writeStrongBinder(new ClientBinder());  Parcel reply = Parcel.obtain();  try {  //testStart的code为1001，reply负责接收service返回的数据   clientBinder.transact(1002, data, reply, 0);  reply.readException();  Log.i("TestFlag", "result is "+reply.readInt());  }   catch (RemoteException e) {  e.printStackTrace();  }  } catch (RemoteException e) {  e.printStackTrace();  }</code></pre>    <p>这就是基本的过程，在系统的源码中，涉及到与ActivityMangerService打交道的地方会有相似的逻辑。</p>    <p>来自：http://www.jianshu.com/p/09f2ecb8237a</p>    <p> </p>