AIDL跨进程Service推送消息到Activity

AIDL的概念不说了,一般都是Activity调用service的方法去获取一些东西,但是如何做到service主动回调activity的方法去推送一些东西的,这种需求一般也是会有的(比如后台有个定位,每次位置更新或者位置分生一定程度的变化的时候就要主动向Ui发送一个消息去通知ui发生变化,当然可以用广播,但是广播是很耗费资源的)
那么如何实现呢
1)先创建俩个aidl文件,

文件IMyAidlInterface 为一个回调注册,注销的接口,可能有很多个地方需要监听这个service变化,所以我们要把他存储起来

interface IMyAidlInterface {
    void registerListener(IListener listener);

    void unregisterListener(IListener listener);
}

IListener 文件是真真执行回调的接口,我们activity创建一个IListener 调用IMyAidlInterface 注册起来

interface IListener {
      void onReceiver(String msg);
}

2)创建我们自己的service,并实现一系列方法
模拟一个handler来更新数据,在onbind成功之后开始推送数据(一定要bing成功之后再操作),回调集合应为进程间是不同步的,所以我们用google官方推荐的一个RemoteCallbackList来操作,该集合内部已经处理了相关的操作,是线程同步的,具体用法就不写了.
在service中我们创建一个 IMyAidlInterface.Stub 的实例,onbind中返回.并实现这俩个方法.

public class MyService extends Service {
    private int count = 0;
    private RemoteCallbackList<IListener> demandList = new RemoteCallbackList<>();
    @SuppressLint("HandlerLeak")
    private Handler mHandler = new Handler() {
        @Override
        public void handleMessage(Message msg) {
            super.handleMessage(msg);

            if (demandList != null) {
                int nums = demandList.beginBroadcast();
                for (int i = 0; i < nums; i++) {
                    try {
                        count++;
                        demandList.getBroadcastItem(i).onReceiver(String.valueOf(count));
                    } catch (RemoteException e) {
                        e.printStackTrace();
                    }
                }
                demandList.finishBroadcast();
            }
            mHandler.sendEmptyMessageDelayed(1000, 100);//每3s推一次消息
        }
    };

    IMyAidlInterface.Stub stub = new IMyAidlInterface.Stub() {

        @Override
        public void registerListener(IListener listener) {
            demandList.register(listener);
        }

        @Override
        public void unregisterListener(IListener listener) {
            demandList.unregister(listener);
          }
    };

    public MyService() {

    }

    @Override
    public IBinder onBind(Intent intent) {
        // TODO: Return the communication channel to the service.
        mHandler.sendEmptyMessageDelayed(1000, 100);
        return stub;
    }


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

  
}

3)客户端注册
在客户端activity中我们启动这个服务(5.0系统已经禁止隐式的启动服务),然后我们调用iMyAidlInterface.registerListener方法去注册一个监听

  /**
     * 启动服务
     */
    private void starService() {
        Intent intent = new Intent(this, MyService.class);
        bindService(intent, new ServiceConnection() {
            @Override
            public void onServiceConnected(ComponentName name, IBinder service) {
                iMyAidlInterface = IMyAidlInterface.Stub.asInterface(service);
               // Log.e("registerListener", iMyAidlInterface.toString());
                try {
                    iMyAidlInterface.registerListener(stub);
                    Log.e("registerListener", "registerListener");
                } catch (RemoteException e) {
                    e.printStackTrace();
                }
            }

            @Override
            public void onServiceDisconnected(ComponentName name) {
                Log.e("ComponentName", name.getClassName());
            }
        }, BIND_AUTO_CREATE);
    }

监听器如下,onReceiver方法回调实际上并非在ui线程,他在binder的线程池中执行,所以我们写个handler来刷新ui

stub = new IListener.Stub() {
            @Override
            public void onReceiver(String msg) throws RemoteException {
                Message obtain = Message.obtain();
                obtain.obj=msg;
                handler.sendMessage(obtain);
            }
        };
--------------------------------------------------------------------------------
  private Handler handler=new Handler(){
        @Override
        public void handleMessage(Message msg) {
            super.handleMessage(msg);
            String obj = (String) msg.obj;
            if (info!=null){
                info.setText(obj);
            }
        }
    };

aidl.gif