android之binder关于RemoteCallbackList的使用

简述

在android关于binder的简朴通讯过程的根本上添加关于RemoteCallbackList的使用,client端对server端举行register与unregister的过程，然后server主动给client端回调处置惩罚。
aidl文件修改

1.在IOnTestDataListener.aidl文件中加入register与unregister的方法

1. package com.example.test;
2. import com.example.test.IOnTestDataCallback;
3. // Declare any non-default types here with import statements
5. interface IOnTestDataListener {
6.     void registerCallback(in IOnTestDataCallback callback);
7.     oneway void sendData(String str, in byte[] bytes,in IOnTestDataCallback callback);
8.     void unRegisterCallback(in IOnTestDataCallback callback);
9. }

复制代码

此中registerCallback与unRegisterCallback是新增的方法。
2.在IOnTestDataCallback.aidl中加入server主动触发远程回调的方法

1. // IOnTestDataCallback.aidl
2. package com.example.test;
3. import com.example.test.TestDataBean;
5. // Declare any non-default types here with import statements
7. interface IOnTestDataCallback {
8.     void onCallback(in TestDataBean dataBean);
9.     void onDealRegisterCbData(String name,int number);
10. }

复制代码

此中onDealRegisterCbData是新增的方法
服务端

重要实今世码如下所示

1. package com.tencent.wemeet.testwhitelist;
3. import android.app.Service;
4. import android.content.Intent;
5. import android.os.IBinder;
6. import android.os.RemoteCallbackList;
7. import android.os.RemoteException;
8. import android.util.Log;
10. import androidx.annotation.Nullable;
12. import com.example.test.IOnTestDataCallback;
13. import com.example.test.IOnTestDataListener;
14. import com.example.test.TestDataBean;
16. import java.util.Arrays;
18. public class TestBinderService extends Service {
20.     private static final String TAG = "TestBinderService";
21.     private final RemoteCallbackList<IOnTestDataCallback> remoteCallbackList = new RemoteCallbackList<>();
23.     @Nullable
24.     @Override
25.     public IBinder onBind(Intent intent) {
26.         return new IOnTestDataListener.Stub() {
27.             @Override
28.             public void registerCallback(IOnTestDataCallback callback) throws RemoteException {
29.                 boolean register = remoteCallbackList.register(callback);
30.                 Log.d(TAG, "register:" + register + ",remoteCallbackList :" + remoteCallbackList);
31.             }
33.             @Override
34.             public void sendData(String str, byte[] bytes, IOnTestDataCallback callback) throws RemoteException {
35.                 Log.d(TAG, "str = " + str + ",bytes = " + Arrays.toString(bytes));
36.                 TestDataBean bean = new TestDataBean();
37.                 bean.setName("zhangsan");
38.                 bean.setNumber(20);
39.                 try {
40.                     Thread.sleep(5000);
41.                     callback.onCallback(bean);
42.                     // callback register data
43.                     int num = remoteCallbackList.beginBroadcast();
44.                     for (int i = 0; i < num; i++) {
45.                         IOnTestDataCallback broadcastItem = remoteCallbackList.getBroadcastItem(i);
46.                         broadcastItem.onDealRegisterCbData("xiaoming", i);
47.                     }
48.                     remoteCallbackList.finishBroadcast();
49.                 } catch (InterruptedException e) {
50.                     throw new RuntimeException(e);
51.                 }
52.             }
54.             @Override
55.             public void unRegisterCallback(IOnTestDataCallback callback) throws RemoteException {
56.                 boolean unregister = remoteCallbackList.unregister(callback);
57.                 Log.d(TAG, "unregister:" + unregister + ",remoteCallbackList :" + remoteCallbackList);
58.             }
59.         };
60.     }
62.     @Override
63.     public void onCreate() {
64.         super.onCreate();
65.         Log.d(TAG, "onCreate");
66.     }
67. }

复制代码

从上代码可以看出多了registerCallback与unRegisterCallback的方法的实现，同时在sendData中模拟了server端给client端的回调实现方式。代码实现如截图中的赤色框所示，其目的是给每个register的client端转达数据。

客户端

重要实今世码如下所示

1. package com.example.test;
3. import android.content.ComponentName;
4. import android.content.Context;
5. import android.content.Intent;
6. import android.content.ServiceConnection;
7. import android.os.Bundle;
8. import android.os.IBinder;
9. import android.os.RemoteException;
10. import android.util.Log;
11. import android.view.View;
13. import androidx.annotation.Nullable;
14. import androidx.appcompat.app.AppCompatActivity;
16. public class TestBinderActivity extends AppCompatActivity {
18.     public static final String TAG = "TestBinderActivity";
19.     private boolean isBinder;
20.     private IOnTestDataListener binder;
22.     @Override
23.     protected void onCreate(@Nullable Bundle savedInstanceState) {
24.         super.onCreate(savedInstanceState);
25.         setContentView(R.layout.activity_binder_test);
26.         // 实现一个带有回调的aidl通信  其中有parcel参数的传递
28.         Intent intent = new Intent();
29.         intent.setAction("com.binder.test.service");
30.         intent.setPackage("com.tencent.wemeet.testwhitelist");
31.         isBinder = bindService(intent, connection, Context.BIND_AUTO_CREATE);
33.         IOnTestDataCallback callback1 = new IOnTestDataCallback.Stub() {
34.             @Override
35.             public void onCallback(TestDataBean dataBean) throws RemoteException {
37.             }
39.             @Override
40.             public void onDealRegisterCbData(String name, int number) throws RemoteException {
41.                 Log.d(TAG, "11111 name = " + name + ",number = " + number);
42.             }
43.         };
45.         IOnTestDataCallback callback2 = new IOnTestDataCallback.Stub() {
46.             @Override
47.             public void onCallback(TestDataBean dataBean) throws RemoteException {
49.             }
51.             @Override
52.             public void onDealRegisterCbData(String name, int number) throws RemoteException {
53.                 Log.d(TAG, "22222 name = " + name + ",number = " + number);
54.             }
55.         };
57.         findViewById(R.id.btn_register).setOnClickListener(new View.OnClickListener() {
58.             @Override
59.             public void onClick(View v) {
60.                 if (binder == null) {
61.                     return;
62.                 }
63.                 try {
64.                     binder.registerCallback(callback1);
65.                     binder.registerCallback(callback2);
66.                 } catch (RemoteException e) {
67.                     throw new RuntimeException(e);
68.                 }
69.             }
70.         });
72.         findViewById(R.id.btn_unregister).setOnClickListener(new View.OnClickListener() {
73.             @Override
74.             public void onClick(View v) {
75.                 try {
76.                     binder.unRegisterCallback(callback2);
77.                     binder.unRegisterCallback(callback1);
78.                 } catch (RemoteException e) {
79.                     throw new RuntimeException(e);
80.                 }
82.             }
83.         });
85.         findViewById(R.id.btn_test).setOnClickListener(new View.OnClickListener() {
86.             @Override
87.             public void onClick(View v) {
88.                 if (binder == null) {
89.                     Log.d(TAG, "binder is null");
90.                     return;
91.                 }
92.                 Log.d(TAG, "begin");
93.                 try {
94.                     binder.sendData("123", new byte[]{1, 2, 3}, new IOnTestDataCallback.Stub() {
95.                         @Override
96.                         public void onCallback(TestDataBean dataBean) throws RemoteException {
97.                             Log.d(TAG, "name = " + dataBean.getName() + ",number = " + dataBean.getNumber());
98.                         }
100.                         @Override
101.                         public void onDealRegisterCbData(String name, int number) throws RemoteException {
102.                             Log.d(TAG, "333333 name = " + name + ",number = " + number);
103.                         }
104.                     });
105.                 } catch (RemoteException e) {
106.                     Log.d(TAG, "sendData RemoteException");
107.                     throw new RuntimeException(e);
108.                 }
110.                 Log.d(TAG, "end");
111.             }
112.         });
114.     }
116.     @Override
117.     protected void onDestroy() {
118.         super.onDestroy();
119.         if (isBinder) {
120.             isBinder = false;
121.             unbindService(connection);
122.             connection = null;
123.             binder = null;
124.         }
125.     }
127.     private ServiceConnection connection = new ServiceConnection() {
128.         @Override
129.         public void onServiceConnected(ComponentName name, IBinder service) {
130.             Log.d(TAG, "onServiceConnected");
131.             binder = IOnTestDataListener.Stub.asInterface(service);
133.         }
135.         @Override
136.         public void onServiceDisconnected(ComponentName name) {
137.             Log.d(TAG, "onServiceDisconnected");
138.         }
139.     };
140. }

复制代码

重要调用流程

1.注册

此处我们注册两个IOnTestDataCallback对象，如上面的callback1、callback2所示，
注册是调用如下实现

1.    binder.registerCallback(callback1);
2.    binder.registerCallback(callback2);

复制代码

点击注册的按钮时，日志打印如下所示，日志泉源于服务端输出信息

1. 2024-09-04 14:02:44.192  4794-4815  TestBinderService       com.tencent.wemeet.testwhitelist     D  register:true,remoteCallbackList :android.os.RemoteCallbackList@825eba6
2. 2024-09-04 14:02:44.193  4794-4815  TestBinderService       com.tencent.wemeet.testwhitelist     D  register:true,remoteCallbackList :android.os.RemoteCallbackList@825eba6

复制代码

2.发送调用

当举行验证时是调用sendData方法，由于服务端针对此方法内部处置惩罚了RemoteCallbackList的远程回调的具体实现

1. binder.sendData()

复制代码

调用发送按钮时，client端的日志打印如下所示，从日志中可以看出客户端注册的回调中的callback1与callback2的onDealRegisterCbData方法被分别调用了。

1. 2024-09-04 14:05:32.087  2900-2900  TestBinderActivity      com.example.test                     D  begin
2. 2024-09-04 14:05:32.088  2900-2900  TestBinderActivity      com.example.test                     D  end
3. 2024-09-04 14:05:37.092  2900-2956  TestBinderActivity      com.example.test                     D  name = zhangsan,number = 20
4. 2024-09-04 14:05:37.096  2900-2956  TestBinderActivity      com.example.test                     D  11111 name = xiaoming,number = 0
5. 2024-09-04 14:05:37.101  2900-2956  TestBinderActivity      com.example.test                     D  22222 name = xiaoming,number = 1

复制代码

3.反注册

反注册时调用如下实现

1.    binder.unRegisterCallback(callback2);
2.    binder.unRegisterCallback(callback1);

复制代码

此时调用unRegister的按钮时，服务端的打印如下所示

1. 2024-09-04 14:10:26.456  4794-4815  TestBinderService       com.tencent.wemeet.testwhitelist     D  unregister:true,remoteCallbackList :android.os.RemoteCallbackList@825eba6
2. 2024-09-04 14:10:26.458  4794-4815  TestBinderService       com.tencent.wemeet.testwhitelist     D  unregister:true,remoteCallbackList :android.os.RemoteCallbackList@825eba6

复制代码