Spring Quartz 动态配置定时任务

from:Spring Quartz 动态配置定时任务

1、Quartz在Spring中的简单配置

Spring配置文件quartz.xml:

Java代码  
  1. <?xml version=“1.0” encoding=“UTF-8”?>
  2.         <!DOCTYPE beans PUBLIC “-//SPRING//DTD BEAN//EN” “http://www.springframework.org/dtd/spring-beans.dtd”>
  3. <beans>
  4.     <bean id=“scheduleInfoService” class=“com.erry.tntops.web.task.ScheduleInfoService”>
  5.          <property name=“scheduler” ref=“schedulerFactory”/>
  6.      </bean>
  7.      <bean id=“jobDetail” class=“org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean”>
  8.          <property name=“targetObject” ref=“scheduleInfoService”/>
  9.          <property name=“targetMethod” value=“test”/>
  10.          <property name=“concurrent” value=“false”/>
  11.      </bean>
  12.      <bean id=“cronTrigger” class=“org.springframework.scheduling.quartz.CronTriggerBean” >
  13.           <property name=“jobDetail” ref=“jobDetail”/>
  14.           <property name=“cronExpression”>
  15.               <value>0/10 * * * * ?</value>
  16.           </property>
  17.       </bean>
  18.      <bean id=“schedulerFactory” class=“org.springframework.scheduling.quartz.SchedulerFactoryBean”>
  19.          <property name=“triggers”>
  20.              <list>
  21.                  <ref local=“cronTrigger”/>
  22.              </list>
  23.          </property>
  24.     </bean>
  25. </beans>

在上面的配置中设定:

① targetMethod: 指定需要定时执行scheduleInfoAction中的test()方法

② concurrent:对于相同的JobDetail,当指定多个Trigger时, 很可能第一个job完成之前,第二个job就开始了。指定concurrent设为false,多个job不会并发运行,第二个job将不会在第一个job完成之前开始。

③ cronExpression:0/10 * * * * ?表示每10秒执行一次,具体可参考附表。

④ triggers:通过再添加其他的ref元素可在list中放置多个触发器。

scheduleInfoAction中的simpleJobTest()方法

注意:此方法没有参数,如果scheduleInfoAction有两个方法test()和test(String argument),则spring只会去执行无参的test().

Java代码  
  1. public void test() {
  2.          log.warn(“uh oh, Job is scheduled !'” + “‘ Success…”);
  3. }

2、Quartz在Spring中动态设置cronTrigger方法一

(1)、Spring配置文件quartz.xml:

Java代码  
  1. <?xml version=“1.0” encoding=“UTF-8”?>
  2.         <!DOCTYPE beans PUBLIC “-//SPRING//DTD BEAN//EN” “http://www.springframework.org/dtd/spring-beans.dtd”>
  3. <beans>
  4.     <bean id=“scheduleInfoAction” class=“com.erry.tntops.web.task.ScheduleInfoAction”>
  5.         <property name=“scheduler” ref=“schedulerFactory”/>
  6.         <!– ref中的emsService是xml中配置的bean的id –>
  7.         <property name=“emsService” ref=“emsService”/>
  8.      </bean>
  9.      <bean id=“jobDetail” class=“org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean”>
  10.          <property name=“targetObject” ref=“scheduleInfoAction”/>
  11.          <property name=“targetMethod” value=“reScheduleJob”/>
  12.          <property name=“concurrent” value=“false”/>
  13.      </bean>
  14.      <bean id=“cronTrigger” class=“com.erry.tntops.web.task.InitCronTrigger”>
  15.           <property name=“jobDetail” ref=“jobDetail”/>
  16.           <property name=“cronExpression”>
  17.               <value>0/10 * * * * ?</value>
  18.           </property>
  19.       </bean>
  20.      <bean id=“schedulerFactory” class=“org.springframework.scheduling.quartz.SchedulerFactoryBean”>
  21.          <property name=“triggers”>
  22.              <list>
  23.                  <ref local=“cronTrigger”/>
  24.              </list>
  25.          </property>
  26.     </bean>
  27. </beans>

(2)、类ScheduleInfoAction:

Java代码  
  1. import org.apache.log4j.Logger;
  2. import org.quartz.Scheduler;
  3. import org.quartz.SchedulerException;
  4. import org.springframework.scheduling.quartz.CronTriggerBean;
  5. import java.text.ParseException;
  6. import java.util.Date;
  7. public class ScheduleInfoAction{
  8.     Logger logger = Logger.getLogger(ScheduleInfoAction.class);
  9.      private Scheduler scheduler;
  10.      // 设值注入,通过setter方法传入被调用者的实例scheduler
  11.      public void setScheduler(Scheduler scheduler) {
  12.          this.scheduler = scheduler;
  13.     }
  14.     private EmsService emsService;
  15.     public void setEmsService(EmsService emsService){
  16.         this.emsService = emsService;
  17.     }
  18.     public void reScheduleJob() throws SchedulerException {
  19.         // 运行时可通过动态注入的scheduler得到trigger,注意采用这种注入方式在有的项目中会有问题,如果遇到注入问题,可以采取在运行方法时候,获得bean来避免错误发生。
  20.         CronTriggerBean trigger = (CronTriggerBean) scheduler.getTrigger(“cronTrigger”, Scheduler.DEFAULT_GROUP);
  21.         logger.info(“*********** trigger: “ + trigger);
  22.         String dbCronExpression = getCronExpressionFromDB();
  23.         logger.info(“*********** dbCronExpression: “ + dbCronExpression);
  24.         String originConExpression = trigger.getCronExpression();
  25.         logger.info(“*********** originConExpression: “ + originConExpression);
  26.         // 判断从DB中取得的任务时间(dbCronExpression)和现在的quartz线程中的任务时间(originConExpression)是否相等
  27.         // 如果相等,则表示用户并没有重新设定数据库中的任务时间,这种情况不需要重新rescheduleJob
  28.         if(!originConExpression.equalsIgnoreCase(dbCronExpression)){
  29.             try{
  30.                 trigger.setCronExpression(dbCronExpression);
  31.                 scheduler.rescheduleJob(“cronTrigger”, Scheduler.DEFAULT_GROUP, trigger);
  32.             } catch (ParseException e) {
  33.                 logger.error(“——————- ParseException Error! ——————-“);
  34.                 e.printStackTrace();
  35.                 logger.error(“————————————————————-“);
  36.             }
  37.         }
  38.         //执行task
  39.         logger.info(“task start time: “ + new Date());
  40.         System.out.println(“Task test success!”);
  41.         logger.info(”  task end time: “ + new Date());
  42.     }
  43.     private String getCronExpressionFromDB(){
  44.         String sql = “select CRON from t_test_task_trigger where available = 1 and trigger_name = ‘cronTrigger'”;
  45.         return emsService.getCron(sql);
  46.     }
  47. }

3、Quartz在Spring中动态设置cronTrigger方法二

在2中我们已经能够实现动态配置cronException,但是我们依然需要设定一个默认的cronException:

Java代码  
  1. <property name=“cronExpression”>
  2.               <value>0/10 * * * * ?</value>
  3.           </property>

如果我们拿掉它,则容器(如Jboss)会报错。

实际上我们希望容器启动时就去数据库获得dbCronException,而不需要再初始化一个cronException。观察CronTriggerBean,需要初始化cronException,我们可以创建类InitCronTrigger继承CronTriggerBean,从DB中获得数据初始化cronException,这样问题就解决了。

(1)、Spring配置文件quartz.xml:

Java代码  
  1. <?xml version=“1.0” encoding=“UTF-8”?>
  2.         <!DOCTYPE beans PUBLIC “-//SPRING//DTD BEAN//EN” “http://www.springframework.org/dtd/spring-beans.dtd”>
  3. <beans>
  4.     <bean id=“scheduleInfoAction” class=“wym.task.ScheduleInfoAction”>
  5.         <property name=“scheduler” ref=“schedulerFactory”/>
  6.         <property name=“emsService” ref=“EmsService”/>
  7.      </bean>
  8.      <bean id=“jobDetail” class=“org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean”>
  9.          <property name=“targetObject” ref=“scheduleInfoAction”/>
  10.          <property name=“targetMethod” value=“reScheduleJob”/>
  11.          <!– concurrent设为false,多个job不会并发运行 –>
  12.          <property name=“concurrent” value=“false”/>
  13.      </bean>
  14.      <bean id=“cronTrigger” class=“wym.task.InitCronTrigger”>
  15.           <property name=“jobDetail” ref=“jobDetail”/>
  16.          <!–<property name=“cronExpression”>–>
  17.              <!–<value>0/30 * * * * ?</value>–>
  18.          <!–</property>–>
  19.           <property name=“emsService” ref=“EmsService”/>
  20.       </bean>
  21.      <bean id=“schedulerFactory” class=“org.springframework.scheduling.quartz.SchedulerFactoryBean”>
  22.          <property name=“triggers”>
  23.              <list>
  24.                  <ref local=“cronTrigger”/>
  25.              </list>
  26.          </property>
  27.     </bean>
  28. </beans>

(2)、类InitCronTrigger

注意:在注入scheduleInfoManager属性的时候,我们可以去读取DB任务时间(之所以放在setter方法中,是因为需要在设置scheduleInfoManager后进行getCronExpressionFromDB(),否则,也可以①②逻辑把放在类的构造函数中).

注意InitializingCronTrigger必须extends CronTriggerBean.

Java代码  
  1. import com.erry.tntops.ems.service.EmsService;
  2. import org.springframework.scheduling.quartz.CronTriggerBean;
  3. import java.io.Serializable;
  4. import java.text.ParseException;
  5. public class InitCronTrigger extends CronTriggerBean implements Serializable {
  6.     private EmsService emsService;
  7.     public void setEmsService(EmsService emsService) throws ParseException {
  8.         this.emsService = emsService;
  9.         String cronException = getCronExceptionDB();
  10.         setCronExpression(cronException);
  11.     }
  12.     private String getCronExceptionDB(){
  13.         String sql = “select CRON from t_test_task_trigger where available = 1 and trigger_name = ‘cronTrigger'”;
  14.         System.out.println(“*****” + sql);
  15.         return emsService.getCron(sql);
  16.     }
  17. }
此条目发表在java分类目录,贴了, 标签。将固定链接加入收藏夹。

发表评论

电子邮件地址不会被公开。 必填项已用*标注