如何動(dòng)態(tài)修改cron參數(shù)呢？那么我們一起看看具體怎么實(shí)現(xiàn)，先看下本節(jié)大綱：

（1）簡(jiǎn)單方式：修改定時(shí)任務(wù)的執(zhí)行周期；

（2）動(dòng)態(tài)修改定時(shí)任務(wù)的執(zhí)行周期；

接下來(lái)看下本節(jié)的具體內(nèi)容：

（1）簡(jiǎn)單方式：修改定時(shí)任務(wù)的執(zhí)行周期；

按正常來(lái)講，修改定時(shí)任務(wù)的執(zhí)行周期，把服務(wù)停下來(lái)，改下任務(wù)的cron參數(shù)，再重啟服務(wù)就搞搞定了。這種方式很簡(jiǎn)單，沒有可說(shuō)的，但是有沒有一種可能，在不停服務(wù)的情況下，就可以動(dòng)態(tài)的修改任務(wù)的cron參數(shù)呢？哈哈，那是必須的必。

（2）動(dòng)態(tài)修改定時(shí)任務(wù)的執(zhí)行周期；

首先我們先會(huì)回顧下，我們之前是使用了@Scheduled(cron =“0/5 * * * * *”)這種方式適用于固定任務(wù)周期的任務(wù)，若要修改任務(wù)執(zhí)行周期，只能走“停服務(wù)—修改任務(wù)執(zhí)行周期—重啟服務(wù)”這條路。那么如何動(dòng)態(tài)修改呢，我們看下步驟：

① 在定時(shí)任務(wù)類上增加@EnabledScheduling注解，并實(shí)現(xiàn)SchedulingConfigurer接口。

② 設(shè)置一個(gè)靜態(tài)的cron，用于存放任務(wù)執(zhí)行周期參數(shù)。

③ 開啟一個(gè)線程，用于模擬實(shí)際業(yè)務(wù)中外部原因修改了任務(wù)執(zhí)行周期。

④ 設(shè)置任務(wù)觸發(fā)器，觸發(fā)任務(wù)執(zhí)行。

具體的代碼如下：

package com.kfit.task;

import java.util.Date;

import org.springframework.scheduling.Trigger;

import org.springframework.scheduling.TriggerContext;

importorg.springframework.scheduling.annotation.EnableScheduling;

importorg.springframework.scheduling.annotation.SchedulingConfigurer;

importorg.springframework.scheduling.config.ScheduledTaskRegistrar;

import org.springframework.scheduling.support.CronTrigger;

import org.springframework.stereotype.Component;

/**

• Spring @Scheduled定時(shí)任務(wù)動(dòng)態(tài)修改cron****參數(shù)
• @author Angel --守護(hù)天使
• @version v.0.1
• @date 2017年4月6日

*/

@Component

@EnableScheduling

**public **class TaskCronChange implements SchedulingConfigurer{

**public ****static** String  *cron* ; 



**public** TaskCronChange() {

    //默認(rèn)情況是：每5秒執(zhí)行一次.

    *cron* = "0/5 * * * * *";

    **new** Thread(**new** Runnable() {

      

       // 開啟新線程模擬外部更改了任務(wù)執(zhí)行周期.

       @Override

       **public ****void** run() {

          **try** {

              // 讓線程睡眠 15秒.

              Thread. *sleep* (15000);

          } **catch** (InterruptedException e) {

              e.printStackTrace();

          }

           //修改為：每10秒執(zhí)行一次.

          *cron* = "0/10 * ** * *";

           System. ***err*** .println("cron change to:"+ *cron* );

       }

   }).start();;

}

 

@Override

**public ****void** configureTasks(ScheduledTaskRegistrar taskRegistrar) {

   Runnable task = **new** Runnable() {

       @Override

       **public ****void** run() {

          //任務(wù)邏輯代碼部分.

          System. ***out*** .println("TaskCronChangetask is running ... "+ **new** Date());

       }

   };

   Trigger trigger = **new** Trigger() {

       @Override

       **public** Date nextExecutionTime(TriggerContext triggerContext) {

          //任務(wù)觸發(fā)，可修改任務(wù)的執(zhí)行周期.

          CronTrigger trigger = **new** CronTrigger( *cron* );

          Date nextExec = trigger.nextExecutionTime(triggerContext);

          **return **nextExec;

       }

   };

   taskRegistrar.addTriggerTask(task, trigger);

}

}

這里核心的主要是使用到了ScheduledTaskRegistrar這個(gè)類有一個(gè)方法addTriggerTask（Runnable,Trigger） 兩個(gè)參數(shù)，一個(gè)Runnable,一個(gè)是Trigger，在Runnable中執(zhí)行業(yè)務(wù)邏輯代碼，在Trigger修改定時(shí)任務(wù)的執(zhí)行周期。

啟動(dòng)查看控制臺(tái)的打印信息如下：

TaskCronChange task is running ... Thu Apr 0605:38:20 CST 2017

TaskCronChangetask is running ... Thu Apr 06 05:38:25CST 2017

TaskCronChangetask is running ... Thu Apr 06 05:38:30CST 2017

cronchange to:0/10 * * * * *

TaskCronChangetask is running ... Thu Apr 06 05:38:35CST 2017

TaskCronChangetask is running ... Thu Apr 06 05:38:40CST 2017

TaskCronChangetask is running ... Thu Apr 06 05:38:50CST 2017