回家

Android插件化原理(三):Service的插件化

2019-10-24  本文已影响0人  曾想念_fce1

  上一节Activity的插件化中我们解决了四大组件中最重要的组件Activity的插件化问题。四大组件中,Service同样是使用相对频繁的组件,所以Service的插件化也是比较重要的。本节我们就跟着VirtualApk源码看一下Service插件化的实现。

Service插件化思路

  在Activity的插件化中我们看到对于Activity的插件化,VirtualApk采用了Hook及在宿主中注册占位Activity的方式解决,那么Service是否可用这种方式解决呢?是可以的,我们同样可以在宿主中注册一些占位Service,再通过Hook相关类,当启动一个Service时,在向AMS请求之前将目标Service替换成占位Service,在AMS回调以后再将目标Service替换回插件Service。但是Activity与Service启动有以下几个不同之处:

  1. 启动一个标准启动模式Activity是可以重复创建实例的,因此标准启动模式的占位Activity只需一个即可,但Service如果已经启动,是不会重复创建的,因此目标Service和占位Service只能是一对一的关系。
  2. Activity随着用户操作有复杂生命周期处理,而Service的生命周期比较简单,可以手动进行管理。

  所以占位Service可以解决Service插件化问题,但是需要在宿主中注册多个占位Service保证有足够的Service可用。VirtualApk采用了另一种思路,基于代理分发的方式实现,在启动插件Service时,会启动一个在宿主中注册过的代理Service,这里是真正的启动而非绕过AMS检查,因此会调用代理Service的onStartCommand(),在该方法中会创建插件Service实例并手动调用它的相关方法完成Service请求的分发。可以看到这种方式下就无需在宿主中注册大量的占位Service就能实现Service的插件化了。下面我们跟着具体源码看下VirtualApk是如何实现的,Service包括了启动和绑定两个过程,我们分别看下这两个过程。

Service的启动过程

  我们先看一下Service启动流程的时序图:


Service启动流程

  当启动一个Service时,会调用ContextWrapper的startService(),Activity、Service以及Application都继承了ContextWrapper,其内部会调用ContextImpl的startService(),最后会调用到startServiceCommon(),其内部又会调用IActivityManager的startService()向AMS发起请求;AMS收到请求并处理完成后,会调用ApplicationThread的scheduleCreateService()回调到应用进程,接着通过主线程Handler发送一条CREATE_SERVICE类型的消息,Handler处理这条消息时会调用ActivityThread的handleCreateService(),在它内部会创建Service实例,并调用attach()完成Service初始化,最后调用Service的onCreate()完成Service启动。

  根据Service的启动流程以及Service插件化实现的思路,我们需要在插件启动Service时先启动代理Service,因此我们同样可以采用Hook的方式,在向AMS发送请求之前将目标Service替换成代理Service,这样AMS收到的就是启动代理Service的请求了,所以我们看看VirtualApk是如何实现的。
  在Activity的插件化中我们说到了VirtualApk初始化的时候会hook多个对象,其中会调用hookSystemServices()hook AMS在应用进程的代理,我们看下这个方法的实现:

protected void hookSystemServices() {
    try {
        Singleton<IActivityManager> defaultSingleton;
        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
            defaultSingleton = Reflector.on(ActivityManager.class).field("IActivityManagerSingleton").get();
        } else {
            defaultSingleton = Reflector.on(ActivityManagerNative.class).field("gDefault").get();
        }
        IActivityManager origin = defaultSingleton.get();
        IActivityManager activityManagerProxy = (IActivityManager) Proxy.newProxyInstance(mContext.getClassLoader(), new Class[] { IActivityManager.class },
            createActivityManagerProxy(origin));
        Reflector.with(defaultSingleton).field("mInstance").set(activityManagerProxy);
        if (defaultSingleton.get() == activityManagerProxy) {
            this.mActivityManager = activityManagerProxy;
            Log.d(TAG, "hookSystemServices succeed : " + mActivityManager);
        }
    } catch (Exception e) {
        Log.w(TAG, e);
    }
}

  因为AMS在应用进程的代理在8.0版本前后的形式有所不同,所以首先根据版本调用不同的获取方式,最终都会得到一个实现了IActivityManager的对象,这是一个单例对象。接着创建了IActivityManager接口的一个动态代理对象,其中调用createActivityManagerProxy()创建了代理的处理对象,最后通过反射将代理对象赋值给单例的容器中,createActivityManagerProxy()内部就直接new了一个ActivityManagerProxy对象,ActivityManagerProxy实现了InvocationHandler接口,因此我们看看ActivityManagerProxy的invoke()做了什么处理:

public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
    if ("startService".equals(method.getName())) {
        try {
            return startService(proxy, method, args);
        } catch (Throwable e) {
            Log.e(TAG, "Start service error", e);
        }
    } else if ("stopService".equals(method.getName())) {
        try {
            return stopService(proxy, method, args);
        } catch (Throwable e) {
            Log.e(TAG, "Stop Service error", e);
        }
    } else if ("bindService".equals(method.getName())) {
        try {
            return bindService(proxy, method, args);
        } catch (Throwable e) {
            Log.w(TAG, e);
        }
    } else if ("unbindService".equals(method.getName())) {
        try {
            return unbindService(proxy, method, args);
        } catch (Throwable e) {
            Log.w(TAG, e);
        }
    }
    ...
}

  invoke()方法根据调用的方法名做不同的处理,上面看到了启动、停止、绑定、解绑服务的处理,稍后我们再看绑定的处理,这里我们先看下startService()

protected Object startService(Object proxy, Method method, Object[] args) throws Throwable {
    IApplicationThread appThread = (IApplicationThread) args[0];
    Intent target = (Intent) args[1];
    ResolveInfo resolveInfo = mPluginManager.resolveService(target, 0);
    if (null == resolveInfo || null == resolveInfo.serviceInfo) {
        return method.invoke(this.mActivityManager, args);
    }
    return startDelegateServiceForTarget(target, resolveInfo.serviceInfo, null, RemoteService.EXTRA_COMMAND_START_SERVICE);
}

  方法首先从参数中取出Intent,调用PluginManager.resolveService()根据Intent中的目标Service信息看是否匹配一个插件Service,如果不是则不做处理,否则则调用startDelegateServiceForTarget(),我们看下这个方法的实现:

protected ComponentName startDelegateServiceForTarget(Intent target, ServiceInfo serviceInfo, Bundle extras, int command) {
    Intent wrapperIntent = wrapperTargetIntent(target, serviceInfo, extras, command);
    return mPluginManager.getHostContext().startService(wrapperIntent);
}

  可以看到方法调用wrapperTargetIntent()将Intent进行转化,接着通过转化后的Intent调用宿主的Context的startService()启动Service,因此我们看下wrapperTargetIntent()是如何处理Intent的,方法如下所示:

protected Intent wrapperTargetIntent(Intent target, ServiceInfo serviceInfo, Bundle extras, int command) {
    target.setComponent(new ComponentName(serviceInfo.packageName, serviceInfo.name));
    String pluginLocation = mPluginManager.getLoadedPlugin(target.getComponent()).getLocation();
    boolean local = PluginUtil.isLocalService(serviceInfo);
    Class<? extends Service> delegate = local ? LocalService.class : RemoteService.class;  // 1
    Intent intent = new Intent();
    intent.setClass(mPluginManager.getHostContext(), delegate);  // 2
    intent.putExtra(RemoteService.EXTRA_TARGET, target);  // 3
    intent.putExtra(RemoteService.EXTRA_COMMAND, command);  // 4
    intent.putExtra(RemoteService.EXTRA_PLUGIN_LOCATION, pluginLocation);
    if (extras != null) {
        intent.putExtras(extras);
    }
    return intent;
}

  在注释1处会根据插件Service运行在的进程名判断该服务是运行在本地还是远程,如果是本地就会用LocalService作为代理Service,否则会使用RemoteService,RemoteService继承自LocalService,但它运行在子进程中,我们可以看一下LocalService以及RemoteService的声明:

<service android:exported="false" android:name="com.didi.virtualapk.delegate.LocalService" />

<service android:exported="false" android:name="com.didi.virtualapk.delegate.RemoteService" android:process=":daemon">
    <intent-filter>
        <action android:name="${applicationId}.intent.ACTION_DAEMON_SERVICE" />
    </intent-filter>
</service>

  可以看到LocalService没有指定进程而RemoteService运行在:daemon进程中。wrapperTargetIntent()方法在注释2处会创建一个新的Intent,并且将目标Service设置成刚选定的代理Service;在注释3会把原本的包含插件Service信息的Intent作为参数添加到新创建的Intent中;在注释4处会向Intent中添加一个参数标识当前执行的操作,用来和绑定服务进行区分,这个参数我们后面还会看到。这样就会启动我们选定的一个代理Service,因为RemoteService继承自LocalService,处理逻辑都在LocalService中,因此我们这里以LocalService为例。LocalService启动以后,它的onStartCommand()会被调用,且即使LocalService已经被创建,onStartCommand()也是会被调用的,所以不会因为LocalService已经启动而影响代理分发逻辑的执行,我们看下onStartCommand()是如何处理的,代码如下:

public int onStartCommand(Intent intent, int flags, int startId) {
    if (null == intent || !intent.hasExtra(EXTRA_TARGET) || !intent.hasExtra(EXTRA_COMMAND)) {
        return START_STICKY;
    }
    Intent target = intent.getParcelableExtra(EXTRA_TARGET);  // 1
    int command = intent.getIntExtra(EXTRA_COMMAND, 0);  // 2
    if (null == target || command <= 0) {
        return START_STICKY;
    }
    ComponentName component = target.getComponent();  // 3
    LoadedPlugin plugin = mPluginManager.getLoadedPlugin(component);
    if (plugin == null) {
        Log.w(TAG, "Error target: " + target.toURI());
        return START_STICKY;
    }
    target.setExtrasClassLoader(plugin.getClassLoader());
    switch (command) {  // 4
        ...
    }
    return START_STICKY;
}

  可以看到方法在注释1和注释2处分别从Intent中取出我们前面作为参数添加到Intent中的目标Intent以及操作标识,在注释3处从目标Intent中取出实际要启动的Service的包名类名,在注释4处根据操作标识做不同处理,这里我们看一下对启动服务的处理,处理逻辑如下所示:

ActivityThread mainThread = ActivityThread.currentActivityThread();
IApplicationThread appThread = mainThread.getApplicationThread();
Service service;
if (mPluginManager.getComponentsHandler().isServiceAvailable(component)) {
    service = mPluginManager.getComponentsHandler().getService(component);  // 1
} else {
    try {
        service = (Service) plugin.getClassLoader().loadClass(component.getClassName()).newInstance();  // 2
        Application app = plugin.getApplication();
        IBinder token = appThread.asBinder();
        Method attach = service.getClass().getMethod("attach", Context.class, ActivityThread.class, String.class, IBinder.class, Application.class, Object.class);  // 3
        IActivityManager am = mPluginManager.getActivityManager();
        attach.invoke(service, plugin.getPluginContext(), mainThread, component.getClassName(), token, app, am);  // 4
        service.onCreate();  // 5
        mPluginManager.getComponentsHandler().rememberService(component, service);
    } catch (Throwable t) {
        return START_STICKY;
    }
}
service.onStartCommand(target, 0, mPluginManager.getComponentsHandler().getServiceCounter(service).getAndIncrement());  // 6

  上面代码在注释1处先判断要启动的插件Service是否已经启动,如果是则从缓存取出,不再重复创建实例,直接在注释6调用它的onStartCommand(),否则在注释2处通过插件Service所在的插件的DexClassLoader加载Service类并创建实例,在注释3处通过反射获得Service类的attach(),并在注释4处对刚刚创建的Service实例调用attach()进行初始化,在注释5处调用Service的onCreate(),最后在注释6处调用Service的onStartCommand(),这样就完成了插件Service的启动。可以看出插件Service的生命周期是由代理Service手动调用的,这就是代理分发的思想,这种思路我们在下面的ContentProvider插件化中还会再次看到。

  上面就是Service启动的插件化实现,接下来看一下Service绑定的插件化实现,绑定和启动的思路都是一致的,因此理解了启动的原理后,绑定也就很简单了。

Service的绑定过程

  我们还是先看一下Service绑定流程的时序图:


Service绑定流程

  绑定Service的流程和启动Service基本一样,只是调用的方法从create变成了bind,大家看时序图基本都能明白,我就不做解释了。但需要注意的一点是,绑定Service的时候,如果Service还没有启动,AMS会先回调应用进程触发Service的启动。

  绑定服务时会调用IActivityManager的bindService()与AMS通信,我们前面已经知道VirtualApk hook了IActivityManager,因此调用bindService()依然会调用到ActivityManagerProxy的invoke(),现在我们看下invoke()对bindService的处理,代码如下:

protected Object bindService(Object proxy, Method method, Object[] args) throws Throwable {
    Intent target = (Intent) args[2];
    ResolveInfo resolveInfo = this.mPluginManager.resolveService(target, 0);
    if (null == resolveInfo || null == resolveInfo.serviceInfo) {
        return method.invoke(this.mActivityManager, args);
    }
    Bundle bundle = new Bundle();
    PluginUtil.putBinder(bundle, "sc", (IBinder) args[4]);  // 1
    startDelegateServiceForTarget(target, resolveInfo.serviceInfo, bundle, RemoteService.EXTRA_COMMAND_BIND_SERVICE);  // 2
    mPluginManager.getComponentsHandler().remberIServiceConnection((IBinder) args[4], target);
    return 1;
}

  可以看到对绑定的处理和启动基本一致,不一样的地方在注释1处从参数中取出了一个ServiceDispatcher对象,它内部封装了我们调用bindService()传递的ServiceConnection对象;并在注释2处调用startDelegateServiceForTarget()启动代理Service时作为参数传入,同时传递了表示绑定Service的标识符,因此在代理Service启动后就会执行绑定Service的逻辑。注意注释2我们执行startDelegateServiceForTarget()启动代理服务,虽然我们这里是绑定一个插件Service,但我们依旧是启动代理Service而非绑定,因为无论是启动还是绑定Service,代理Service的分发逻辑都在onStartCommand()中,所以我们这里还是需要启动代理Service。startDelegateServiceForTarget()的逻辑我们前面已经看过了,这里就不再赘述了。我们依旧是以LocalService为例,在LocalService启动以后,还是会调用到LocalService的onStartCommand(),这个方法我们前面也看到过了,是从Intent中取出目标Intent以及标识符command,并根据command决定执行的逻辑,这里我们会执行到绑定Service的逻辑,代码如下所示:

ActivityThread mainThread = ActivityThread.currentActivityThread();
IApplicationThread appThread = mainThread.getApplicationThread();
Service service = null;
if (mPluginManager.getComponentsHandler().isServiceAvailable(component)) {
    service = mPluginManager.getComponentsHandler().getService(component);  // 1
} else {
    try {
        service = (Service) plugin.getClassLoader().loadClass(component.getClassName()).newInstance();  // 2
        Application app = plugin.getApplication();
        IBinder token = appThread.asBinder();
        Method attach = service.getClass().getMethod("attach", Context.class, ActivityThread.class, String.class, IBinder.class, Application.class, Object.class);  // 3
        IActivityManager am = mPluginManager.getActivityManager();
        attach.invoke(service, plugin.getPluginContext(), mainThread, component.getClassName(), token, app, am);  // 4
        service.onCreate();  // 5
        mPluginManager.getComponentsHandler().rememberService(component, service);
    } catch (Throwable t) {
        Log.w(TAG, t);
    }
}
try {
    IBinder binder = service.onBind(target);  // 6
    IBinder serviceConnection = PluginUtil.getBinder(intent.getExtras(), "sc");  // 7
    IServiceConnection iServiceConnection = IServiceConnection.Stub.asInterface(serviceConnection);
    if (Build.VERSION.SDK_INT >= 26) {
        iServiceConnection.connected(component, binder, false);  // 8
    } else {
        Reflector.QuietReflector.with(iServiceConnection).method("connected", ComponentName.class, IBinder.class).call(component, binder);
    }
} catch (Exception e) {
    Log.w(TAG, e);
}

  在注释1处判断是否已经创建过Service实例,如果是则从缓存中取出,否则在注释2处通过插件Service所在的插件的DexClassLoader加载Service类并创建实例,注释3处反射获取到attach()方法并在注释4处调用进行Service初始化,在注释5处手动调用插件Service的onCreate(),到这里Service的创建及初始化就完成了。接着在注释6处手动调用插件Service的onBind()进行绑定请求的分发,onBind()会返回一个Binder对象,在注释7处取出我们之前作为作为参数添加到Intent的ServiceDispatcher对象,并将其转化成ServiceConnection类型,在注释8处将onBind()获取到的Binder对象作为参数调用ServiceConnection的connected(),这样我们调用bindService()时传递的ServiceConnection的监听就能收到回调,并且通过拿到的Binder对象与插件Service进行通信了。

  到这里Service的启动以及绑定的插件化原理都分析清楚了,可以看出Service插件化采用了与Activity插件化不一样的思路,采用了代理分发的思想,通过代理分发的思路可以保证宿主只需要注册少量的代理Service就可以完成全部插件Service的启动,我们在ContentProvider的插件化上还会再次看到这种思路。我们主要讲了启动和绑定的流程,还有停止和解绑流程,但是相信理解了前两个流程以后,剩下两个流程也不是问题了。下一节会介绍一下剩下两个组件—BroadcastReceiver和ContentProvider的插件化实现原理。

上一篇下一篇

猜你喜欢

热点阅读