IPC机制之Binder连接池

AIDL典型的使用流程

首先是创建一个Service和一个AIDL接口,接着创建一个类继承自AIDL接口中的Stub 并实现Stub中的抽象方法,在Service的onBind方法返回这个类的对象,然后客户端就可以绑定服务端的Service,建立连接之后可以访问远程服务端的方法.

Binder连接池

但是如果公司的项目越来越大,有很多个业务模块需要使用AIDL来进行进程间通信,如果按照之前的就需要创建多个service,但是service是系统四大组件之一,过多使用会造成性能资源消耗。 因此,这个时候有必要使用Binder连接池。
流程大致是:
每个业务模块创建自己的AIDL接口并实现此接口,这个时候不同业务模块之间不能有耦合的,所有实现细节我们要单独开来,然后向服务端提供一个属于自己的key和其对应的对象;那么服务端只需要一个Service然后提供一个查询的queryBinder接口,然后根据业务模块来返回对应的Binder。工作原理如图所示


Binder连接池的工作原理

具体可以通过代码来实现一下。

Example代码

新建AIDL ISecurityCenter

声明如下

// ISecurityCenter.aidl
package com.cayden.collect.study.binder;

// Declare any non-default types here with import statements

interface ISecurityCenter {
    String encrypt(String content);
    String decrypt(String password);
}

再新建一个提供计算的AIDL ICompute

// ICompute.aidl
package com.cayden.collect.study.binder;

// Declare any non-default types here with import statements

interface ICompute {
    int add(int a,int b);
}

然后需要build工程 再对上面2个AIDL接口做具体的实现操作

package com.cayden.collect.study.binder;

import android.os.RemoteException;

/**
 * Created by cuiran
 * Time  16/9/18 14:24
 * Email cuiran2001@163.com
 * Description
 */
public class SecurityCenterImpl extends ISecurityCenter.Stub {

    private static  final  char SECRET_CODE='^';

    @Override
    public String encrypt(String content) throws RemoteException {
        char[] chars=content.toCharArray();
        for(int i=0;i<chars.length;i++){
            chars[i]^=SECRET_CODE;
        }
        return new String(chars);
    }

    @Override
    public String decrypt(String password) throws RemoteException {
        return encrypt(password);
    }
}

package com.cayden.collect.study.binder;

import android.os.RemoteException;

/**
 * Created by cuiran
 * Time  16/9/18 14:28
 * Email cuiran2001@163.com
 * Description
 */
public class ComputeImpl extends ICompute.Stub {
    @Override
    public int add(int a, int b) throws RemoteException {
        return a+b;
    }
}

接着需要为连接池创建一个AIDL接口 IBinderPool

// IBinderPool.aidl
package com.cayden.collect.study.binder;

// Declare any non-default types here with import statements

interface IBinderPool {
    IBinder queryBinder(int binderCode);
}

然后创建连接池

package com.cayden.collect.study.binder;

import android.content.ComponentName;
import android.content.Context;
import android.content.Intent;
import android.content.ServiceConnection;
import android.os.IBinder;
import android.os.RemoteException;
import android.util.Log;

import java.util.concurrent.CountDownLatch;


/**
 * Created by cuiran
 * Time  16/9/18 14:36
 * Email cuiran2001@163.com
 * Description
 */
public class BinderPool {

    private static final String TAG="BinderPool";
    public static final int BINDER_NONE=-1;
    public static final int BINDER_COMPUTE=0;
    public static final int BINDER_SECRITY_CENTER=1;

    private Context mContext;

    private IBinderPool mBinderPool;
    private static volatile BinderPool sInstance;
    private CountDownLatch mCountDownLatch;

    private BinderPool(Context context){
        mContext=context.getApplicationContext();
        connectBinderPoolService();
    }

    public static BinderPool getInstance(Context context){
        if(sInstance==null){
            synchronized (BinderPool.class){
                if(sInstance==null){
                    sInstance=new BinderPool(context);
                }
            }
        }
        return sInstance;
    }

    private synchronized void connectBinderPoolService(){
        mCountDownLatch=new CountDownLatch(1);
        Intent service=new Intent(mContext,BinderPoolService.class);
        mContext.bindService(service,mBinderPoolConnection,Context.BIND_AUTO_CREATE);
        try{
            mCountDownLatch.await();
        }catch (InterruptedException e){
            e.printStackTrace();
        }
    }

    public IBinder queryBinder(int binderCode){
        IBinder binder=null;
        try{
            if(mBinderPool!=null){
                binder=mBinderPool.queryBinder(binderCode);
            }
        }catch (RemoteException e){
            e.printStackTrace();
        }
        return binder;
    }

    private ServiceConnection mBinderPoolConnection=new ServiceConnection() {
         @Override
         public void onServiceConnected(ComponentName componentName, IBinder iBinder) {
                  mBinderPool=IBinderPool.Stub.asInterface(iBinder);
             try{
                 mBinderPool.asBinder().linkToDeath(mBinderPoolDeathRecipient,0);
             }catch (RemoteException e){
                 e.printStackTrace();
             }
             mCountDownLatch.countDown();
         }

         @Override
         public void onServiceDisconnected(ComponentName componentName) {

         }
     };





    private IBinder.DeathRecipient mBinderPoolDeathRecipient=new IBinder.DeathRecipient() {
        @Override
        public void binderDied() {
            Log.d(TAG,"binder died");
            mBinderPool.asBinder().unlinkToDeath(mBinderPoolDeathRecipient,0);
            mBinderPool=null;
            connectBinderPoolService();

        }
    };

  public static class  BinderPoolImpl extends IBinderPool.Stub{
      public BinderPoolImpl(){
          super();
      }

      @Override
      public IBinder queryBinder(int binderCode) throws RemoteException {
          IBinder binder=null;
          switch (binderCode){
              case BINDER_SECRITY_CENTER:{
                  binder=new SecurityCenterImpl();
                  break;
              }
              case BINDER_COMPUTE:{
                  binder=new ComputeImpl();
                  break;
              }
              default:

                  break;
          }
          return binder;
      }
  }
}

接着需要实现远程service

package com.cayden.collect.study.binder;

import android.app.Service;
import android.content.Intent;
import android.os.Binder;
import android.os.IBinder;
import android.support.annotation.Nullable;

/**
 * Created by cuiran
 * Time  16/9/18 14:33
 * Email cuiran2001@163.com
 * Description
 */
public class BinderPoolService extends Service {

    private static final String TAG="BinderPoolService";

    private Binder mBinderPool=new BinderPool.BinderPoolImpl();


    @Override
    public void onCreate() {
        super.onCreate();
    }

    @Nullable
    @Override
    public IBinder onBind(Intent intent) {
        return mBinderPool;
    }

    @Override
    public void onDestroy() {
        super.onDestroy();
    }
}

最后执行 验证一下

需要在Activity的线程里面调用方法

 ISecurityCenter securityCenter;
    ICompute mCompute;
    private void doWork(){
        Log.d(TAG,"doWork.......");
        BinderPool binderPool=BinderPool.getInstance(getActivity());
        IBinder securityBinder=binderPool.queryBinder(BinderPool.BINDER_SECRITY_CENTER);
        securityCenter=(ISecurityCenter) SecurityCenterImpl.asInterface(securityBinder);

        Log.d(TAG,"访问ISecurityCenter");
        String msg="HelloWorld ,I'm cayden";
        Log.d(TAG,"content="+msg);
        try {
            String password=securityCenter.encrypt(msg);
            Log.d(TAG,"password="+password);
            Log.d(TAG,"decrypt="+securityCenter.decrypt(password));
        }catch (Exception e){
            e.printStackTrace();
        }


        Log.d(TAG,"访问ICompute");
        IBinder computeBinder=binderPool.queryBinder(BinderPool.BINDER_COMPUTE);
        mCompute=(ICompute) ComputeImpl.asInterface(computeBinder);
        try {
            Log.d(TAG,"3+5="+mCompute.add(3,5));
        }catch (Exception e){
            e.printStackTrace();
        }
    }

执行结果如下

09-19 11:46:56.080 7923-9643/com.cayden.collect D/MessengerFragment: doWork.......
09-19 11:46:56.132 7923-9643/com.cayden.collect D/MessengerFragment: 访问ISecurityCenter
09-19 11:46:56.132 7923-9643/com.cayden.collect D/MessengerFragment: content=HelloWorld ,I'm cayden
09-19 11:46:56.132 7923-9643/com.cayden.collect D/MessengerFragment: password=�;221 1,2:~r�y3~=?':;0
09-19 11:46:56.132 7923-9643/com.cayden.collect D/MessengerFragment: decrypt=HelloWorld ,I'm cayden
09-19 11:46:56.132 7923-9643/com.cayden.collect D/MessengerFragment: 访问ICompute
09-19 11:46:56.136 7923-9643/com.cayden.collect D/MessengerFragment: 3+5=8

这样Binder的连接池的demo版就结束了
源码地址:代码地址
最后需要注明内容参考自大神的书《Android开发艺术探索》,在这里做个笔记进行整理 也是对这部分有更好的掌握。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,937评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,503评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,712评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,668评论 1 276
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,677评论 5 366
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,601评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,975评论 3 396
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,637评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,881评论 1 298
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,621评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,710评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,387评论 4 319
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,971评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,947评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,189评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 44,805评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,449评论 2 342

推荐阅读更多精彩内容