基于SchedulingConfigurer实现多定时任务注册及动态修改执行周期

本文主要是介绍基于SchedulingConfigurer实现多定时任务注册及动态修改执行周期,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

基于SchedulingConfigurer实现多定时任务注册及动态修改执行周期
Java中实现定时任务有三种方式:
1.JDK自带的Timer
2.Spring中的Spring Task
3.借助第三方的Quartz
工作中常用的是Spring Task和Quartz,今天主要用一下Spring Task。
Spring Task有两种实现方式:
1.@Scheduled(cron表达式)
2.基于SchedulingConfigurer注册定时任务
这两者的区别主要有
1.@Scheduled不支持动态修改定时周期,只能停止服务器,修改cron表达式,再启动服务器;SchedulingConfigurer可以动态修改
2.@Scheduled只能是单线程,而SchedulingConfigurer默认是单线程,可以通过添加线程池,实现多线程下定时任务的运行
接下来我们一步步操作下基于SchedulingConfigurer的定时任务实现
一、在Spring Boot中实现一个简单的定时任务,熟悉ScheduledTaskRegistrar的用法

/**
* 先注册,后执行(根据返回的时间执行)
**/
@EnableScheduling
@Slf4j
@Configuration
public class TaskConfig implements SchedulingConfigurer {private String cron = "0 0/5 * * * ?";@Overridepublic void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {log.info("***************初始化定时任务设置开始*************");//lambda表达式实现简单的任务逻辑scheduledTaskRegistrar.addTriggerTask(() -> {log.info("执行了定时任务");},sheduledConfig->{//设置定时任务的执行频率并返回下次执行时间Date date = new CronTrigger(cron).nextExecutionTime(sheduledConfig);log.info("执行定时任务的时间:" + formatDate(date));return date;});}}
}

注意几个地方:
1.添加@EnableScheduling注解,使得当前类支持定时任务
2.实现SchedulingConfigurer接口,重写configureTasks方法
我们看下addTriggerTask方法及其两个参数:

 public void addTriggerTask(Runnable task, Trigger trigger) {this.addTriggerTask(new TriggerTask(task, trigger));}
@FunctionalInterface
public interface Runnable {public abstract void run();
}

Runnable是一个函数式接口,用来定义定时任务的执行逻辑,内部的run方法会被定时任务触发器回调执行,单个简单的任务逻辑我们可以采用上面的Lambda表达式实现,多个定时任务且逻辑复杂的话,采用另外的方式实现,下面会讲。

public interface Trigger {@NullableDate nextExecutionTime(TriggerContext var1);
}

Trigger:定时任务的周期设置,该接口的实现类有CronTrigger和PeriodicTrigger,一般使用CronTrigger来设置定时任务的执行频率,接口会返回下次定时任务的执行时间。
二、实现多任务,不同频率的定时任务注册和执行

addTriggerTask(Runnable task, Trigger trigger)

分析这个方法,实现上面功能的大致逻辑如下:
1.因为Runnable:任务执行逻辑,只能传入一个任务,所以如果是多个任务的话,可以采用循环一个个注册,那既然要循环的话,我们就需要获取所有的定时任务类,那如何获取所有的定时任务类呢,还是通过入参参数思考,定时任务类需要实现Runable接口,那么我们就可以通过Bean的类型来获取所有实现Runable接口的类,遍历执行就可以了
2.定时任务执行周期:跟着1思考,每个定时任务的执行频率不同,我们就把这个参数放到定时任务类中作为属性,循环注册时,可以拿到定时任务类,也就可以通过类拿到定时任务的执行频率了
按照上面的思路,开始撸代码
1.定义接口

public interface BaskTask extends Runnable {//获取执行频率String getCron();//执行任务逻辑void execute();
}

2.定义两个定时任务类

@Slf4j
@Component
@Data
public class TaskOne implements BaskTask {//从配置文件获取任务执行频率@Value("${task.taskOneCron}")private String taskCron;//外部获取执行频率@Overridepublic String getCron() {return taskCron;}@Overridepublic void execute() {//可写复杂的任务逻辑log.info("taskOne在"+ formatDate(new Date()) +"执行了")}//执行任务@Overridepublic void run() {execute();}
}

这里说一下任务执行频率,其实将执行频率写在配置文件中不能体现出可以动态修改执行频率的效果,因为配置文件修改就得重启,最理想的做法就是通过页面输入执行频率,同步到这里(可以实现)

@Slf4j
@Component
@Data
public class TaskTwo implements BaskTask {@Value("${task.taskTwoCron}")private String taskCron;@Overridepublic String getCron() {return taskCron;}@Overridepublic void execute() {log.info("taskTwo在"+ formatDate(new Date()) +"执行了");}@Overridepublic void run() {execute();}
}

3.定义定时任务注册器

@EnableScheduling
@Slf4j
@Configuration
public class TaskConfig implements SchedulingConfigurer {@Autowiredprivate ApplicationContext applicationContext;@Overridepublic void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {//获取所有的定时任务Map<String,BaskTask> map = applicationContext.getBeansOfType(BaskTask.class);//遍历注册for(String key :map.keySet()){BaskTask baskTask = map.get(key);//baskTask:回调内部的run方法//baskTask.getCron() 获取各个任务的执行频率scheduledTaskRegistrar.addTriggerTask(baskTask,sheduledConfig->{Date date = new CronTrigger(baskTask.getCron()).nextExecutionTime(sheduledConfig);log.info(key + "执行定时任务的时间:" + formatDate(date));return date;});}}}

4.执行结果如下:
在这里插入图片描述
5.细心的小伙伴可以发现,两个定时任务是在同一个线程中执行的,那么可不可以实现在不同的线程中执行呢,答案是肯定的,因为SchedulingConfigurer是支持多线程的,只需要向定时任务注册器中添加线程池就好了,如下:

//在注册器添加定时任务前添加线程池
ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
taskScheduler.setPoolSize(10);
taskScheduler.initialize();
scheduledTaskRegistrar.setTaskScheduler(taskScheduler);

再运行结果如下:
在这里插入图片描述
最后留个悬念吧:如果某个定时任务不想让继续运行了,又该怎么做呢,有没有小伙伴注意到这行日志:No TaskScheduler/ScheduledExecutorService bean found for scheduled processing
和这个有关系,剩下的内容下篇再写!

这篇关于基于SchedulingConfigurer实现多定时任务注册及动态修改执行周期的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/362140

相关文章

c++ 类成员变量默认初始值的实现

《c++类成员变量默认初始值的实现》本文主要介绍了c++类成员变量默认初始值,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录C++类成员变量初始化c++类的变量的初始化在C++中,如果使用类成员变量时未给定其初始值,那么它将被

Qt使用QSqlDatabase连接MySQL实现增删改查功能

《Qt使用QSqlDatabase连接MySQL实现增删改查功能》这篇文章主要为大家详细介绍了Qt如何使用QSqlDatabase连接MySQL实现增删改查功能,文中的示例代码讲解详细,感兴趣的小伙伴... 目录一、创建数据表二、连接mysql数据库三、封装成一个完整的轻量级 ORM 风格类3.1 表结构

基于Python实现一个图片拆分工具

《基于Python实现一个图片拆分工具》这篇文章主要为大家详细介绍了如何基于Python实现一个图片拆分工具,可以根据需要的行数和列数进行拆分,感兴趣的小伙伴可以跟随小编一起学习一下... 简单介绍先自己选择输入的图片,默认是输出到项目文件夹中,可以自己选择其他的文件夹,选择需要拆分的行数和列数,可以通过

一文详解SpringBoot中控制器的动态注册与卸载

《一文详解SpringBoot中控制器的动态注册与卸载》在项目开发中,通过动态注册和卸载控制器功能,可以根据业务场景和项目需要实现功能的动态增加、删除,提高系统的灵活性和可扩展性,下面我们就来看看Sp... 目录项目结构1. 创建 Spring Boot 启动类2. 创建一个测试控制器3. 创建动态控制器注

Python中将嵌套列表扁平化的多种实现方法

《Python中将嵌套列表扁平化的多种实现方法》在Python编程中,我们常常会遇到需要将嵌套列表(即列表中包含列表)转换为一个一维的扁平列表的需求,本文将给大家介绍了多种实现这一目标的方法,需要的朋... 目录python中将嵌套列表扁平化的方法技术背景实现步骤1. 使用嵌套列表推导式2. 使用itert

Python使用pip工具实现包自动更新的多种方法

《Python使用pip工具实现包自动更新的多种方法》本文深入探讨了使用Python的pip工具实现包自动更新的各种方法和技术,我们将从基础概念开始,逐步介绍手动更新方法、自动化脚本编写、结合CI/C... 目录1. 背景介绍1.1 目的和范围1.2 预期读者1.3 文档结构概述1.4 术语表1.4.1 核

在Linux中改变echo输出颜色的实现方法

《在Linux中改变echo输出颜色的实现方法》在Linux系统的命令行环境下,为了使输出信息更加清晰、突出,便于用户快速识别和区分不同类型的信息,常常需要改变echo命令的输出颜色,所以本文给大家介... 目python录在linux中改变echo输出颜色的方法技术背景实现步骤使用ANSI转义码使用tpu

Python使用python-can实现合并BLF文件

《Python使用python-can实现合并BLF文件》python-can库是Python生态中专注于CAN总线通信与数据处理的强大工具,本文将使用python-can为BLF文件合并提供高效灵活... 目录一、python-can 库:CAN 数据处理的利器二、BLF 文件合并核心代码解析1. 基础合

Python使用OpenCV实现获取视频时长的小工具

《Python使用OpenCV实现获取视频时长的小工具》在处理视频数据时,获取视频的时长是一项常见且基础的需求,本文将详细介绍如何使用Python和OpenCV获取视频时长,并对每一行代码进行深入解析... 目录一、代码实现二、代码解析1. 导入 OpenCV 库2. 定义获取视频时长的函数3. 打开视频文

golang版本升级如何实现

《golang版本升级如何实现》:本文主要介绍golang版本升级如何实现问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录golanwww.chinasem.cng版本升级linux上golang版本升级删除golang旧版本安装golang最新版本总结gola