原创  最新 Spring 4.2.2 集成 Quartz Scheduler 2.2.2 任务调度示例

分类: 2017-04-04T17:16:45    276人阅读   

转载于:http://blog.csdn.net/defonds/article/details/49496895

本文将演示如何通过 Spring 使用 Quartz Scheduler 进行任务调度。Spring 为简化 Quartz 的操作提供了相关支持类。
本文示例使用的相关工具如下:
  • Spring 4.2.2 (发布于 2015 年 10 月)
  • Quartz Scheduler 2.2.2 (发布于 2015 年 10 月)
  • Maven 3
  • JDK 1.7
  • Eclipse Luna Service Release 1 (4.4.1)

步骤 1:新建 Maven 项目

新建maven项目.png
这一步如果不知道怎么做可以参考博客《使用 Eclipse 的 Maven 2 插件开发一个 JEE 项目》。

步骤 2:第三方依赖包的引入

Maven pom.xml 编辑如下:
[html] view plain copy
 print?
  1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  2.   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">  
  3.   <modelVersion>4.0.0</modelVersion>  
  4.   
  5.   <groupId>settle</groupId>  
  6.   <artifactId>spring-quartz</artifactId>  
  7.   <version>1.0.0</version>  
  8.   <packaging>jar</packaging>  
  9.   <name>spring-quartz</name>  
  10.   <url>http://maven.apache.org</url>  
  11.   
  12.     <properties>  
  13.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>  
  14.         <springframework.version>4.2.2.RELEASE</springframework.version>  
  15.         <quartz.version>2.2.2</quartz.version>  
  16.     </properties>  
  17.   
  18.     <dependencies>  
  19.         <dependency>  
  20.             <groupId>org.springframework</groupId>  
  21.             <artifactId>spring-core</artifactId>  
  22.             <version>${springframework.version}</version>  
  23.         </dependency>  
  24.         <dependency>  
  25.             <groupId>org.springframework</groupId>  
  26.             <artifactId>spring-context-support</artifactId>  
  27.             <version>${springframework.version}</version>  
  28.         </dependency>  
  29.         <!-- Transaction dependency is required with Quartz integration -->  
  30.         <dependency>  
  31.             <groupId>org.springframework</groupId>  
  32.             <artifactId>spring-tx</artifactId>  
  33.             <version>${springframework.version}</version>  
  34.         </dependency>  
  35.            
  36.         <!-- Quartz framework -->  
  37.         <dependency>  
  38.             <groupId>org.quartz-scheduler</groupId>  
  39.             <artifactId>quartz</artifactId>  
  40.             <version>${quartz.version}</version>  
  41.         </dependency>  
  42.     </dependencies>  
  43. </project>  

步骤 3:Quartz Scheduler 配置作业

有两种方式在 Spring 中使用 Quartz 来配置一个作业。
A:使用 MethodInvokingJobDetailFactoryBean
这种方式在你想要调用特定 bean 的一个方法的时候很是方便,比另一种方法要简单的多。
[html] view plain copy
 print?
  1. <!-- For times when you just need to invoke a method on a specific object -->  
  2. <bean id="simpleJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">  
  3.     <property name="targetObject" ref="myBean" />  
  4.     <property name="targetMethod" value="printMessage" />  
  5. </bean>  

以上作业配置简单调用了 myBean 的 printMessage 方法,myBean 是一个简单的 POJO。
B:使用 JobDetailFactoryBean
如果你需要更高级的设置,需要给作业传递数据,想更加灵活的话就使用这种方式。
[html] view plain copy
 print?
  1. <!-- For times when you need more complex processing, passing data to the scheduled job -->  
  2. <bean name="firstComplexJobDetail"    class="org.springframework.scheduling.quartz.JobDetailFactoryBean">  
  3.     <property name="jobClass" value="com.defonds.scheduler.jobs.FirstScheduledJob" />  
  4.     <property name="jobDataMap">  
  5.         <map>  
  6.             <entry key="anotherBean" value-ref="anotherBean" />  
  7.         </map>  
  8.     </property>  
  9.     <property name="durability" value="true" />  
  10. </bean>  

jobClass 关联到一个继承自 QuartzJobBean 的类,它实现了 Quartz 作业接口。调用到这个作业的时候,它的 executeInternal 将被执行。
jobDataMap 允许我们给相关作业 bean 传递一些数据。在这个例子里,我们将 ScheduledJob 将要使用到的 \'anotherBean\' 传递给它。
以下是引用 jobclass(FirstScheduledJob)的具体实现。
com.defonds.scheduler.jobs.FirstScheduledJob
[java] view plain copy
 print?
  1. /** 
  2.  * File Name:ScheduledJob.java 
  3.  * 
  4.  * Copyright Defonds Corporation 2015  
  5.  * All Rights Reserved 
  6.  * 
  7.  */  
  8. package com.defonds.scheduler.jobs;  
  9.   
  10. import org.quartz.JobExecutionContext;  
  11. import org.quartz.JobExecutionException;  
  12. import org.springframework.scheduling.quartz.QuartzJobBean;  
  13.   
  14. import com.defonds.scheduler.util.AnotherBean;  
  15.   
  16. /** 
  17.  *  
  18.  * Project Name:spring-quartz 
  19.  * Type Name:ScheduledJob 
  20.  * Type Description: 
  21.  * Author:Defonds 
  22.  * Create Date:2015-10-29 
  23.  * @version  
  24.  *  
  25.  */  
  26. public class FirstScheduledJob extends QuartzJobBean {  
  27.       
  28.     private AnotherBean anotherBean;  
  29.   
  30.     @Override  
  31.     protected void executeInternal(JobExecutionContext arg0)  
  32.             throws JobExecutionException {  
  33.         System.out.println("I am FirstScheduledJob");  
  34.         this.anotherBean.printAnotherMessage();  
  35.   
  36.     }  
  37.   
  38.     public void setAnotherBean(AnotherBean anotherBean) {  
  39.         this.anotherBean = anotherBean;  
  40.     }  
  41. }  

步骤 4:配置 Quartz 调度时要使用到的触发器

触发器用来定义调度器何时将会执行你的调度任务的那个时间。有两种可能的触发器类型:
A:简单触发器,使用 SimpleTriggerFactoryBean
你可以定义作业的启动时间、触发器之间的延迟时间以及 repeatInterval(频率)。
[html] view plain copy
 print?
  1. <!-- Run the job every 2 seconds with initial delay of 1 second -->  
  2. <bean id="simpleTrigger"  class="org.springframework.scheduling.quartz.SimpleTriggerFactoryBean">  
  3.     <property name="jobDetail" ref="simpleJobDetail" />  
  4.     <property name="startDelay" value="1000" />  
  5.     <property name="repeatInterval" value="2000" />  
  6. </bean>  

B:计划触发器,使用 CronTriggerFactoryBean
这种类型更加灵活,允许你针对特定实例选择计划方案以及将来要执行的频率。