Quartz 在 Spring 中如何动态配置时间

转载：

http://sundoctor.iteye.com/blog/399980

?

在项目中有一个需求，需要灵活配置调度任务时间，并能自由启动或停止调度。
有关调度的实现我就第一就想到了Quartz这个开源调度组件，因为很多项目使用过，Spring结合Quartz静态配置调度任务时间，非常easy。比如：每天凌晨几点定时运行一个程序，这只要在工程中的spring配置文件中配置好spring整合quartz的几个属性就好。

Spring配置文件

<property name="targetMethod" value="test" />
</bean>
<bean id="cronTrigger" ref="jobDetail" />
<property name="cronExpression" value="0 0/50 * ? * * *" />
</bean>
<bean? id="schedulerTrigger" alt="Quartz 在 Spring 中怎么动态配置时间">

三、配置数据库连接池
配置jdbc.properties文件

<beans xmlns="http://www.springframework.org/schema/beans"
??? xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
??? xmlns:aop="http://www.springframework.org/schema/aop"
??? xmlns:tx="http://www.springframework.org/schema/tx"
??? xmlns:context="http://www.springframework.org/schema/context"
???? xmlns:jee="http://www.springframework.org/schema/jee"
??? xsi:schemaLocation="
??? http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd
??? http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
??? http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd
??? http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd
???? http://www.springframework.org/schema/jee
?????? http://www.springframework.org/schema/jee/spring-jee-2.5.xsd"? >
?
?? <context:component-scan base-package="com.sundoctor"/>

<!-- 属性文件读入 -->
<bean id="propertyConfigurer" destroy-method="close">
<property name="driverClass" value="${jdbc.driverClassName}" />
<property name="jdbcUrl" value="${jdbc.url}" />
<property name="user" value="${jdbc.username}" />
<property name="password" value="${jdbc.password}" />
<property name="initialPoolSize" value="${cpool.minPoolSize}"/>
<property name="minPoolSize" value="${cpool.minPoolSize}" />
<property name="maxPoolSize" value="${cpool.maxPoolSize}" />
<property name="acquireIncrement" value="${cpool.acquireIncrement}" />
??? <property name="maxIdleTime" value="${cpool.maxIdleTime}"/>??
</bean>

</beans>

这里只是配置了数据连接池，我使用c3p0 连接池，还没有涉及到Quartx有关配置，下面且听我慢慢道来。

四、实现动态定时任务
? 什么是动态定时任务：是由客户制定生成的，服务端只知道该去执行什么任务，但任务的定时是不确定的（是由客户制定）。
这样总不能修改配置文件每定制个定时任务就增加一个trigger吧，即便允许客户修改配置文件，但总需要重新启动web服务啊，研究了下Quartz在Spring中的动态定时，发现

???????? <property name="jobDetail" ref="schedulerJobDetail"/>
???????? <property name="cronExpression">
???????????? <value>0/10 * * * * ?</value>
???????? </property>

中cronExpression是关键，如果可以动态设置cronExpression的值，就可以顺利解决问题了。这样我们就不能直接使用org.springframework.scheduling.quartz.CronTriggerBean，需要自己实现一个动态调度服务类，在其中构建CronTrigger或SimpleTrigger，动态配置时间。
动态调度服务接口：

<property name="targetMethod" value="testMethod" />
</bean>



中使用org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean。在这里使用org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean。会报

<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN 2.0//EN" "http://www.springframework.org/dtd/spring-beans-2.0.dtd">

<beans>
<bean name="quartzScheduler" />?
</property>
<property name="applicationContextSchedulerContextKey"? value="applicationContextKey" />
<property name="configLocation" value="classpath:quartz.properties"/>
</bean>

<bean id="jobDetail" />
</entry>
</map>
</property>

</bean>
</beans>




quartzScheduler中没有了

</entry>
</map>
</property>




中需要注入调度业务类，否则会报空指指错误。

dataSource：项目中用到的数据源，里面包含了quartz用到的12张数据库表；
applicationContextSchedulerContextKey： 是org.springframework.scheduling.quartz.SchedulerFactoryBean这个类中把spring上下文以key/value的方式存放在了quartz的上下文中了，可以用applicationContextSchedulerContextKey所定义的key得到对应的spring上下文；
configLocation：用于指明quartz的配置文件的位置，如果不用spring配置quartz的话，本身quartz是通过一个配置文件进行配置的，默认名称是quartz.properties，里面配置的参数在quartz的doc文档中都有介绍，可以调整quartz，我在项目中也用这个文件部分的配置了一些属性，代码如下：

package?com.sundoctor.example.test; ????import?java.text.ParseException; ??import?java.text.SimpleDateFormat; ??import?java.util.Date; ????import?org.springframework.context.ApplicationContext; ??import?org.springframework.context.support.ClassPathXmlApplicationContext; ????import?com.sundoctor.quartz.service.SchedulerService; ????public?class?MainTest?{ ????????/** ??????*?@param?args ??????*/??????public?static?void?main(String[]?args)?{ ??????????ApplicationContext?springContext?=?new?ClassPathXmlApplicationContext(new?String[]{"classpath:applicationContext.xml","classpath:applicationContext-quartz.xml"}); ??????????SchedulerService?schedulerService?=?(SchedulerService)springContext.getBean("schedulerService"); ?????????? ??????????//执行业务逻辑... ?????????? ??????????//设置调度任务 ??????????//每10秒中执行调试一次 ??????????schedulerService.schedule("0/10?*?*???*?*?*");? ?????????? ??????????Date?startTime?=?parse("2009-06-01?22:16:00"); ??????????Date?endTime?=??parse("2009-06-01?22:20:00"); ?????????? ??????????//2009-06-01?21:50:00开始执行调度 ??????????schedulerService.schedule(startTime); ????????????<s