Quartz 的启动流程分析

一、简要

1.1、quartz 的核心元素

1. Scheduler为调度器负责整个定时系统的调度，内部通过线程池进行调度，下文阐述。

2. Trigger为触发器记录着调度任务的时间规则，主要有四种类型：SimpleTrigger、CronTrigger、DataIntervalTrigger、NthIncludedTrigger，在项目中常用的为：SimpleTrigger和CronTrigger。

3. JobDetail为定时任务的信息载体，可以记录Job的名字、组及任务执行的具体类和任务执行所需要的参数

4. Job为任务的真正执行体，承载着具体的业务逻辑。

   （像我们昨天的小案例中，简单定时任务就是实现了 job 接口）

大致流程就是：

• 先由 SchedulerFactory 创建 Scheduler 调度器
• 再由 Scheduler 调度器去调取即将执行的 Trigger ，
• 执行时获取到对于的 JobDetail 信息，
• 最后找到对应的 Job 类执行业务逻辑。

1.2、quartz中的线程

• 执行线程主要由一个线程池维护，在需要执行定时的时候使用，

• 这里使用的线程池是 org.quartz.simpl.SimpleThreadPool ，默认线程数为 10

  （这些在程序启动过程中的打印信息处就能看到）

• 调度线程主要分为 Regular Scheduler Thread 和 Misfire Scheduler Thread ；
• 其中 Regular Thread 轮询Trigger ，如果有将要触发的Trigger，则从任务线程池中获取一个空闲线程，然后执行与改Trigger关联的job；
• Misfire Thraed 则是扫描所有的trigger，查看是否有错失的，如果有的话，根据一定的策略进行处理。

二、quartz 启动流程

通常是使用 StdSchedulerFactory 创建 Scheduler 调度器。

在 SchedulerFactoryBean 配置类中配了相关的配置及配置文件参数，所以会读取配置文件参数，初始化各个组件。

启动流程的大致步骤如下：

1. 先读取配置文件

1. 初始化 SchedulerFactoryBean

1. 初始化SchedulerFactory

1. 实例化执行线程池（TheadPool）

1. 实例化数据存储

1. 初始化 QuartzScheduler (为Scheduler的简单实现，包括调度作业、注册JobListener实例等方法。)

1. new一个 QuartzSchedulerThread 调度线程（负责执行在QuartzScheduler中注册的触发触发器的线程。），并开始运行

1. 调度开始，注册监听器，注册Job和Trigger

1. SchedulerFactoryBean 初始化完成后执行start()方法

1. 创建ClusterManager线程并启动线程

1. 创建MisfireHandler线程并启动线程

1. 置 QuartzSchedulerThread 的paused=false，调度线程真正开始调度，开始执行run方法

2.1、读取配置文件

这里的读取，没有去debug，配置文件的位置是在

org.quartz 的包下，文件名为 quartz.properties

其内容为：

2.2、初始化SchedulerFactoryBean

当服务器启动时，Spring就加载相关的bean。

SchedulerFactoryBean实现了InitializingBean接口，因此在初始化bean的时候，会执行afterPropertiesSet方法，

该方法将会调用SchedulerFactory，通常是调用StdSchedulerFactory 来创建Scheduler调度器

2.3、初始化SchedulerFactory

这一步是在 SchedulerFactoryBean 的 prepareSchedulerFactory 方法中进行初始化，在上一步也已经看到~

我们接着往下Debug

这一大段都是在获取配置文件信息，我们直接将断点放到方法的末尾，看一下里面的值，和接下来要debug的方法

到这之后，我们会回到

this.scheduler = prepareScheduler(prepareSchedulerFactory()); 这一步，拿到

prepareSchedulerFactory() 返回的，接着往下走。

上面的if就不看了，直接看create方法做了什么

这里的 this.schedulerName 是 quartzScheduler

这里的 schedulerFactory.getScheduler() 是值得我们注意的，点进去看，我们看看 StdSchedulerFactory 的 getScheduler() 方法做了什么呢？

引来袭来的就是quartz中的重要组件，而且都是null，这说明我们要到下一步啦

2.4、实例化执行线程池（TheadPool）

2.5、实例化数据存储

2.6、初始化QuartzScheduler

QuartzScheduler 为Scheduler的简单实现，包括调度作业、注册JobListener实例等方法。

2.7、new一个 QuartzSchedulerThread 调度线程

QuartzSchedulerThread 负责执行在QuartzScheduler中注册的触发触发器的线程，并开始运行

走到就不在继续逗留了，我们直接回到方法调用处去。

2.8、注册监听器，注册Job和Trigger

里面不再点进去看如何注册啦，想看的xdm，继续去Debug就可以了~

到这里 SchedulerFactoryBean 初始化就算是完成了。接下来就是执行 start（）方法

2.9、 SchedulerFactoryBean 执行start()方法

这里的start方法是bean的生命周期中的，我们关注的不是这里，

而是方法内部的 startScheduler(this.scheduler,this.startupDelay) 方法

这两个不接着往下看啦~，疲啦 ...

添上红字的这两个就不继续看，我们关注一下 this.resources.getJobStore().schedulerStarted(); ，这也是下一步骤的开始~

2.10、创建Cluszaizaianager线程、创建MisfireHandler线程

我原本想关注一下 void recoverJobs() 方法

原本我是还想点进 executeInNonManagedTXLock() 方法继续看一眼，直接看麻了，知道这里是恢复任务就行了，看起来很难受，里面更加庞大啦，主要是没有思绪~

2.11、QuartzSchedulerThread开始执行run方法

置 QuartzSchedulerThread 的paused=false，调度线程真正开始调度，开始执行run方法

这才是调度的真正开始，前面都只能算是准备工作吧。

什么时候触发，获取线程执行任务，怎么查询数据库等等，可以说是从这里开始的。不过，咱们今天跑路了，明天或下次再来~