Quartz 的启动流程分析 quartz启动不执行
yuyutoo 2024-11-01 15:55 5 浏览 0 评论
昨天写了篇SpringBoot整合Quartz的文章,然后也正巧不知道写什么了,就带着好奇写了这篇文章,明天的话再谈一谈执行流程。
一、简要
1.1、quartz 的核心元素
- Scheduler为调度器负责整个定时系统的调度,内部通过线程池进行调度,下文阐述。
- Trigger为触发器记录着调度任务的时间规则,主要有四种类型:SimpleTrigger、CronTrigger、DataIntervalTrigger、NthIncludedTrigger,在项目中常用的为:SimpleTrigger和CronTrigger。
- JobDetail为定时任务的信息载体,可以记录Job的名字、组及任务执行的具体类和任务执行所需要的参数
- 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配置类中配了相关的配置及配置文件参数,所以会读取配置文件参数,初始化各个组件。
启动流程的大致步骤如下:
- 先读取配置文件
- 初始化 SchedulerFactoryBean
- 初始化SchedulerFactory
- 实例化执行线程池(TheadPool)
- 实例化数据存储
- 初始化 QuartzScheduler(为Scheduler的简单实现,包括调度作业、注册JobListener实例等方法。)
- new一个QuartzSchedulerThread调度线程(负责执行在QuartzScheduler中注册的触发触发器的线程。),并开始运行
- 调度开始,注册监听器,注册Job和Trigger
- SchedulerFactoryBean初始化完成后执行start()方法
- 创建ClusterManager线程并启动线程
- 创建MisfireHandler线程并启动线程
- 置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
相关推荐
- 全局和隐式 using 指令详解(全局命令)
-
1.什么是全局和隐式using?在.NET6及更高版本中,Microsoft引入了...
- 请停止微服务,做好单体的模块化才是王道:Spring Modulith介绍
-
1、介绍模块化单体是一种架构风格,代码是根据模块的概念构成的。对于许多组织而言,模块化单体可能是一个很好的选择。它有助于保持一定程度的独立性,这有助于我们在需要的时候轻松过渡到微服务架构。Spri...
- ASP.NET程序集引用之痛:版本冲突、依赖地狱等解析与实战
-
我是一位多年后端经验的工程师,其中前几年用ASP.NET...
- .NET AOT 详解(.net 6 aot)
-
简介AOT(Ahead-Of-TimeCompilation)是一种将代码直接编译为机器码的技术,与传统的...
- 一款基于Yii2开发的免费商城系统(一款基于yii2开发的免费商城系统是什么)
-
哈喽,我是老鱼,一名致力于在技术道路上的终身学习者、实践者、分享者!...
- asar归档解包(游戏arc文件解包)
-
要学习Electron逆向,首先要有一个Electron开发的程序的发布的包,这里就以其官方的electron-quick-start作为例子来进行一下逆向的过程。...
- 在PyCharm 中免费集成Amazon CodeWhisperer
-
CodeWhisperer是Amazon发布的一款免费的AI编程辅助小工具,可在你的集成开发环境(IDE)中生成实时单行或全函数代码建议,帮助你快速构建软件。简单来说,AmazonCodeWhi...
- 2014年最优秀JavaScript编辑器大盘点
-
1.WebstormWebStorm是一种轻量级的、功能强大的IDE,为Node.js复杂的客户端开发和服务器端开发提供完美的解决方案。WebStorm的智能代码编辑器支持JavaScript,...
- 基于springboot、tio、oauth2.0前端vuede 超轻量级聊天软件分享
-
项目简介:基于JS的超轻量级聊天软件。前端:vue、iview、electron实现的PC桌面版聊天程序,主要适用于私有云项目内部聊天,企业内部管理通讯等功能,主要通讯协议websocket。支持...
- JetBrains Toolbox推出全新产品订阅授权模式
-
捷克知名软件开发公司JetBrains最为人所熟知的产品是Java编程语言开发撰写时所用的集成开发环境IntelliJIDEA,相信很多开发者都有所了解。而近期自2015年11月2日起,JetBr...
- idea最新激活jetbrains-agent.jar包,亲测有效
-
这里分享一个2019.3.3版本的jetbrains-agent.jar,亲测有效,在网上找了很多都不能使用,终于找到一个可以使用的了,这里分享一下具体激活步骤,此方法适用于Jebrains家所有产品...
- CountDownTimer的理解(countdowntomars)
-
CountDownTimer是android开发常用的计时类,按照注释中的说明使用方法如下:kotlin:object:CountDownTimer(30000,1000){...
- 反射为什么性能会很慢?(反射时为什么会越来越长)
-
1.背景前段时间维护一个5、6年前的项目,项目总是在某些功能使用上不尽人意,性能上总是差一些,仔细过了一下代码发现使用了不少封装好的工具类,工具类里面用了好多的反射,反射会影响到执行效率吗?盲猜了一...
- btrace 开源!基于 Systrace 高性能 Trace 工具
-
介绍btrace(又名RheaTrace)是抖音基础技术团队自研的一款高性能AndroidTrace工具,它基于Systrace实现,并针对Systrace不足之处加以改进,核心改进...
你 发表评论:
欢迎- 一周热门
- 最近发表
-
- .NET 奇葩问题调试经历之3——使用了grpc通讯类库后,内存一直增长......
- 全局和隐式 using 指令详解(全局命令)
- 请停止微服务,做好单体的模块化才是王道:Spring Modulith介绍
- ASP.NET程序集引用之痛:版本冲突、依赖地狱等解析与实战
- .NET AOT 详解(.net 6 aot)
- 一款基于Yii2开发的免费商城系统(一款基于yii2开发的免费商城系统是什么)
- asar归档解包(游戏arc文件解包)
- 在PyCharm 中免费集成Amazon CodeWhisperer
- 2014年最优秀JavaScript编辑器大盘点
- 基于springboot、tio、oauth2.0前端vuede 超轻量级聊天软件分享
- 标签列表
-
- mybatis plus (70)
- scheduledtask (71)
- css滚动条 (60)
- java学生成绩管理系统 (59)
- 结构体数组 (69)
- databasemetadata (64)
- javastatic (68)
- jsp实用教程 (53)
- fontawesome (57)
- widget开发 (57)
- vb net教程 (62)
- hibernate 教程 (63)
- case语句 (57)
- svn连接 (74)
- directoryindex (69)
- session timeout (58)
- textbox换行 (67)
- extension_dir (64)
- linearlayout (58)
- vba高级教程 (75)
- iframe用法 (58)
- sqlparameter (59)
- trim函数 (59)
- flex布局 (63)
- contextloaderlistener (56)