`

114. Spring Boot 定时任务升级篇(动态添加修改删除定时任务)

阅读更多

  

 

需求缘起:在发布了《Spring Boot定时任务升级篇》之后得到不少反馈,其中有一个反馈就是如何动态添加修改删除定时任务?那么我们一起看看具体怎么实现,先看下本节大纲:

(1)思路说明;
(2)代码解析;
(3)修改定时任务执行周期特别说明;

 

       接下来看看本节的大纲:

1)思路说明;

a)首先这里我们需要重新认识一个类ThreadPoolTaskScheduler:线程池任务调度类,能够开启线程池进行任务调度。

bThreadPoolTaskScheduler.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 201746

 */

@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";

    }

 à悟空学院:https://t.cn/Rg3fKJD

学院中有Spring Boot相关的课程!点击「阅读原文」进行查看!

SpringBoot视频:http://t.cn/A6ZagYTi

Spring Cloud视频:http://t.cn/A6ZagxSR

SpringBoot Shiro视频:http://t.cn/A6Zag7IV

SpringBoot交流平台:https://t.cn/R3QDhU0

SpringData和JPA视频:http://t.cn/A6Zad1OH

SpringSecurity5.0视频:http://t.cn/A6ZadMBe

Sharding-JDBC分库分表实战http://t.cn/A6ZarrqS

分布式事务解决方案「手写代码」:http://t.cn/A6ZaBnIr

分享到:
评论
4 楼 KIWIFLY 2017-04-28  
new MyRunnable() 通过new来生成任务对象,那就用不了spring的其它bean了
3 楼 林祥纤 2017-04-24  
KIWIFLY 写道
谢谢你,很有用,能否添加好友,探讨问题


可以先添加QQ  群。
2 楼 KIWIFLY 2017-04-24  
谢谢你,很有用,能否添加好友,探讨问题
1 楼 xiaozhudi 2017-04-17  
Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler]: Circular reference involving containing bean 'dynamicTask' - consider declaring the factory method as static for independence from its containing instance. Factory method 'threadPoolTaskScheduler' threw exception; nested exception is java.lang.NullPointerException


复制的报这个错

相关推荐

Global site tag (gtag.js) - Google Analytics