Spring Quartz 浅析

今天在解决项目的一个问题的时候（后期维护），发现项目中有用到Spring配置Quartz，花了点时间去熟悉了一下：

 

1. Quartz是一个强大的企业级任务调度框架，Spring中继承并简化了Quartz。

 

2. 驱动工作流：比如，如果新创建的流程任务需要在2小时内处理完，则在2小时后Quartz会检查订单是否成功处理。如果没有处理，则Quartz会依据工作流定义的规则来对订单进行处理，销毁它，或者进行其他处理。

 

3. 系统维护工作：比如，在每个工作日的固定时间将RDBMS中的内容导出为XML文件。

 

下面是项目中用到的Spring配置信息：

<?xml version="1.0"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">

<beans>
	<bean name="confirFeedback" class="com.test.service.FeedbackManager">
		<property name="feedback" ref="feedbackService" />
	</bean>

	<bean id="confirFeedbackJob" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
		<property name="targetObject" ref="confirFeedback" />
		<property name="targetMethod" value="doIt" />
		<property name="concurrent" value="false" />
	</bean>

	<bean id="confirFeedbackTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean">
		<!-- see the example of method invoking job above -->
		<property name="jobDetail" ref="confirFeedbackJob" />
		<!-- 10 seconds -->
		<property name="startDelay" value="10000" />
		<!-- repeat every 5 minutes -->
		<property name="repeatInterval" value="600000" />
	</bean>

	<bean name="autoHostDownloadService" class="com.test.service.AutoHostDownloadService" lazy-init="true">
		<property name="hostDownloadService" ref="hostDownloadService" />
		<property name="hostDownloadAlertService" ref="hostDownloadAlertService" />
		<property name="type" value="1" />
	</bean>

	<bean id="autoHostDownloadJob" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
		<property name="targetObject" ref="autoHostDownloadService" />
		<property name="targetMethod" value="work" />
		<property name="concurrent" value="false" />
	</bean>

	<bean id="autoHostDownloadTrigger1" class="org.springframework.scheduling.quartz.CronTriggerBean">
		<property name="jobDetail" ref="autoHostDownloadJob" />

		<!-- every five minutes for test -->
		<!-- <property name="cronExpression" value="0 0/5 * * * ?" /> -->

		<!-- 9:55 AM in every day -->
		<!-- <property name="cronExpression" value="0 55 9 * * ?" /> -->

		<!-- 9:55 AM from Mondy to Friday -->
		<property name="cronExpression" value="0 55 9 ? * MON-FRI" />
		
	</bean>

	<bean id="autoHostDownloadTrigger2" class="org.springframework.scheduling.quartz.CronTriggerBean">
		<property name="jobDetail" ref="autoHostDownloadJob" />

		<!-- 15:25 AM in every day -->
		<!-- <property name="cronExpression" value="0 25 15 * * ?" /> -->

		<!-- 15:25 AM from Mondy to Friday -->
		<property name="cronExpression" value="0 25 15 ? * MON-FRI" />
	</bean>

	<bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
		<property name="triggers">
			<list>
				<ref bean="confirFeedbackTrigger" />
				<ref bean="autoHostDownloadTrigger1" />
				<ref bean="autoHostDownloadTrigger2" />
			</list>
		</property>
		<property name="waitForJobsToCompleteOnShutdown" value="true" />
	</bean>

</beans>

   其中cronExpression的表达式说明如下：

  

表达式意义 
"0 0 12 * * ?"                 每天中午12点触发 
"0 15 10 ? * *"               每天上午10:15触发 
"0 15 10 * * ?" 	       每天上午10:15触发 
"0 15 10 * * ? *"            每天上午10:15触发 
"0 15 10 * * ? 2005"      2005年的每天上午10:15触发 
"0 * 14 * * ?"                 在每天下午2点到下午2:59期间的每1分钟触发 
"0 0/5 14 * * ?"              在每天下午2点到下午2:55期间的每5分钟触发 
"0 0/5 14,18 * * ?"         在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发 
"0 0-5 14 * * ?"              在每天下午2点到下午2:05期间的每1分钟触发 
"0 10,44 14 ? 3 WED"     每年三月的星期三的下午2:10和2:44触发 
"0 15 10 ? * MON-FRI"    周一至周五的上午10:15触发 
"0 15 10 15 * ?"              每月15日上午10:15触发 
"0 15 10 L * ?"                每月最后一日的上午10:15触发 
"0 15 10 ? * 6L"              每月的最后一个星期五上午10:15触发 
"0 15 10 ? * 6#3"           每月的第三个星期五上午10:15触发 
"0 15 10 ? * 6L 2002-2005"       2002年至2005年的每月的最后一个星期五上午10:15触发 

 

 

   FeedBackManager代码

  

package test;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import com.test.service.IFeedbackService;

public class FeedbackManager {

	protected final Log log = LogFactory.getLog(this.getClass());

	private IFeedbackService feedback;

	public void doIt() {
		feedback.feedbackTest1(true);
		feedback.feedbackTest2(true);
		feedback.feedbackTest3(true);
		feedback.feedbackTest4(true);
		feedback.feedbackTest5(true);
	}

	public void setFeedback(IFeedbackService feedback) {
		this.feedback = feedback;
	}

}

 

 

 

【参考文章】

1. http://developer.51cto.com/art/200906/130436.htm

2. http://developer.51cto.com/art/200906/131888.htm