(二)Quartz配置详解
(三)Quartz持久化
一、Quartz概述
Quartz是一个完全由Java编写的开源作业调度框架,为在Java应用程序中进行作业调度提供了简单却强大的机制。Quartz允许开发人员根据一定的时间间隔来调度作业。
我学一样东西,从来都是从实践出发,边用边学,用起来自然就学会了。
二、使用Quartz
1、Quartz Jar
我推荐大家使用Maven来加入Jar依赖,方便而且可以对依赖有效地管理。
1
2
3
4
5
6 1<dependency>
2<span style="white-space:pre"> </span><groupId>org.quartz-scheduler</groupId>
3 <artifactId>quartz</artifactId>
4 <version>2.2.1</version>
5</dependency>
6
1
2 1**2、Quartz工具类,核心组件详解**
2
我们开发不光要考虑功能的实现,还要考虑效率、耦合程度与开闭性等问题,可根据实际情况应用恰当的设计模式。回归正题:
下面这个例子很好的覆盖了Quartz最重要的4个基本要素(考验英语水平的时候到了~(>_<)~):
Scheduler:调度器,所有的作业调度都是由它控制。
Trigger: 触发器,定义触发的条件。例子中,它的类型是CronTrigger,是常见的几种触发器类型中最强大、最灵活的一类,但不要害怕,它并不是很复杂,只是多了一个Cron表达式,会在下面说到。
JobDetail: 任务细节,定义作业的标识与携带的数据。
Job:执行类,实现org.quartz.Job的接口,实现excute方法,作为作业执行体。
**注意:**作业真正的执行逻辑是在Job实现类中,为什么设计成JobDetail + Job结构,不直接使用Job?这是因为作业是有可能并发执行,如果Scheduler直接调度Job,就会存在对同一个Job实例并发访问的问题。而JobDetail + Job 方式,sheduler每次执行都会根据JobDetail创建一个新的Job实例,这样就可以规避并发访问的问题。
实现类代码(测试绝对可用,jar包正确导入,复制两个类,即可运行^_^):
1
2
3
4
5
6
7
8
9
10
11 1<span style="font-size:14px;">public class JobExcuteClass implements org.quartz.Job{
2 //实现excute方法
3 @Override
4 public void execute(JobExecutionContext context) {
5 //通过context上下文对象获得map中的Job数据
6 JobDataMap map = context.getJobDetail().getJobDataMap();
7 String jobName = (String)map.get("jobName");
8 System.out.println(jobName + "执行");
9 }
10}</span>
11
JobUtil代码:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54 1<span style="font-size:14px;">public class JobUtil {
2
3 //声明调度器对象
4 private static Scheduler scheduler = null;
5 //Job组名
6 public static String GroupName = "JobsGroup";
7
8 //创建调度器对象
9 private static Scheduler createScheduler() throws SchedulerException {
10 SchedulerFactory schedulerFactory = new StdSchedulerFactory();
11 return schedulerFactory.getScheduler();
12 }
13
14 //为调度器添加调度任务
15 public static void addJod(String jobName) throws SchedulerException{
16 //用于给Job实现类的excute方法传递数据
17 JobDataMap map = new JobDataMap();
18 map.put("jobName", jobName);
19 //创建JobDetail对象
20 //设定Job执行类,设定Job标识,设定数据map
21 JobDetail myJob = newJob(JobExcuteClass.class)
22 .withIdentity(jobName, GroupName)
23 .usingJobData(map)
24 .build();
25 //执行策略,Cron表达式,代表十秒执行一次
26 String strategy = "0/10 0/1 0/1 1/1 * ?";
27 //创建触发器,应用策略
28 CronTrigger trigger = newTrigger()
29 .withSchedule(cronSchedule(strategy))
30 .build();
31 //创建调度器对象
32 scheduler = createScheduler();
33 //启动调度器
34 scheduler.start();
35 //将myJob对象与trigger对象加入调度器
36 scheduler.scheduleJob(myJob, trigger);
37 }
38
39 //停止调度任务
40 public static void removeJob(String jobName) throws SchedulerException {
41 //Job标识对象
42 JobKey key = new JobKey(jobName, GroupName);
43 //注意这里一定要再次创建调度器对象,否则涉及持久化时,会抛出空指针异常
44 scheduler = createScheduler();
45 //从调度器中移除任务
46 scheduler.deleteJob(key);
47 }
48
49 //test
50 public static void main(String[] args) throws SchedulerException{
51 JobUtil.addJod("testQuartz");
52 }
53}</span>
54
测试结果:每十秒打印一次数据(这里考虑到不想加过多的Quartz无关内容,没有加时间标识)
透过实例看本质,可以总结出Quartz的工作原理(转自熔岩大神的博客,说的比较好理解):
1、scheduler是一个计划调度器容器(总部),容器里面可以盛放众多的JobDetail和trigger,当容器启动后,里面的每个JobDetail都会根据trigger按部就班自动去执行。
2、JobDetail是一个可执行的工作,它本身可能是有状态的。
3、Trigger代表一个调度参数的配置,什么时候去调。
4、当JobDetail和Trigger在scheduler容器上注册后,形成了装配好的作业(JobDetail和Trigger所组成的一对儿),就可以伴随容器启动而调度执行了。
5、scheduler是个容器,容器中有一个线程池,用来并行调度执行每个作业,这样可以提高容器效率。
6、将上述的结构用一个图来表示,如下:
关于Trigger实现类(转载自:http://www.cnblogs.com/drift-ice/p/3817269.html,这篇文章里还有很多Quartz组件详解、写的很详细,就不赘述了)
Quartz有以下几种Trigger实现:
SimpleTrigger
指定从某一个时间开始,以一定的时间间隔(单位是毫秒)执行的任务。
它适合的任务类似于:9:00 开始,每隔1小时,执行一次。
它的属性有:
- repeatInterval 重复间隔
- repeatCount 重复次数。实际执行次数是 repeatCount+1。因为在startTime的时候一定会执行一次。** 下面有关repeatCount 属性的都是同理。 **
例子:
1
2
3
4
5
6
7
8
9
10
11 1simpleSchedule()
2 .withIntervalInHours(1) //每小时执行一次
3 .repeatForever() //次数不限
4 .build();
5
6simpleSchedule()
7 .withIntervalInMinutes(1) //每分钟执行一次
8 .withRepeatCount(10) //次数为10次
9 .build();
10
11
CalendarIntervalTrigger
类似于SimpleTrigger,指定从某一个时间开始,以一定的时间间隔执行的任务。 但是不同的是SimpleTrigger指定的时间间隔为
毫秒,没办法指定每隔一个月执行一次(每月的时间间隔不是固定值),而CalendarIntervalTrigger支持的间隔单位有
秒,分钟,小时,天,月,年,星期。
相较于SimpleTrigger有两个优势:1、更方便,比如每隔1小时执行,你不用自己去计算1小时等于多少毫秒。 2、支持不是固定长度的间隔,比如间隔为月和年。但劣势是精度只能到秒。
它适合的任务类似于:9:00 开始执行,并且以后每周 9:00 执行一次
它的属性有:
- interval 执行间隔
- intervalUnit 执行间隔的单位(秒,分钟,小时,天,月,年,星期)
例子:
1
2
3
4
5
6
7
8
9 1calendarIntervalSchedule()
2 .withIntervalInDays(1) //每天执行一次
3 .build();
4
5calendarIntervalSchedule()
6 .withIntervalInWeeks(1) //每周执行一次
7 .build();
8
9
DailyTimeIntervalTrigger
指定每天的某个时间段内,以一定的时间间隔执行任务。并且它可以支持指定星期。
它适合的任务类似于:指定每天9:00 至 18:00 ,每隔70秒执行一次,并且只要周一至周五执行。
它的属性有:
- startTimeOfDay 每天开始时间
- endTimeOfDay 每天结束时间
- daysOfWeek 需要执行的星期
- interval 执行间隔
- intervalUnit 执行间隔的单位(秒,分钟,小时,天,月,年,星期)
- repeatCount 重复次数
例子:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 1dailyTimeIntervalSchedule()
2 .startingDailyAt(TimeOfDay.hourAndMinuteOfDay(9, 0)) //第天9:00开始
3 .endingDailyAt(TimeOfDay.hourAndMinuteOfDay(16, 0)) //16:00 结束
4 .onDaysOfTheWeek(MONDAY,TUESDAY,WEDNESDAY,THURSDAY,FRIDAY) //周一至周五执行
5 .withIntervalInHours(1) //每间隔1小时执行一次
6 .withRepeatCount(100) //最多重复100次(实际执行100+1次)
7 .build();
8
9dailyTimeIntervalSchedule()
10 .startingDailyAt(TimeOfDay.hourAndMinuteOfDay(9, 0)) //第天9:00开始
11 .endingDailyAfterCount(10) //每天执行10次,这个方法实际上根据 startTimeOfDay+interval*count 算出 endTimeOfDay
12 .onDaysOfTheWeek(MONDAY,TUESDAY,WEDNESDAY,THURSDAY,FRIDAY) //周一至周五执行
13 .withIntervalInHours(1) //每间隔1小时执行一次
14 .build();
15
16
CronTrigger
适合于更复杂的任务,它支持类型于Linux Cron的语法(并且更强大)。基本上它覆盖了以上三个Trigger的绝大部分能力(但不是全部)—— 当然,也更难理解。
它适合的任务类似于:每天0:00,9:00,18:00各执行一次。
它的属性只有:
- Cron表达式。但这个表示式本身就够复杂了。下面会有说明。
例子:
1
2
3
4
5
6
7
8
9
10 1cronSchedule("0 0/2 8-17 * * ?") // 每天8:00-17:00,每隔2分钟执行一次
2 .build();
3
4cronSchedule("0 30 9 ? * MON") // 每周一,9:30执行一次
5.build();
6
7weeklyOnDayAndHourAndMinute(MONDAY,9, 30) //等同于 0 30 9 ? * MON
8 .build();
9
10
Cron表达式
1
秒
0-59
, – * /
2
分钟
0-59
, – * /
3
小时
0-23
, – * /
4
日期
1-31
, – * ? / L W C
5
月份
1-12
, – * /
6
星期
1-7
, – * ? / L C #
7
年份(可选)
1-31
, – * /
星号(
):可用在所有字段中,表示对应时间域的每一个时刻,例如, 在分钟字段时,表示“每分钟”;
问号(?):该字符只在日期和星期字段中使用,它通常指定为“无意义的值”,相当于点位符;
减号(-):表达一个范围,如在小时字段中使用“10-12”,则表示从10到12点,即10,11,12;
逗号(,):表达一个列表值,如在星期字段中使用“MON,WED,FRI”,则表示星期一,星期三和星期五;
斜杠(/):x/y表达一个等步长序列,x为起始值,y为增量步长值。如在分钟字段中使用0/15,则表示为0,15,30和45秒,而5/15在分钟字段中表示5,20,35,50,你也可以使用*/y,它等同于0/y;
L:该字符只在日期和星期字段中使用,代表“Last”的意思,但它在两个字段中意思不同。L在日期字段中,表示这个月份的最后一天,如一月的31号,非闰年二月的28号;如果L用在星期中,则表示星期六,等同于7。但是,如果L出现在星期字段里,而且在前面有一个数值X,则表示“这个月的最后X天”,例如,6L表示该月的最后星期五;
W:该字符只能出现在日期字段里,是对前导日期的修饰,表示离该日期最近的工作日。例如15W表示离该月15号最近的工作日,如果该月15号是星期六,则匹配14号星期五;如果15日是星期日,则匹配16号星期一;如果15号是星期二,那结果就是15号星期二。但必须注意关联的匹配日期不能够跨月,如你指定1W,如果1号是星期六,结果匹配的是3号星期一,而非上个月最后的那天。W字符串只能指定单一日期,而不能指定日期范围;
LW组合:在日期字段可以组合使用LW,它的意思是当月的最后一个工作日;
井号(#):该字符只能在星期字段中使用,表示当月某个工作日。如6#3表示当月的第三个星期五(6表示星期五,#3表示当前的第三个),而4#5表示当月的第五个星期三,假设当月没有第五个星期三,忽略不触发;
C:该字符只在日期和星期字段中使用,代表“Calendar”的意思。它的意思是计划所关联的日期,如果日期没有被关联,则相当于日历中所有日期。例如5C在日期字段中就相当于日历5日以后的第一天。1C在星期字段中相当于星期日后的第一天。
Cron表达式对特殊字符的大小写不敏感,对代表星期的缩写英文大小写也不敏感。
一些例子:
0 0 12 * * ?
每天12点运行
0 15 10 ? * *
每天10:15运行
0 15 10 * * ?
每天10:15运行
0 15 10 * * ? *
每天10:15运行
0 15 10 * * ? 2008
在2008年的每天10:15运行
0 * 14 * * ?
每天14点到15点之间每分钟运行一次,开始于14:00,结束于14:59。
0 0/5 14 * * ?
每天14点到15点每5分钟运行一次,开始于14:00,结束于14:55。
0 0/5 14,18 * * ?
每天14点到15点每5分钟运行一次,此外每天18点到19点每5钟也运行一次。
0 0-5 14 * * ?
每天14:00点到14:05,每分钟运行一次。
0 10,44 14 ? 3 WED
3月每周三的14:10分到14:44,每分钟运行一次。
0 15 10 ? * MON-FRI
每周一,二,三,四,五的10:15分运行。
0 15 10 15 * ?
每月15日10:15分运行。
0 15 10 L * ?
每月最后一天10:15分运行。
0 15 10 ? * 6L
每月最后一个星期五10:15分运行。
0 15 10 ? * 6L 2007-2009
在2007,2008,2009年每个月的最后一个星期五的10:15分运行。
0 15 10 ? * 6#3
每月第三个星期五的10:15分运行。关于Cron表达式还可以参考http://cron.qqe2.com/的在线Cron表达式生成器,网上是能够查到源码的哦,有兴趣的可以看看: