Spring Schedule Task动态改写Cron配置方式

更新时间：2021年11月01日 10:42:10 作者：如锋

这篇文章主要介绍了Spring Schedule Task动态改写Cron配置方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教

Spring Schedule Task动态改写Cron配置

使用Spring @Scheduled标签可以很简单地定义Scheduled Task，但是有时我们需要在程序里动态地改写Cron的配置。

什么时候呢？

额，比如：

老板觉得Cron配置太难看了，想直接这样：10：15

Scheduling Tasks的常规使用

两个标签： @EnableScheduling， @Scheduled

@SpringBootApplication
@EnableScheduling
public class SchedulingTasksApplication {
 public static void main(String[] args) {
  SpringApplication.run(SchedulingTasksApplication.class);
 }
}

public class ScheduleTaskSimpleJob {
    @Scheduled(cron = "0 15 10 * * ?")
    public void scheduleCronTask() {    
        long now = System.currentTimeMillis() / 1000;
        System.out.println(
        "schedule tasks using cron jobs - " + now);
    }
}

动态改写Cron

Implements SchedulingConfigurer就可以，想怎么改怎么改。
public class ScheduleTaskSimpleJob implements SchedulingConfigurer {    
    public void scheduleCronTask() {    
        long now = System.currentTimeMillis() / 1000;
        System.out.println(
        "schedule tasks using cron jobs - " + now);
    }
    @Override
 public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
  taskRegistrar.addTriggerTask(new Runnable() {
   @Override
   public void run() {
    scheduleCronTask();
   }
  }, new Trigger() {
   @Override
   public Date nextExecutionTime(TriggerContext triggerContext) {
    //TODO 将时间配置10：15转换为cron
    String cron = "0 15 10 * * ?";       
    CronTrigger trigger = new CronTrigger(cron);    
    Date nextExecDate = trigger.nextExecutionTime(triggerContext);
    return nextExecDate;
   }
  });  
 }
}

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

Spring框架自3.0版本起，自带了任务调度功能，好比是一个轻量级的Quartz，而且使用起来也方便、简单，且不需要依赖其他的JAR包。秉承着Spring的一贯风格，Spring任务调度的实现同时支持注解配置和XML配置两种方式。

再来谈谈变态的项目需求：我们正在做一个智能数字电表的数据采集项目，项目最终会在多个工业园上线，每个工业园对电表数据的采集周期可以进行自定义，例如A工业园想每10分钟采集一次数据，B工业园想每15分钟采集一次数据。因为数据采集是个重复的周期性工作，那么就可以考虑使用Spring框架的定时任务功能了。

按正常来讲，修改定时任务的执行周期还不简单，把服务停下来，改下任务的cron参数，再重启服务就搞定了。但有没有一种可能，在不停服务的情况下，就可以动态的修改任务的cron参数呢？完全是有可能的！

先来看下Spring常规定时任务的配置

如下

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xmlns:task="http://www.springframework.org/schema/task"
 xmlns:context="http://www.springframework.org/schema/context"
 xsi:schemaLocation="
  http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd 
  http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task.xsd 
  http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd ">
 
 <context:component-scan base-package="com.pes_soft.task.demo" />
 
 <!-- Spring注解方式配置调度任务 -->
 <task:executor id="executor" pool-size="3"/>
 <task:scheduler id="scheduler" pool-size="3"/>
 <task:annotation-driven executor="executor" scheduler="scheduler"/>
</beans>

注意：配置Spring定时任务时，需要在Spring配置文件的xml头部加入

xmlns:task="http://www.springframework.org/schema/task"和xsi:schemaLocation位置中加入

http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task.xsd

然后是注解式任务逻辑代码SpringStaticCronTask.java

package com.pes_soft.task.demo; 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Lazy;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
 
@Lazy(false)
@Component
public class SpringStaticCronTask {
 private static final Logger logger = LoggerFactory.getLogger(SpringStaticCronTask.class);
 
 @Scheduled(cron="0/5 * * * * ?")
 public void staticCronTask() {
  logger.debug("staticCronTask is running...");
        }
}

上述任务适用于具有固定任务周期的任务，若要修改任务执行周期，只能走“停服务→修改任务执行周期→重启服务”这条路。

下面来看看可以在不停服务的情况下动态修改任务周期的实现

步骤如下：

在定时任务类上增加@EnableScheduling注解，并实现SchedulingConfigurer接口。（值得注意的是：@EnableScheduling对Spring的版本要求比较高，一开始使用的3.2.6版本时一直未成功，后来改成4.2.5版本就可以了）

设置一个静态变量cron，用于存放任务执行周期参数。

另辟一线程，用于模拟实际业务中外部原因修改了任务执行周期。

设置任务触发器，触发任务执行，其中就可以修改任务的执行周期。

完整的SpringDynamicCronTask.java代码如下：

package com.pes_soft.task.demo; 
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;
 
@Lazy(false)
@Component
@EnableScheduling
public class SpringDynamicCronTask implements SchedulingConfigurer {
 private static final Logger logger = LoggerFactory.getLogger(SpringDynamicCronTask.class);
 private static String cron;
 public SpringDynamicCronTask() {
 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.err.println("cron change to: " + cron);
   }
  }).start();
 }
 
 @Override
 public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
  taskRegistrar.addTriggerTask(new Runnable() {
   @Override
   public void run() {
    // 任务逻辑
    logger.debug("dynamicCronTask is running...");
   }
  }, new Trigger() {
   @Override
   public Date nextExecutionTime(TriggerContext triggerContext) {
    // 任务触发，可修改任务的执行周期
    CronTrigger trigger = new CronTrigger(cron);
                Date nextExec = trigger.nextExecutionTime(triggerContext);
                return nextExec;
   }
  });
 }
}

将demo运行起来，查看任务执行情况，可以观察到任务的执行周期由5秒变成了10秒，期间服务并未停止。

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

您可能感兴趣的文章:

mybatis框架入门学习教程
MyBatis是一个支持普通SQL查询，存储过程和高级映射的优秀持久层框架。这篇文章主要介绍了mybatis框架入门学习教程,需要的朋友可以参考下
2017-02-02
SpringBoot中的自定义Banner详细解析
这篇文章主要介绍了SpringBoot中的自定义Banner详细解析,Banner即横幅标语,我们在启动SpringBoot项目时会将Banner信息打印至控制台,我们可以输出一些图形、SpringBoot版本信息等内容,需要的朋友可以参考下
2024-01-01
Java NIO：浅析IO模型_动力节点Java学院整理
在进入Java NIO编程之前，我们今天先来讨论一些比较基础的知识：I/O模型。对java io nio相关知识感兴趣的朋友一起学习吧
2017-05-05
如何彻底删除SVN中的文件和文件夹(附恢复方法)
在SVN中如果删除某个文件或文件夹也可以在历史记录中进行找回，有的时候需要彻底删除某些文件，即不希望通过历史记录进行恢复，需要在服务器上对SVN的数据进行重新整理
2014-08-08
HttpClient基础解析
这篇文章主要介绍了HttpClient基础知识，算是比较详细地对知识点和相关实例进行解释,需要的朋友可以参考下
2017-09-09
基于SpringBoot和MongoDB实现实时分析和日志处理功能
实时分析和日志处理在现代应用程序开发中扮演着重要的角色，MongoDB是一个非常流行的NoSQL数据库，其高性能和灵活性使其成为实时分析和日志处理的理想选择，本文将介绍如何使用 Spring Boot 和 MongoDB 实现实时分析和日志处理的功能
2023-06-06
Java基础-Java的体系结构
这篇文章主要介绍了Java的体系结构,Java几乎成为了“开源”的代名词。第三方开源软件和框架。如Tomcat、Struts，MyBatis，Spring等,下面我们来看看文章具体的内容介绍吧
2022-01-01
JAVA字符串类型switch的底层原理详析
这篇文章主要给大家介绍了关于JAVA字符串类型switch的底层原理的相关资料，文中通过示例代码介绍的非常详细，对大家学习或者使用JAVA具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧
2019-09-09
Java快速排序的实现方法示例
快速排序是对冒泡排序的一种改进,下面这篇文章主要给大家介绍了关于Java快速排序的实现方法,文中通过代码介绍的非常详细,对大家的学习或者工作具有一定的参考借鉴价值,需要的朋友可以参考下
2024-03-03
解决@PathVariable参数接收不完整的问题
这篇文章主要介绍了解决@PathVariable参数接收不完整的问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-08-08