Spring整合Quartz实现定时任务步骤很简单,大致需要经过如下几步:创建任务(Job)、配置JobDetail、配置触发器(Trigger)、配置SchedulerFactoryBean
首先使用Maven创建一个web项目并引入Spring和quartz的依赖(习惯使用这种开发模式了,当然不使用Maven也可以)
需要引入的依赖包如下:
- <dependency>
- <groupId>org.springframework</groupId>
- <artifactId>spring-context</artifactId>
- <version>3.2.6.RELEASE</version>
- </dependency>
- <dependency>
- <groupId>org.springframework</groupId>
- <artifactId>spring-context-support</artifactId>
- <version>3.2.6.RELEASE</version>
- </dependency>
- <dependency>
- <groupId>org.springframework</groupId>
- <artifactId>spring-web</artifactId>
- <version>3.2.6.RELEASE</version>
- </dependency>
- <dependency>
- <groupId>org.springframework</groupId>
- <artifactId>spring-tx</artifactId>
- <version>3.2.6.RELEASE</version>
- </dependency>
- <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>
此处我们使用的是Spring3.2.6+Quartz2.2.1版本进行实验。
增加完Spring和Quartz的依赖包之后,就需要创建Spring配置文件,并在web.xml文件中引入Spring支持。
- <listener>
- <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
- </listener>
- <context-param>
- <param-name>contextConfigLocation</param-name>
- <param-value>/WEB-INF/classes/applicationContext.xml</param-value>
- </context-param>
好了,到现在为止,基本的环境算是搭建好了,接下来我们就要开始Spring+Quartz实现定时任务了。
一、创建任务(Job)
Spring+Quartz实现Job有两种方式:一种是继承org.springframework.scheduling.quartz.QuartzJobBean类来实现Job任务,并实现里面的抽象方法executeInternal;另一种是不继承任何类,创建普通的Java类,然后自己指定任务的执行方法(个人感觉此种方式较好,实现起来方便而且大大降低了系统的业务的耦合性)。
我们先来看一下继承QuartzJobBean类的这种形式,创建一个任务类ExampleJob,具体代码如下:
- package com.mhy.quartz;
- /**
- * 继承QuartzJobBean形式的定时任务
- */
- import java.text.SimpleDateFormat;
- import java.util.Date;
- import org.quartz.JobExecutionContext;
- import org.quartz.JobExecutionException;
- import org.springframework.scheduling.quartz.QuartzJobBean;
- /**
- * @author mhy2011@163.com
- * @date 2013年12月21日
- */
- public class ExampleJob extends QuartzJobBean {
- private int timeout;
- @Override
- protected void executeInternal(JobExecutionContext context)
- throws JobExecutionException {
- System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + "执行ExampleJob的定时任务");
- }
- public int getTimeout() {
- return timeout;
- }
- public void setTimeout(int timeout) {
- this.timeout = timeout;
- }
- }
为了演示方便,executeInternal方法中没有写复杂的业务逻辑,只简单的输出一句话,真正的生产环境中在该方法中实现你所需要的业务逻辑即可。
二、在Spring配置文件中配置JobDetail
- <bean name="exampleJobDetail" class="org.springframework.scheduling.quartz.JobDetailBean">
- <property name="jobClass" value="com.mhy.quartz.ExampleJob" />
- <property name="jobDataAsMap">
- <map>
- <entry key="timeout" value="5" />
- </map>
- </property>
- </bean>
三、配置触发器(Trigger)
Spring提供了两种触发器,如下:
1、org.springframework.scheduling.quartz.SimpleTriggerFactoryBean(此种方式是很隔多长时间进行触发一次,比如每隔24小时触发一次)
2、org.springframework.scheduling.quartz.CronTriggerFactoryBean(此种方式是在指定的时间进行触发,比如只在周一进行触发。不过根据配置也很方便的实现类似SimpleTriggerFactoryBean形式的定时任务)
Spring所提供的这两种触发器方式和前面提到的任务创建方式均可以相互之间混用,很灵活。
这里我们先使用SimpleTriggerFactoryBean这个trigger来配置
- <bean id="exampleJobTrigger"
- class="org.springframework.scheduling.quartz.SimpleTriggerFactoryBean">
- <property name="jobDetail" ref="exampleJobDetail" />
- <!-- 延迟触发时间,延迟10秒进行触发 -->
- <property name="startDelay" value="10000" />
- <!-- 重复触发的时间间隔,5秒 -->
- <property name="repeatInterval" value="5000" />
- </bean>
四、配置SchedulerFactoryBean
- <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
- <property name="triggers">
- <list>
- <ref bean="exampleJobTrigger" />
- </list>
- </property>
- </bean>
好了,到现在为止,一个简单的定时任务就完成了,下面我们来启动一下web项目,看运行结果如何。
从异常信息中我们可以看出,JobDetailBean引用了一个接口来作为父类了。既然是这样的话,那我们就需要看一下JobDetailBean的源码了。
从源码中我们可以看到Spring的JobDetailBean继承了Quartz的JobDetail,接下来我们就要看Quartz的JobDetail这个源码了。
Quartz从1.X升级到2.X之后,JobDetail由类修改为接口了,为啥要改?那你得去问Quartz作者了,嘿嘿。那如果再继续采用这种模式的话那肯定会错喽。那我们对它就没有法子了么?怎么可能。处理它很简单啊:一、把Quartz降到1.X版本;二、更改Job的实现方式。
可以看到在Quartz1.X版本中,JobDetail还是一个类。接下来我们再启动一下web项目看看运行结果何如。
可以看到,在更换Quartz版本为1.X之后,定时任务正常运行了。
第二部分:实现Spring3+Quartz2的定时任务。
首先创建一个基本的Java类来做为Job任务类,代码如下:
- /**
- * 单独Job类形式
- */
- package com.mhy.quartz;
- import java.text.SimpleDateFormat;
- import java.util.Date;
- /**
- * @author mhy2011@163.com
- * @date 2013年12月21日
- */
- public class ExampleJob2 {
- /**
- * 执行定时统计任务
- * 自行指定方法
- */
- public void execute(){
- System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + "执行ExampleJob2");
- }
- }
接下来是在Spring配置文件中配置JobDetail、Trigger、SchedulerFactoryBean
- <bean id="exampleJob2" class="com.mhy.quartz.ExampleJob2"></bean>
- <bean id="exampleJob2Detail"
- class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
- <!-- 指定任务类 -->
- <property name="targetObject" ref="exampleJob2" />
- <!-- 指定任务执行的方法 -->
- <property name="targetMethod" value="execute" />
- </bean>
- <bean id="exampleJob2Trigger"
- class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
- <property name="jobDetail" ref="exampleJob2Detail" />
- <!-- 每10秒运行一次 -->
- <property name="cronExpression" value="0/10 * * * * ?" />
- </bean>
- <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
- <property name="triggers">
- <list>
- <!-- <ref bean="exampleJobTrigger" /> -->
- <ref bean="exampleJob2Trigger" />
- </list>
- </property>
- </bean>
好了,配置完之后我们再启动一下程序,看看定时任务时否运行良好(这里我们使用的Trigger是CronTriggerFactoryBean,当然也可以使用SimpleTriggerFactoryBean)
关于Trigger中时间如何配置,quartz官网描述的很清楚,大家可以参考如下网址:http://quartz-scheduler.org/documentation/quartz-2.2.x/tutorials/crontrigger