文章目录
前言
为什么需要Quartz
所谓"调度"就是制定好的什么时间做什么事情的计划
我们使用过的最简单的调度方法就是Timer
但是Timer的调度功能过于单一,只能是指定时间的延时调用和周期运行
而Quartz可以更详细的指定时间,进行计划调用
提示:以下是本篇文章正文内容,下面案例可供参考
一、什么是Quartz
quartz:石英钟的意思
是一个当今市面上流行的高效的任务调度管理工具
所谓"调度"就是制定好的什么时间做什么事情的计划
由OpenSymphony开源组织开发
是java编写的,我们使用时需要导入依赖即可
二、使用Quartz
1.Quartz核心组件
调度器:Scheduler
任务:job
触发器:Trigger
调度器来配置\计划什么时间触发什么任务
简单来说就是调度器规定什么时间做什么事情
-
job(工作\任务):Quartz 实现过程中是一个接口,接口中有一个方法execute(执行的意思)
我们创建一个类,实现这个接口,在方法中编写要进行的操作(执行具体任务)
我们还需要一个JobDetail的类型的对象,Quartz每次执行job时
会实例化job类型对象,去调用这个方法,JobDetail是用来描述Job实现类的静态信息,
比如任务运行时在Quartz中的名称
-
Trigger(触发器):能够描述触发指定job的规则,分为简单触发和复杂触发
简单触发可以使用SimplTrigger实现类.功能类似timer
复杂触发可以使用CronTrigger实现类,内部利用cron表达式描述各种复杂的时间调度计划
-
Scheduler(调度器):一个可以规定哪个触发器绑定哪个job的容器
在调度器中保存全部的Quartz 保存的任务
SpringBoot框架下,添加Quartz依赖后,调度器由SpringBoot管理,我们不需要编写
2.Cron表达式
表示2022年9月3日凌晨4点的cron表达式
0 0 4 3 9 ? 2022
-
* 表示任何值,如果在分的字段上编写*,表示每分钟都会触发
-
, 是个分割符如果秒字段我想20秒和40秒时触发两次就写 20,40
-
- 表示一个区间 秒字段5-10 表示 5,6,7,8,9,10
-
/ 表示递增触发 秒字段 5/10表示5秒开始每隔10秒触发一次
日字段编写1/3表示从每月1日起每隔3天触发一次
-
? 表示不确定值, 因为我们在定日期时,一般确定日期就不确定是周几,相反确定周几时就不确定日期
-
L 表示last最后的意思,我们可以设置当月的最后一天,就会在日字段用L表示,
周字段使用L表示最后一周,一般会和1-7的数字组合
例如6L表示本月最后一周的周五
-
W (work)表示最近的工作日(单纯的周一到周五) 如果日字段编写15W表示
每月15日最近的工作日触发,如果15日是周六就14日触发,如果15日是周日就16日触发
LW通常一起使用,表示本月的最后一个工作日
-
# 表示第几个,只能使用在周字段上,6#3表示每月的第三个周五
如果#后面数字写大了,是一个不存在的日期,那就不运行了
适合设计在母亲节或父亲节这样的日期运行
网络上可用的Cron表达式生成器很多
推荐一个http://cron.ciding.cc/
未来每年的母亲节(时间9点)
0 0 9 ? 5 1#2
3.SpringBoot使用Quartz
SpringBoot框架下使用Quartz格式还是非常固定的
我们选用之前学习微服务的项目csmall为例,实现每隔2分钟运行一次添加库存的操作
首先添加依赖
我们选项csmall-stock-webapi模块pom文件
<dependency> <groupId>org.springframework.bootgroupId> <artifactId>spring-boot-starter-quartzartifactId>dependency>
先编写要执行的任务
当前项目模块中创建quartz包
包中创建一个QuartzAddStock的类,实现Job接口
代码如下
public class QuartzAddStock implements Job { @Autowired private IStockService stockService; @Override public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { StockReduceCountDTO countDTO=new StockReduceCountDTO(); countDTO.setCommodityCode("PC100"); countDTO.setReduceCount(-10); stockService.reduceCommodityCount(countDTO); System.out.println("定时增加库存完成!"); }}
上面编写的是Job接口的实现类,要想运行还需要将它封装为JobDetail对象保存在Spring容器中
还有要创建一个Trigger设置要运行的时机,也保存到Spring容器中
在quartz包下,再创建一个QuartzConfig类,其中编写它们的调度绑定关系
这个格式是固定的,后面再需要绑定,直接套用即可
// 要配置Quartz的调度器Scheduler// 调度器由SpringBoot管理,所以就变成了配置Spring@Configurationpublic class QuartzConfig { // 配置的核心是向Spring容器保存一个job和保存一个Trigger // 创建一个封装Job对象的类型JobDetail // 使用@Bean注解标记的方法将这个对象保存到Spring容器@Beanpublic JobDetail addStock(){//newJob方法就是在绑定要运行的Job接口实现类,需要实现类的反射做参数 return JobBuilder.newJob(QuartzAddStock.class) // 给当前JobDetail对象在调度环境中起名 .withIdentity("addStock") // 即使没有触发器绑定当前JobDetail对象,也不会被删除 .storeDurably() .build();}// 下面是触发器的声明,也会保存到Spring容器中// 它能够设置job的运行时机@Beanpublic Trigger addStockTrigger(){System.out.println("Trigger保存到Spring容器中"); // 定义Cron表达式 CronScheduleBuilder cron= CronScheduleBuilder.cronSchedule("0 0/2 * * * ?"); return TriggerBuilder.newTrigger() // 绑定要运行的JobDetail对象 .forJob(addStock()) // 为触发器起名 .withIdentity("addStockTrigger") // 绑定cron表达式 .withSchedule(cron) .build();}}
总结
提示:这里对文章进行总结:
以上就是今天要讲的内容,本文仅仅简单介绍了SpringBoot使用Quartz的基本步骤。
来源地址:https://blog.csdn.net/weixin_43816557/article/details/128135201