Quartz.基本使用

一、定时任务

Scheduled 参数 @Scheduled(fixedRate=5000): 上⼀次开始执⾏时间点之后 5 秒再执⾏ @Scheduled(fixedDelay=5000): 上⼀次执⾏完毕时间点之后 5 秒再执⾏ @Scheduled(initialDelay=1000, fixedRate=5000): 第⼀次延迟 1 秒后执⾏ , 之后按 fixedRate 的规则 每5 秒执⾏⼀次 @Scheduled(cron="*/5 * * * * *"): 通过 cron 表达式定义规则

1、Scheduled创建定时任务

 ②、创建定时任务实现类

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依赖

org.springframework.bootspring-boot-starter-quartz

2、内存方式：

①、实例化调度器工厂：

StdSchedulerFactory：可读取配置文件

SchedulerFactory SchedulerFactory=new StdSchedulerFactory();

②、得到调度器

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

Scheduler scheduler = SchedulerFactory.getScheduler();

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

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

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

④、创建触发器

触发器常用属性 触发器也有很多属性，这些属性都是在使用 TriggerBuilder 定义触发器时设置的。 TriggerKey ，唯一标识，在一个 Scheduler 中必须是唯一的 startTime ，开始时间，通常使用 startAt(java.util.Date) endTime ，结束时间，设置了结束时间则在这之后，不再触发

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

触发器的优先级 有时候，会安排很多任务，但是 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();

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！