SpringBoot定時任務升級篇（動態添加修改刪除定時任務）

需求緣起：在發布了《Spring Boot定時任務升級篇》之后得到不少反饋，其中有一個反饋就是如何動態添加修改刪除定時任務？那么我們一起看看具體怎么實現，先看下本節大綱：

（1）思路說明；
（2）代碼解析；
（3）修改定時任務執行周期特別說明； 

接下來看看本節的大綱：

（1）思路說明；

（a）首先這里我們需要重新認識一個類ThreadPoolTaskScheduler：線程池任務調度類，能夠開啟線程池進行任務調度。

（b）ThreadPoolTaskScheduler.schedule()方法會創建一個定時計划ScheduledFuture，在這個方法需要添加兩個參數，Runnable（線程接口類） 和CronTrigger（定時任務觸發器）

（c）在ScheduledFuture中有一個cancel可以停止定時任務。

（2）代碼解析；

       根據以上的思路分析，我們很容易就知道如何進行編碼了，先提供代碼如下：

 

package com.kfit.task;

import java.util.Date;
import java.util.concurrent.ScheduledFuture;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.scheduling.support.CronTrigger;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController; 

/**

 * @author Angel --守護天使

 * @version v.0.1

 * @date 2017年4月6日

 */

@RestController
@Component
public class DynamicTask { 

    @Autowired
    private ThreadPoolTaskScheduler threadPoolTaskScheduler; 

    private ScheduledFuture<?> future; 

    @Bean
    public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
       return new ThreadPoolTaskScheduler();
    } 

    @RequestMapping("/startCron")
    public String startCron() {

       future = threadPoolTaskScheduler.schedule(new MyRunnable(), new CronTrigger("0/5 * * * * *"));
       System.out.println("DynamicTask.startCron()");
       return "startCron";
    } 

    @RequestMapping("/stopCron")
    public String stopCron() {

       if (future != null) {
           future.cancel(true);
       }
       System.out.println("DynamicTask.stopCron()");
       return "stopCron";
    }

    @RequestMapping("/changeCron10")
    public String startCron10() {

       stopCron();// 先停止，在開啟.
       future = threadPoolTaskScheduler.schedule(new MyRunnable(), new CronTrigger("*/10 * * * * *"));
       System.out.println("DynamicTask.startCron10()");
       return "changeCron10";
    }

    private class MyRunnable implements Runnable {

       @Override
       public void run() {
           System.out.println("DynamicTask.MyRunnable.run()，" + new Date());
       }
    } 
}


小結：

 
           （a）我們首先了一個類DynamicTask;
（b）定義了兩個變量，threadPoolTaskScheduler和future 其中future是treadPoolTaskScheduler執行方法schedule的返回值，主要用於定時任務的停止。
（c）編寫啟動定時器的方法startCron()；
（d）編寫停止方法stopCron(),這里編碼的時候，需要注意下需要判斷下future為null的時候，不然就很容易拋出NullPointerException；
（e）編寫修改定時任務執行周期方法changeCron10（），這里的原理就是關閉之前的定時器，創新在創建一個新的定時器。 
          

（3）修改定時任務執行周期特別說明；

       在上一篇博客中，我們使用了一種方式通過全局變量的方式修改cron參數的值，那么在這里的我們也是可以這么做的，這里簡單提供下思路，大家自己去實現。

注意ThreadPoolTaskScheduler中的schedule（）第二個參數支持Trigger:

ThreadPoolTaskScheduler.schedule(Runnable arg0, Trigger arg1)

那么我們就可以自己定義一個Trigger，然后動態進行修改了，這里提供核心的代碼如下：

private String cronStr = "*/5 * * * * *";

    @RequestMapping("/startCron1")

    public String startCron1(){

        System.out.println("startCron1 >>>>");

        threadPoolTaskScheduler.schedule(new MyRunnable(), new Trigger(){

            @Override
            public Date nextExecutionTime(TriggerContext triggerContext){
                returnnew CronTrigger(cronStr).nextExecutionTime(triggerContext);
            }
        });

        System.out.println("startCron1 <<<<");
        return "startCron1";
    }