CmProcess 为Android跨进程调用与通信更简洁而生

Posted 2023-02-15 zhangke3016

年后第一发，带来一款更简洁方便的android进程通信方案。看了网上太多的Binder以及跨进程讲解，最后回到我们自己来进行跨进程通信时发现还是相当繁琐，定义aidl、定义Service、bindService等一系列操作搞得头都大了。CmProcess 可简单轻松解决进程间通信问题，几行代码搞定，任意进程随时注册服务，随时同步获取服务以及支持跨进程的事件总线。

介绍

CmProcess 更方便更简洁的Android进程通信方案，无需进行bindService()操作，不用定义Service，也不需要定义aidl。 支持IPC级的Callback，并且支持跨进程的事件总线。可同步获取服务。采用面向接口方式进行服务注册与调用，服务调用方和使用者完全解耦。

接入

1. 在全局build里添加仓库

    allprojects 
                repositories 
                    ......
                    maven  url 'https://jitpack.io' 
        
    

2. 在app的build里添加依赖

    dependencies 
        implementation 'com.github.zhangke3016:CmProcess:1.0.3'
    

使用

1. 在Application的attachBaseContext方法中初始化

  @Override
  protected void attachBaseContext(Context base) 
      super.attachBaseContext(base);
      VCore.init(base);
  

2. 定义对外提供服务功能的接口和实现

如果注册本地服务，参数以及回调接口没有限制；
如果注册远程服务，参数类型必须为基本数据类型或者可序列化类型(serializable/parcelable),并且异步回调接口需要使用提供的’IPCCallback`。

  public interface IPayManager 
     String pay(int count);
     //远程服务调用，异步回调接口需要使用提供的'IPCCallback`。
     String pay(int count, IPCCallback callBack);
  

3. 注册或者反注册服务，可在任意进程调用；注册的进程本地服务需要在本进程取消注册

  //注册本地 + 远程服务
  VCore.getCore().registerService(IPayManager.class, this);
  //取消注册本地 + 远程服务
  VCore.getCore().unregisterService(IPayManager.class);
  
  //注册本地服务
  VCore.getCore().registerLocalService(IPayManager.class, this);
  //取消注册本地服务
  VCore.getCore().unregisterLocalService(IPayManager.class);

4. 可在任意进程通过接口类型获取服务调用

  IPayManager service = VCore.getCore().getService(IPayManager.class);
  //获取本地服务
  //IPayManager service = VCore.getCore().getLocalService(IPayManager.class);
  //注意：如果服务未注册时，service为null
  if(service != null)
    //同步调用.
    String message = service.pay(5000);
    
    //异步回调. 推荐使用提供的 BaseCallback 已将回调结果切换至主线程
    service.pay(5000, new BaseCallback() 
         @Override
         public void onSucceed(Bundle result) 
             //Main thread 回调结果在主线程
         
    
         @Override
         public void onFailed(String reason) 
             //Main thread
         
     );
     //或者
     service.pay(5000, new IPCCallback.Stub() 
         @Override
         public void onSuccess(Bundle bundle) throws RemoteException 
             // binder thread
         
         
         @Override
         public void onFail(String s) throws RemoteException 
         
         
     )
  

5. 事件的发布与订阅

    //订阅事件   可在任意进程的多个位置订阅
    VCore.getCore().subscribe("key", new EventCallback() 
        @Override
        public void onEventCallBack(Bundle event) 
            //main thread
            String name = event.getString("name");
            Log.e("TAG", "onEventCallBack: " + name + " " + (Looper.myLooper() == Looper.getMainLooper()));
        
    );
    
    //发布事件  发布事件后 多个进程注册的EventCallback会同时回调:
    Bundle bundle = new Bundle();
    bundle.putString("name", "DoDo");
    VCore.getCore().post("key",bundle);
    
    //取消订阅 
    VCore.getCore().unsubscribe("key");