（一）定时任务

---

Scheduled创建定时任务

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

---

cron表达式

{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" 的缩写

---

 

2.SpringBoot整合Quartz框架

【示例】创建SpringBoot项目并整合Quartz框架，实现定时任务功能。

2.1创建项目

（1）创建SpringBoot项目，项目结构图如下：

 

2.2 创建定时任务实现类

注：要导入Slf4j日志的主键，在pox.xml中添加此依赖

<dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId>
</dependency>

SpringBoot自带的调度器 

@Component
@Slf4j
public class Task {//fixedRate 上⼀次开始执⾏时间点之后5秒再执⾏//fixedDelay 上⼀次执⾏完毕时间点之后5秒再执⾏//initialDelay :第⼀次延迟1秒后执⾏,之后按fixedRate的规则,每5秒执⾏⼀次//cron="*/5 * * * * *" 每隔五秒执行一次//cron="10 10 * * * ?" 每隔一个小时的第10分 第10秒执行一次@Scheduled(cron="10 10 * * * ?")public void test(){log.warn("现在时间：" + LocalDateTime.now());}
}

在测试类test运行效果如下：

 注：如果在test测试类中添加一个死循环，则只要项目不关闭，则会一直执行效果

运行效果如下：

@Test
void contextLoads() throws Exception{
while (true){}

}

 

 Scheduled参数

---

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

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

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

每5秒执⾏⼀次

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

 

3.Quartz创建定时任务

（1）使用Maven在pox.xml中添加Quartz依赖

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

任务存储方式

内存方式 (RAMJobStore) ：将任务临时存储到内存中，仅支持单项目部署，项目重启后任务会失效，不

支持由调度器控制任务漂移，不建议使用。

数据库方式 (JDBCJobStore) ： Quartz 提供了多种数据库的所需表结构脚本，它内部通过 DataSource 来

操作数据，支持分布式方式部署、支持任务漂移，项目重启后任务不会丢失，直到任务执行完成后才会

被从数据库内清除。

SchedulerFactory 调度器工厂

SchedulerFactory factory = new StdSchedulerFactory() 

Scheduler 调度器 

Scheduler scheduler = factory.getScheduler()

 Job 定时任务

 实例化的过程

创建一个类 SalesReportJob 实现 Job 接口，用做销售报表使用。

可以通过 JobDataMap 指定销售员的名称和销售报表的依据等等。

这就会创建多个 JobDetails ，例如 SalesReportForJoe ， SalesReportForMike 分别对应在

JobDataMap 中指定的名字 joe 和 mike 。

JobBuilder 用于创建 JobDetail，如果没有调用 withIdentity 指定 job 的名字，会自动生成一个。

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

Trigger 触发器 

 代码如下：

注：实现Job接口，实现pulic void execute方法

MyJob类

package com.yk.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+"搞卫生");}
}

测试类 

package com.yk.code;import org.junit.jupiter.api.Test;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import org.springframework.boot.test.context.SpringBootTest;import java.util.Date;import static org.quartz.JobBuilder.newJob;@SpringBootTest
class Quartz01ApplicationTests {@Testvoid contextLoads() throws Exception{//1.实例化调度器工厂SchedulerFactory factory = new StdSchedulerFactory();//2.得到调度器Scheduler scheduler = factory.getScheduler();//3.创建任务//job（模板）  jobDetail（实例）JobDetail jobDetail = newJob(MyJob.class).withDescription("开年大扫除")//描述.withIdentity("a", "b")//任务id a+b.usingJobData("name","张三").build();//构建调度器JobDetail jobDetail02 = newJob(MyJob.class).withDescription("开年大扫除")//描述.withIdentity("a", "b")//任务id a+b.usingJobData("name","李四").build();//构建调度器//4.创建触发器Trigger trigger = TriggerBuilder.newTrigger().withDescription("大扫除触发器")//描述.withIdentity("c", "d")//任务id c+d.startAt(new Date())//触发时间.build();//构建//5.将触发器和任务绑定到哪里去？ 调度器scheduler.scheduleJob(jobDetail,trigger);//6.启动调度器scheduler.start();}}

执行效果如下：

 

注：在第六步后面加上一个死循环就是每一秒钟循环输出10次

while (true){ }

执行效果如下：