Spring Schedule Task动态改写Cron配置
使用Spring @Scheduled标签可以很简单地定义Scheduled Task，但是有时我们需要在程序里动态地改写Cron的配置。
什么时候呢？
额，比如：
老板觉得Cron配置太难看了，想直接这样：10：15
Scheduling Tasks的常规使用
两个标签： @EnableScheduling， @Scheduled
|
1 2 3 4 5 6 7 |
@SpringBootApplication @EnableScheduling public class SchedulingTasksApplication { public static void main(String[] args) { SpringApplication.run(SchedulingTasksApplication. class ); } } |
|
1 2 3 4 5 6 7 8 |
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
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 |
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常规定时任务的配置
如下
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 |
<? 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
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 |
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代码如下：
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 |
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秒，期间服务并未停止。
以上为个人经验，希望能给大家一个参考，也希望大家多多支持。
原文链接：https://blog.csdn.net/prufeng/article/details/116565999
查看更多关于Spring Schedule Task动态改写Cron配置方式的详细内容...