Quartz在Spring中動態設置cronExpression （spring設置動態定時任務）

時間 2019-11-10

標籤 quartz spring 動態設置 cronexpression 定時任務欄目 Quartz 简体版

原文原文鏈接

什麼是動態定時任務：是由客戶制定生成的，服務端只知道該去執行什麼任務，但任務的定時是不肯定的（是由客戶制定）。

這樣總不能修改配置文件每定製個定時任務就增長一個trigger吧，即使容許客戶修改配置文件，但總須要從新啓動web服務啊，研究了下Quartz在Spring中的動態定時，發現<bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean" >

</property>

中cronExpression是關鍵，若是能夠動態設置cronExpression的值，也就說若是咱們能夠直接調用CronTriggerBean中設置cronExpression的方法，就能夠順利解決問題了。

熟悉1的朋友能夠跳過不看，下面二、3是動態定時任務的具體實現。

1． Quartz在Spring中的簡單配置

Spring配置文件：

</bean>

</property>

</bean>

<list>

</list>

</property>

</bean>

在上面的配置中設定了

① targetMethod: 指定須要定時執行scheduleInfoAction中的simpleJobTest()方法

② concurrent：對於相同的JobDetail，當指定多個Trigger時, 極可能第一個job完成以前，第二個job就開始了。指定concurrent設爲false，多個job不會併發運行，第二個job將不會在第一個job完成以前開始。

③ cronExpression：0/10 * * * * ?表示每10秒執行一次，具體可參考附表。

④ triggers：經過再添加其餘的ref元素可在list中放置多個觸發器。

scheduleInfoAction中的simpleJobTest()方法

注意：此方法沒有參數，若是scheduleInfoAction有兩個方法simpleJobTest()和simpleJobTest(String argument)，則spring只會去執行無參的simpleJobTest().

public void simpleJobTest() {

log.warn("uh oh, Job is scheduled !'" + "' Success...");

}

2．Quartz在Spring中動態設置cronTrigger方法一

Spring配置文件：

</bean>

</bean>

</property>

</bean>

<list>

</list>

</property>

</bean>

scheduleInfoAction中的reScheduleJob ()方法及相關方法

① reScheduleJob讀取數據庫，得到自定義定時器調度時間():

private void reScheduleJob() throws SchedulerException, ParseException {

// 運行時可經過動態注入的scheduler獲得trigger

CronTriggerBean trigger = (CronTriggerBean) scheduler.getTrigger(

"cronTrigger", Scheduler.DEFAULT_GROUP);

String dbCronExpression = getCronExpressionFromDB();

String originConExpression = trigger.getCronExpression();

// 判斷從DB中取得的任務時間(dbCronExpression)和如今的quartz線程中的任務時間(originConExpression)是否相等

// 若是相等，則表示用戶並無從新設定數據庫中的任務時間，這種狀況不須要從新rescheduleJob

if(!originConExpression.equalsIgnoreCase(dbCronExpression)){

trigger.setCronExpression(dbCronExpression);

scheduler.rescheduleJob("cronTrigger", Scheduler.DEFAULT_GROUP, trigger);

}

// 下面是具體的job內容，可自行設置

// executeJobDetail();

}

② getCronExpressionFromDB()：從數據庫中得到dbCronExpression的具體代碼，因爲使用了scheduleInfoManager，因此要在定義相應的setter方法

private String getCronExpressionFromDB(){

String sql="from ScheduleInfo scheduleInfo where 1=1 ";

sql=sql+" and scheduleInfo.infoId = '"+"1" + "'";

List scheduleList = scheduleInfoManager.queryScheduleInListBySql(sql);

ScheduleInfo scheduleInfo = (ScheduleInfo)scheduleList.get(0);

String dbCronExpression = scheduleInfo.getCronExpression();

return dbCronExpression;

}

③ 在spring配置文件的scheduleInfoAction配置了相應的property（scheduler/ scheduleInfoManager）,要爲其設置setter方法

private Scheduler scheduler;

// 設值注入，經過setter方法傳入被調用者的實例scheduler

public void setScheduler(Scheduler scheduler) {

this.scheduler = scheduler;

}

private ScheduleInfoManager scheduleInfoManager;

// 設值注入，經過setter方法傳入被調用者的實例scheduleInfoManager

public void setScheduleInfoManager(ScheduleInfoManager scheduleInfoManager){

this.scheduleInfoManager = scheduleInfoManager;

}

3． Quartz在Spring中動態設置cronTrigger方法二

在上面的2中咱們能夠看到，儘管已經能夠動態進行rescheduleJob了，不過依然須要咱們設置一個cronExpression，若是嘗試一下拿掉spring配置中的

</property>

則容器（如tomcat）啓動時會報錯。

實際中咱們但願tomcat啓動時就能夠直接去讀數據庫，拿到相應的dbCronExpression，而後定時執行一個job，而不但願配置初始的cronExpression ，觀察下面的CronTriggerBean，考慮到cronExpression須要初始化，若是設定一個類InitializingCronTrigger繼承CronTriggerBean，而後在這個類中作一些讀取DB的初始化工做（設置cronExpression），問題就能夠解決了。

Spring配置文件：

</bean>

</bean>

<!--<property name="cronExpression">

</property>-->

</bean>

<list>

</list>

</property>

</bean>

InitializingCronTrigger中的相關方法

注意：在注入scheduleInfoManager屬性的時候，咱們能夠去讀取DB任務時間（之因此放在setter方法中，是由於須要在設置scheduleInfoManager後進行getCronExpressionFromDB()，不然，也能夠①②邏輯把放在類的構造函數中）.

注意InitializingCronTrigger必須extends CronTriggerBean.

public class InitializingCronTrigger extends CronTriggerBean implements Serializable {

private ScheduleInfoManager scheduleInfoManager;

// 設值注入，經過setter方法傳入被調用者的實例scheduleInfoManager

public void setScheduleInfoManager(ScheduleInfoManager scheduleInfoManager){

this.scheduleInfoManager = scheduleInfoManager;

// 由於在getCronExpressionFromDB使用到了scheduleInfoManager，因此

// 必須上一行代碼設置scheduleInfoManager後進行getCronExpressionFromDB

String cronExpression = getCronExpressionFromDB (); // ①

// 由於extends CronTriggerBean ，此處調用父類方法初始化cronExpression

setCronExpression(cronExpression); // ②

}

private String getCronExpressionFromDB(){

String sql="from ScheduleInfo scheduleInfo where 1=1 ";

sql=sql+" and scheduleInfo.infoId = '"+"1" + "'";

List scheduleList = scheduleInfoManager.queryScheduleInListBySql(sql);

ScheduleInfo scheduleInfo = (ScheduleInfo)scheduleList.get(0);

String dbCronExpression = scheduleInfo.getCronExpression();

return dbCronExpression;

}

……

}

附表：

"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 ? * 6L 2002-2005" 2002年至2005年的每個月的最後一個星期五上午10:15觸發
"0 15 10 ? * 6#3" 每個月的第三個星期五上午10:15觸發

至於每一個符號看看例子就行了.很簡單了.web