百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 编程网 > 正文

Quartz 的启动流程分析 quartz启动不执行

yuyutoo 2024-11-01 15:55 3 浏览 0 评论

昨天写了篇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. 先读取配置文件
  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方法

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

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

后记

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


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

相关推荐

【Socket】解决UDP丢包问题

一、介绍UDP是一种不可靠的、无连接的、基于数据报的传输层协议。相比于TCP就比较简单,像写信一样,直接打包丢过去,就不用管了,而不用TCP这样的反复确认。所以UDP的优势就是速度快,开销小。但是随之...

深入学习IO多路复用select/poll/epoll实现原理

Linux服务器处理网络请求有三种机制,select、poll、epoll,本文打算深入学习下其实现原理。0.结论...

25-1-Python网络编程-基础概念

1-网络编程基础概念1-1-基本概念1-2-OSI七层网络模型OSI(开放系统互联)七层网络模型是国际标准化组织(ISO)提出的网络通信分层架构,用于描述计算机网络中数据传输的过程。...

Java NIO多路复用机制

NIO多路复用机制JavaNIO(Non-blockingI/O或NewI/O)是Java提供的用于执行非阻塞I/O操作的API,它极大地增强了Java在处理网络通信和文件系统访问方面的能力。N...

Python 网络编程完全指南:从零开始掌握 Socket 和网络工具

Python网络编程完全指南:从零开始掌握Socket和网络工具在现代应用开发中,网络编程是不可或缺的技能。Python提供了一系列高效的工具和库来处理网络通信、数据传输和协议操作。本指南将从...

Rust中的UDP编程:高效网络通信的实践指南

在实时性要求高、允许少量数据丢失的场景中,UDP(用户数据报协议)凭借其无连接、低延迟的特性成为理想选择。Rust语言凭借内存安全和高性能的特点,为UDP网络编程提供了强大的工具支持。本文将深入探讨如...

Python 网络编程的基础复习:理解Socket的作用

计算机网络的组成部分在逻辑上可以划分为这样的结构五层网络体系应用层:应用层是网络协议的最高层,解决的是具体应用问题...

25-2-Python网络编程-TCP 编程示例

2-TCP编程示例应用程序通常通过“套接字”(socket)向网络发出请求或者应答网络请求,使主机间或者一台计算机上的进程间可以通信。Python语言提供了两种访问网络服务的功能。...

linux下C++ socket网络编程——即时通信系统(含源码)

一:项目内容本项目使用C++实现一个具备服务器端和客户端即时通信且具有私聊功能的聊天室。目的是学习C++网络开发的基本概念,同时也可以熟悉下Linux下的C++程序编译和简单MakeFile编写二:需...

Python快速入门教程7:循环语句

一、循环语句简介循环语句用于重复执行一段代码块,直到满足特定条件为止。Python支持两种主要的循环结构:for循环和while循环。...

10分钟学会Socket通讯,学不会你打我

Socket通讯是软硬件直接常用的一种通讯方式,分为TCP和UDP通讯。在我的职业生涯中,有且仅用过一次UDP通讯。而TCP通讯系统却经常写,正好今天写了一个TCP通讯的软件。总结一下内容软件使用C#...

Python 高级编程之网络编程 Socket(六)

一、概述Python网络编程是指使用Python语言编写的网络应用程序。这种编程涉及到网络通信、套接字编程、协议解析等多种方面的知识。...

linux网络编程Socket之RST详解

产生RST的三个条件:1.目的地为某端口的SYN到达,然而该端口上没有正在监听的服务器;2.TCP想取消一个已有的连接;3.TCP接收到一个根本不存在的连接上的分节;现在模拟上面的三种情况:cl...

ABB机器人编程实用技巧,多项案例

...

Python中实现Socket通讯(附详细代码)

套接字(socket)是一种在计算机网络中进行进程间通信的方法,它允许不同主机上的程序通过网络相互通信。套接字是网络编程的基础,几乎所有的网络应用程序都使用某种形式的套接字来实现网络功能。套接字可以用...

取消回复欢迎 发表评论: