0
点赞
收藏
分享

微信扫一扫

Quartz基本使用

殇感故事 2022-02-10 阅读 108

 (一)定时任务



Scheduled创建定时任务

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


cron表达式

cron 表达式是一个字符串 , 5 或者 6 个空格隔开 ( 示例中是被 5 个空格隔开 ), 字符串被切割为 6 个或者 7 个域 ,

每个域都代表不同的含义

 

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

列:

*/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 相同


 

2.SpringBoot整合Quartz框架

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

2.1创建项目

(1)创建SpringBoot项目,项目结构图如下:

 

2.2 创建定时任务实现类

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

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测试类中添加一个死循环,则只要项目不关闭,则会一直执行效果

运行效果如下:

 

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

任务存储方式

SchedulerFactory 调度器工厂

Scheduler 调度器 

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

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

一旦在 Scheduler 注册过了,当定时任务触发时间一到,调度程序就会负责执行预先定义的 Job

调度程序创建之后,处于 待机 状态,必须调用 scheduler start() 方法启用调度程序

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

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

执行

 Job 定时任务

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

当关联这个任务实例的触发器表明的执行时间到了的时候,调度程序 Scheduler 会调用这个方法来执行

任务,任务内容就可以在这个方法中执行

 实例化的过程

创建一个 Job 类,在调度程序中可以创建很多个 JobDetai ,分别设置不同的 JobDataMap

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

Trigger 触发器 

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

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

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

触发器常用属性

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

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

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

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

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

触发器的优先级

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

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

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

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

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

常见触发器

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

简单触发器 SimpleTrigger

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

绑定与启动

 代码如下:

注:实现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 {
    @Override
    public 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 {

    @Test
    void 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次

执行效果如下:

 

 

举报

相关推荐

0 条评论