Quartz 作业调度器

本文主要是介绍Quartz 作业调度器，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

1、Quartz  java实现 

注：这里使用的是Quartz1.6.5版本(包：quartz-1.6.5.jar)

测试工作类

第三方包

通过测试。一个简单任务只需要以下几个包：commons-beanutils.jar、commons-collections.jar、commons-logging.jar、commons-digester.jar、quartz.jar即可

2，Quartz触发器

Quartz中一个Job往往是一个任务业务逻辑的实现，Job并不知道何时被执行。那么执行一个Quartz Job的是一个Trigger实例。Quartz Trigger继承了Quartz框架中的org.quartz.Trigger类，在Quartz框架中目前有三个实现的触发器可用：

· org.quartz.SimpleTrigger

· org.quartz.CronTrigger

· org.quartz.NthIncludedDayTrigger

其实还有一个触发器实现，叫做UICronTrigger，不过在Quartz1.5版本之后，这个触发器便不推荐使用。它主要用在Quartz Web应用程序中，Quartz本身并不再使用。

使用org.quartz.SimpleTrigger

从类的命名上，想必聪明的你已经明白，SimpleTrigger主要是针对一些相对简单的时间触发进行配置使用，比如在指定的时间开始然后在一定的时间间隔之内重复执行一个Job，同事可以任意指定重复的次数.下面就是使用一个SimpleTrigger的例子:

public class Listing_4_9 {
static Log logger = LogFactory.getLog(Listing_4_9.class);

public static void main(String[] args) {
Listing_4_9 example = new Listing_4_9();
example.startScheduler();
}

public void startScheduler() {
try {
// 创建并启动调度实例
Scheduler scheduler =
StdSchedulerFactory.getDefaultScheduler();
scheduler.start();
logger.info("Scheduler has been started");
JobDetail jobDetail =
new JobDetail("PrintInfoJob",
Scheduler.DEFAULT_GROUP,
PrintInfoJob.class);
/*
* 创建一个立即启动的触发器，这个触发器没有结束日期，每一分钟（60000毫秒）
* 执行一次。
*/
Trigger trigger =
new SimpleTrigger("myTrigger",
Scheduler.DEFAULT_GROUP, new Date(), null,
SimpleTrigger.REPEAT_INDEFINITELY,
60000L);
scheduler.scheduleJob(jobDetail, trigger );
} catch (SchedulerException ex) {
logger.error(ex);
}
}
}
在SimpleTrigger中有多个构造函数。下面的代码创建了一个带有名称和默认组的trigger：

//No Argument Constructor
SimpleTrigger sTrigger = new SimpleTrigger("myTrigger", Scheduler.DEFAULT_GROUP);
上面创建这个触发器在创建后便立即执行，单并且没有重复。同样SimpleTrigger还有其他构造函数参数来配置创建特定时间、重复次数和触发器每次执行的延迟时间，如下面这个构造函数：

public SimpleTrigger(String name, String group, String jobName, String jobGroup, Date startTime, Date endTime, int repeatCount, long repeatInterval);
使用org.quartz.CronTrigger
CronTrigger可以配置更复杂的触发时刻表，当然使用一个或者多个SimpleTriggers也许同样可以达到效果，但是CronTrigger却可以用更简单的方法解决更复杂的事情。

CronTrigger的时刻表配置类似于Unix下的cron表达式。比如，可能有这样一个Job需要在每周的星期一和星期五早上8点到9点每五分钟执行一次，如果直接使用SimpleTrigger来实现的话，想必要费一些周折。那么此时就可以使用一个类似于cron表达式的表达语句来指定此触发时刻表。

"0 0/5 8 ? * MON,FRI"
try {
CronTrigger cTrigger = new CronTrigger("myTrigger",
Scheduler.DEFAULT_GROUP, "0 0/5 8 ? *MON,FRI");
} catch (ParseException ex) {
ex.printStackTrace();
}
CronTriggers在时刻的触发配置上拥有非常大的弹性，几乎可以创建所有的时刻表表达式。后续我们会更详细的讲解CronTriggers和cron表达式的用法。

使用 org.quartz.NthIncludedDayTrigger
org.quartz.NthIncludedDayTrigger是Quartz开发团队在Quartz框架中新添加的一个触发器。它设计的目标是提供不同时间间隔的第n天执行时刻表。比如，你想在每个月的第15日处理财务发票记帐，那么可以使用NthIncludedDayTrigger来完成这项工作。Quartz日历（Calendar）同样可以和一个触发器进行关联来设定双休日或者假期。下面我们来创建一个实例来说明如何使用NthIncludedDayTrigger：

NthIncludedDayTrigger trigger =
new NthIncludedDayTrigger("MyTrigger", Scheduler.DEFAULT_GROUP);
trigger.setN(15);
trigger.setIntervalType(NthIncludedDayTrigger.INTERVAL_TYPE_MONTHLY);

3.配置文件形式

采用配置文件方式的Quartz调度：

1、所需的第三方包

commons-beanutils.jar

commons-collections-3.2.jar

commons-digester.jar

commons-logging.jar

jta.jar

quartz.jar

2、自定被调度的Job

package com.allen;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class MyJob implements Job {

 /**
  * 需要定时调度的方法
  */
 public void execute(JobExecutionContext arg0) throws JobExecutionException {
  
  System.out.println("我是被定时调度的方法啊，当前时间为："+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss SS").format(new Date()));

 }

}

4.spring 整合

最近在研究Spring中的定时任务功能，最好的办法当然是使用Quartz来实现。对于一个新手来说，花了我不少时间，这里我写个笔记，给大家参考。 
我使用的是Maven来管理项目，需要的Jar包我给大家贴出来。 
quartz-1.8.5.jar 
commons-logging.jar 
spring-core-3.0.5.RELEASE.jar 
spring-beans-3.0.5.RELEASE.jar 
spring-context-3.0.5.RELEASE.jar 
spring-context-support-3.0.5.RELEASE.jar 
spring-asm-3.0.5.RELEASE.jar 
spring-expression-3.0.5.RELEASE.jar 
spring.transaction-3.0.5.RELEASE.jar 
spring-web-3.0.5.RELEASE.jar 
Maven的pom.xml的配置： 

Xml代码  

1. <?xml version="1.0" encoding="UTF-8"?>  
2. <project xmlns="http://maven.apache.org/POM/4.0.0"  
3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">  
5.     <modelVersion>4.0.0</modelVersion>  
6.   
7.     <groupId>QtzTest</groupId>  
8.     <artifactId>QtzTest</artifactId>  
9.     <version>1.0</version>  
10.   
11.     <properties>  
12.         <springframework.version>3.0.5.RELEASE</springframework.version>  
13.     </properties>  
14.   
15.     <dependencies>  
16.         <dependency>  
17.             <groupId>org.springframework</groupId>  
18.             <artifactId>spring-context</artifactId>  
19.             <version>${springframework.version}</version>  
20.         </dependency>  
21.   
22.         <dependency>  
23.             <groupId>org.springframework</groupId>  
24.             <artifactId>spring-context-support</artifactId>  
25.             <version>${springframework.version}</version>  
26.         </dependency>  
27.   
28.         <dependency>  
29.             <groupId>org.springframework</groupId>  
30.             <artifactId>spring-tx</artifactId>  
31.             <version>${springframework.version}</version>  
32.         </dependency>  
33.   
34.         <dependency>  
35.             <groupId>org.springframework</groupId>  
36.             <artifactId>spring-web</artifactId>  
37.             <version>${springframework.version}</version>  
38.         </dependency>  
39.   
40.         <dependency>  
41.             <groupId>org.quartz-scheduler</groupId>  
42.             <artifactId>quartz</artifactId>  
43.             <version>1.8.5</version>  
44.         </dependency>  
45.     </dependencies>  
46.   
47.     <build>  
48.         <finalName>${project.artifactId}</finalName>  
49.         <plugins>  
50.             <plugin>  
51.                 <groupId>org.mortbay.jetty</groupId>  
52.                 <artifactId>jetty-maven-plugin</artifactId>  
53.                 <version>7.5.4.v20111024</version>  
54.                 <configuration>  
55.                     <scanIntervalSeconds>10</scanIntervalSeconds>  
56.                     <webApp>  
57.                         <contextPath>/${project.artifactId}</contextPath>  
58.                     </webApp>  
59.                 </configuration>  
60.             </plugin>  
61.         </plugins>  
62.     </build>  
63. </project>  

Java代码  

1. package com.ncs.hj;  
2.   
3. import org.quartz.JobExecutionContext;  
4. import org.quartz.JobExecutionException;  
5. import org.springframework.scheduling.quartz.QuartzJobBean;  
6.   
7. public class SpringQtz extends QuartzJobBean{  
8.     private static int counter = 0;  
9.     protected void executeInternal(JobExecutionContext context) throws JobExecutionException {  
10.         System.out.println();  
11.         long ms = System.currentTimeMillis();  
12.         System.out.println("\t\t" + new Date(ms));  
13.         System.out.println(ms);  
14.         System.out.println("(" + counter++ + ")");  
15.         String s = (String) context.getMergedJobDataMap().get("service");  
16.         System.out.println(s);  
17.         System.out.println();  
18.     }  
19. }  

Java代码  

1. package com.ncs.hj;  
2.   
3. import org.quartz.JobExecutionContext;  
4. import org.quartz.JobExecutionException;  
5. import org.springframework.scheduling.quartz.QuartzJobBean;  
6.   
7. import java.util.Date;  
8.   
9. public class SpringQtz {  
10.     private static int counter = 0;  
11.     protected void execute()  {  
12.         long ms = System.currentTimeMillis();  
13.         System.out.println("\t\t" + new Date(ms));  
14.         System.out.println("(" + counter++ + ")");  
15.     }  
16. }  

Xml代码  

1. <!------------ 配置调度程序quartz ，其中配置JobDetail有两种方式-------------->    
2.     <!--方式一：使用JobDetailBean，任务类必须实现Job接口 -->     
3.     <bean id="myjob" class="org.springframework.scheduling.quartz.JobDetailBean">    
4.      <property name="name" value="exampleJob"></property>    
5.      <property name="jobClass" value="com.ncs.hj.SpringQtz"></property>   
6.      <property name="jobDataAsMap">  
7. <map>  
8.     <entry key="service"><value>simple is the beat</value></entry>  
9. </map>  
10. ;/property>  
11.     </bean>   
12.     <!--运行时请将方式一注释掉！ -->    
13.     <!-- 方式二：使用MethodInvokingJobDetailFactoryBean，任务类可以不实现Job接口，通过targetMethod指定调用方法-->    
14.     <!-- 定义目标bean和bean中的方法 -->  
15.     <bean id="SpringQtzJob" class="com.ncs.hj.SpringQtz"/>  
16.     <bean id="SpringQtzJobMethod" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">  
17.     <property name="targetObject">  
18.         <ref bean="SpringQtzJob"/>  
19.     </property>  
20.     <property name="targetMethod">  <!-- 要执行的方法名称 -->  
21.         <value>execute</value>  
22.     </property>  
23. </bean>  
24.   
25. <!-- ======================== 调度触发器 ======================== -->  
26. <bean id="CronTriggerBean" class="org.springframework.scheduling.quartz.CronTriggerBean">  
27.     <property name="jobDetail" ref="SpringQtzJobMethod"></property>  
28.     <property name="cronExpression" value="0/5 * * * * ?"></property>  
29. </bean>  
30.   
31. <!-- ======================== 调度工厂 ======================== -->  
32. <bean id="SpringJobSchedulerFactoryBean" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">  
33.     <property name="triggers">  
34.         <list>  
35.             <ref bean="CronTriggerBean"/>  
36.         </list>  
37.     </property>  
38. </bean>    

Xml代码  

1. <?xml version="1.0" encoding="UTF-8"?>  
2. <web-app xmlns="http://java.sun.com/xml/ns/javaee"  
3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
4.          xsi:schemaLocation="http://java.sun.com/xml/ns/javaee  
5.           http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"  
6.          version="2.5">  
7.     <welcome-file-list>  
8.         <welcome-file>index.html</welcome-file>  
9.     </welcome-file-list>  
10.   
11.     <context-param>  
12.         <param-name>contextConfigLocation</param-name>  
13.         <param-value>/WEB-INF/spring-config.xml</param-value>  
14.     </context-param>  
15.   
16.     <listener>  
17.         <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>  
18.     </listener>  
19. </web-app>  

这篇关于Quartz 作业调度器的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！