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

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

目录Spring Schedule Task动态改写Cron配置Scheduling Tasks的常规使用动态改写Cron@Scheduled定时任务动态修改cron参数先来看下Spring常规定时任务的配置下面来看看可以在不停服务的情况下动态修改任务周期的实现

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常规定时任务的配置

如下

xmlns:xsi="http://w3.org/2001/XMLSchema-instance"

xmlns:task="http://springframework.org/schema/task"

xmlns:conthttp://ext="http://springframework.org/schema/context"

xsi:schemaLocation="

http://springframework.org/schema/beans http://springframework.org/schema/beans/spring-beans.xsd

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

http://springframework.org/schema/context http://springframework.org/schema/context/spring-context.xsd ">

xmlns:xsi="http://w3.org/2001/XMLSchema-instance"

xmlns:task="http://springframework.org/schema/task"

xmlns:conthttp://ext="http://springframework.org/schema/context"

xsi:schemaLocation="

http://springframework.org/schema/beans http://springframework.org/schema/beans/spring-beans.xsd

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

http://springframework.org/schema/context http://springframework.org/schema/context/spring-context.xsd ">

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

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

http://springframework.org/schema/task http://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运行起来，查看IqfnIj任务执行情况，可以观察到任务的执行周期由5秒变成了10秒，期间服务并未停止。

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。