Springboot实现动态定时任务流程详解
一、静态
静态的定时任务可以直接使用注解@Scheduled,并在启动类上配置@EnableScheduling即可
二、动态
动态的定时任务需要根据ScheduledTaskRegistrar的addTriggerTask方法进行实现,网上大多数资料是在Trigger中动态查询cron表达式来实现,但存在一个问题就是只有在下一次执行的时候才会刷新,比如一开始设置的每天12点执行一次,如果项目启动后,修改为每小时执行一次的话,需要等到下一次12点执行之后,才会刷新cron表达式,所以通过对ScheduledTaskRegistrar的源码分析,构建了以下解决方案,可以实现对定时任务的额单次额外执行、停止、启动三个基本功能。在此只列出关键代码,关于项目启动、数据库连接的代码等就不过多说明了。
1、基本代码
首先新建定时任务信息的库表及实体类
用于获取bean实例的工具类
实现定时任务类
控制调用类,RCResult为自定义封装的返回结果类,可自行定义
2、方案详解
2.1 初始化
通过@EnableScheduling和@EnableAsync两个标签,开启定时任务和多线程
重写SchedulingConfigurer的configureTasks方法,可以在项目启动时自动加载状态为启用(cron_flag为1)定时任务列表
TriggerTask创建的两个参数Runnable和Trigger可以理解为实现的操作和执行的周期,在Runnable中我们通过反射的方式,从库中取到调用方法的类名和方法名,来执行接口操作,在Trigger中我们根据库中的cron表达式来设置执行周期
库表数据
从执行结果中可以看到状态为已启用的task1和task2执行了,而task3并没有执行
2.2 单次执行
我们可以通过获取TriggerTask的Runnable来执行run()方法,来单次执行定时任务
任务类中定义run方法
接口调用
模拟接口调用
从调用结果中可以看到,task1在06秒的时候单独执行了一次,并且没有影响后续执行
2.3 停止任务
停止任务需要执行ScheduledTask类的cancel()方法,由于在初始化时通过addTriggerTask方法并不会立刻加入到ScheduledTask列表中,所以需要在调用时通过ScheduledTaskRegistrar获取ScheduledTask列表,然后与TriggerTask的Runnable进行比较判断是否一致
任务类中定义stop
调用
在调用结果中可以看到,task1不再执行了
2.4 启用任务
启用任务需要通过ScheduledTaskRegistrar的scheduleTriggerTask()方法进行调用,由于源码中并未提供针对Runnable或Trigger的单独修改方法,所以在这里我们通过新建实例进行替换,在执行前先停止任务
调用
通过调用结果,可以看到在启用后,task1重新加入到定时任务队列中了
在修改task1的执行周期后再次调用start方法
从调用结果中可以看到,task1的周期已被更改
三、小结
昨天刚接触定时任务,一开始也是在网上搜索资料,后来发现案例都无法满足自身需求,或者只是讲解怎么使用,根本无法映射到实际业务上,所以通过对源码的分析,一层层的梳理,模拟了此篇关于定时任务的解决方案,由于时间原因,在此省略了前端界面的编写,但大多数实际需求无非也就是通过一个开关或按钮来对任务进行启用、停止操作,或者额外需要单次执行任务,在此对动态定时任务的方案进行记录,同时也希望能帮助到遇到同样问题的同学们
到此这篇关于Springboot实现动态定时任务流程详解的文章就介绍到这了,更多相关Springboot动态定时任务内容请搜索编程学习网以前的文章希望大家以后多多支持编程学习网!