Quartz.基本使用

一、定时任务

在很多情况下任务并非需要立即执行 , 而是需要往后或定期执行 , 这不可能人工去操作 , 所以定时任务就出现了

Scheduled 参数

@Scheduled(fixedRate=5000): 上⼀次开始执⾏时间点之后 5 秒再执⾏

@Scheduled(fixedDelay=5000): 上⼀次执⾏完毕时间点之后 5 秒再执⾏

@Scheduled(initialDelay=1000, fixedRate=5000): 第⼀次延迟 1 秒后执⾏ , 之后按 fixedRate 的规则每5 秒执⾏⼀次

@Scheduled(cron="*/5 * * * * *"): 通过 cron 表达式定义规则

1、Scheduled创建定时任务

①、在SpringBoot的启动类类中加⼊ @EnableScheduling 注解,启⽤定时任务的配置

②、创建定时任务实现类

package com.mwy.code;import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;import java.time.LocalDateTime;@Component
@Slf4j
public class Task {@Scheduled(fixedRate = 2000)public void work() {log.warn("现在时间：" + LocalDateTime.now());}
}

测试：

测试类测试只能执行一次，使用死循环执行多次

cron 表达式

cron 表达式是一个字符串 , 以 5 或者 6 个空格隔开 ( 示例中是被 5 个空格隔开 ), 字符串被切割为 6 个或者 7 个域 , 每个域都代表不同的含义

{Seconds} {Minutes} {Hours} {DayofMonth} {Month} {DayofWeek} {Year}

{Seconds} {Minutes} {Hours} {DayofMonth} {Month} {DayofWeek}

每个域都可以用数字表示,还可以出现如下特殊字符

* : 表示匹配该域的任意值 , 比如 Minutes 域使用 *, 就表示每分钟都会触发

- : 表示范围 , 比如 Minutes 域使用 10-20, 就表示从 10 分钟到 20 分钟每分钟都会触发一次

, : 表示列出枚举值 , 比如 Minutes 域使用 1,3. 就表示 1 分钟和 3 分钟都会触发一次

/ : 表示间隔时间触发 ( 开始时间 / 时间间隔 ), 例如在 Minutes 域使用 5/10, 就表示从第 5 分钟开始 , 每隔 10 分钟触发一次

? : 表示不指定值 , 简单理解就是忽略该字段的值 , 直接根据另一个字段的值触发执行

# : 表示该月第 n 个星期 x(x#n), 仅用星期域 , 如：星期： 6#3, 表示该月的第三个星期五

L : 表示最后 , 是单词 "last" 的缩写（最后一天或最后一个星期几）；仅出现在日和星期的域中 , 用在日则表示该月的最后一天, 用在星期则表示该月的最后一个星期 , 如：星期域上的值为 5L, 则表示该月最后一个星期的星期四, 在使用 'L' 时 , 不要指定列表 ',' 或范围 '-', 否则易导致出现意料之外的结果

W: 仅用在日的域中 , 表示距离当月给定日期最近的工作日（周一到周五） , 是词 "weekday" 的缩写

例如：

*/10 * * * * ?

0 */5 * * * ?

0 2,22,32 * * * ?

0 0 4-8 * * ?

0 0 2 * * ?

0 0 2 1 * ?

0 * 14 * * ?

0 0/5 14,18 * * ?

0 0-5 14 * * ?

0 10,44 14 ? 3 3

0 15 10 ? * MON-FRI

0 15 10 L * ? 0 15 10 ? * 6L 2002-2005

星期里， 1 表示的是星期天， 2 表示的是星期一，以此类推， 7 表示的是星期六

？只存在于某天或某星期中，且不能同时存在 ( 还不支持同时指定某天和星期 )

'L' 和 'W' 字符也可以在日期字段中组合以产生 'LW' ，这转换为 “ 最后一个工作日 ”

法定字符以及月份和星期的名称不区分大小写，如 MON 与 mon 相同

注意：日和星期不能同时出现

cron表达式的缺点：

1.任务在内存中执行，一旦系统断开，任务就消失了，任务数据也就没有了

2.不能实现共享，存在于本机内存中

二、Quartz创建定时任务

任务存储方式：

（1）内存方式(RAMJobStore) ：将任务临时存储到内存中，仅支持单项目部署，项目重启后任务会失效，不支持由调度器控制任务漂移，不建议使用。

（2）数据库方式(JDBCJobStore)： Quartz提供了多种数据库的所需表结构脚本，它内部通过 DataSource 来操作数据支持分布式方式部署、支持任务漂移，项目重启后任务不会丢失，直到任务执行完成后才会被从数据库内清除。

SchedulerFactory 调度器工厂：

SchedulerFactory factory = new StdSchedulerFactory();

Scheduler 调度器：

Scheduler scheduler = factory.getScheduler();

用于与调度程序交互的主程序接口 .

Scheduler 维护了一个 JobDetails 和 Triggers 的注册表。

一旦在 Scheduler 注册过了，当定时任务触发时间一到，调度程序就会负责执行预先定义的 Job调度程序创建之后，处于“ 待机 ” 状态，必须调用 scheduler 的 start() 方法启用调度程序

可以使用 shutdown() 方法关闭调度程序，使用 isShutdown() 方法判断该调度程序是否已经处于关闭状态

通过 Scheduler.scheduleJob(…) 方法将任务纳入调度程序中，当任务触发时间到了的时候，该任务将被执行

1、导入pom依赖

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-quartz</artifactId>
</dependency>

2、内存方式：

①、实例化调度器工厂：

StdSchedulerFactory：可读取配置文件

SchedulerFactory SchedulerFactory=new StdSchedulerFactory();

②、得到调度器

Scheduler 维护了一个 JobDetails（任务）和 Triggers（触发时间）的注册表

Scheduler scheduler = SchedulerFactory.getScheduler();

③、创建一个任务类MyJob，实现job接口成为一个任务，实现方法

任务是一个实现 org.quartz.Job 接口的类，任务类必须含有空构造器

当关联这个任务实例的触发器表明的执行时间到了的时候，调度程序 Scheduler 会调用这个方法来执行任务，任务内容就可以在这个方法中执行

JobDataMap 提供了一种 “ 初始化成员属性数据的机制 ”, 在实现该 Job 接口的时候可以取到需要的数据

JobDetail jobDetail = newJob(MyJob.class).withDescription("教员布置作业").withIdentity("敲代码", "Quartz的基本使用").usingJobData("name", "mwy").build();

context.getJobDetail().getKey() = name + group

④、创建触发器

触发器使用 TriggerBuilder 来实例化，有一个 TriggerKey 关联，在一个 Scheduler 中必须是唯一的。

多个触发器可以指向同一个工作，但一个触发器只能指向一个工作。

触发器可以传送数据给 job ，通过将数据放进触发器的 JobDataMap 。

触发器常用属性

触发器也有很多属性，这些属性都是在使用 TriggerBuilder 定义触发器时设置的。

TriggerKey ，唯一标识，在一个 Scheduler 中必须是唯一的

startTime ，开始时间，通常使用 startAt(java.util.Date)

endTime ，结束时间，设置了结束时间则在这之后，不再触发

Trigger trigger = TriggerBuilder.newTrigger().withDescription("写作业触发器").withIdentity("敲代码", "Quartz的基本使用").startAt(new Date()).build();

如果没有使用 withIdentity(..) 会自动生成一个触发器名称。

触发器的优先级

有时候，会安排很多任务，但是 Quartz 并没有更多的资源去处理它。

这种情况下，必须需要很好地控制哪个任务先执行。这时候可以设置 priority 属性（使用方法

withPriority(int) ）来控制触发器的优先级。

优先级只有触发器出发时间一样的时候才有意义。

当一个任务请求恢复执行时，它的优先级和原始优先级是一样的。

常见触发器

TriggerBuilder 用于创建 Trigger ，如果没有调用 withSchedule(..) 方法，会使用默认的 schedule 。

简单触发器 SimpleTrigger

SimpleTrigger 包含几个特点：开始时间、结束时间、重复次数以及重复执行的时间间隔

基于 Cron 表达式的触发器 CronTrigger

Trigger trigger = TriggerBuilder . newTrigger ()

. withIdentity ( "test" , "test" )

. withDescription ( " 测试的触发器 " )

. withSchedule ( CronScheduleBuilder . cronSchedule ( "2 * * * * *" ))

. build ();

⑤、将触发器和任务绑定到调度器

scheduler.scheduleJob(jobDetail,trigger);

⑥、启动调度器

scheduler.start();

⑦、测试结果

3、 job和jobDetail的区别

job是任务模板，jobDetail是实例

①、创建两个jobDetail实例，usingJobData不同

②、在任务模板中获取到name属性（MyJob）

package com.mwy.code;
import lombok.extern.slf4j.Slf4j;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
@Slf4j
public class MyJob implements Job {@Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {Object name= context.getJobDetail().getJobDataMap().get("name");log.warn(name+"写作业");}
}

运行结果：

如果想要放入很多数据，可以用JobDataMap集合

③、设置时间以及执行次数

SimpleTrigger 特点：开始时间、结束时间、重复次数以及重复执行的时间间隔。

Trigger trigger = TriggerBuilder.newTrigger().withDescription("写作业触发器").withIdentity("敲代码", "Quartz的基本使用").startAt(new Date()).withSchedule(simpleSchedule().withIntervalInSeconds(1)//时间间隔.withRepeatCount(SimpleTrigger.REPEAT_INDEFINITELY) //SimpleTrigger.REPEAT_INDEFINITELY).build();

Cron生成器： http://cron.ciding.cc/

基于 Cron 表达式的触发器 CronTrigger

Trigger trigger = TriggerBuilder.newTrigger().withDescription("写作业触发器").withIdentity("敲代码", "Quartz的基本使用").startAt(new Date()).withSchedule(CronScheduleBuilder.cronSchedule("* * * * * ?")).build();