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

 更新时间:2021年11月02日 09:45:01   作者:叠影  
这篇文章主要介绍了Spring Task 动态修改任务执行计划cron方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教

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

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

原理

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

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

Demo如下

首先,xml里不需要配置springTask相关的executor和scheduler。其次,在代码里自定义scheduler和taskRegistrar(SpringTask启动的类)。最后,开个线程,模拟动态修改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...

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • Java BIO实现聊天程序

    Java BIO实现聊天程序

    这篇文章主要为大家详细介绍了Java BIO实现聊天程序,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-11-11
  • maven中profile动态打包不同环境配置文件的实现

    maven中profile动态打包不同环境配置文件的实现

    开发项目时会遇到这个问题:开发环境,测试环境,生产环境的配置文件不同, 打包时经常要手动更改配置文件,本文就来介绍一下maven中profile动态打包不同环境配置文件的实现,感兴趣的可以了解一下
    2023-10-10
  • 浅谈Servlet 实现网页重定向的方法

    浅谈Servlet 实现网页重定向的方法

    本篇文章主要介绍了Servlet 实现重定向几种方法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-08-08
  • Java 实现限流器处理Rest接口请求详解流程

    Java 实现限流器处理Rest接口请求详解流程

    在工作中是否会碰到这样的场景,高并发的请求但是无法全部执行,需要一定的限流。如果你是使用的微服务框架,比如SpringCloud,可以使用Gateway增加限流策略来解决。本篇文章是在没有框架的情况实现限流器
    2021-11-11
  • IDEA 中配置 Gradle 和安装使用教程

    IDEA 中配置 Gradle 和安装使用教程

    Gradle本身是基于Groovy脚本语言进行构建的,并通过 Domain Specific Language(DSL 语言)进行描述和控制构建逻辑,本文重介绍了IDEA 中配置 Gradle 和使用,需要的朋友可以参考下
    2023-10-10
  • Spring中@Conditional注解用法详解

    Spring中@Conditional注解用法详解

    这篇文章主要介绍了Spring中@Conditional注解用法详解,@Conditional是Spring4版本新提供的一种注解,它的作用是按照设定的条件进行判断,把满足判断条件的bean注册到Spring容器,需要的朋友可以参考下
    2023-11-11
  • 基于Java+SpringBoot实现人脸识别搜索

    基于Java+SpringBoot实现人脸识别搜索

    人脸识别搜索技术作为现代计算机视觉领域的重要研究方向之一,已经在多个领域展现出巨大的应用潜力,随着信息技术的飞速发展,人脸识别搜索在多个领域得到了广泛关注和应用,本文旨在探讨人脸识别搜索技术的背景、原理以及其在实际应用中的意义和挑战
    2023-08-08
  • spring @Validated 注解开发中使用group分组校验的实现

    spring @Validated 注解开发中使用group分组校验的实现

    这篇文章主要介绍了spring @Validated 注解开发中使用group分组校验的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-05-05
  • java实现微信公众平台自定义菜单的创建示例

    java实现微信公众平台自定义菜单的创建示例

    这篇文章主要介绍了java实现微信公众平台自定义菜单的创建示例,需要的朋友可以参考下
    2014-04-04
  • Spring Batch批处理框架操作指南

    Spring Batch批处理框架操作指南

    Spring Batch 是 Spring 提供的一个数据处理框架。企业域中的许多应用程序需要批量处理才能在关键任务环境中执行业务操作,这篇文章主要介绍了Spring Batch批处理框架操作指南,需要的朋友可以参考下
    2022-07-07

最新评论