您好,登錄后才能下訂單哦!
這篇文章給大家分享的是有關(guān)如何實(shí)現(xiàn)CmProcess跨進(jìn)程通信的內(nèi)容。小編覺得挺實(shí)用的,因此分享給大家做個(gè)參考,一起跟隨小編過來看看吧。
Android多進(jìn)程概念:一般一個(gè) app 只有一個(gè)進(jìn)程,所有的 components 都運(yùn)行在同一個(gè)進(jìn)程中,進(jìn)程名稱就是 app 包名。但是每一個(gè)進(jìn)程都有內(nèi)存的限制,如果一個(gè)進(jìn)程的內(nèi)存超過了這個(gè)限制的時(shí)候就會(huì)報(bào) OOM 錯(cuò)誤。為了解決內(nèi)存限制的問題,Android 引入了多進(jìn)程的概念,將占用內(nèi)存的操作放在一個(gè)單獨(dú)的進(jìn)程中分擔(dān)主進(jìn)程的壓力。
多進(jìn)程的好處:
分擔(dān)主進(jìn)程的內(nèi)存壓力。
常駐后臺任務(wù)。
守護(hù)進(jìn)程,主進(jìn)程和守護(hù)進(jìn)程相互監(jiān)視,有一方被殺就重新啟動(dòng)它。
多么塊,對有風(fēng)險(xiǎn)的模塊放在單獨(dú)進(jìn)程,崩潰后不會(huì)影響主進(jìn)程的運(yùn)行。
多進(jìn)程的缺點(diǎn):
Applicaton的重新創(chuàng)建,每個(gè)進(jìn)程有自己獨(dú)立的virtual machine,每次創(chuàng)建新的進(jìn)程就像創(chuàng)建一個(gè)新的Application
靜態(tài)成員變量和單例模式失效,每個(gè)進(jìn)程有自己獨(dú)立的虛擬機(jī),不同虛擬機(jī)在內(nèi)存分配上有不同的地址空間,這就導(dǎo)致不同虛擬機(jī)在訪問同一個(gè)對象時(shí)會(huì)產(chǎn)生多分副本。
SharedPreference的可靠性下降,不支持多進(jìn)程
線程同步機(jī)制失效
bundle 定義 bundle 是一個(gè) final 類,final 類通常功能是完整的,它們不能被繼承。Java 中有許多類是 final 的,譬如 String, Interger 以及其他包裝類。
public final class Bundle extends BaseBundle implements Cloneable, Parcelable
bundle 傳遞的數(shù)據(jù)可以是 boolean、byte、int、long、float、double、string 等基本類型或它們對應(yīng)的數(shù)組,也可以是對象或?qū)ο髷?shù)組。但是如果傳遞對象或?qū)ο髷?shù)組,該對象必須實(shí)現(xiàn) Serializable 或 Parcelable 接口。由 Bundle 定義我們也可以看到其實(shí)現(xiàn)了 Parcelable 接口,所以支持實(shí)現(xiàn)了Parcelable 接口的對象。
因此當(dāng)我們在一個(gè)進(jìn)程中啟動(dòng)了另外一個(gè)進(jìn)程的 Activity、Service、Receiver,我們就可以在 Bundle 中附加我們需要傳輸給遠(yuǎn)程進(jìn)程的信息(前提是能夠被序列化)并通過 Intent 發(fā)送出去。
1、IEventReceiver:事件接收器
// 事件接受器 interface IEventReceiver { // 這里的 event 是 bundle 類型 void onEventReceive(String key,in Bundle event); }
2、IPCCallback:看名字也可以看出來是跨進(jìn)程 callback
interface IPCCallback { // result 也是 bundle void onSuccess(in Bundle result); void onFail(String reason); }
3、IServiceFetcher:獲取服務(wù)的??梢栽俅诉M(jìn)行注冊。
interface IServiceFetcher { // service 是 Ibinder 類型 android.os.IBinder getService(java.lang.String name); // 注冊服務(wù) void addService(java.lang.String name, android.os.IBinder service); // 添加回調(diào) void addEventListener(java.lang.String name, android.os.IBinder service); // 移除 service void removeService(java.lang.String name); // 移除回調(diào) void removeEventListener(java.lang.String name); // 發(fā)送消息 void post(String key,in Bundle result); }
根據(jù)代碼可知,咱們有三個(gè)進(jìn)程,分別是:
com.ipc.code:vc :TestActivity 運(yùn)行所在的進(jìn)程;這是屬于用戶測的。
com.ipc.code:vm : 也就是BinderProvider 存在的進(jìn)程;IPCBus 也在該進(jìn)程,主要是用于保存和傳遞數(shù)據(jù)
com.ipc.code :MainActivity 主進(jìn)程;
也就是每個(gè)進(jìn)程在初始化的時(shí)候,都會(huì)走一遍Application 的初始化,因此如果需要對進(jìn)程做啥操作,可以判斷出具體的進(jìn)程,然后做一些額外的操作。對于 CmProcess ,所有進(jìn)程的初始化邏輯都是一樣的。
public class App extends Application { private static final String TAG = "App"; @Override protected void attachBaseContext(Context base) { super.attachBaseContext(base); // 先啟動(dòng)主進(jìn)程,之后才啟動(dòng)其他進(jìn)程 VCore.init(base); } }
啟動(dòng)過程中,會(huì)主動(dòng)為每個(gè)進(jìn)程注冊回調(diào),注意是每個(gè)進(jìn)程。
該 init 方法最終會(huì)走入到下面的方法中:
public void startup(Context context) { if (!isStartUp) { // 在主線程啟動(dòng),每個(gè)進(jìn)程都有一個(gè)自己的主線程 if (Looper.myLooper() != Looper.getMainLooper()) { throw new IllegalStateException("VirtualCore.startup() must called in main thread."); } ServiceManagerNative.SERVICE_CP_AUTH = context.getPackageName() + "." + ServiceManagerNative.SERVICE_DEF_AUTH; this.context = context; // 傳入了一個(gè) cache 實(shí)例,這個(gè)實(shí)例是只有主線程有的 IPCBus.initialize(new IServerCache() { @Override public void join(String serverName, IBinder binder) { ServiceManagerNative.addService(serverName, binder); } @Override public void joinLocal(String serverName, Object object) { ServiceCache.addLocalService(serverName,object); } @Override public void removeService(String serverName) { ServiceManagerNative.removeService(serverName); } @Override public void removeLocalService(String serverName) { ServiceCache.removeLocalService(serverName); } @Override public IBinder query(String serverName) { return ServiceManagerNative.getService(serverName); } @Override public Object queryLocal(String serverName) { return ServiceCache.getLocalService(serverName); } @Override public void post(String key,Bundle bundle) { ServiceManagerNative.post(key,bundle); } }); // 這里是根據(jù)進(jìn)程名字添加注冊的事件接收器 ServiceManagerNative.addEventListener(AppUtil.getProcessName(context, Process.myPid()), EventReceiver.getInstance()); isStartUp = true; } }
這里整個(gè)邏輯很簡單,就是在主線程初始化了IPCBus,然后給該進(jìn)程注冊了一個(gè)事件分發(fā)的監(jiān)聽。
public class EventReceiver extends IEventReceiver.Stub { private static final String TAG = "EventReceiver"; private static final EventReceiver EVENT_RECEIVER = new EventReceiver(); private EventReceiver(){} public static final EventReceiver getInstance(){ return EVENT_RECEIVER; } @Override public void onEventReceive(String key,Bundle event) { EventCenter.onEventReceive(key,event); } }
整個(gè)類的代碼很簡單。但是要注意的是,其繼承了IEventReceiver.Stub,說明他具有跨進(jìn)程傳輸?shù)哪芰?。主要就是通過EventCenter 來分發(fā)消息。
由于每個(gè)進(jìn)程都會(huì)走一遍初始化邏輯,所以每個(gè)進(jìn)程都注冊了事件的接收。
從名字也可以看出來,這個(gè)跟我們平時(shí)看到的ServiceManager 很像。主要就是用來獲取 service 和注冊 listener 的。
public static void addEventListener(String name, IBinder service) { IServiceFetcher fetcher = getServiceFetcher(); if (fetcher != null) { try { fetcher.addEventListener(name, service); } catch (RemoteException e) { e.printStackTrace(); } } }
首先是調(diào)用getServiceFetcher 來獲取最終保存服務(wù)的 fetcher。
注冊回調(diào)的時(shí)候,會(huì)先獲取是否存在 (binder)ServiceFetcher ,在將其轉(zhuǎn)化為本地 binder;這樣 ServiceFetcher 的管理器就可以用了。
private static IServiceFetcher getServiceFetcher() { if (sFetcher == null || !sFetcher.asBinder().isBinderAlive()) { synchronized (ServiceManagerNative.class) { Context context = VirtualCore.get().getContext(); Bundle response = new ProviderCall.Builder(context, SERVICE_CP_AUTH).methodName("@").call(); if (response != null) { IBinder binder = BundleCompat.getBinder(response, "_VM_|_binder_"); linkBinderDied(binder); sFetcher = IServiceFetcher.Stub.asInterface(binder); } } } return sFetcher; }
首先是看ProviderCall.Builder(context, SERVICE_CP_AUTH).methodName("@").call(),他最終會(huì)調(diào)用下面的方法:
//ContentProviderCompat public static Bundle call(Context context, Uri uri, String method, String arg, Bundle extras) { // 這里還區(qū)分了版本 if (Build.VERSION.SDK_INT < Build.VERSION_CODES.JELLY_BEAN_MR1) { return context.getContentResolver().call(uri, method, arg, extras); } ContentProviderClient client = crazyAcquireContentProvider(context, uri); // 這里會(huì)不斷重試最終會(huì)獲得對 BinderProvider 的引用 Bundle res = null; try { // 通過約定好的方法名字獲得bindle res = client.call(method, arg, extras); } catch (RemoteException e) { e.printStackTrace(); } finally { releaseQuietly(client); } return res; }
下面看下 BinderProvider 的 call 方法。
新建了一個(gè) bundle 對象,然后將 binder 保存在里面。注意這是通過跨進(jìn)程調(diào)用,最終將 bundle 傳回主進(jìn)程,然后拿到了ServiceFetcher 的 binder,并將其轉(zhuǎn)為本地 binder。
可以發(fā)現(xiàn)這里對于方法名是 "@" 時(shí),就會(huì)返回 bundle ,否則就是返回 null 。
public Bundle call(String method, String arg, Bundle extras) { if ("@".equals(method)) { Bundle bundle = new Bundle(); BundleCompat.putBinder(bundle, "_VM_|_binder_", mServiceFetcher); return bundle; } return null; }
簡單來說,就是大家都通過 binderProvider 這個(gè)進(jìn)程來保存對于回調(diào)的注冊,保存是基于進(jìn)城名字來的,因此可以保證不會(huì)被覆蓋。
此處的mServiceFetcher 是BinderProvider 內(nèi)部內(nèi)的實(shí)例,但是其繼承了IServiceFetcher.Stub,因此也就有了跨進(jìn)程的能力。
到這里,理一下前面的邏輯:
ServiceManagerNative.addEventListener(AppUtil.getProcessName(context, Process.myPid()), EventReceiver.getInstance());
某個(gè)進(jìn)程的主線程調(diào)用這個(gè)方法,所做的具體事情如下:
1.通過 binder 拿到了binderProvider 中的 IServiceFetcher.Stub 的實(shí)例;
2.向IServiceFetcher.Stub 注冊回調(diào),該回調(diào)最終會(huì)被保存binderProvider 進(jìn)程里面。
上面介紹了其是怎么將 listener 注冊到 binderProvider 進(jìn)程的,但是并沒有講到接下去我們看下 BinderProvider 的啟動(dòng)過程,
下圖是ContentProvider 的啟動(dòng)流程。當(dāng)我們在主進(jìn)程想獲取 server 的時(shí)候,這時(shí)候,會(huì)看看 provider 存不存在,沒有的就會(huì)進(jìn)行啟動(dòng),同時(shí)會(huì)走 Application 的初始化邏輯,
具體我們可以看下面這個(gè)啟動(dòng)流程圖:
Application 的 attachBaseContext 方法是優(yōu)先執(zhí)行的;
ContentProvider 的 onCreate的方法 比 Application的onCreate的方法先執(zhí)行;
Activity、Service 的 onCreate 方法以及 BroadcastReceiver 的 onReceive 方法,是在 MainApplication 的 onCreate 方法之后執(zhí)行的;
調(diào)用流程為: Application 的 attachBaseContext ---> ContentProvider 的 onCreate ----> Application 的 onCreate ---> Activity、Service 等的 onCreate(Activity 和 Service 不分先后);
這里主要是梳理了下 provider 的啟動(dòng)過程,并沒有很細(xì)講,但是有必要了解一下。
接下去,開始看MainActivity 里面的代碼。
調(diào)用registerService 注冊服務(wù),傳入IPayManager.class 和MainActivity;記得MainActivity 也實(shí)現(xiàn)了IPayManager 接口。
VCore.getCore().registerService(IPayManager.class, this);
看下,里面的具體代碼邏輯
// Vcore public VCore registerService(Class<?> interfaceClass, Object server){ if (VirtualCore.get().getContext() == null){ return this; } Object o = IPCBus.getLocalService(interfaceClass); // 如果是第一次調(diào)用就會(huì)返回空 IBinder service = ServiceManagerNative.getService(interfaceClass.getName()); if (service != null && o != null){ return this; } IPCBus.registerLocal(interfaceClass,server); // 這里的注冊就是把 server 保存到 binder 中 IPCBus.register(interfaceClass,server); return this; }
這里使用了一個(gè)registerLocal和register 方法,但是本質(zhì)上兩個(gè)方法是有區(qū)別的。registerLocal 意思很明確,就是本地ServiceCache保存一份。但是register,確實(shí)做了一些額外的操作。
public static void register(Class<?> interfaceClass, Object server) { checkInitialized(); // 這里主要是獲取一個(gè) binder,或者換句話來說,采用 binder 來保存相關(guān)數(shù)據(jù) ServerInterface serverInterface = new ServerInterface(interfaceClass); // 這里就是把 binder 保存到 binderProvider TransformBinder binder = new TransformBinder(serverInterface, server); sCache.join(serverInterface.getInterfaceName(), binder); }
首先這里創(chuàng)建了一個(gè)ServerInterface 實(shí)例,該實(shí)例內(nèi)部保存了傳過了來的接口和接口的方法,并將方法和 code 聯(lián)系在一起。
public ServerInterface(Class<?> interfaceClass) { this.interfaceClass = interfaceClass; Method[] methods = interfaceClass.getMethods(); codeToInterfaceMethod = new SparseArray<>(methods.length); methodToIPCMethodMap = new HashMap<>(methods.length); for (int i = 0; i < methods.length; i++) {// 這里每一個(gè)方法都有一個(gè) code int code = Binder.FIRST_CALL_TRANSACTION + i;// 組成一個(gè) ipcMenhod IPCMethod ipcMethod = new IPCMethod(code, methods[i], interfaceClass.getName()); codeToInterfaceMethod.put(code, ipcMethod);// 保存他們的映射關(guān)系 methodToIPCMethodMap.put(methods[i], ipcMethod); } }
同時(shí)利用TransformBinder 將接口和 實(shí)例保存到 binder 中。再將 binder 和 接口名字 保存到ServiceCache 中。
注冊完以后,下面是調(diào)用獲取本地服務(wù):
// 其實(shí) service 本質(zhì)還是這個(gè) MainActivity IPayManager service = VCore.getCore().getLocalService(IPayManager.class);
最后注冊了一個(gè)回調(diào):
VCore.getCore().subscribe("key", new EventCallback() { @Override public void onEventCallBack(Bundle event) { } });
最終EventCenter 會(huì)保存相關(guān)信息;
最后啟動(dòng) TestActivity ,這個(gè)是在另一個(gè)進(jìn)程。在 onCreate 里面調(diào)用下面的方法:
IPayManager service = VCore.getCore().getService(IPayManager.class);
進(jìn)程剛剛創(chuàng)建,我們看看是怎么獲取服務(wù)的:
// Vcore public <T> T getService(Class<T> ipcClass){ T localService = IPCBus.getLocalService(ipcClass); if (localService != null){ return localService; } return VManager.get().getService(ipcClass); }
這里很明確,本地肯定是沒有的,因此,最后會(huì)從 VManager 中獲?。?/p>
// VManager public <T> T getService(Class<T> ipcClass) { T t = IPCBus.get(ipcClass); if (t != null){ return t; } IPCSingleton<T> tipcSingleton = mIPCSingletonArrayMap.get(ipcClass); if (tipcSingleton == null){ tipcSingleton = new IPCSingleton<>(ipcClass); mIPCSingletonArrayMap.put(ipcClass,tipcSingleton); } return tipcSingleton.get(); }
接下去我們看下IPCSingleton 相關(guān)邏輯
// IPCSingleton public T get() { if (instance == null) { synchronized (this) { if (instance == null) { instance = IPCBus.get(ipcClass); } } } return instance; }
這是一個(gè)單例,目的也很明確,就是只獲取一次,可以看到后面又調(diào)到了 IPCBus 里面。
// IPCBus public static <T> T get(Class<?> interfaceClass) { checkInitialized(); ServerInterface serverInterface = new ServerInterface(interfaceClass); // 這里獲取的 binder 應(yīng)該是 TransformBinder IBinder binder = sCache.query(serverInterface.getInterfaceName()); if (binder == null) { return null; } // 這里使用了動(dòng)態(tài)代理 return (T) Proxy.newProxyInstance(interfaceClass.getClassLoader(), new Class[]{interfaceClass}, new IPCInvocationBridge(serverInterface, binder)); }
這里采用了動(dòng)態(tài)代理創(chuàng)造了一個(gè)實(shí)例,最終返回的實(shí)例被保存在一個(gè)單例中。
可以看到,這里回去查找存不存在 binder。
// VirtualCore public IBinder query(String serverName) { return ServiceManagerNative.getService(serverName); }
還是通過ServiceManagerNative 來獲取的 service;這里又回到我們之前分析過的邏輯。先從 binderProvider 獲取fetcher, 也就是 ServiceFetcher。
IServiceFetcher fetcher = getServiceFetcher();
它也會(huì)從ServiceFetcher 中獲取到 binder ,而這個(gè) binder 就是之前我們保存的TransformBinder 。拿到這個(gè)之后,還是一樣,將其轉(zhuǎn)化為該進(jìn)程的本地 binder .
// BinderProvider private class ServiceFetcher extends IServiceFetcher.Stub {
最后,我們通過動(dòng)態(tài)代理的形式,創(chuàng)建了一個(gè) IPayManager 的實(shí)例。
return (T) Proxy.newProxyInstance(interfaceClass.getClassLoader(), new Class[]{interfaceClass}, new IPCInvocationBridge(serverInterface, binder));
這里需要注意的是IPCInvocationBridge 繼承自InvocationHandler。
拿到后,開始調(diào)用對應(yīng)的方法:
if (service != null){ Log.d(TAG, "onCreate: shentest before vcore " + AppUtil.getAppName(this)); // 首先這個(gè) service 是跨進(jìn)程調(diào)用的,怎么才通知到其他組件?這里大家可以思考下 service.pay(5000, new BaseCallback() { @Override public void onSucceed(Bundle result) { textview.setText(result.getString("pay")); Bundle bundle = new Bundle(); bundle.putString("name", "DoDo"); VCore.getCore().post("key",bundle); } @Override public void onFailed(String reason) { } }); }
調(diào)用 service.pay 的時(shí)候,就會(huì)調(diào)用動(dòng)態(tài)代理中的 invoke 方法:
public Object invoke(Object o, Method method, Object[] args) throws Throwable { IPCMethod ipcMethod = serverInterface.getIPCMethod(method); if (ipcMethod == null) { throw new IllegalStateException("Can not found the ipc method : " + method.getDeclaringClass().getName() + "@" + method.getName()); } // 這里很關(guān)鍵 return ipcMethod.callRemote(binder, args); }
首先根據(jù)方法名獲得ipcMethod,里面保存了方法的 code,接口名字,參數(shù),返回值。接著調(diào)用了 ipcMethod.callRemote, 該方法又會(huì)調(diào)用:
// IPCMethod // 這個(gè)方法很重要,需要理解其實(shí)現(xiàn)過程 public Object callRemote(IBinder server, Object[] args) throws RemoteException { Parcel data = Parcel.obtain(); // 獲取一個(gè)新的 parcel 對象 Parcel reply = Parcel.obtain(); Object result; try { data.writeInterfaceToken(interfaceName); data.writeArray(args); // 這里 server 就是 transformBinder server.transact(code, data, reply, 0); reply.readException(); result = readValue(reply); if (resultConverter != null) { result = resultConverter.convert(result); } } finally { data.recycle(); reply.recycle(); } return result; }
code 變量用于標(biāo)識客戶端期望調(diào)用服務(wù)端的哪個(gè)函數(shù),因此,雙方需要約定一組 int 值,不同的值代表不同的服務(wù)端函數(shù),該值和客戶端的 transact() 函數(shù)中第一個(gè)參數(shù) code 的值是一致的。
enforceInterface() 是為了某種校驗(yàn),它與客戶端的 writeInterfaceToken() 對應(yīng),具體見下一小節(jié)。
readString() 用于從包裹中取出一個(gè)字符串。如果該 IPC 調(diào)用的客戶端期望返回一些結(jié)果,則可以在返回包裹 reply 中調(diào)用 Parcel 提供的相關(guān)函數(shù)寫入相應(yīng)的結(jié)果。 Parcel.writeXXX();
現(xiàn)在要看的是怎么通過 binder 一步一步拿到參數(shù)。
使用 Parcel 一般是通過 Parcel.obtain() 從對象池中獲取一個(gè)新的 Parcel 對象,如果對象池中沒有則直接 new 的 Parcel 則直接創(chuàng)建新的一個(gè) Parcel 對象,并且會(huì)自動(dòng)創(chuàng)建一個(gè)Parcel-Native 對象。
writeInterfaceToken 用于寫入 IBinder 接口標(biāo)志,所帶參數(shù)是 String 類型的,如 IServiceManager.descriptor = "android.os.IServiceManager"。
之前說的 code 在這里用上了,code 是一個(gè)私有變量,跟 method 綁定在一起的。
中間有個(gè) server.transact(code, data, reply, 0); 該方法實(shí)現(xiàn)了跨進(jìn)程調(diào)用,最終會(huì)走到 binderProvider 的下面onTransact方法:
// TransformBinder 運(yùn)行在主進(jìn)程 @Override protected boolean onTransact(int code, Parcel data, Parcel reply, int flags) throws RemoteException { // 回調(diào)進(jìn)來后,就到了 MainActivity 的進(jìn)程 if (code == INTERFACE_TRANSACTION) { reply.writeString(serverInterface.getInterfaceName()); return true; } IPCMethod method = serverInterface.getIPCMethod(code); if (method != null) { try { method.handleTransact(server, data, reply); } catch (Throwable e) { e.printStackTrace(); } return true; } return super.onTransact(code, data, reply, flags); }
這里主要是根據(jù) code 來獲取到是哪個(gè)方法被調(diào)用了,下面才是真正的處理。
// IPCMethod public void handleTransact(Object server, Parcel data, Parcel reply) { data.enforceInterface(interfaceName); // 確保是目標(biāo)接口 Object[] parameters = data.readArray(getClass().getClassLoader()); if (parameters != null && parameters.length > 0) { for (int i = 0; i < parameters.length; i++) { if (converters[i] != null) { parameters[i] = converters[i].convert(parameters[i]); } // 如果參數(shù)里面包含有 binder if (parameters[i] instanceof IBinder){ parameters[i] = IPCCallback.Stub.asInterface(((IBinder)parameters[i])); } } } try { // 最終通過反射的形式實(shí)現(xiàn)了的調(diào)用 // 其實(shí)最主要的是通過 binder 拿到參數(shù),然后知道對方調(diào)用的是哪個(gè)方法。 // 現(xiàn)在要分析的是,他怎么將數(shù)據(jù)傳過來的 Object res = method.invoke(server, parameters); reply.writeNoException(); reply.writeValue(res); } catch (IllegalAccessException e) { e.printStackTrace(); reply.writeException(e); } catch (InvocationTargetException e) { e.printStackTrace(); reply.writeException(e); } }
看看 convert 里面的操作:
public Object convert(Object param) { if (param != null) { if (asInterfaceMethod == null) { synchronized (this) { if (asInterfaceMethod == null) { // 找到 asInterface 方法 asInterfaceMethod = findAsInterfaceMethod(type); } } } try { // 因?yàn)?nbsp;asInterface 方法是靜態(tài)方法,所以對象可以傳入空,最終轉(zhuǎn)變成所需要的參數(shù)類型 return asInterfaceMethod.invoke(null, param); } catch (Throwable e) { throw new IllegalStateException(e); } } return null; }
通過 convert 這個(gè)一調(diào)用,就轉(zhuǎn)變成我們所需要的參數(shù)了。
private static Method findAsInterfaceMethod(Class<?> type) { for (Class<?> innerClass : type.getDeclaredClasses()) { // public static class Stub extends Binder implements IType if (Modifier.isStatic(innerClass.getModifiers()) && Binder.class.isAssignableFrom(innerClass) && type.isAssignableFrom(innerClass)) { // public static IType asInterface(android.os.IBinder obj) for (Method method : innerClass.getDeclaredMethods()) { if (Modifier.isStatic(method.getModifiers())) { Class<?>[] types = method.getParameterTypes(); if (types.length == 1 && types[0] == IBinder.class) { return method; } } } } } throw new IllegalStateException("Can not found the " + type.getName() + "$Stub.asInterface method."); }
findAsInterfaceMethod 通過層層篩選,最終獲得需要的那個(gè)方法:
public static com.cmprocess.ipc.server.IPCCallback com.cmprocess.ipc.server.IPCCallback$Stub.asInterface(android.os.IBinder)
通過 invoke 方法,終將獲得了我們需要的類型。
這里 server 就是 mainActivity。在把對應(yīng)的參數(shù)傳進(jìn)去即可。最終調(diào)到了mainActivity 里面的 pay 方法。
public void pay(final int count, final IPCCallback callBack) { new Thread(new Runnable() { @Override public void run() { SystemClock.sleep(2000); Bundle bundle = new Bundle(); bundle.putString("pay", count + 100 + ""); try { // callback 也是一個(gè)binder callBack.onSuccess(bundle); } catch (RemoteException e) { e.printStackTrace(); } } }).start(); }
此處,callback 也是一個(gè)binder,調(diào)用成功后,發(fā)送了post。 其實(shí)最終也是調(diào)用了ServiceFetcher 。
// TestActivity VCore.getCore().post("key",bundle);
其實(shí)也是通過 binder 來進(jìn)行發(fā)送消息的。由于每個(gè)進(jìn)程都注冊了消息回調(diào),因此,每個(gè)進(jìn)程都會(huì)收到。
// ServiceCache public static synchronized void sendEvent(String key,Bundle event){ if (sEventCache.isEmpty()){ return; } for (IBinder binder:sEventCache.values()){ IEventReceiver eventReceiver = IEventReceiver.Stub.asInterface(binder); try { eventReceiver.onEventReceive(key, event); } catch (RemoteException e) { e.printStackTrace(); } } }
EventReceiver 存在于每個(gè)進(jìn)程,因此,對于 binderprovider 來說都是客戶端,其他進(jìn)程則是服務(wù)端。最終 EventCenter 會(huì)根據(jù) KEY 值來做分發(fā)。
到這里整個(gè)流程就基本講完了。
不過我們發(fā)現(xiàn)還有兩個(gè) service ,他們的作用是干嘛用的呢?感覺是用來?;畹?,防止 provider 死了。
感謝各位的閱讀!關(guān)于“如何實(shí)現(xiàn)CmProcess跨進(jìn)程通信”這篇文章就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,讓大家可以學(xué)到更多知識,如果覺得文章不錯(cuò),可以把它分享出去讓更多的人看到吧!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。