您的位置:首页 > 编程语言 > Java开发

初识一个任务调度框架quartz

2016-08-12 00:00 155 查看
摘要: quartz框架的简单用法

QUARTZ的官网http://www.quartz-scheduler.org/

使用前准备,使用Maven导入依赖(Jar包可在官网上下载):

<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.2.1</version>
</dependency>
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz-jobs</artifactId>
<version>2.2.1</version>
</dependency>


1.Quartz的简单入门

public class MyJob implements Job {
@Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
System.out.println("执行了指定的任务!------" + new SimpleDateFormat("HH:mm:ss").format(new Date()));
}

public static void main(String[] args) {
try {
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
scheduler.start();
JobDetail job = JobBuilder.newJob(MyJob.class)
.withIdentity("job1", "group1")
.build();
Trigger trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger1", "group1")
.startNow()
.withSchedule(SimpleScheduleBuilder.simpleSchedule()
.withIntervalInSeconds(5)
.repeatForever())
.build();

scheduler.scheduleJob(job, trigger);
Thread.sleep(100 * 1000);
scheduler.shutdown();
} catch (Exception e) {
e.printStackTrace();
}
}
}

首先必须自定义一个Job,如上的MyJob类并实现org.quartz.Job接口,在重写的方法里就是需要定时调用的任务。

注意: scheduler.scheduleJob(job, trigger);这条语句执行后该任务并不会被激活,需要在 scheduler.start();这条语句执行后,Scheduler任务才会执行,这条语句scheduler.shutdown();将会关闭被定时执行的任务。

以上使用了简单的Scheduler,以下可以使用更加复杂的Scheduler:



其中最关键的是CroneExpression,它表示该任务执行的时间,每个时间表示:秒 分钟 小时 日 月 周 年(可选填)。

含义如下:



其中特殊字符含义如下:

'*' 字符可以用于所有字段,在“分”字段中设为"*"表示"每一分钟"的含义。

'?' 字符可以用在“日”和“周几”字段. 它用来指定 '不明确的值'. 这在你需要指定这两个字段中的某一个值而不是另外一个的时候会被用到。在后面的例子中可以看到其含义。

'-' 字符被用来指定一个值的范围,比如在“小时”字段中设为"10-12"表示"10点到12点".

',' 字符指定数个值。比如在“周几”字段中设为"MON,WED,FRI"表示"the days Monday, Wednesday, and Friday".

'/' 字符用来指定一个值的的增加幅度. 比如在“秒”字段中设置为"0/15"表示"第0, 15, 30, 和 45秒"。而 "5/15"则表示"第5, 20, 35, 和 50". 在'/'前加"*"字符相当于指定从0秒开始. 每个字段都有一系列可以开始或结束的数值。对于“秒”和“分”字段来说,其数值范围为0到59,对于“小时”字段来说其为0到23, 对于“日”字段来说为0到31, 而对于“月”字段来说为1到12。"/"字段仅仅只是帮助你在允许的数值范围内从开始"第n"的值。 因此对于“月”字段来说"7/6"只是表示7月被开启而不是“每六个月”, 请注意其中微妙的差别。

'L'字符可用在“日”和“周几”这两个字段。它是"last"的缩写, 但是在这两个字段中有不同的含义。例如,“日”字段中的"L"表示"一个月中的最后一天" —— 对于一月就是31号对于二月来说就是28号(非闰年)。而在“周几”字段中, 它简单的表示"7" or "SAT",但是如果在“周几”字段中使用时跟在某个数字之后, 它表示"该月最后一个星期×" —— 比如"6L"表示"该月最后一个周五"。当使用'L'选项时,指定确定的列表或者范围非常重要,否则你会被结果搞糊涂的。

'W' 可用于“日”字段。用来指定历给定日期最近的工作日(周一到周五) 。比如你将“日”字段设为"15W",意为: "离该月15号最近的工作日"。因此如果15号为周六,触发器会在14号即周五调用。如果15号为周日, 触发器会在16号也就是周一触发。如果15号为周二,那么当天就会触发。然而如果你将“日”字段设为"1W", 而一号又是周六, 触发器会于下周一也就是当月的3号触发,因为它不会越过当月的值的范围边界。'W'字符只能用于“日”字段的值为单独的一天而不是一系列值的时候。

'L'和'W'可以组合用于“日”字段表示为'LW',意为"该月最后一个工作日"。

'#' 字符可用于“周几”字段。该字符表示“该月第几个周×”,比如"6#3"表示该月第三个周五( 6表示周五而"#3"该月第三个)。再比如: "2#1" = 表示该月第一个周一而 "4#5" = 该月第五个周三。注意如果你指定"#5"该月没有第五个“周×”,该月是不会触发的。

'C' 字符可用于“日”和“周几”字段,它是"calendar"的缩写。它表示为基于相关的日历所计算出的值(如果有的话)。如果没有关联的日历, 那它等同于包含全部日历。“日”字段值为"5C"表示"日历中的第一天或者5号及其以后",“周几”字段值为"1C"则表示"日历中的第一天或者周日及其以后"。

对于“月份”字段和“周几”字段来说合法的字符都不是大小写敏感的。

更准确的信息请参考官方API文档:http://www.quartz-scheduler.org/api/2.2.1/index.html

2.Quartz与Spring的整合及使用

增加导入Spring的支持包:

<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
<version>4.2.4.RELEASE</version>
</dependency>

首先写一个任务类:

public class MyTasks {

public void task1() {
System.out.println("Quartz与Spring的集成-----" + new SimpleDateFormat("HH:mm:ss").format(new Date()));
}

public void task2() {
System.out.println("这是另一个任务-----" + new SimpleDateFormat("HH:mm:ss").format(new Date()));
}
}

Spring的配置文件:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns = "http://www.springframework.org/schema/beans"
xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation = "http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd"> 
<bean id = "mytask" class = "at.flying.quartz.MyTasks" />
<!--设置JobDetail-->
<bean id = "jobDetail1" class = "org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
<!--指定要执行的任务的类-->
<property name = "targetObject" ref = "mytask" />
<!--指定执行的方法-->
<property name = "targetMethod" value = "task1" />
<!--指定任务可否同步执行-->
<property name = "concurrent" value = "false" />
</bean>
<bean id = "jobDetail2" class = "org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
<!--指定要执行的任务的类-->
<property name = "targetObject" ref = "mytask" />
<!--指定执行的方法-->
<property name = "targetMethod" value = "task2" />
<!--指定任务可否同步执行-->
<property name = "concurrent" value = "false" />
</bean>

<!--设置简单的Trigger-->
<bean id = "simpleTrigger" class = "org.springframework.scheduling.quartz.SimpleTriggerFactoryBean">
<!--设置jobDetail-->
<property name = "jobDetail" ref = "jobDetail1" />
<!--延迟执行的时间,毫秒-->
<property name = "startDelay" value = "#{10*1000}" />
<!--每次执行的间隔时间,毫秒-->
<property name = "repeatInterval" value = "5000" />
<!--设置重复执行任务的次数,这里注意设置10次其实是共执行11次,执行总次数在此基础上加上1,-->
<property name = "repeatCount" value = "10" />
</bean>

<!--设置复杂的Trigger-->
<bean id = "cronTrigger" class = "org.springframework.scheduling.quartz.CronTriggerFactoryBean">
<!--设置jobDetail-->
<property name = "jobDetail" ref = "jobDetail2" />
<!--设置CronExpression表达式(这里表示:2016年8月12日15时每分钟的第20秒)-->
<property name = "cronExpression" value = "20 * 15 12 8 ? 2016" />
</bean>

<!--设置任务调度工厂-->
<bean id = "scheduler" class = "org.springframework.scheduling.quartz.SchedulerFactoryBean">
<property name = "triggers">
<list>
<ref bean = "simpleTrigger" />
<ref bean = "cronTrigger" />
</list>
</property>
</bean>
</beans>

启动Web就可以看到任务执行成功。

以上代码中注释详尽就不再解释了。

总结:

我们可以看到无论是采用Spring的配置文件配置定时任务,还是使用纯Java代码配置定时任务,总体的过程大体一致:

1.写自己的任务类,这里似乎采用Spring的集成比较好。如果使用纯Java代码,需要实现org.quartz.Job接口,并且如果需要设置多个任务的话就要写多个类,每一个类只能完成一个任务。但是在Spring中,可以把多个任务写成多个方法放在一个Java普通类中,在使用时,只需在Spring配置文件中配置即可。

2.创建JobDetail类。该类的主要作用是指定具体的要执行的任务。

3.创建Trigger类。该类的主要作用是设置执行的任务的执行时间(执行方式)

4.创建Scheduler类。该类的主要作用是管理任务触发器(Trigger),Trigger的触发最终由Scheduler发起。

简单触发器与复杂触发器的主要点在于:简单触发器只支持简单的执行时间点和执行方式,复杂触发器可以使用规定的CronExpression表达出更加复杂的时间点和执行方式。

更多内容可查看QUARTZ的官网:http://www.quartz-scheduler.org/
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  Quartz java