quartz集成spring下的集群配置

写在前头

    spring3.0以后就开始支持quartz2.x，因为org.quartz.CronTrigger在2.0从class变成了一个interface,Spring4.0.6配置文件中使用CronTriggerFactoryBean来集成quartz2.x,使用CronTriggerBean来集成quartz1.8.x及以前版本.

准备环境

我用的是spring4.0.6 + quartz 2.1.7

1. quartz官网： http://www.quartz-scheduler.org/

2. spring集成环境

<dependency>
    <groupId>org.quartz-scheduler</groupId>
    <artifactId>quartz</artifactId>
    <version>2.1.7</version>
</dependency>
<dependency>
    <groupId>org.quartz-scheduler</groupId>
    <artifactId>quartz-oracle</artifactId>
    <version>2.1.7</version>
</dependency>
<dependency>
    <groupId>org.quartz-scheduler</groupId>
    <artifactId>quartz-weblogic</artifactId>
    <version>2.1.7</version>
</dependency>
<dependency>
    <groupId>org.quartz-scheduler</groupId>
    <artifactId>quartz-jboss</artifactId>
    <version>2.1.7</version>
</dependency>
           

搭建环境

创建数据库表结构

文件路径：quartz-2.1.7\docs\dbTables\*.sql 选择对应数据库的脚本，然后执行。我选择的ORACLE.

创建quartz.properties文件

#============================================================================
# Configure Main Scheduler Properties  
#============================================================================
org.quartz.scheduler.instanceName = EventScheduler   
org.quartz.scheduler.instanceId = AUTO  
 
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool 
org.quartz.threadPool.threadCount = 10 
org.quartz.threadPool.threadPriority = 5 
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true 
 

#============================================================================
# Configure JobStore  
#============================================================================
org.quartz.jobStore.misfireThreshold = 60000 
org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
# mysql 
#org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate
# Oracle 
org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.oracle.OracleDelegate  
org.quartz.jobStore.tablePrefix = QRTZ_ 
org.quartz.jobStore.maxMisfiresToHandleAtATime=10 
org.quartz.jobStore.isClustered = true  
org.quartz.jobStore.clusterCheckinInterval = 20000 
           

创建spring配置文件applicationContext-job.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
	xmlns:mvc="http://www.springframework.org/schema/mvc"
	xmlns:p="http://www.springframework.org/schema/p"
	xmlns:util="http://www.springframework.org/schema/util"
	xsi:schemaLocation="    
        http://www.springframework.org/schema/beans     
        http://www.springframework.org/schema/beans/spring-beans.xsd    
        http://www.springframework.org/schema/context     
        http://www.springframework.org/schema/context/spring-context.xsd    
        http://www.springframework.org/schema/mvc     
        http://www.springframework.org/schema/mvc/spring-mvc-3.1.xsd 
        http://www.springframework.org/schema/util 
        http://www.springframework.org/schema/util/spring-util-3.2.xsd">
        
    <bean id="jobService" class="com.test.service.TestJobservice"/>
 
 
    <!-- 定义任务 -->
    <bean id="vcaEventJobTask" class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
        <property name="jobClass">
            <!-- 上面的任务代理类 -->
            <value>com.test.service.DetailQuartzJobBean</value>
        </property>
        <property name="jobDataAsMap">
            <map>
                <!-- 实际的任务的Bean name，填上EventMonitorService的Bean name -->
                <entry key="targetObject" value="jobService" />
                <!-- 执行Bean中的哪个方法 -->
                <entry key="targetMethod" value="executeTask" />
            </map>
        </property>
        <property name="durability" value="true"></property> 
    </bean>
 
    <!-- 任务触发器 -->
    <bean id="eventTaskTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <property name="jobDetail">
            <!-- 任务代理Bean name -->
            <ref bean="vcaEventJobTask" />
        </property>
        <property name="cronExpression">
            <!-- 配置表达式，这里表示每五分钟执行一次 -->
            <value>0 0/1 * * * ?</value>
        </property>
    </bean>
    <!-- 任务调度入口 -->
    <bean autowire="no"
        class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="dataSource">
            <ref bean="dataSource" />
        </property>
        <!-- 任务列表，可以配置多个任务加入到该List -->
        <property name="triggers">
            <list>
               <ref bean="eventTaskTrigger"/>  
            </list>
        </property>
        <property name="configLocation" value="classpath:quartz.properties" />
        <property name="applicationContextSchedulerContextKey" value="applicationContext" />
        <property name="startupDelay" value="30" />
        <property name="autoStartup" value="true" />
        <property name="overwriteExistingJobs" value="true" />
    </bean>
</beans>
           

创建任务类

代理类DetailQuartzJobBean.java

package com.test.service;
import java.lang.reflect.Method;


import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.context.ApplicationContext;
import org.springframework.scheduling.quartz.QuartzJobBean;


public class DetailQuartzJobBean extends QuartzJobBean {
	 private ApplicationContext applicationContext;  
	 
	 private String targetObject;
	 
	private String targetMethod;
	 
     public String getTargetObject() {
		return targetObject;
	}


	public void setTargetObject(String targetObject) {
		this.targetObject = targetObject;
	}


	public String getTargetMethod() {
		return targetMethod;
	}


	public void setTargetMethod(String targetMethod) {
		this.targetMethod = targetMethod;
	}


	public ApplicationContext getApplicationContext() {
		return applicationContext;
	}
	  
     /** 
	   * 从SchedulerFactoryBean注入的applicationContext. 
	   */  
     public void setApplicationContext(ApplicationContext applicationContext) {  
        this.applicationContext = applicationContext;  
    }  
	  
	    @Override  
	protected void executeInternal(JobExecutionContext ctx)
			throws JobExecutionException {
		try {


			// logger.info("execute [" + targetObject + "] at once>>>>>>");
			Object otargetObject = applicationContext.getBean(targetObject);
			Method m = null;
			try {
				m = otargetObject.getClass().getMethod(targetMethod,
						new Class[] {});
				m.invoke(otargetObject, new Object[] {});
			} catch (SecurityException e) {
				// logger.error(e);
			} catch (NoSuchMethodException e) {
				// logger.error(e);
			}


		} catch (Exception e) {
			throw new JobExecutionException(e);
		}


	}
}
           

目标类TestJobservice.java

package com.test.service;

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

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class TestJobservice {

	private static final transient Logger logger = LoggerFactory.getLogger(TestJobservice.class);  
	
	public void executeTask() {
		logger.info("executing at " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
	}
}
           

配置以上操作，即可完成集群下quartz的功能。