Java定时框架Quartz实例详解与定时任务的Mongodb、Mysql持久化实现(一)Quartz组件

释放双眼,带上耳机,听听看~!

(二)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&lt;span style=&quot;font-size:14px;&quot;&gt;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(&quot;jobName&quot;);
8       System.out.println(jobName + &quot;执行&quot;);
9   }
10}&lt;/span&gt;
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&lt;span style=&quot;font-size:14px;&quot;&gt;public class JobUtil {
2
3   //声明调度器对象
4   private static Scheduler scheduler = null;
5   //Job组名
6   public static String GroupName = &quot;JobsGroup&quot;;
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(&quot;jobName&quot;, 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 = &quot;0/10 0/1 0/1 1/1 * ?&quot;;
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(&quot;testQuartz&quot;);
52  }
53}&lt;/span&gt;
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(&quot;0 0/2 8-17 * * ?&quot;) // 每天8:00-17:00,每隔2分钟执行一次
2    .build();
3
4cronSchedule(&quot;0 30 9 ? * MON&quot;) // 每周一,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表达式生成器,网上是能够查到源码的哦,有兴趣的可以看看:

给TA打赏
共{{data.count}}人
人已打赏
安全运维

OpenSSH-8.7p1离线升级修复安全漏洞

2021-10-23 10:13:25

安全运维

设计模式的设计原则

2021-12-12 17:36:11

个人中心
购物车
优惠劵
今日签到
有新私信 私信列表
搜索