Android多进程之Binder解绑监听的问题
Android多进程系列
接上一篇文章《Android多进程之手动编写Binder类》中向服务端注册监听事件的问题，在扩展了Binder类后，咱们还须要改造对应的服务端和客户端
客户端和服务端的改造
服务端改造
- 增长注册监听接口的功能
private CopyOnWriteArrayList<IOnNewBookArrivedListener> mListenerList = new CopyOnWriteArrayList<IOnNewBookArrivedListener>();
private Binder mBinder = new BookManagerImpl(){
@Override
public List<Book> getBookList() throws RemoteException {
Log.e(TAG, "getBookList-->"+ System.currentTimeMillis());
return mBookList;
}
@Override
public void addBook(Book book) throws RemoteException {
Log.e(TAG, "addBook-->");
mBookList.add(book);
}
@Override
public void registerListener(IOnNewBookArrivedListener listener) {
if (!mListenerList.contains(listener)) {
mListenerList.add(listener);
}else {
Log.e(TAG, "already exists");
}
Log.e(TAG, "registerListener, size:"+mListenerList.size());
}
@Override
public void unRegisterListener(IOnNewBookArrivedListener listener) {
if (mListenerList.contains(listener)) {
mListenerList.remove(listener);
Log.e(TAG, "unRegisterListener listener succeed");
}else {
Log.e(TAG, "not found, can not unregister");
}
Log.e(TAG, "unRegisterListener, current size:"+mListenerList.size());
}
};
复制代码
- 添加一个任务，定时像书籍列表中添加一本书，并触发通知客户端的操做
@Override
public void onCreate() {
super.onCreate();
Log.e(TAG, "onCreate-->"+ System.currentTimeMillis());
mBookList.add(new Book(1, "Android"));
mBookList.add(new Book(2, "IOS"));
new Thread(new ServiceWorker()).start();
}
private void onNewBookArrived(Book book) throws RemoteException{
mBookList.add(book);
Log.e(TAG, "new book arrived, notify listeners:" + mListenerList.size());
for (int i=0; i<mListenerList.size(); i++) {
IOnNewBookArrivedListener listener = mListenerList.get(i);
Log.e(TAG, "new book arrived, notify listener:" + listener);
listener.onNewBookArrived(book);
}
}
private class ServiceWorker implements Runnable {
@Override
public void run() {
while (!mIsServiceDestoryed.get()) {
try {
Thread.sleep(5000);
}catch (InterruptedException e) {
e.printStackTrace();
}
int bookId = mBookList.size() + 1;
Book newBook = new Book(bookId, "new book#" + bookId);
try {
onNewBookArrived(newBook);
}catch (RemoteException e) {
e.printStackTrace();
}
}
}
}
复制代码
- 通知客户端的过程就是调用每一个注册的监听接口的onNewBookArrived方法，也就是一个服务端调用客户端的过程，分别是调用onNewBookArrived-->onTransact-->Proxy的onNewBookArrived-->客户端
客户端改造
- 首先要声明一个IOnNewBookArrivedListener对象，并注册到服务端中
private IBookManager mRemoteBookManager;
private ServiceConnection mConnection = new ServiceConnection() {
@Override
public void onServiceConnected(ComponentName componentName, IBinder iBinder) {
Log.e(TAG, "ServiceConnection-->"+ System.currentTimeMillis());
IBookManager bookManager = BookManagerImpl.asInterface(iBinder);
mRemoteBookManager = bookManager;
try {
List<Book> list = bookManager.getBookList();
Log.e(TAG, "query book list, list type:" + list.getClass().getCanonicalName());
Log.e(TAG, "query book list:" + list.toString());
Book newBook = new Book(3, "Android 进阶");
bookManager.addBook(newBook);
Log.e(TAG, "add book:" + newBook);
List<Book> newList = bookManager.getBookList();
Log.e(TAG, "query book list:" + newList.toString());
bookManager.registerListener(mOnNewBookArrivedListener);
} catch (RemoteException e) {
e.printStackTrace();
}
}
@Override
public void onServiceDisconnected(ComponentName componentName) {
mRemoteBookManager = null;
Log.e(TAG, "binder died");
}
};
/**
* 这个方法运行在客户端的binder线程池中，不能直接进行UI操做
*/
private IOnNewBookArrivedListener mOnNewBookArrivedListener = new OnNewBookArrivedListenerImpl(){
@Override
public void onNewBookArrived(Book book) {
mHandler.obtainMessage(MESSAGE_NEW_BOOK_ARRIVED, book).sendToTarget();
}
};
复制代码
- 而后因为客户端的IOnNewBookArrivedListener回调方法onNewBookArrived运行在Binder线程池中，因此须要一个Handler来切换到UI线程
private static final int MESSAGE_NEW_BOOK_ARRIVED = 1;
private Handler mHandler = new Handler() {
@Override
public void handleMessage(Message message) {
switch (message.what) {
case MESSAGE_NEW_BOOK_ARRIVED:
Log.e(TAG, "receive new book:" + message.obj);
break;
default:
super.handleMessage(message);
}
}
};
复制代码
- 最后须要在客户端退出时解除服务端的注册监听
@Override
protected void onDestroy() {
if (mRemoteBookManager != null && mRemoteBookManager.asBinder().isBinderAlive()) {
try {
Log.e(TAG, "unRegister listener:" + mOnNewBookArrivedListener);
mRemoteBookManager.unRegisterListener(mOnNewBookArrivedListener);
}catch (RemoteException e) {
e.printStackTrace();
}
}
unbindService(mConnection);
super.onDestroy();
}
复制代码
改造结果
-
经过上图咱们能够看到，咱们已经成功实现了预期的功能，而且服务端通知客户端的调用过程也如咱们上面所说的那样bash
-
接下去咱们退出应用，这样能够测试解绑监听的功能 微信
-
从上图咱们能够看到，服务端调用解绑失败了，提示找不到接口，这是咋回事呢？cookie
利用Binder进行进程间通讯，Binder会把客户端传递的参数AIDL接口和Parcelable对象，从新转化并生成一个新的对象。由于对象是不能跨进程传输的，对象的跨进程传输本质上就是序列化和反序列化的过程。因此上述状况服务端根本就没有客户端的那个对象，那确定找不到会解绑失败。那咋办呢？
RemoteCallBackList
RemoteCallBackList是啥
public class RemoteCallbackList<E extends IInterface> {
/*package*/ ArrayMap<IBinder, Callback> mCallbacks
= new ArrayMap<IBinder, Callback>();
...
}
复制代码
- RemoteCallBackList的内部有一个Map结构用来保存全部的AIDL回调，这个Map的key是IBinder类型，value是CallBack类型
public boolean register(E callback, Object cookie) {
synchronized (mCallbacks) {
if (mKilled) {
return false;
}
IBinder binder = callback.asBinder();
try {
Callback cb = new Callback(callback, cookie);
binder.linkToDeath(cb, 0);
mCallbacks.put(binder, cb);
return true;
} catch (RemoteException e) {
return false;
}
}
}
复制代码
- 每次有新的接口来，就调用register方法注册，添加到mCallbacks中
- 经过上面的源码咱们能够看到，因为客户端跨进程传输的对象的底层的Binder对象都是同一个，因此咱们能够经过这一点，当须要解除注册监听时，就能够经过遍历RemoteCallBackList找到与解绑客户端Binder对象相同的listener并删除便可
- 并且咱们能够看到RemoteCallBackList中实现了线程同步，咱们在利用它进行注册和解注册时不须要处理同步问题。
- 特别的是，客户端进程终止后，RemoteCallBackList可以自动解除客户端所注册的listener
用RemoteCallBackList实现实现解绑注册
private RemoteCallbackList<IOnNewBookArrivedListener> mListenerList = new RemoteCallbackList<IOnNewBookArrivedListener>();
private Binder mBinder = new BookManagerImpl(){
@Override
public List<Book> getBookList() throws RemoteException {
Log.e(TAG, "getBookList-->"+ System.currentTimeMillis());
return mBookList;
}
@Override
public void addBook(Book book) throws RemoteException {
Log.e(TAG, "addBook-->");
mBookList.add(book);
}
@Override
public void registerListener(IOnNewBookArrivedListener listener) {
//注册接口
mListenerList.register(listener);
}
@Override
public void unRegisterListener(IOnNewBookArrivedListener listener) {
//解注册接口
mListenerList.unregister(listener);
}
};
//通知客户端
private void onNewBookArrived(Book book) throws RemoteException{
mBookList.add(book);
final int N = mListenerList.beginBroadcast();
for (int i=0; i<N; i++) {
IOnNewBookArrivedListener listener = mListenerList.getBroadcastItem(i);
if (listener != null) {
try {
listener.onNewBookArrived(book);
}catch (RemoteException e) {
e.printStackTrace();
}
}
}
mListenerList.finishBroadcast();
}
复制代码
- 经过RemoteCallBackList的改造，咱们就能够成功解注册客户端的listener了
注意点
- RemoteCallBackList并非一个List，咱们没法像操做list同样操做它，好比调用size方法
- 遍历RemoteCallBackList必须按照上面代码中的方式进行，beginBroadcast方法和finishBroadcast方法必须配对使用
欢迎关注个人微信公众号，和我一块儿学习一块儿成长！
复制代码
相关文章
- 1. Android多进程之Binder解绑监听的问题
- 2. Android多进程之Binder的使用
- 3. Android 编程技巧之 ----- 解决短信监听 onChange 触发两次的问题
- 4. Android监听程序进入后台
- 5. Android多进程之手动编写Binder类
- 6. Android中短信监听的各类问题,实现监听短信的功能
- 7. android监听全局监听
- 8. Android 开发中踩过的坑之八:多进程问题
- 9. Oracle监听问题及解决方法
- 10. android 跨进程通信的代表Binder
- 更多相关文章...
- • Redis悲观锁解决高并发抢红包的问题 - 红包项目实战
- • Redis乐观锁解决高并发抢红包的问题 - 红包项目实战
- • PHP Ajax 跨域问题最佳解决方案
- • IntelliJ IDEA中SpringBoot properties文件不能自动提示问题解决
相关标签/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
欢迎关注本站公众号,获取更多信息
