Firebase JobDispatcher源码深度剖析：从调度到执行的完整链路

Firebase JobDispatcher源码深度剖析：从调度到执行的完整链路

【免费下载链接】firebase-jobdispatcher-androidDEPRECATED please see the README.md below for details.项目地址: https://gitcode.com/gh_mirrors/fi/firebase-jobdispatcher-android

Firebase JobDispatcher是一个驱动程序无关的API，用于在Android应用中调度和取消作业。它提供了灵活的作业调度机制，允许开发者根据各种条件（如网络状态、设备充电状态等）安排后台任务的执行。本文将深入剖析Firebase JobDispatcher的源码，从作业调度到执行的完整链路，帮助开发者更好地理解和使用这个强大的工具。

核心组件解析

Firebase JobDispatcher的核心组件包括FirebaseJobDispatcher、Driver、Job、JobService和JobTrigger等。这些组件协同工作，构成了作业调度和执行的完整框架。

FirebaseJobDispatcher类

FirebaseJobDispatcher是整个框架的入口点，负责作业的调度和取消。它使用Driver来与底层系统交互，实现作业的实际调度。

public final class FirebaseJobDispatcher { /** Instantiates a new FirebaseJobDispatcher using the provided Driver. */ public FirebaseJobDispatcher(@NonNull Driver driver) { this.driver = driver; this.validator = new ValidationEnforcer(new DefaultJobValidator(driver)); } // 调度作业的方法 public int schedule(@NonNull Job job) { // 验证作业合法性 validator.ensureValid(job); // 使用驱动程序调度作业 return driver.schedule(job); } // 取消作业的方法 public int cancel(@NonNull String tag) { return driver.cancel(tag); } }

FirebaseJobDispatcher提供了schedule和cancel等方法，分别用于调度和取消作业。在调度作业之前，它会使用ValidationEnforcer和DefaultJobValidator对作业进行验证，确保作业的合法性。

Driver接口

Driver接口定义了与底层系统交互的方法，负责实际的作业调度和取消。Firebase JobDispatcher提供了GooglePlayDriver实现，用于与Google Play服务交互。

public interface Driver { int schedule(@NonNull Job job); int cancel(@NonNull String tag); int cancelAll(); }

GooglePlayDriver实现了Driver接口，使用Google Play服务的GcmNetworkManager来调度作业。它将Firebase JobDispatcher的作业转换为GcmNetworkManager可以理解的格式，并进行调度。

Job类

Job类表示一个要执行的作业，包含作业的各种属性，如触发器、约束条件、重试策略等。开发者可以使用Job.Builder来构建作业实例。

public class Job { private final String tag; private final String service; private final JobTrigger trigger; private final Set<Constraint> constraints; private final RetryStrategy retryStrategy; private final boolean recurring; private final Bundle extras; private final Lifetime lifetime; // 作业属性的getter方法 public String getTag() { return tag; } public String getService() { return service; } public JobTrigger getTrigger() { return trigger; } // ...其他getter方法 public static class Builder { // 构建作业的方法 public Builder setTag(String tag) { ... } public Builder setService(Class<? extends JobService> serviceClass) { ... } public Builder setTrigger(JobTrigger trigger) { ... } // ...其他设置方法 public Job build() { ... } } }

JobService类

JobService是一个抽象类，开发者需要继承它并实现onStartJob和onStopJob方法来定义作业的具体执行逻辑。

public abstract class JobService extends Service { public static final int RESULT_SUCCESS = 0; public static final int RESULT_FAIL = 1; public static final int RESULT_FAIL_RETRY = 2; public abstract boolean onStartJob(JobParameters params); public abstract boolean onStopJob(JobParameters params); // 通知作业完成的方法 public final void jobFinished(JobParameters params, boolean needsReschedule) { // ...实现逻辑 } }

当作业被调度执行时，系统会调用onStartJob方法。如果作业执行完成，开发者需要调用jobFinished方法通知系统。如果作业需要重新调度，可以将needsReschedule参数设为true。

JobTrigger接口

JobTrigger接口定义了作业触发的条件。Firebase JobDispatcher提供了多种触发器实现，如ImmediateTrigger（立即触发）、ExecutionWindowTrigger（执行窗口触发）和ContentUriTrigger（内容URI触发）等。

public interface JobTrigger { class ImmediateTrigger implements JobTrigger { ... } class ExecutionWindowTrigger implements JobTrigger { private final int windowStart; private final int windowEnd; public ExecutionWindowTrigger(int windowStart, int windowEnd) { this.windowStart = windowStart; this.windowEnd = windowEnd; } public int getWindowStart() { return windowStart; } public int getWindowEnd() { return windowEnd; } } class ContentUriTrigger implements JobTrigger { private final List<ObservedUri> uris; public ContentUriTrigger(List<ObservedUri> uris) { this.uris = uris; } public List<ObservedUri> getUris() { return uris; } } }

作业调度流程

Firebase JobDispatcher的作业调度流程可以分为以下几个步骤：

1. 创建FirebaseJobDispatcher实例：使用GooglePlayDriver创建FirebaseJobDispatcher实例。

FirebaseJobDispatcher dispatcher = new FirebaseJobDispatcher(new GooglePlayDriver(context));

2. 构建Job实例：使用Job.Builder构建作业实例，设置作业的标签、服务、触发器、约束条件等属性。

Job job = dispatcher.newJobBuilder() .setTag("my-job-tag") .setService(MyJobService.class) .setTrigger(Trigger.executionWindow(60, 120)) // 60-120秒后触发 .setConstraints(Constraint.ON_ANY_NETWORK) // 在任何网络状态下执行 .build();

3. 调度作业：调用FirebaseJobDispatcher的schedule方法调度作业。

int result = dispatcher.schedule(job); if (result == FirebaseJobDispatcher.SCHEDULE_RESULT_SUCCESS) { Log.d("JobScheduler", "Job scheduled successfully"); }

4. 作业执行：当作业的触发条件满足时，系统会启动JobService的实例，并调用onStartJob方法执行作业。

public class MyJobService extends JobService { @Override public boolean onStartJob(JobParameters params) { // 执行作业逻辑 new Thread(() -> { // 耗时操作 // ... jobFinished(params, false); // 作业完成，不需要重新调度 }).start(); return true; // 表示作业在后台线程中执行 } @Override public boolean onStopJob(JobParameters params) { // 作业被停止时的处理逻辑 return false; // 表示不需要重新调度 } }

作业执行流程

作业执行流程主要涉及ExecutionDelegator、JobServiceConnection和JobService等组件的交互。

1. 作业触发：当作业的触发条件满足时，GooglePlayReceiver会接收到触发事件，并将作业信息传递给ExecutionDelegator。

2. 启动JobService：ExecutionDelegator会通过JobServiceConnection绑定到JobService，并调用onStartJob方法执行作业。

3. 作业执行：JobService的onStartJob方法被调用，开发者实现的作业逻辑在这里执行。如果作业需要在后台线程中执行，onStartJob方法应返回true，并在作业完成后调用jobFinished方法。

4. 作业完成：当作业执行完成或被停止时，JobService会调用jobFinished方法，通知系统作业的执行结果。系统根据返回的结果决定是否重新调度作业。

总结

Firebase JobDispatcher提供了一个灵活、强大的作业调度框架，使开发者能够轻松地安排后台任务的执行。通过深入了解其核心组件和工作流程，开发者可以更好地利用这个框架来优化应用的后台任务处理，提高应用的性能和用户体验。

虽然Firebase JobDispatcher已被标记为 deprecated，但它的设计思想和实现方式对于理解Android作业调度机制仍然具有重要的参考价值。对于新的项目，建议使用Android Jetpack中的WorkManager，它提供了更强大、更灵活的作业调度功能。

【免费下载链接】firebase-jobdispatcher-androidDEPRECATED please see the README.md below for details.项目地址: https://gitcode.com/gh_mirrors/fi/firebase-jobdispatcher-android