Spring Task 动态修改任务执行计划cron方式_Java教程

Spring Task 动态修改任务执行计划cron

Spring Task 能够在不重启服务的情况下，动态修改批量任务执行时间。

原理

Spring Task目前仅支持TriggerContext上修改下次执行时间（批量任务执行后回调SchedulingConfigurer.configureTasks，让用户可以重新设置Trigger，从而动态修改下次执行时间）），这种方法的弊端就是“执行时间不能实时生效”。

为此，看了下task文档，感觉若要实现实时生效功能，必须代码里手工启动/停止Spring task任务。

Demo如下

首先，xml里不需要配置springTask相关的executor和scheduler。其次，在代码里自定义scheduler和taskRegistrar（SpringTask启动的类）。最后，开个线程，模拟动态修改cron表达式的接口。

Spring Task 动态修改任务执行计划cron方式

输出如下：（35min没有执行原task）

INFO 27-11 14:34:10,476 - Initializing ExecutorService
INFO 27-11 14:34:10,484 - nextExecutionTime: 0 35 14 * * ?
修改cron为: 0 36 14 * * ?
INFO 27-11 14:34:20,487 - Initializing ExecutorService
INFO 27-11 14:34:20,488 - nextExecutionTime: 0 36 14 * * ?
INFO 27-11 14:36:00,001 - dynamicCronTask is running...
INFO 27-11 14:36:00,001 - nextExecutionTime: 0 36 14 * * ?

Spring @Scheduled定时任务动态修改cron参数

在定时任务类上增加@EnableScheduling注解，并实现SchedulingConfigurer接口。（注意低版本无效）
设置一个静态变量cron，用于存放任务执行周期参数。
另辟一线程，用于模拟实际业务中外部原因修改了任务执行周期。
设置任务触发器，触发任务执行，其中就可以修改任务的执行周期。

Class ： SpringDynamicCornTask

				?

									package com.xindatai.ibs.lime.dycSchedul;

									import java.util.Date;

									import org.slf4j.Logger;

									import org.slf4j.LoggerFactory;

									import org.springframework.context.annotation.Lazy;

									import org.springframework.scheduling.Trigger;

									import org.springframework.scheduling.TriggerContext;

									import org.springframework.scheduling.annotation.EnableScheduling;

									import org.springframework.scheduling.annotation.SchedulingConfigurer;

									import org.springframework.scheduling.config.ScheduledTaskRegistrar;

									import org.springframework.scheduling.support.CronTrigger;

									import org.springframework.stereotype.Component;

									/**

									 * Spring动态周期定时任务 在不停应用的情况下更改任务执行周期

									 * 

									 * @author Liang

									 *

									 *         2017年6月1日

									 */

									@Lazy(false)

									@Component

									@EnableScheduling

									public class SpringDynamicCornTask implements SchedulingConfigurer {

									    private static final Logger logger = LoggerFactory.getLogger(SpringDynamicCornTask.class);

									    private static String cron;

									    private SpringDynamicCornTask() {

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

									        // 开启新线程模拟外部更改了任务执行周期

									        new Thread(new Runnable() {

									            @Override

									            public void run() {

									                try {

									                    Thread.sleep(15 * 1000);

									                } catch (InterruptedException e) {

									                    e.printStackTrace();

									                }

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

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

									            }

									        }).start();

									    }

									    @Override

									    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {

									        taskRegistrar.addTriggerTask(new Runnable() {

									            @Override

									            public void run() {

									                // 任务逻辑

									                logger.info("dynamicCronTask is running...");

									            }

									        }, new Trigger() {

									            @Override

									            public Date nextExecutionTime(TriggerContext triggerContext) {

									                // 任务触发，可修改任务的执行周期

									                CronTrigger trigger = new CronTrigger(cron);

									                Date nextExecutionTime = trigger.nextExecutionTime(triggerContext);

									                return nextExecutionTime;

									            }

									        });

									    } 

									}

Console ：

[INFO 2017-06-01 12:26:25 SpringDynamicCornTask] - dynamicCronTask is running...
[INFO 2017-06-01 12:26:30 SpringDynamicCornTask] - dynamicCronTask is running...
[INFO 2017-06-01 12:26:35 SpringDynamicCornTask] - dynamicCronTask is running...
cron change to : 0/10 * * * * ?
[INFO 2017-06-01 12:26:40 SpringDynamicCornTask] - dynamicCronTask is running...
[INFO 2017-06-01 12:26:50 SpringDynamicCornTask] - dynamicCronTask is running...
[INFO 2017-06-01 12:27:00 SpringDynamicCornTask] - dynamicCronTask is running...

以上为个人经验，希望能给大家一个参考，也希望大家多多支持服务器之家。

原文链接：https://blog.csdn.net/JJ_LIJIN/article/details/78644985