美文网首页面试题
startService启动源码分析

startService启动源码分析

作者: 月止风溟 | 来源:发表于2019-11-10 19:55 被阅读0次

    1.Service生命周期

    前面已经分析了Activity的启动流程。这里篇开始分析常用组件Service。Service的生命周期如下。这篇从源码角度,分析startService的启动流程。

    Service生命周期

    2.StartService时序图

    老规矩,看代码前先放图。相较Activity的生命周期流程,这个就比较简单。


    StartService时序图

    3.源码分析

    并没有多涉及新增类。直接从源码开始看吧。
    这里还是使用Android P的源码,好找。Android Q的代码并没有很大的差异。
    startService事实上通过mBase调用到ContextImplstartService。一路调用到ActivityManager.getService().startService。前篇已经说过,这个通过IPC调用到System_service进程的ActivityManagerService
    ContextImpl

    
        @Override
        public ComponentName startService(Intent service) {
            warnIfCallingFromSystemProcess();
            return startServiceCommon(service, false, mUser);
        }
    
        private ComponentName startServiceCommon(Intent service, boolean requireForeground,
                UserHandle user) {
            try {
                validateServiceIntent(service);
                service.prepareToLeaveProcess(this);
                ComponentName cn = ActivityManager.getService().startService(
                    mMainThread.getApplicationThread(), service, service.resolveTypeIfNeeded(
                                getContentResolver()), requireForeground,
                                getOpPackageName(), user.getIdentifier());
                ...
            } catch (RemoteException e) {
                throw e.rethrowFromSystemServer();
            }
        }
    

    ActivityManagerService就比较轻松了,直接调用ActiveServicesstartServiceLocked方法。
    ActivityManagerService

        @Override
        public ComponentName startService(IApplicationThread caller, Intent service,
                String resolvedType, boolean requireForeground, String callingPackage, int userId)
                throws TransactionTooLargeException {
            ...
            synchronized(this) {
                final int callingPid = Binder.getCallingPid();
                final int callingUid = Binder.getCallingUid();
                final long origId = Binder.clearCallingIdentity();
                ComponentName res;
                try {
                    res = mServices.startServiceLocked(caller, service,
                            resolvedType, callingPid, callingUid,
                            requireForeground, callingPackage, userId);
                } finally {
                    Binder.restoreCallingIdentity(origId);
                }
                return res;
            }
        }
    

    ActiveServices

        ComponentName startServiceLocked(IApplicationThread caller, Intent service, String resolvedType,
                int callingPid, int callingUid, boolean fgRequired, String callingPackage, final int userId)
                throws TransactionTooLargeException {
            ...
            //需要注意,从这里看,这里构建了一个res.record.bindings为空的ServiceLookupResult。
            //这也就是startService为什么不会调用到onBInd的原因。
            //这里面还做了权限检测,有兴趣的朋友可以细看
            ServiceLookupResult res =
                retrieveServiceLocked(service, resolvedType, callingPackage,
                        callingPid, callingUid, userId, true, callerFg, false, false);
            ...
            ServiceRecord r = res.record;
    
            ...
    
            ComponentName cmp = startServiceInnerLocked(smap, service, r, callerFg, addToStarting);
            return cmp;
        }
    
        ComponentName startServiceInnerLocked(ServiceMap smap, Intent service, ServiceRecord r,
                boolean callerFg, boolean addToStarting) throws TransactionTooLargeException {
            ...
                    String error = bringUpServiceLocked(r, service.getFlags(), callerFg, false, false);
            ...
            //后面是一些超时检测
        }
    
    
        private String bringUpServiceLocked(ServiceRecord r, int intentFlags, boolean execInFg,
                boolean whileRestarting, boolean permissionsReviewRequired)
                throws TransactionTooLargeException {
            //Slog.i(TAG, "Bring up service:");
            //r.dump("  ");
            //看到这,如果Service已经在运行状态,则调用sendServiceArgsLocked,
            //也就是说只触发onStartCommond
            if (r.app != null && r.app.thread != null) {
                sendServiceArgsLocked(r, execInFg, false);
                return null;
            }
    
            ...
    
            //眼熟,如果Service有自己的独立进程,需要在它的进程启动。
            //这里需要走到else去等待。否则的话,走进if逻辑。
            if (!isolated) {
                app = mAm.getProcessRecordLocked(procName, r.appInfo.uid, false);
                if (DEBUG_MU) Slog.v(TAG_MU, "bringUpServiceLocked: appInfo.uid=" + r.appInfo.uid
                            + " app=" + app);
                //如果Serice所在进程已启动,直接调用realStartServiceLocked
                if (app != null && app.thread != null) {
                    try {
                        app.addPackage(r.appInfo.packageName, r.appInfo.longVersionCode, mAm.mProcessStats);
                        realStartServiceLocked(r, app, execInFg);
                        return null;
                    } catch (TransactionTooLargeException e) {
                        throw e;
                    } catch (RemoteException e) {
                        Slog.w(TAG, "Exception when starting service " + r.shortName, e);
                    }
    
                    // If a dead object exception was thrown -- fall through to
                    // restart the application.
                }
            } else {
                // If this service runs in an isolated process, then each time
                // we call startProcessLocked() we will get a new isolated
                // process, starting another process if we are currently waiting
                // for a previous process to come up.  To deal with this, we store
                // in the service any current isolated process it is running in or
                // waiting to have come up.
                app = r.isolatedProc;
                if (WebViewZygote.isMultiprocessEnabled()
                        && r.serviceInfo.packageName.equals(WebViewZygote.getPackageName())) {
                    hostingType = "webview_service";
                }
            }
    
            // Not running -- get it started, and enqueue this service record
            // to be executed when the app comes up.
            //如果进程还没启动,通过startProcessLocked去启动对应的进程,
            //然后在AMS的attachApplicationLocked方法里,
            //通过mServices.attachApplicationLocked又调用到了realStartServiceLocked。
            //这里我在之前的这篇[新app进程创建过程](https://www.jianshu.com/p/6af5667c2d30)
            //已经详细描述,这里不再赘述
            if (app == null && !permissionsReviewRequired) {
                if ((app=mAm.startProcessLocked(procName, r.appInfo, true, intentFlags,
                        hostingType, r.name, false, isolated, false)) == null) {
                    String msg = "Unable to launch app "
                            + r.appInfo.packageName + "/"
                            + r.appInfo.uid + " for service "
                            + r.intent.getIntent() + ": process is bad";
                    Slog.w(TAG, msg);
                    bringDownServiceLocked(r);
                    return msg;
                }
                if (isolated) {
                    r.isolatedProc = app;
                }
            }
    
            ...
        }
    
    
        private final void realStartServiceLocked(ServiceRecord r,
                ProcessRecord app, boolean execInFg) throws RemoteException {
            ...
    
            boolean created = false;
            try {
                if (LOG_SERVICE_START_STOP) {
                    String nameTerm;
                    int lastPeriod = r.shortName.lastIndexOf('.');
                    nameTerm = lastPeriod >= 0 ? r.shortName.substring(lastPeriod) : r.shortName;
                    EventLogTags.writeAmCreateService(
                            r.userId, System.identityHashCode(r), nameTerm, r.app.uid, r.app.pid);
                }
                synchronized (r.stats.getBatteryStats()) {
                    r.stats.startLaunchedLocked();
                }
                mAm.notifyPackageUse(r.serviceInfo.packageName,
                                     PackageManager.NOTIFY_PACKAGE_USE_SERVICE);
                app.forceProcessStateUpTo(ActivityManager.PROCESS_STATE_SERVICE);
                //你看,这里调用了ApplicationThread的scheduleCreateService。
                //又是我们熟悉的ActvityThread的调用流程
                app.thread.scheduleCreateService(r, r.serviceInfo,
                        mAm.compatibilityInfoForPackageLocked(r.serviceInfo.applicationInfo),
                        app.repProcState);
                r.postNotification();
                created = true;
            } catch (DeadObjectException e) {
                Slog.w(TAG, "Application dead when creating service " + r);
                mAm.appDiedLocked(app);
                throw e;
            } finally {
                if (!created) {
                    // Keep the executeNesting count accurate.
                    final boolean inDestroying = mDestroyingServices.contains(r);
                    serviceDoneExecutingLocked(r, inDestroying, inDestroying);
    
                    // Cleanup.
                    if (newService) {
                        app.services.remove(r);
                        r.app = null;
                    }
    
                    // Retry.
                    if (!inDestroying) {
                        scheduleServiceRestartLocked(r, false);
                    }
                }
            }
    
            if (r.whitelistManager) {
                app.whitelistManager = true;
            }
    
            //因为r.bindings为空,所以这个没有调用onBind
            requestServiceBindingsLocked(r, execInFg);
    
            ...
    
            //这里面会去调用onStartCommond
            sendServiceArgsLocked(r, execInFg, true);
    
            ...
        }
    
        private final void sendServiceArgsLocked(ServiceRecord r, boolean execInFg,
                boolean oomAdjusted) throws TransactionTooLargeException {
            ...
            try {
                //同样的,这里调用了ApplicationThread的scheduleServiceArgs。
                //又是我们熟悉的ActvityThread的调用流程
                r.app.thread.scheduleServiceArgs(r, slice);
            }
            ...
        }
    
    

    上面的流程,已经可以清晰的看出了,关键的是,调用了ApplicationThreadscheduleCreateServicescheduleServiceArgs方法。
    熟悉的ApplicationThread->H->ActivityThread三连招。
    ApplicationThread

            public final void scheduleCreateService(IBinder token,
                    ServiceInfo info, CompatibilityInfo compatInfo, int processState) {
                updateProcessState(processState, false);
                CreateServiceData s = new CreateServiceData();
                s.token = token;
                s.info = info;
                s.compatInfo = compatInfo;
    
                sendMessage(H.CREATE_SERVICE, s);
            }
    

    H

                    case CREATE_SERVICE:
                        Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, ("serviceCreate: " + String.valueOf(msg.obj)));
                        handleCreateService((CreateServiceData)msg.obj);
                        Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                        break;
    

    ActvityThread

        private void handleCreateService(CreateServiceData data) {
            // If we are getting ready to gc after going to the background, well
            // we are back active so skip it.
            unscheduleGcIdler();
    
            LoadedApk packageInfo = getPackageInfoNoCheck(
                    data.info.applicationInfo, data.compatInfo);
            Service service = null;
            try {
                //创建Service对象
                java.lang.ClassLoader cl = packageInfo.getClassLoader();
                service = packageInfo.getAppFactory()
                        .instantiateService(cl, data.info.name, data.intent);
            } catch (Exception e) {
                if (!mInstrumentation.onException(service, e)) {
                    throw new RuntimeException(
                        "Unable to instantiate service " + data.info.name
                        + ": " + e.toString(), e);
                }
            }
    
            try {
                if (localLOGV) Slog.v(TAG, "Creating service " + data.info.name);
    
                ContextImpl context = ContextImpl.createAppContext(this, packageInfo);
                context.setOuterContext(service);
    
                Application app = packageInfo.makeApplication(false, mInstrumentation);
                //调用Service的attach方法
                service.attach(context, this, data.info.name, data.token, app,
                        ActivityManager.getService());
                //调用Service的onCreate方法
                service.onCreate();
                mServices.put(data.token, service);
                try {
                    ActivityManager.getService().serviceDoneExecuting(
                            data.token, SERVICE_DONE_EXECUTING_ANON, 0, 0);
                } catch (RemoteException e) {
                    throw e.rethrowFromSystemServer();
                }
            } catch (Exception e) {
                if (!mInstrumentation.onException(service, e)) {
                    throw new RuntimeException(
                        "Unable to create service " + data.info.name
                        + ": " + e.toString(), e);
                }
            }
        }
    

    上面可以看到,Service已经创建并且调用onCreate方法。下面我们看下scheduleServiceArgs做了什么。
    ApplicationThread

            public final void scheduleServiceArgs(IBinder token, ParceledListSlice args) {
                List<ServiceStartArgs> list = args.getList();
    
                for (int i = 0; i < list.size(); i++) {
                    ServiceStartArgs ssa = list.get(i);
                    ServiceArgsData s = new ServiceArgsData();
                    s.token = token;
                    s.taskRemoved = ssa.taskRemoved;
                    s.startId = ssa.startId;
                    s.flags = ssa.flags;
                    s.args = ssa.args;
    
                    sendMessage(H.SERVICE_ARGS, s);
                }
            }
    

    H

                    case SERVICE_ARGS:
                        Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER, ("serviceStart: " + String.valueOf(msg.obj)));
                        handleServiceArgs((ServiceArgsData)msg.obj);
                        Trace.traceEnd(Trace.TRACE_TAG_ACTIVITY_MANAGER);
                        break;
    

    ActvityThread

        private void handleServiceArgs(ServiceArgsData data) {
            Service s = mServices.get(data.token);
            if (s != null) {
                try {
                    if (data.args != null) {
                        data.args.setExtrasClassLoader(s.getClassLoader());
                        data.args.prepareToEnterProcess();
                    }
                    int res;
                    if (!data.taskRemoved) {
                        //这里调用了onStartCommand方法
                        res = s.onStartCommand(data.args, data.flags, data.startId);
                    } else {
                        s.onTaskRemoved(data.args);
                        res = Service.START_TASK_REMOVED_COMPLETE;
                    }
    
                    QueuedWork.waitToFinish();
    
                    try {
                        ActivityManager.getService().serviceDoneExecuting(
                                data.token, SERVICE_DONE_EXECUTING_START, data.startId, res);
                    } catch (RemoteException e) {
                        throw e.rethrowFromSystemServer();
                    }
                    ensureJitEnabled();
                } catch (Exception e) {
                    if (!mInstrumentation.onException(s, e)) {
                        throw new RuntimeException(
                                "Unable to start service " + s
                                + " with " + data.args + ": " + e.toString(), e);
                    }
                }
            }
        }
    

    这篇的话,是基于之前Activity启动流程分析进行的,默认朋友们已经看过了。所以像ApplicationThread->H->ActivityThread三连招,从App->ServiceService->app,和Service所在进程未启动的话,启动对应进程的流程,都一笔带过了。因为这个在之前几篇都已经熟悉介绍过。
    如果是没有看过的朋友,可以着重看这两篇。
    Activity启动源码分析--总篇
    Activity启动源码分析(3)-- 新app进程创建过程
    参考文档:

    1. Service启动过程源码阅读

    相关文章

      网友评论

        本文标题:startService启动源码分析

        本文链接:https://www.haomeiwen.com/subject/tgwabctx.html