欢迎大家来到IT世界,在知识的湖畔探索吧!

昨天写了篇SpringBoot整合Quartz的文章，然后也正巧不知道写什么了，就带着好奇写了这篇文章，明天的话再谈一谈执行流程。

一、简要

1.1、quartz 的核心元素

1. Scheduler为调度器负责整个定时系统的调度，内部通过线程池进行调度，下文阐述。
2. Trigger为触发器记录着调度任务的时间规则，主要有四种类型：SimpleTrigger、CronTrigger、DataIntervalTrigger、NthIncludedTrigger，在项目中常用的为：SimpleTrigger和CronTrigger。
3. JobDetail为定时任务的信息载体，可以记录Job的名字、组及任务执行的具体类和任务执行所需要的参数
4. Job为任务的真正执行体，承载着具体的业务逻辑。
5. （像我们昨天的小案例中，简单定时任务就是实现了 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. 先读取配置文件

2. 初始化 SchedulerFactoryBean

3. 初始化SchedulerFactory

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

5. 实例化数据存储

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

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

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

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

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

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

12. 置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方法

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

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

后记

昨天写了一个Quartz 的小案例，就顺带Debug了一下，简单的走了流程，里面的代码太多值得分析的啦，明天再来看看run方法，这里才是调度的重点~

作者：宁在春
链接：https://juejin.cn/post/7131376773148721188