目录

• 前言
• 代码编写
• 效果演示
• 启动
• 修改
• 停止
• 后记

前言 定时器是我们项目中经常会用到的，SpringBoot使用@Scheduled注解可以快速启用一个简单的定时器（详情请看我们之前的博客《SpringBoot系列——定时器》），然而这种方式的定时器缺乏灵活性，如果需要对定时器进行调整，需要重启项目才生效，本文记录SpringBoot如何灵活配置动态定时任务

代码编写 首先先建表，重要字段：唯一表id、Runnable任务类、Cron表达式，其他的都是一些额外补充字段

DROP TABLE IF EXISTS `tb_task`; CREATE TABLE `tb_task`(`task_id` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT '定时任务id',`task_name` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '定时任务名称',`task_desc` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '定时任务描述',`task_exp` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '定时任务Cron表达式',`task_status` int(1) NULL DEFAULT NULL COMMENT '定时任务状态，0停用 1启用',`task_class` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL COMMENT '定时任务的Runnable任务类完整路径',`update_time` datetime NULL DEFAULT NULL COMMENT '更新时间',`create_time` datetime NULL DEFAULT NULL COMMENT '创建时间',PRIMARY KEY (`task_id`) USING BTREE) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci COMMENT = '动态定时任务表' ROW_FORMAT = Compact; INSERT INTO `tb_task` VALUES ('1', 'task1', '测试动态定时任务1', '0/5 * * * * ?', 0, 'cn.huanzi.qch.springboottimer.task.MyRunnable1', '2021-08-06 17:39:23', '2021-08-06 17:39:25'); INSERT INTO `tb_task` VALUES ('2', 'task2', '测试动态定时任务2', '0/5 * * * * ?', 0, 'cn.huanzi.qch.springboottimer.task.MyRunnable2', '2021-08-06 17:39:23', '2021-08-06 17:39:25');

项目引入jpa、数据库驱动，用于数据库操作

org.springframework.bootspring-boot-starter-data-jpamysqlmysql-connector-java

数据库相关配置文件

spring:datasource: #数据库相关url: jdbc:mysql://localhost:3306/test?serverTimezone=GMT%2B8&characterEncoding=utf-8username: rootpassword: 123456driver-class-name: com.mysql.jdbc.Drivermvc:date-format: yyyy-MM-dd HH:mm:ss #mvc接收参数时对日期进行格式化jackson:date-format: yyyy-MM-dd HH:mm:ss #jackson对响应回去的日期参数进行格式化time-zone: GMT+8jpa:show-sql: true

entity实体与数据表映射，以及与之对应的repository

/** * 动态定时任务表 * 重要属性：唯一表id、Runnable任务类、Cron表达式， * 其他的都是一些额外补充说明属性 */@Entity@Table(name = "tb_task")@Datapublic class TbTask {@Idprivate String taskId; //定时任务idprivate String taskName; //定时任务名称private String taskDesc; //定时任务描述private String taskExp; //定时任务Cron表达式private Integer taskStatus; //定时任务状态，0停用 1启用private String taskClass; //定时任务的Runnable任务类完整路径private Date updateTime; //更新时间private Date createTime; //创建时间}

/** * TbTask动态定时任务Repository */@Repositorypublic interface TbTaskRepository extends JpaRepository, JpaSpecificationExecutor {}

测试动态定时器的配置类，主要作用：初始化线程池任务调度、读取/更新数据库任务、启动/停止定时器等

/** * 测试定时器2-动态定时器 */@Slf4j@Componentpublic class TestScheduler2 {//数据库的任务public static ConcurrentHashMap tasks = new ConcurrentHashMap<>(10); //正在运行的任务public static ConcurrentHashMap runTasks = new ConcurrentHashMap<>(10); //线程池任务调度private ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler(); @Autowiredprivate TbTaskRepository tbTaskRepository; /*** 初始化线程池任务调度*/@Autowiredpublic TestScheduler2(){this.threadPoolTaskScheduler.setPoolSize(10); this.threadPoolTaskScheduler.setThreadNamePrefix("task-thread-"); this.threadPoolTaskScheduler.setWaitForTasksToCompleteOnShutdown(true); this.threadPoolTaskScheduler.initialize(); }/*** 获取所有数据库里的定时任务*/private void getAllTbTask(){//查询所有，并put到tasksTestScheduler2.tasks.clear(); List list = tbTaskRepository.findAll(); list.forEach((task)-> TestScheduler2.tasks.put(task.getTaskId(),task)); }/*** 根据定时任务id，启动定时任务*/void start(String taskId){try {//如果为空，重新获取if(TestScheduler2.tasks.size() <= 0){this.getAllTbTask(); }TbTask tbTask = TestScheduler2.tasks.get(taskId); //获取并实例化Runnable任务类Class clazz = Class.forName(tbTask.getTaskClass()); Runnable runnable = (Runnable)clazz.newInstance(); //Cron表达式CronTrigger cron = new CronTrigger(tbTask.getTaskExp()); //执行，并put到runTasksTestScheduler2.runTasks.put(taskId, Objects.requireNonNull(this.threadPoolTaskScheduler.schedule(runnable, cron))); this.updateTaskStatus(taskId,1); log.info("{}，任务启动！",taskId); } catch (ClassNotFoundException | InstantiationException | IllegalAccessException e) {log.error("{}，任务启动失败...",taskId); e.printStackTrace(); }}/*** 根据定时任务id，停止定时任务*/void stop(String taskId){TestScheduler2.runTasks.get(taskId).cancel(true); TestScheduler2.runTasks.remove(taskId); this.updateTaskStatus(taskId,0); log.info("{}，任务停止...",taskId); }/*** 更新数据库动态定时任务状态*/private void updateTaskStatus(String taskId,int status){TbTask task = tbTaskRepository.getOne(taskId); task.setTaskStatus(status); task.setUpdateTime(new Date()); tbTaskRepository.save(task); }}

接下来就是编写测试接口、测试Runnable类（3个Runnable类，这里就不贴那么多了，就贴个MyRunnable1）

/** * Runnable任务类1 */@Slf4jpublic class MyRunnable1 implements Runnable {@Overridepublic void run() {log.info("MyRunnable1{}",new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())); }}

Controller接口

/** * 动态定时任务Controller测试 */@RestController@RequestMapping("/tbTask/")public class TbTaskController {@Autowiredprivate TestScheduler2 testScheduler2; @Autowiredprivate TbTaskRepository tbTaskRepository; /*** 启动一个动态定时任务* http://localhost:10085/tbTask/start/2*/@RequestMapping("start/{taskId}")public String start(@PathVariable("taskId") String taskId){testScheduler2.start(taskId); return "操作成功"; }/*** 停止一个动态定时任务* http://localhost:10085/tbTask/stop/2*/@RequestMapping("stop/{taskId}")public String stop(@PathVariable("taskId") String taskId){testScheduler2.stop(taskId); return "操作成功"; }/*** 更新一个动态定时任务* http://localhost:10085/tbTask/save?taskId=2&taskExp=0/2 * * * * ?&taskClass=cn.huanzi.qch.springboottimer.task.MyRunnable3*/@RequestMapping("save")public String save(TbTask task) throws IllegalAccessException {//先更新表数据TbTask tbTask = tbTaskRepository.getOne(task.getTaskId()); //null值忽略List ignoreProperties = new ArrayList<>(7); //反射获取Class的属性（Field表示类中的成员变量）for (Field field : task.getClass().getDeclaredFields()) {//获取授权field.setAccessible(true); //属性名称String fieldName = field.getName(); //属性的值Object fieldValue = https://www.it610.com/article/field.get(task); //找出值为空的属性，我们复制的时候不进行赋值if(null == fieldValue){ignoreProperties.add(fieldName); }}//org.springframework.beans BeanUtils.copyProperties(A,B)：A中的值付给BBeanUtils.copyProperties(task, tbTask,ignoreProperties.toArray(new String[0])); tbTaskRepository.save(tbTask); TestScheduler2.tasks.clear(); //停止旧任务testScheduler2.stop(tbTask.getTaskId()); //重新启动testScheduler2.start(tbTask.getTaskId()); return"操作成功"; }}

效果演示
启动
启动一个定时任务，http://localhost:10085/tbTask/start/2

文章图片

可以看到，id为2的定时任务已经被启动，corn表达式为5秒执行一次，runnable任务为MyRunnable2

修改
修改一个定时任务，http://localhost:10085/tbTask/save?taskId=2&taskExp=0/2 * * * * ?&taskClass=cn.huanzi.qch.springboottimer.task.MyRunnable3

文章图片

调用修改后，数据库信息被修改，id为2的旧任务被停止重新启用新任务，corn表达式为2秒执行一次，runnable任务类为MyRunnable3

停止
停止一个定时任务，http://localhost:10085/tbTask/stop/2

文章图片

id为2的定时任务被停止

后记 可以看到，配置动态定时任务后，可以方便、实时的对定时任务进行修改、调整，再也不用重启项目啦
SpringBoot配置动态定时任务暂时先记录到这，后续再进行补充
代码开源
代码已经开源、托管到我的GitHub、码云：
GitHub：https://github.com/huanzi-qch/springBoot
码云：https://gitee.com/huanzi-qch/springBoot
【SpringBoot开发实战系列之动态定时任务】到此这篇关于SpringBoot开发实战系列之动态定时任务的文章就介绍到这了,更多相关SpringBoot动态定时任务内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

推荐阅读

• 

  基金初级训练营－毕业感言
• 

  iphone怎么换行输入 iphone如何换行
• 

  （家）‖盼啊盼，五月终于开始发“牙”了。
• 

  浙江省台州市神仙居门票多少钱 台州神仙居免费门票答题入口在哪
• 

  奇亚籽食用方法 奇亚籽食用方法介绍
• 

  芯片|无缘麒麟芯片，荣耀新机曝光，要与小米争第一
• 

  孕妇可不可以吃毛豆
• 

  各种app图标大全现代朗动，现代朗动里面有个小车图标要不要亮起的
• 

  算法分析与设计 耿国华
• 

  保健养生应顺应节气的变化
• 

  颈椎病需要注意什么 颈椎病的病因是什么
• 

  南通人才公寓出租 南通人才公寓房租多少？
• 

  原发性高血压|致2.45亿高血压患者：若掉进6个坑，并发症可能提早10年来
• 

  马齿苋的副作用你知道吗？ 马齿苋的副作用
• 

  《和平精英》11.4光子将24套“绝版皮肤”进行投票,排名前6会返场！你喜欢哪一个？
• 

  快速傅立叶变换 例题 n=8 数值分析
• 

  无线网络地址怎么设置 无线如何设置
• 

  林内牌热水器代码故障怎么自己解除，常见故障处理技巧知识介绍 ,该怎么解决呢？
• 

  黄金圈法则
• 

  商标注册分为哪几类 水商标分为多少类，商标按知名度可分为哪几类

• 深入理解Go之generate
• Activiti（一）SpringBoot2集成Activiti6
• 标签、语法规范、内联框架、超链接、CSS的编写位置、CSS语法、开发工具、块和内联、常用选择器、后代元素选择器、伪类、伪元素。
• SpringBoot调用公共模块的自定义注解失效的解决
• 解决SpringBoot引用别的模块无法注入的问题
• 《机器学习实战》高清中文版PDF英文版PDF+源代码下载
• --木木--|--木木-- 第二课作业#翼丰会（每日一淘6+1实战裂变被动引流# 6+1模式）
• 我的软件测试开发工程师书单
• echart|echart 双轴图开发
• NPDP拆书（三）（新产品开发战略（经营与创新战略））