Quartz定時任務觸發器啟動時設置

需求


 
 
 
         


  
  
  
          
為了將觸發器的Cron表達式放在數據庫里，方便維護。所以需要在項目啟動時去數據庫獲取Cron表達式，並配置觸發器，添加到調度器里。

 
 
 
         

實現


 
 
 
         


  
  
  
          
在配置定時任務相關的Bean時，通過設置init方法，實現配置Bean時執行從數據庫獲取Cron表達式。

  
  
  
          
因為需要新增ini方法，所以需要新建一個類，繼承CronTriggerBean。

  
  
  
          
在ini方法中從數據庫獲取Cron表達式，並設置到trigger里。

 
 
 
         

<bean id="Task" class="xxx" >
</bean>

<bean id="TaskDetail"
        class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    <property name="targetObject">
        <ref bean="Task" />
    </property>
    <property name="targetMethod">
        <value>exec</value>
    </property>
</bean>
<!--觸發器的Cron表達式是啟動時從數據庫獲取的 -->  
<bean id="TaskTrigger" class="CronTriggerBean"
    lazy-init="false" init-method="init">
    <property name="jobDetail" ref="TaskDetail" />
</bean>


public class CronTriggerBean extends CronTriggerBean{
    public void init(){
        String hql = "xxx";        
        List<TRetryCron> list = Dao.getHibernateTemplate().find(sb.toString());
        String cronExpression=null;
        if(null!=list&&list.size()>0){
            cronExpression=list.get(0).getCCronExpression();
        }else{
            // 避免沒能從數據庫取到Cron表達式，導致出現異常，這兒給個永遠不會執行的Cron表達式
            cronExpression="0 0 5 31 2 ?";
            logger.error("未能從數據庫取到有效的Cron表達式。");    
        }
        try {
            super.setCronExpression(cronExpression);
        } catch (ParseException e) {
            logger.error(String.format("解析Cron表達式失敗，設置一個永不執行的Cron表達式【0 0 5 31 2 ?】，解析失敗的Cron表達式為【%s】。", cronExpression));   
            // 解析Crontab表達式失敗，設置一個永不執行的Cron表達式
            try {
                super.setCronExpression("0 0 5 31 2 ?");
            } catch (ParseException e1) {
            }
        }
    }
}



查看原文：http://yuyy.info/uncategorized/quartz%e5%ae%9a%e6%97%b6%e4%bb%bb%e5%8a%a1%e8%a7%a6%e5%8f%91%e5%99%a8%e5%90%af%e5%8a%a8%e6%97%b6%e8%ae%be%e7%bd%ae/