飞哥的技术博客

quartz

author iconjokereye icon...calendar icon2021年10月12日timer icon大约 17 分钟
文章链接
https://gitee.com/fakerlove/quartz

quartz

1. 简介

1.1 概念

官网

http://www.quartz-scheduler.org/

学习文档

https://www.w3cschool.cn/quartz_doc/

简介

Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目，完全由Java开发，可以用来执行定时任务，类似于java.util.Timer。但是相较于Timer， Quartz增加了很多功能：

  • 持久性作业 - 就是保持调度定时的状态;
  • 作业管理 - 对调度作业进行有效的管理;

1.2 组成部分

  • 调度器：Scheduler
  • 任务：JobDetail
  • 触发器：Trigger，包括SimpleTrigger和CronTrigger

1.3 设计模式

  • Builer模式
  • Factory模式
  • 组件模式
  • 链式写法

2. 讲解

2.1 入门demo

引入依赖

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>org.example</groupId>
    <artifactId>quartz-demo</artifactId>
    <version>1.0-SNAPSHOT</version>

    <properties>
        <maven.compiler.source>11</maven.compiler.source>
        <maven.compiler.target>11</maven.compiler.target>
    </properties>


    <dependencies>
        <!-- https://mvnrepository.com/artifact/org.quartz-scheduler/quartz -->
        <dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz</artifactId>
            <version>2.3.2</version>
        </dependency>

        <!--        工具类的包-->
        <dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz-jobs</artifactId>
            <version>2.3.2</version>
        </dependency>

        <!--        日志包-->
        <!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-log4j12 -->
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
            <version>2.0.0-alpha1</version>
        </dependency>

        <!-- https://mvnrepository.com/artifact/log4j/log4j -->
        <!-- https://mvnrepository.com/artifact/org.apache.logging.log4j/log4j-core -->
        <dependency>
            <groupId>org.apache.logging.log4j</groupId>
            <artifactId>log4j-core</artifactId>
            <version>2.14.0</version>
        </dependency>

        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-simple</artifactId>
            <version>1.7.25</version>
            <scope>compile</scope>
        </dependency>



        <!--        &lt;!&ndash; https://mvnrepository.com/artifact/org.slf4j/slf4j-simple &ndash;&gt;-->
<!--        <dependency>-->
<!--            <groupId>org.slf4j</groupId>-->
<!--            <artifactId>slf4j-simple</artifactId>-->
<!--            <version>2.0.0-alpha1</version>-->
<!--            <scope>compile</scope>-->
<!--        </dependency>-->

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.14</version>
            <scope>provided</scope>
        </dependency>
    </dependencies>


</project>

创建log4j.properties

log4j.rootLogger=debug,stdout,DAILY_ROLLING_FILE

log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d %p [%c] - %m%n

########################
# DailyRolling File
########################
log4j.appender.DAILY_ROLLING_FILE=org.apache.log4j.DailyRollingFileAppender
log4j.appender.DAILY_ROLLING_FILE.Append=true
log4j.appender.DAILY_ROLLING_FILE.Threshold=debug
log4j.appender.DAILY_ROLLING_FILE.Encoding=UTF-8

#通过读取系统变量来制定日志目标位置
log4j.appender.DAILY_ROLLING_FILE.File=${logDir}/log.txt
log4j.appender.DAILY_ROLLING_FILE.DatePattern='.'yyyy-MM-dd
log4j.appender.DAILY_ROLLING_FILE.layout=org.apache.log4j.PatternLayout
log4j.appender.DAILY_ROLLING_FILE.layout.ConversionPattern=[%-5p] %d{yyyy-MM-dd HH:mm:ss,SSS} [%c] %m%n

###################
# Console Appender
###################
log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
log4j.appender.Threshold=debug
log4j.appender.CONSOLE.Target=System.out
log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
log4j.appender.CONSOLE.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %5p (%c:%L) - %m%n

###################
#指定特定类的输出级别
###################
#指定struts2日志级别
#log4j.logger.com.opensymphony.xwork2=info
#log4j.logger.org.apache.struts2=info
#指定某个类的日志级别
#log4j.logger.com.test.LogTest=info

创建job

package com.ak.demo.myjob;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.SchedulerException;

import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
import java.util.Date;

/**
 * 自定义业务
 */
public class HelloJob implements Job {

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
          System.out.println(new  SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
    }

}

注册job,并执行

package com.ak.demo;

import com.ak.demo.myjob.HelloJob;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;

public class MyTest {
    public static void main(String[] args) throws SchedulerException {

        //创建一个scheduler
        Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();

        //创建一个job,和Helloword 完成绑定
        JobDetail job = JobBuilder.newJob(HelloJob.class)
                // 放入job 业务中的数据
                 // 参数一： 任务的实例（唯一），任务组的名称
                .withIdentity("myjob", "mygroup")
                .build();

        //创建一个Trigger
        Trigger trigger = TriggerBuilder.newTrigger()
                // 触发器的名称 ，参数二：触发器的 组
                .withIdentity("trigger1", "group1")
                // 设置
                .withSchedule(
                        SimpleScheduleBuilder
                        .simpleSchedule()
                                // 3秒钟重复 执行一次
                        .withIntervalInSeconds(3)
                                // 一直重复下去
                        .repeatForever())
                .build();

        //注册trigger并启动scheduler
        scheduler.scheduleJob(job,trigger);

        // 触发器开始执行
        scheduler.start();

    }
}

结果

image-20210117123116663

2.2 Job 和JobDetail

每次执行任务时，都会实例化一个新的job,

jobDetail 为job实例提供了许多设置属性，以及jobDetaMap成员属性，它用来存储特定job实例的状态信息，调度器需要借助jobDetail 对象添加job 实例

具体代码

package com.ak.demo;

import com.ak.demo.myjob.HelloJob;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;

public class MyTest {
    public static void main(String[] args) throws SchedulerException {

        //创建一个scheduler
        Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();

        //创建一个job,和Helloword 完成绑定
        JobDetail job = JobBuilder.newJob(HelloJob.class)
                // 放入job 业务中的数据
                 // 参数一： 任务的实例（唯一），任务组的名称
                .withIdentity("myjob", "mygroup")
                .build();

        System.out.println("job的名称"+job.getKey().getName());
        System.out.println("job的组的名称"+job.getKey().getGroup());
        System.out.println("job 实例的名称"+job.getJobClass().getName());
        //创建一个Trigger
        Trigger trigger = TriggerBuilder.newTrigger()
                // 触发器的名称 ，参数二：触发器的 组
                .withIdentity("trigger1", "group1")
                // 设置
                .withSchedule(
                        SimpleScheduleBuilder
                        .simpleSchedule()
                                // 3秒钟重复 执行一次
                        .withIntervalInSeconds(3)
                                // 一直重复下去
                        .repeatForever())
                .build();

        //注册trigger并启动scheduler
        scheduler.scheduleJob(job,trigger);

        // 触发器开始执行
        scheduler.start();

    }
}

重要部分

System.out.println("job的名称"+job.getKey().getName());
System.out.println("job的组的名称"+job.getKey().getGroup());
System.out.println("job 实例的名称"+job.getJobClass().getName());

结果

job的名称myjob
job的组的名称mygroup
job 实例的名称com.ak.demo.myjob.HelloJob

2.3 jobDataMap-参数传递

jobExecutionContext

  • 当Scheduler 调用job,就会将JobExecutionContext 传递给Job 的Execute方法
  • job能通过JobExecutionContext 对象访问到Quartz 运行时的环境以及job 本身详细的数据

JobDataMap

  • 在进行任务调度是，JobDataMap 存储咋JobExecuteContext 中，十分方便获取
  • JobDataMap 可以用来装在任何可序列化的数据对象，当Job实例对象被执行时，这些参数对象会传递给它
  • JobDataMap 兑现了JDK的Map 接口，并且添加了非常方便的方法用来存储基本数据类型

创建job

package com.ak.demo.myjob;

import org.quartz.*;

import java.time.LocalDateTime;

public class HelloJobDataMap implements Job{

        @Override
        public void execute(JobExecutionContext context) throws JobExecutionException {
            System.out.println("工作任务名称"+context.getJobDetail().getKey().getName());
            System.out.println("工作组的名称"+context.getJobDetail().getKey().getGroup());
            System.out.println("任务类的名称"+context.getJobDetail().getJobClass().getName());
            // 这个是触发器的内容
            Object tv1 = context.getTrigger().getJobDataMap().get("t1");
            Object tv2 = context.getTrigger().getJobDataMap().get("t2");
            // 这个是JobDetail 中的内容
            Object jv1 = context.getJobDetail().getJobDataMap().get("job1");
            Object jv2 = context.getJobDetail().getJobDataMap().get("j2");

            // 这个是Scheduler 中的内容
            Object sv = null;
            try {
                // 获取
                sv = context.getScheduler().getContext().get("skey");
            } catch (SchedulerException e) {
                e.printStackTrace();
            }
            System.out.println(tv1+":"+tv2);
            System.out.println(jv1+":"+jv2);
            System.out.println(sv);
            // 打印当地时间
            System.out.println("hello:"+ LocalDateTime.now());
        }

}

注册job

package com.ak.demo;

import com.ak.demo.myjob.HelloJob;
import com.ak.demo.myjob.HelloJobDataMap;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;

public class MyTestJobDataMap {
    public static void main(String[] args) throws SchedulerException {

        //创建一个scheduler
        Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
        // scheduler 中放置值
        scheduler.getContext().put("skey", "svalue");

        //创建一个job,和Helloword 完成绑定
        JobDetail job = JobBuilder.newJob(HelloJobDataMap.class)
                // 放入job 业务中的数据
                .usingJobData("job1", "job1_value_1")
                 // 参数一： 任务的实例（唯一），任务组的名称
                .withIdentity("myjob", "mygroup")
                .build();

        System.out.println("job的名称"+job.getKey().getName());
        System.out.println("job的组的名称"+job.getKey().getGroup());
        System.out.println("job 实例的名称"+job.getJobClass().getName());
        // job 业务中的一个值，
        job.getJobDataMap().put("j2", "jv2");

        //创建一个Trigger
        Trigger trigger = TriggerBuilder.newTrigger()
                // 触发器的名称 ，参数二：触发器的 组
                .withIdentity("trigger1", "group1")
                // 放置job 业务中的数据
                .usingJobData("t1", "tv1")
                // 设置
                .withSchedule(
                        SimpleScheduleBuilder
                        .simpleSchedule()
                                // 3秒钟重复 执行一次
                        .withIntervalInSeconds(3)
                                // 一直重复下去
                        .repeatForever())
                .build();

        // 触发器中放置数据
        trigger.getJobDataMap().put("t2", "tv2");

        //注册trigger并启动scheduler
        scheduler.scheduleJob(job,trigger);

        // 触发器开始执行
        scheduler.start();

    }
}

结果

image-20210117120449689

2.4 有状态的job和无状态job

@PersistJobDataAfterExecution

创建job

package com.ak.demo.myjob;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.PersistJobDataAfterExecution;

import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * 自定义业务
 */
@PersistJobDataAfterExecution
public class HelloJobPersist implements Job {
    private Integer count=0;

    public void setCount(Integer count) {
        this.count = count;
    }

    /**
     * 虽说每次都是创建新的，但是其中的 jobDataMap都一直延续了下去
     * @param context
     * @throws JobExecutionException
     */
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
          this.count=(Integer) context.getJobDetail().getJobDataMap().get("count");
          count++;
          System.out.println(count);
          context.getJobDetail().getJobDataMap().put("count",count);
    }

}

注册job

package com.ak.demo;

import com.ak.demo.myjob.HelloJob;
import com.ak.demo.myjob.HelloJobPersist;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;

public class MyTestPersist {
    public static void main(String[] args) throws SchedulerException {

        //创建一个scheduler
        Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();

        //创建一个job,和Helloword 完成绑定
        JobDetail job = JobBuilder.newJob(HelloJobPersist.class)
                // 放入job 业务中的数据
                 // 参数一： 任务的实例（唯一），任务组的名称

                .withIdentity("myjob", "mygroup")
                // 设置计数器
                .usingJobData("count",0)
                .build();

        //创建一个Trigger
        Trigger trigger = TriggerBuilder.newTrigger()
                // 触发器的名称 ，参数二：触发器的 组
                .withIdentity("trigger1", "group1")
                // 设置
                .withSchedule(
                        SimpleScheduleBuilder
                        .simpleSchedule()
                                // 3秒钟重复 执行一次
                        .withIntervalInSeconds(3)
                                // 一直重复下去
                        .repeatForever())
                .build();

        //注册trigger并启动scheduler
        scheduler.scheduleJob(job,trigger);

        // 触发器开始执行
        scheduler.start();

    }
}

结果

image-20210117191301886

3. 触发器

3.1 触发器

package com.ak.demo.trigger;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.Trigger;

import java.text.SimpleDateFormat;

public class HelloTrigger implements Job {
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        Trigger trigger=context.getTrigger();
        SimpleDateFormat dateFormat=new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");

        System.out.println("开始时间"+dateFormat.format(trigger.getStartTime()));
        System.out.println("结束时间"+dateFormat.format(trigger.getEndTime()));
    }
}

注册job

package com.ak.demo;

import com.ak.demo.trigger.HelloTrigger;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;

import java.time.LocalDateTime;
import java.util.Date;

public class MyHelloTrigger {
    public static void main(String[] args) throws SchedulerException {

        Scheduler scheduler= StdSchedulerFactory.getDefaultScheduler();

        JobDetail jobDetail= JobBuilder.newJob(HelloTrigger.class)
                .withIdentity("trigger","group1")
                .usingJobData("joker","data1")
                .build();

        Date start=new Date();
        start.setTime(System.currentTimeMillis()+3000);
        Date end=new Date();
        end.setTime(System.currentTimeMillis()+10000);
        Trigger trigger=TriggerBuilder.newTrigger()
                .withIdentity("trigger","group1")
                .startAt(start)
                .endAt(end)
                .build();
        scheduler.scheduleJob(jobDetail,trigger);

        scheduler.start();
    }
}

3.2 SimpleTrigger

在指定间隔内执行

package com.ak.demo.trigger;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.Trigger;

import java.text.SimpleDateFormat;

public class HelloSimpleTrigger implements Job {
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        Trigger trigger=context.getTrigger();
        SimpleDateFormat dateFormat=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

        System.out.println("开始时间"+dateFormat.format(trigger.getStartTime()));
        System.out.println("结束时间"+dateFormat.format(trigger.getEndTime()));
        System.out.println();
    }
}

注册job

package com.ak.demo;

import com.ak.demo.trigger.HelloSimpleTrigger;
import com.ak.demo.trigger.HelloTrigger;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;

import java.util.Date;

public class MyHelloSimpleTrigger {
    public static void main(String[] args) throws SchedulerException {

        Scheduler scheduler= StdSchedulerFactory.getDefaultScheduler();

        JobDetail jobDetail= JobBuilder.newJob(HelloSimpleTrigger.class)
                .withIdentity("trigger","group1")
                .usingJobData("joker","data1")
                .build();

        Date start=new Date();
        start.setTime(System.currentTimeMillis()+1000);
        Date end=new Date();

        end.setTime(System.currentTimeMillis()+10000);
        Trigger trigger=TriggerBuilder.newTrigger()
                .withIdentity("trigger","group1")
                .startAt(start)
                .endAt(end)
                // 启动时间1 秒后
                // 结束时间10 秒后
                // 期间运行每隔 3秒运行一次
                .withSchedule(SimpleScheduleBuilder
                        .simpleSchedule()
                        .withIntervalInSeconds(3)
                        .repeatForever()
                )
                .build();
        scheduler.scheduleJob(jobDetail,trigger);
        scheduler.start();
    }
}

结果

image-20210117200105197

3.3 CronTrigger

如果需要像日历一样按日程来做任务，而不是像SimpleTrigger 特定的时间触发，CronTriggers 通常比SimpleTrigger 更有用，因为它是基于日历的作业调度器

3.3.1 cron expression 表达式

在线生成表达式网址

https://cron.qqe2.com/

{秒数} {分钟} {小时} {日期} {月份} {星期} {年份(可为空)}

{秒数} ==> 允许值范围: 0~59 ,不允许为空值，若值不合法，调度器将抛出SchedulerException异常

"*" 代表每隔1秒钟触发；

"," 代表在指定的秒数触发，比如"0,15,45"代表0秒、15秒和45秒时触发任务

"-" 代表在指定的范围内触发，比如"25-45"代表从25秒开始触发到45秒结束触发，每隔1秒触发1次

"/" 代表触发步进(step)，"/"前面的值代表初始值(""等同"0")，后面的值代表偏移量，比如"0/20"或者"/20"代表从0秒钟开始，每隔20秒钟触发1次，即0秒触发1次，20秒触发1次，40秒触发1次；"5/20"代表5秒触发1次，25秒触发1次，45秒触发1次；"10-45/20"代表在[10,45]内步进20秒命中的时间点触发，即10秒触发1次，30秒触发1次

{分钟} ==> 允许值范围: 0~59 ,不允许为空值，若值不合法，调度器将抛出SchedulerException异常

"*" 代表每隔1分钟触发；

"," 代表在指定的分钟触发，比如"10,20,40"代表10分钟、20分钟和40分钟时触发任务

"-" 代表在指定的范围内触发，比如"5-30"代表从5分钟开始触发到30分钟结束触 发，每隔1分钟触发

"/" 代表触发步进(step)，"/"前面的值代表初始值(""等同"0")，后面的值代表偏移量，比如"0/25"或者"/25"代表从0分钟开始，每隔25分钟触发1次，即0分钟触发1次，第25分钟触发1次，第50分钟触发1次；"5/25"代表5分钟触发1次，30分钟触发1次，55分钟触发1次；"10-45/20"代表在[10,45]内步进20分钟命中的时间点触发，即10分钟触发1次，30分钟触发1次

{小时} ==> 允许值范围: 0~23 ,不允许为空值，若值不合法，调度器将抛出SchedulerException异常

"*" 代表每隔1小时触发；

"," 代表在指定的时间点触发，比如"10,20,23"代表10点钟、20点钟和23点触发任务

"-" 代表在指定的时间段内触发，比如"20-23"代表从20点开始触发到23点结束触发，每隔1小时触发

"/" 代表触发步进(step)，"/"前面的值代表初始值(""等同"0")，后面的值代表偏移量，比如"0/1"或者"/1"代表从0点开始触发，每隔1小时触发1次；"1/2"代表从1点开始触发，以后每隔2小时触发一次；"19-20/2"表达式将只在19点触发

{日期} ==> 允许值范围: 1~31 ,不允许为空值，若值不合法，调度器将抛出SchedulerException异常

"*" 代表每天触发；

"?" 与{星期}互斥，即意味着若明确指定{星期}触发，则表示{日期}无意义，以免引起 冲突和混乱

"," 代表在指定的日期触发，比如"1,10,20"代表1号、10号和20号这3天触发

"-" 代表在指定的日期范围内触发，比如"10-15"代表从10号开始触发到15号结束触发，每隔1天触发

"/" 代表触发步进(step)，"/"前面的值代表初始值(""等同"1")，后面的值代表偏移量，比如"1/5"或者"/5"代表从1号开始触发，每隔5天触发1次；"10/5"代表从10号开始触发，以后每隔5天触发一次；"1-10/2"表达式意味着在[1,10]范围内，每隔2天触发，即1号，3号，5号，7号，9号触发

"L" 如果{日期}占位符如果是"L"，即意味着当月的最后一天触发

"W "意味着在本月内离当天最近的工作日触发，所谓最近工作日，即当天到工作日的前后最短距离，如果当天即为工作日，则距离为0；所谓本月内的说法，就是不能跨月取到最近工作日，即使前/后月份的最后一天/第一天确实满足最近工作日；因此，"LW"则意味着本月的最后一个工作日触发，"W"强烈依赖{月份}

"C" 根据日历触发，由于使用较少，暂时不做解释

{月份} ==> 允许值范围: 1~12 (JAN-DEC),不允许为空值，若值不合法，调度器将抛出SchedulerException异常

"*" 代表每个月都触发；

"," 代表在指定的月份触发，比如"1,6,12"代表1月份、6月份和12月份触发任务

"-" 代表在指定的月份范围内触发，比如"1-6"代表从1月份开始触发到6月份结束触发，每隔1个月触发

"/" 代表触发步进(step)，"/"前面的值代表初始值(""等同"1")，后面的值代表偏移量，比如"1/2"或者"/2"代表从1月份开始触发，每隔2个月触发1次；"6/6"代表从6月份开始触发，以后每隔6个月触发一次；"1-6/12"表达式意味着每年1月份触发

{星期} ==> 允许值范围: 1~7 (SUN-SAT),1代表星期天(一星期的第一天)，以此类推，7代表星期六(一星期的最后一天)，不允许为空值，若值不合法，调度器将抛出SchedulerException异常

"*" 代表每星期都触发；

"?" 与{日期}互斥，即意味着若明确指定{日期}触发，则表示{星期}无意义，以免引起冲突和混乱

"," 代表在指定的星期约定触发，比如"1,3,5"代表星期天、星期二和星期四触发

"-" 代表在指定的星期范围内触发，比如"2-4"代表从星期一开始触发到星期三结束触发，每隔1天触发

"/" 代表触发步进(step)，"/"前面的值代表初始值(""等同"1")，后面的值代表偏移量，比如"1/3"或者"/3"代表从星期天开始触发，每隔3天触发1次；"1-5/2"表达式意味着在[1,5]范围内，每隔2天触发，即星期天、星期二、星期四触发

"L" 如果{星期}占位符如果是"L"，即意味着星期的的最后一天触发，即星期六触发，L= 7或者 L = SAT，因此，"5L"意味着一个月的最后一个星期四触发

"#" 用来指定具体的周数，"#"前面代表星期，"#"后面代表本月第几周，比如"2#2"表示本月第二周的星期一，"5#3"表示本月第三周的星期四，因此，"5L"这种形式只不过是"#"的特殊形式而已

"C" 根据日历触发，由于使用较少，暂时不做解释

{年份} ==> 允许值范围: 1970~2099 ,允许为空，若值不合法，调度器将抛出SchedulerException异常

"*"代表每年都触发；

","代表在指定的年份才触发，比如"2011,2012,2013"代表2011年、2012年和2013年触发任务

"-"代表在指定的年份范围内触发，比如"2011-2020"代表从2011年开始触发到2020年结束触发，每隔1年触发

"/"代表触发步进(step)，"/"前面的值代表初始值(""等同"1970")，后面的值代表偏移量，比如"2011/2"或者"/2"代表从2011年开始触发，每隔2年触发1次

3.3.2 样例

"30 * * * * ?" 每半分钟触发任务

"1 0 0 * * ?"每天0时0分0秒执行任务

"30 10 * * * ?" 每小时的10分30秒触发任务

"30 10 1 * * ?" 每天1点10分30秒触发任务

"30 10 1 20 * ?" 每月20号1点10分30秒触发任务

"30 10 1 20 10 ? *" 每年10月20号1点10分30秒触发任务

"30 10 1 20 10 ? 2011" 2011年10月20号1点10分30秒触发任务

"30 10 1 ? 10 * 2011" 2011年10月每天1点10分30秒触发任务

"30 10 1 ? 10 SUN 2011" 2011年10月每周日1点10分30秒触发任务

"15,30,45 * * * * ?" 每15秒，30秒，45秒时触发任务

"15-45 * * * * ?" 15到45秒内，每秒都触发任务

"15/5 * * * * ?" 每分钟的每15秒开始触发，每隔5秒触发一次

"15-30/5 * * * * ?" 每分钟的15秒到30秒之间开始触发，每隔5秒触发一次

"0 0/3 * * * ?" 每小时的第0分0秒开始，每三分钟触发一次

"0 15 10 ? * MON-FRI" 星期一到星期五的10点15分0秒触发任务

"0 15 10 L * ?" 每个月最后一天的10点15分0秒触发任务

"0 15 10 LW * ?" 每个月最后一个工作日的10点15分0秒触发任务

"0 15 10 ? * 5L" 每个月最后一个星期四的10点15分0秒触发任务

"0 15 10 ? * 5#3" 每个月第三周的星期四的10点15分0秒触发任务

3.3.3 具体使用

创建job

package com.ak.demo.trigger;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

import java.text.SimpleDateFormat;
import java.util.Date;

public class HelloCronTrigger implements Job {
    @Override
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
    }
}

注册job

package com.ak.demo;

import com.ak.demo.trigger.HelloCronTrigger;
import com.ak.demo.trigger.HelloSimpleTrigger;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;

import java.util.Date;

public class MyHelloCronTrigger {
    public static void main(String[] args) throws SchedulerException {

        Scheduler scheduler= StdSchedulerFactory.getDefaultScheduler();

        JobDetail jobDetail= JobBuilder.newJob(HelloCronTrigger.class)
                .withIdentity("trigger","group1")
                .build();

        Trigger trigger= TriggerBuilder.newTrigger()
                .withIdentity("trigger","group1")
                // 0 1 0 * * ? 每天 0点1 分开始执行
                // 0/2 * * * * ? 每两秒执行一次
                .withSchedule(CronScheduleBuilder.cronSchedule("0/2 * * * * ?")
                )
                .build();
        scheduler.scheduleJob(jobDetail,trigger);

        scheduler.start();
    }
}

结果

image-20210117203630208

4. 监听器

4.1 JobListener

创建job

package com.ak.demo.linster;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * 自定义业务
 */
public class HelloJob2 implements Job {

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
          System.out.println(context.getJobDetail().getKey().getName()+"---"+new  SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
    }

}

创建listener

package com.ak.demo.linster;

import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobListener;

public class MyJobListener implements JobListener {

    @Override
    public String getName() {

        return "监听器名称";
    }

    @Override
    public void jobToBeExecuted(JobExecutionContext jobExecutionContext) {
        System.out.println("--job 在执行前会被调用---"+jobExecutionContext.getJobDetail().getKey().getName());
    }

    @Override
    public void jobExecutionVetoed(JobExecutionContext jobExecutionContext) {

    }

    @Override
    public void jobWasExecuted(JobExecutionContext jobExecutionContext, JobExecutionException e) {
        System.out.println("---job 在执行完毕会调用");
    }
}

注册job 和linstener

package com.ak.demo;

import com.ak.demo.linster.HelloJob2;
import com.ak.demo.linster.MyJobListener;
import com.ak.demo.myjob.HelloJob;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import org.quartz.impl.matchers.EverythingMatcher;
import org.w3c.dom.events.EventListener;

public class MyTestLinster {
    public static void main(String[] args) throws SchedulerException {

        //创建一个scheduler
        Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();

        //创建一个job,和Helloword 完成绑定
        JobDetail job = JobBuilder.newJob(HelloJob2.class)
                // 放入job 业务中的数据
                 // 参数一： 任务的实例（唯一），任务组的名称
                .withIdentity("myjob1", "mygroup")
                .build();

        JobDetail job2 = JobBuilder.newJob(HelloJob2.class)
                // 放入job 业务中的数据
                // 参数一： 任务的实例（唯一），任务组的名称
                .withIdentity("myjob2", "mygroup2")
                .build();

        //创建一个Trigger
        Trigger trigger = TriggerBuilder.newTrigger()
                // 触发器的名称 ，参数二：触发器的 组
                .withIdentity("trigger1", "group1")
                // 设置
                .withSchedule(
                        SimpleScheduleBuilder
                        .simpleSchedule()
                                // 3秒钟重复 执行一次
                        .withIntervalInSeconds(3)
                                // 一直重复下去
                        .repeatForever())
                .build();

        Trigger trigger2 = TriggerBuilder.newTrigger()
                // 触发器的名称 ，参数二：触发器的 组
                .withIdentity("trigger2", "group1")
                // 设置
                .withSchedule(
                        SimpleScheduleBuilder
                                .simpleSchedule()
                                // 3秒钟重复 执行一次
                                .withIntervalInSeconds(3)
                                // 一直重复下去
                                .repeatForever())
                .build();


        //注册trigger并启动scheduler
        // 一个job能够绑定很多 trigger ,
        // 一个trigger 只能绑定一个 job
        scheduler.scheduleJob(job,trigger);
        scheduler.scheduleJob(job2,trigger2);

        // 创建全局的linster
        scheduler.getListenerManager().addJobListener(new MyJobListener(), EverythingMatcher.allJobs());

        // 创建局部的Linster

        // 触发器开始执行
        scheduler.start();


    }
}

结果

image-20210117220435470

设置局部监听

  scheduler.getListenerManager().addJobListener(new MyJobListener(), KeyMatcher.keyEquals(JobKey.jobKey("myjob1", "mygroup")));

4.2 TriggerListener

4.3 SchedulerListener

上次编辑于: 2021/10/12 下午4:55:55
贡献者: fakerlove1