Quartz入门Demo(二)之CronTrigger

时间:2021-07-12 20:03:09

介绍

Quartz框架是一个全功能、开源的任务调度服务,可以集成几乎任何的Java应用程序—从小的单片机系统到大型的电子商务系统。Quartz可以执行上千上万的任务调度。

SimpleTrigger就不说了,着重记录一下CronTrigger,CronTrigger 支持比 SimpleTrigger 更具体的调度,而且也不是很复杂。基于 cron 表达式,CronTrigger 支持类似日历的重复间隔,而不是单一的时间间隔。

Cron 表达式包括以下 7 个字段:

格式: [秒] [分] [小时] [日] [月] [周] [年]
序号 说明 是否必填 允许填写的值 允许的通配符
1 秒 是 0-59 , - * /
2 分 是 0-59 , - * /
3 时 是 0-23 , - * /
4 日 是 1-31 , - * ? / L W
5 月 是 1-12 or JAN-DEC , - * /
6 周 是 1-7 or SUN-SAT , - * ? / L #
7 年 否 empty1970-2099   , - * /

通配符说明:
1. 反斜线(/)字符表示增量值。例如,在秒字段中“5/15”代表从第 5 秒开始,每 15 秒一次。
2. 星号(*)字符是通配字符,表示该字段可以接受任何可能的值(例如:在分的字段上设置 "*",表示每一分钟都会触发)。
3. 问号(?)问号表示这个字段不包含具体值。所以,如果指定月内日期,可以在月内日期字段中插入“?”,表示周内日期值无关紧要。字母 L 字符是 last 的缩写。放在月内日期字段中,表示安排在当月最后一天执行。在周内日期字段中,如果“L”单独存在,就等于“7”,否则代表当月内周内日期的最后一个实例。所以“0L”表示安排在当月的最后一个星期日执行。
4. - 表示区间,例如 在小时上设置 "10-12",表示 10,11,12点都会触发。
5. 逗号(, ) 表示指定多个值,例如在周字段上设置 "MON,WED,FRI" 表示周一,周三和周五触发
6. 井号(#)字符为给定月份指定具体的工作日实例。把“MON#2”放在周内日期字段中,表示把任务安排在当月的第二个星期一。
7. L 表示最后的意思。在日字段设置上,表示当月的最后一天(依据当前月份,如果是二月还会依据是否是润年[leap]), 在周字段上表示星期六,相当于"7""SAT"。如果在"L"前加上数字,则表示该数据的最后一个。例如在周字段上设置"6L"这样的格式,则表示“本月最后一个星期五"。
8. W 表示离指定日期的最近那个工作日(周一至周五). 例如在日字段上设置"
15W",表示离每月15号最近的那个工作日触发。如果15号正好是周六,则找最近的周五(14号)触发, 如果15号是周未,则找最近的下周一(16号)触发.如果15号正好在工作日(周一至周五),则就在该天触发。如果指定格式为 "1W",它则表示每月1号往后最近的工作日触发。如果1号正是周六,则将在3号下周一触发。(注,"W"前只能设置具体的数字,不允许区间"-")。
注:'L'和 'W'可以一组合使用。如果在日字段上设置"
LW",则表示在本月的最后一个工作日触发。

下面直接上Demo

QuartzTest2类

package com.v.test;

import static org.quartz.JobBuilder.newJob;
import static org.quartz.TriggerBuilder.newTrigger;

import java.util.Date;

import org.junit.Test;
import org.quartz.CronTrigger;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.impl.StdSchedulerFactory;

import static org.quartz.CronScheduleBuilder.cronSchedule;

public class QuartzTest2 {
public static CronTrigger trigger = null;

public static void main(String[] args) {

trigger = newTrigger().withIdentity("trigger1", "group1").withSchedule(cronSchedule("0/5 * * * * ?")).build(); // 5秒运行一次任务
/*
* trigger = newTrigger().withIdentity("trigger2",
* "group1").withSchedule(cronSchedule("10 0/1 * * * ?")).build();//
* Log---- 13:31:10,096 INFO - Hello World! - Mon May 01 13:31:10 CST
* 2017 在秒针为10秒的时候开始运行,1分钟运行一次
*/

/*
* trigger = newTrigger() .withIdentity("trigger3", "group1")
* .withSchedule(cronSchedule("0 0/1 8-17 * * ?")) .build();
* 在8-17点运行,0秒开始每分钟运行一次
*/

/*
* trigger = newTrigger() .withIdentity("trigger5", "group1")
* .withSchedule(cronSchedule("40 4 14 1,15 * ?")) .build();
* 每月1、15号14点4分40秒运行
*/

/*
* trigger = newTrigger() .withIdentity("trigger5", "group1")
* .withSchedule(cronSchedule("0 8/1 14 1,15 * ?")) .build();
* 每月1、15号14点8分0秒开始运行,每分钟运行一次
*/

/*
* trigger = newTrigger() .withIdentity("trigger6", "group1")
* .withSchedule(cronSchedule("0,30 * * ? * MON-FRI")) .build();
* 每周一至周五任何时间0秒开始30秒运行一次
*/

/*
* trigger = newTrigger() .withIdentity("trigger7", "group1")
* .withSchedule(cronSchedule("0,30 * * ? * MON,SUN")) .build();
* 每周一、周日任何时间0秒开始30秒运行一次
*/

/*
* trigger = newTrigger() .withIdentity("trigger6", "group1")
* .withSchedule(cronSchedule("0,30 * * ? 5 MON-FRI")) .build();
* 5月每周一、周日任何时间0秒开始30秒运行一次
*/

/*
* 参数说明: Seconds 0-59 , - * / Minutes 0-59 , - * / Hours 0-23 , - * /
* Day-of-month 1-31 , - * ? / L W Month 1-12 or JAN-DEC , - * /
* Day-of-Week 1-7 or SUN-SAT , - * ? / L # Year (Optional) empty,
* 1970-2199 , - * /
*
*/

test1(trigger);
}

public static void test1(CronTrigger trigger) {
try {
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
Scheduler scheduler = null;
scheduler = schedulerFactory.getScheduler();
JobDetail job = newJob(HelloJob.class).withIdentity("job1", "group1").build();
scheduler.scheduleJob(job, trigger);
scheduler.start();
} catch (Exception se) {
se.printStackTrace();
}
}

}

HelloJob类

package com.v.test;

import java.util.Date;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class HelloJob implements Job{
Logger _log = LoggerFactory.getLogger(HelloJob.class);
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
// TODO Auto-generated method stub
_log.info("Hello World! - " + context.getJobDetail().getKey()+"["+ new Date()+"]");
System.err.println(" -" + context.getJobDetail().getKey() + ".");

}

}

运行日志就不贴了,自行测试

附上Demo地址:QuartzDemo