分布式任务调度QuartZ框架使用(通过注解使用quartz)

news/2024/11/24 8:57:00/

1、Quartz概述

quartz官网文档：http://www.quartz-scheduler.org/

quartz是一个定时调度的框架，属于比较早期的产品，现在市面上流行的xxl-Job，elastic-Job分布式调度框架都是基于该产品。虽然很多人说quartz的使用不是很方便，api不人性化。但是学习quartz还是有助于我们理解其他的框架。并且市面上依旧有大量的项目正在使用quartz。

Quartz能够与spring完美整合，使用Quartz可以开发多个定时任务，每个任务都可以单独指定触发的时间频率。例如每周日下午五点执行一次。

1.1、quartz使用场景及作用

1、运行定时任务、发送定时消息：如每天早上七点发送消息、定时生成报表、自动结账、自动更新静态数据、定时的数据备份。

2、定义周期任务：本质还是定时任务，在定时的基础上设置成周期任务。

3、分布式和集群能力：Quartz支持集群和分布式环境，

4、任务优先级和调度：Quartz允许你设置任务的优先级，并且可以基于优先级调度任务。这意味着，如果两个任务同时可用，那么优先级较高的任务会优先执行。

5、任务失败重试：Quartz可以配置任务失败时候的重试策略。

6、任务依赖关系：Quartz允许任务之间建立依赖关系，这使得任务调度更加灵活和可配置。

1.2、QuartZ的四大核心组件及关联

从图中可以看出QuartZ主要有四大核心：

1、调度器(Scheduler)：任务运行的容器或地点。

2、任务(JobDetail)：定时任务本身的消息，如任务的名称，组等。

3、触发器(Trigger)：任务触发规则，例如：每小时触发一次等。

4、任务：Job(任务的具体执行内容)

1、Scheduler详解:调度器，Quartz独立的运行容器。从图中可以看出，触发器(Trigger)和任务(JobDetail)都会被注册到Scheduler中。一个job可以被多个jobDetail装载，一个jobDetail可以被多个trigger来配置规则，但一个trigger只能装载一个jobDetail。当Trigger被触发时，对应的job就会执行。一个Job可以对应多个Trigger，但一个Trigger只能对应一个Job。任务：JobDetail。

2、触发器详解：Trigger，描述触发job执行的时间规则，实现类包括

SimpleTrigger简单触发器：实现固定时刻或固定间隔

CronTrigger触发器：基于Cron表达式触发器、

CalendarIntervalTrigger基于日历的触发器：如每个月的1 号15号执行。

DailyTimeIntervalTrigger基于日期的触发器，每天的固定时间

 其中CronTrigger可以通过cron表示式定义出复杂的调度方案，表达式使用地址如下：

   在线Cron表达式生成器

3、JobDetail详解：当Trigger被触发时，Quartz创建一个Job实例，对应的job就会执行。JobDetail就是用来描述Job实现类以及相关静态信息，比如任务在scheduler中的组名等信息。

4、Job详解：需要实现QuartzJobBean类重写executeInternal方法，在这个方法中创建具体的任务细节。

2、QuartZ快速上手案例

2.1、工程结构

2.2、创建springboot工程，引入quartz包

核心包：spring-boot-starter-quartz

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>3.1.6</version><relativePath/> <!-- lookup parent from repository --></parent><groupId>com.example</groupId><artifactId>quartzdemo1</artifactId><version>0.0.1-SNAPSHOT</version><name>quartzdemo1</name><description>quartzdemo1</description><properties><java.version>17</java.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-quartz</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><configuration><image><builder>paketobuildpacks/builder-jammy-base:latest</builder></image><excludes><exclude><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></exclude></excludes></configuration></plugin></plugins></build></project>

2.3、创建Quartz配置类

在配置类中配置触发器(Trigger)和任务(JobDetail)

但是此时的trigger没有设置时间规则，只会触发一次。

@Configuration
public class QuartzJobConfig {@Beanpublic JobDetail jobDetail(){JobDetail detail= JobBuilder.newJob(MyQuartzJob.class).withIdentity("job1","group1").storeDurably()//设置Job持久化//设置job数据.usingJobData("username","xiaochun").usingJobData("useraddr","安徽合肥").build();return detail;}//创建触发器，触发实例@Beanpublic Trigger trigger(){Trigger trigger= TriggerBuilder.newTrigger().forJob(jobDetail()).withIdentity("trigger1","group1").startNow().build();return trigger;}
}

2.4、创建JoB具体任务

@Slf4j
public class MyQuartzJob extends QuartzJobBean {@Overrideprotected void executeInternal(JobExecutionContext context) throws JobExecutionException {//执行的具体内容log.info("=========quartz具体内容============");}
}

2.5、启动工程后效果

如下图项目启动的时候，任务启动，但是只会启动一次。

2.6、通过CronScheduleBuilder配置时间规则

在上面案例的基础上配置时间规则，如每5秒执行一次。

表达式的使用可以使用官网中直接生成。

在线Cron表达式生成器：在线Cron表达式生成器

常用案例如下：

常用cron表达式例子

  （1）0/2 * * * * ?   表示每2秒 执行任务

  （1）0 0/2 * * * ?    表示每2分钟 执行任务

  （1）0 0 2 1 * ?   表示在每月的1日的凌晨2点调整任务

  （2）0 15 10 ? * MON-FRI   表示周一到周五每天上午10:15执行作业

  （3）0 15 10 ? 6L 2002-2006   表示2002-2006年的每个月的最后一个星期五上午10:15执行作

  （4）0 0 10,14,16 * * ?   每天上午10点，下午2点，4点 

  （5）0 0/30 9-17 * * ?   朝九晚五工作时间内每半小时 

  （6）0 0 12 ? * WED    表示每个星期三中午12点 

  （7）0 0 12 * * ?   每天中午12点触发 

  （8）0 15 10 ? * *    每天上午10:15触发 

  （9）0 15 10 * * ?     每天上午10:15触发 

  （10）0 15 10 * * ?    每天上午10:15触发 

  （11）0 15 10 * * ? 2005    2005年的每天上午10:15触发 

  （12）0 * 14 * * ?     在每天下午2点到下午2:59期间的每1分钟触发 

  （13）0 0/5 14 * * ?    在每天下午2点到下午2:55期间的每5分钟触发 

  （14）0 0/5 14,18 * * ?     在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发 

  （15）0 0-5 14 * * ?    在每天下午2点到下午2:05期间的每1分钟触发 

  （16）0 10,44 14 ? 3 WED    每年三月的星期三的下午2:10和2:44触发 

  （17）0 15 10 ? * MON-FRI    周一至周五的上午10:15触发 

  （18）0 15 10 15 * ?    每月15日上午10:15触发 

  （19）0 15 10 L * ?    每月最后一日的上午10:15触发 

  （20）0 15 10 ? * 6L    每月的最后一个星期五上午10:15触发 

  （21）0 15 10 ? * 6L 2002-2005   2002年至2005年的每月的最后一个星期五上午10:15触发 

  （22）0 15 10 ? * 6#3   每月的第三个星期五上午10:15触发

@Configuration
public class QuartzJobConfig {//每隔5秒执行一次CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0/5 * * * * ?");@Beanpublic JobDetail jobDetail(){JobDetail detail= JobBuilder.newJob(MyQuartzJob.class).withIdentity("job1","group1").storeDurably()//设置Job持久化//设置job数据.usingJobData("data","自定义数据").build();return detail;}//创建触发器，触发实例@Beanpublic Trigger trigger(){Trigger trigger= TriggerBuilder.newTrigger()//关联jobDetail.forJob(jobDetail()).withIdentity("trigger1","group1").withSchedule(cronScheduleBuilder).startNow().build();return trigger;}
}

输出结果

从结果可以看出：任务每隔五秒执行一次。

2.7、通过SimpleScheduleBuilder配置时间规则

如果时间规则没有name复杂，可以使用SimpleScheduleBuilder配置简单的时间规则。

withIntervalInSeconds(3)：时间规则为秒，还有小时，分钟，毫秒单位等。

@Configuration
public class QuartzJobConfig {@Beanpublic JobDetail jobDetail(){JobDetail detail= JobBuilder.newJob(MyQuartzJob.class).withIdentity("job1","group1").storeDurably()//设置Job持久化//设置job数据.usingJobData("username","xiaochun").usingJobData("useraddr","安徽合肥").build();return detail;}//创建触发器，触发实例@Beanpublic Trigger trigger(){Trigger trigger= TriggerBuilder.newTrigger()//关联jobDetail.forJob(jobDetail()).withIdentity("trigger1","group1").withSchedule(SimpleScheduleBuilder.simpleSchedule()//执行间隔.withIntervalInSeconds(3)//执行次数.repeatForever()).startNow().build();return trigger;}
}

输出结果

2.8、在Job中获取JobDetail中定义的信息

也就是获取JobDetail中通过//设置job数据.usingJobData("username","xiaochun")设置的参数，

通过context.getJobDetail().getJobDataMap().get("username")可以获取到。

@Slf4j
public class MyQuartzJob extends QuartzJobBean {@Overrideprotected void executeInternal(JobExecutionContext context) throws JobExecutionException {//执行的具体内容log.info("=========quartz具体内容============");System.out.println(context.getJobInstance());System.out.println(context.getJobDetail().getJobDataMap().get("username"));}
}

输出结果：

2.9、上面操作源码下载

源码下载：https://download.csdn.net/download/tangshiyilang/88632313

3、在springboot中通过注解使用quartz

@Scheduled   任务调度执行 注解用该注解修饰方法

@EnableScheduling  开启任务调度  需要配置在启动类上 

3.1、创建springboot工程配置包

核心类：spring-boot-starter-quartz

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>3.2.0</version><relativePath/> <!-- lookup parent from repository --></parent><groupId>com.txc</groupId><artifactId>quartzannotationdemo1</artifactId><version>0.0.1-SNAPSHOT</version><name>quartzannotationdemo1</name><description>quartzannotationdemo1</description><properties><java.version>17</java.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-quartz</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><configuration><excludes><exclude><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></exclude></excludes></configuration></plugin></plugins></build></project>

3.2、在启动类上开启任务调度

@EnableScheduling：开启任务调度

@SpringBootApplication
@EnableScheduling
public class Quartzannotationdemo1Application {public static void main(String[] args) {SpringApplication.run(Quartzannotationdemo1Application.class, args);}
}

3.3、任务调度快速使用

@Component
public class QuartzTimedTask {//每5s执行一次@Scheduled(cron = "0/5 * * * * ?")public void process(){System.out.println("======process======"+new Date());}
}

结果输出：

3.4、源码下载

https://download.csdn.net/download/tangshiyilang/88632535


http://www.ppmy.cn/news/1278831.html

相关文章

【Mysql】哪些sql无法使用到索引

【Mysql】哪些sql无法使用到索引

目录 1.使用 OR 连接多个条件&#xff1a; 2.使用 LIKE 通配符 % 作为前缀&#xff1a; 3.使用 BETWEEN 范围查询&#xff1a; 4.使用 ! 或 <> 操作符&#xff1a; 5.使用 DISTINCT 关键字&#xff1a; 6.使用 FUNCTION() 或 EXPRESSION 包含列&#xff1a; 7.使用…
阅读更多...
什么是数据仪表板？数据可视化仪表盘怎么制作？

什么是数据仪表板？数据可视化仪表盘怎么制作？

在数据经济时代&#xff0c;分析数据是每个企业做出最佳决策的关键。但是&#xff0c;手动分析和解释大量数据是不可行的。数据可视化对于分析数据中存在的各种有价值信息至关重要&#xff0c;包括可见趋势和隐藏趋势等。仪表盘显示可视化趋势和信息&#xff0c;例如 KPI、趋势…
阅读更多...
rich.sql

rich.sql

1、 CURRENT_TIMESTAMP 2、like concat (%,#{},%) 3、var num 2.446242342; num num.toFixed(2); // 输出结果为 2.45 4、left (case when hour(create_time) < 7 then DATE_ADD(create_time,INTERVAL -1 DAY) else create_time end ,10) as date 5、service mysqld …
阅读更多...
如何在Windows上搭建WebDAV服务并通过内网穿透实现公网访问

如何在Windows上搭建WebDAV服务并通过内网穿透实现公网访问

文章目录 前言1. 安装IIS必要WebDav组件2. 客户端测试3. 使用cpolar内网穿透&#xff0c;将WebDav服务暴露在公网3.1 安装cpolar内网穿透3.2 配置WebDav公网访问地址 4. 映射本地盘符访问 前言 在Windows上如何搭建WebDav&#xff0c;并且结合cpolar的内网穿透工具实现在公网访…
阅读更多...
俄罗斯联邦税务局遭乌克兰入侵，数据库和副本被清空，政府数据安全不容忽视

俄罗斯联邦税务局遭乌克兰入侵，数据库和副本被清空，政府数据安全不容忽视

俄罗斯联邦税务局遭乌克兰入侵&#xff0c;数据库和副本被清空&#xff0c;政府数据安全不容忽视 据相关报道&#xff0c;2023年12月12日&#xff0c;乌克兰国防情报局(GUR)称其成功入侵了俄罗斯联邦税务局&#xff08;FNS&#xff09;系统&#xff0c;并清除了该机构的数据库和…
阅读更多...
嵌入式中断理解

嵌入式中断理解

一、概念 中断&#xff1a; 在主程序运行过程中&#xff0c;出现了特定的中断触发条件&#xff08;中断源&#xff09;&#xff0c;使得CPU暂停当前正在运行的程序&#xff0c;转而去处理中断程序&#xff0c;处理完成后又返回原来被暂停的位置继续运行。 中断优先级&#x…
阅读更多...
Java学习系列（九）

Java学习系列（九）

1.枚举&#xff08;enum&#xff09; Java 枚举是一个特殊的类&#xff0c;一般表示一组常量。 如&#xff1a;一年的 4 个季节&#xff0c;一年的 12 个月份&#xff0c;一个星期的 7 天&#xff0c;方向有东南西北等。 enum Color { RED, GREEN, BLUE; } 枚举类使用 en…
阅读更多...
Spring接口返回的类型是json格式，里面字段对应base64格式的excel文件

Spring接口返回的类型是json格式，里面字段对应base64格式的excel文件

使用场景&#xff1a;需要对前端导入的excel文件中的内容进行验证&#xff0c;如期中有验证失败的信息需要转成excel反馈给前端&#xff0c;用户下载查看信息&#xff0c;并且前端需要获取json返回的状态&#xff0c;给用户提示失败或者成功&#xff0c;所以需要导出json的同时…
阅读更多...
最新文章

Copyright @ 2022~2023