顶部右侧 | 自行修改
顶部左侧内容
百度360必应搜狗淘宝本站头条
打开后台 看右上角 主题配置 自行修改
当前位置：网站首页 > 在线教程 > 正文

实践:SpringBoot实现定时任务的动态增删启停

gosiye 2024-08-19 14:56 6 浏览 0 评论

在spring boot项目中，可以通过@EnableScheduling注解和@Scheduled注解实现定时任务，也可以通过SchedulingConfigurer接口来实现定时任务。但是这两种方式不能动态添加、删除、启动、停止任务。

要实现动态增删启停定时任务功能，比较广泛的做法是集成Quartz框架。但是本人的开发原则是：在满足项目需求的情况下，尽量少的依赖其它框架，避免项目过于臃肿和复杂。

查看spring-context这个jar包中org.springframework.scheduling.ScheduledTaskRegistrar这个类的源代码，发现可以通过改造这个类就能实现动态增删启停定时任务功能。

定时任务列表页

定时任务执行日志

添加执行定时任务的线程池配置类

@Configuration
public?class?SchedulingConfig?{
????@Bean
????public?TaskScheduler?taskScheduler()?{
????????ThreadPoolTaskScheduler?taskScheduler?=?new?ThreadPoolTaskScheduler();
????????//?定时任务执行线程池核心线程数
????????taskScheduler.setPoolSize(4);
????????taskScheduler.setRemoveOnCancelPolicy(true);
????????taskScheduler.setThreadNamePrefix("TaskSchedulerThreadPool-");
????????return?taskScheduler;
????}
}

添加ScheduledFuture的包装类。ScheduledFuture是ScheduledExecutorService定时任务线程池的执行结果。

public?final?class?ScheduledTask?{

????volatile?ScheduledFuture<?>?future;

????/**
?????*?取消定时任务
?????*/
????public?void?cancel()?{
????????ScheduledFuture<?>?future?=?this.future;
????????if?(future?!=?null)?{
????????????future.cancel(true);
????????}
????}
}

添加Runnable接口实现类，被定时任务线程池调用，用来执行指定bean里面的方法。

public?class?SchedulingRunnable?implements?Runnable?{

????private?static?final?Logger?logger?=?LoggerFactory.getLogger(SchedulingRunnable.class);

????private?String?beanName;

????private?String?methodName;

????private?String?params;

????public?SchedulingRunnable(String?beanName,?String?methodName)?{
????????this(beanName,?methodName,?null);
????}

????public?SchedulingRunnable(String?beanName,?String?methodName,?String?params)?{
????????this.beanName?=?beanName;
????????this.methodName?=?methodName;
????????this.params?=?params;
????}

????@Override
????public?void?run()?{
????????logger.info("定时任务开始执行?- bean：{}，方法：{}，参数：{}",?beanName,?methodName,?params);
????????long?startTime?=?System.currentTimeMillis();

????????try?{
????????????Object?target?=?SpringContextUtils.getBean(beanName);

????????????Method?method?=?null;
????????????if?(StringUtils.isNotEmpty(params))?{
????????????????method?=?target.getClass().getDeclaredMethod(methodName,?String.class);
????????????}?else?{
????????????????method?=?target.getClass().getDeclaredMethod(methodName);
????????????}

????????????ReflectionUtils.makeAccessible(method);
????????????if?(StringUtils.isNotEmpty(params))?{
????????????????method.invoke(target,?params);
????????????}?else?{
????????????????method.invoke(target);
????????????}
????????}?catch?(Exception?ex)?{
????????????logger.error(String.format("定时任务执行异常?- bean：%s，方法：%s，参数：%s ",?beanName,?methodName,?params),?ex);
????????}

????????long?times?=?System.currentTimeMillis()?-?startTime;
????????logger.info("定时任务执行结束?- bean：{}，方法：{}，参数：{}，耗时：{}?毫秒",?beanName,?methodName,?params,?times);
????}

????@Override
????public?boolean?equals(Object?o)?{
????????if?(this?==?o)?return?true;
????????if?(o?==?null?||?getClass()?!=?o.getClass())?return?false;
????????SchedulingRunnable?that?=?(SchedulingRunnable)?o;
????????if?(params?==?null)?{
????????????return?beanName.equals(that.beanName)?&&
????????????????????methodName.equals(that.methodName)?&&
????????????????????that.params?==?null;
????????}

????????return?beanName.equals(that.beanName)?&&
????????????????methodName.equals(that.methodName)?&&
????????????????params.equals(that.params);
????}

????@Override
????public?int?hashCode()?{
????????if?(params?==?null)?{
????????????return?Objects.hash(beanName,?methodName);
????????}

????????return?Objects.hash(beanName,?methodName,?params);
????}
}

添加定时任务注册类，用来增加、删除定时任务。

@Component
public?class?CronTaskRegistrar?implements?DisposableBean?{

????private?final?Map<Runnable,?ScheduledTask>?scheduledTasks?=?new?ConcurrentHashMap<>(16);

????@Autowired
????private?TaskScheduler?taskScheduler;

????public?TaskScheduler?getScheduler()?{
????????return?this.taskScheduler;
????}

????public?void?addCronTask(Runnable?task,?String?cronExpression)?{
????????addCronTask(new?CronTask(task,?cronExpression));
????}

????public?void?addCronTask(CronTask?cronTask)?{
????????if?(cronTask?!=?null)?{
????????????Runnable?task?=?cronTask.getRunnable();
????????????if?(this.scheduledTasks.containsKey(task))?{
????????????????removeCronTask(task);
????????????}

????????????this.scheduledTasks.put(task,?scheduleCronTask(cronTask));
????????}
????}

????public?void?removeCronTask(Runnable?task)?{
????????ScheduledTask?scheduledTask?=?this.scheduledTasks.remove(task);
????????if?(scheduledTask?!=?null)
????????????scheduledTask.cancel();
????}

????public?ScheduledTask?scheduleCronTask(CronTask?cronTask)?{
????????ScheduledTask?scheduledTask?=?new?ScheduledTask();
????????scheduledTask.future?=?this.taskScheduler.schedule(cronTask.getRunnable(),?cronTask.getTrigger());

????????return?scheduledTask;
????}


????@Override
????public?void?destroy()?{
????????for?(ScheduledTask?task?:?this.scheduledTasks.values())?{
????????????task.cancel();
????????}

????????this.scheduledTasks.clear();
????}
}

添加定时任务示例类

@Component("demoTask")
public?class?DemoTask?{
????public?void?taskWithParams(String?params)?{
????????System.out.println("执行有参示例任务："?+?params);
????}

????public?void?taskNoParams()?{
????????System.out.println("执行无参示例任务");
????}
}

定时任务数据库表设计

定时任务数据库表设计

添加定时任务实体类

public?class?SysJobPO?{
????/**
?????*?任务ID
?????*/
????private?Integer?jobId;
????/**
?????*?bean名称
?????*/
????private?String?beanName;
????/**
?????*?方法名称
?????*/
????private?String?methodName;
????/**
?????*?方法参数
?????*/
????private?String?methodParams;
????/**
?????*?cron表达式
?????*/
????private?String?cronExpression;
????/**
?????*?状态（1正常?0暂停）
?????*/
????private?Integer?jobStatus;
????/**
?????*?备注
?????*/
????private?String?remark;
????/**
?????*?创建时间
?????*/
????private?Date?createTime;
????/**
?????*?更新时间
?????*/
????private?Date?updateTime;

????public?Integer?getJobId()?{
????????return?jobId;
????}

????public?void?setJobId(Integer?jobId)?{
????????this.jobId?=?jobId;
????}

????public?String?getBeanName()?{
????????return?beanName;
????}

????public?void?setBeanName(String?beanName)?{
????????this.beanName?=?beanName;
????}

????public?String?getMethodName()?{
????????return?methodName;
????}

????public?void?setMethodName(String?methodName)?{
????????this.methodName?=?methodName;
????}

????public?String?getMethodParams()?{
????????return?methodParams;
????}

????public?void?setMethodParams(String?methodParams)?{
????????this.methodParams?=?methodParams;
????}

????public?String?getCronExpression()?{
????????return?cronExpression;
????}

????public?void?setCronExpression(String?cronExpression)?{
????????this.cronExpression?=?cronExpression;
????}

????public?Integer?getJobStatus()?{
????????return?jobStatus;
????}

????public?void?setJobStatus(Integer?jobStatus)?{
????????this.jobStatus?=?jobStatus;
????}

????public?String?getRemark()?{
????????return?remark;
????}

????public?void?setRemark(String?remark)?{
????????this.remark?=?remark;
????}

????public?Date?getCreateTime()?{
????????return?createTime;
????}

????public?void?setCreateTime(Date?createTime)?{
????????this.createTime?=?createTime;
????}

????public?Date?getUpdateTime()?{
????????return?updateTime;
????}

????public?void?setUpdateTime(Date?updateTime)?{
????????this.updateTime?=?updateTime;
????}

}

新增定时任务

新增定时任务

boolean?success?=?sysJobRepository.addSysJob(sysJob);
if?(!success)
????return?OperationResUtils.fail("新增失败");
else?{
????if?(sysJob.getJobStatus().equals(SysJobStatus.NORMAL.ordinal()))?{
????????SchedulingRunnable?task?=?new?SchedulingRunnable(sysJob.getBeanName(),?sysJob.getMethodName(),?sysJob.getMethodParams());
????????cronTaskRegistrar.addCronTask(task,?sysJob.getCronExpression());
????}
}

return?OperationResUtils.success();

修改定时任务，先移除原来的任务，再启动新任务

boolean?success?=?sysJobRepository.editSysJob(sysJob);
if?(!success)
????return?OperationResUtils.fail("编辑失败");
else?{
????//先移除再添加
????if?(existedSysJob.getJobStatus().equals(SysJobStatus.NORMAL.ordinal()))?{
????????SchedulingRunnable?task?=?new?SchedulingRunnable(existedSysJob.getBeanName(),?existedSysJob.getMethodName(),?existedSysJob.getMethodParams());
????????cronTaskRegistrar.removeCronTask(task);
????}

????if?(sysJob.getJobStatus().equals(SysJobStatus.NORMAL.ordinal()))?{
????????SchedulingRunnable?task?=?new?SchedulingRunnable(sysJob.getBeanName(),?sysJob.getMethodName(),?sysJob.getMethodParams());
????????cronTaskRegistrar.addCronTask(task,?sysJob.getCronExpression());
????}
}

return?OperationResUtils.success();

删除定时任务

boolean?success?=?sysJobRepository.deleteSysJobById(req.getJobId());
if?(!success)
????return?OperationResUtils.fail("删除失败");
else{
????if?(existedSysJob.getJobStatus().equals(SysJobStatus.NORMAL.ordinal()))?{
????????SchedulingRunnable?task?=?new?SchedulingRunnable(existedSysJob.getBeanName(),?existedSysJob.getMethodName(),?existedSysJob.getMethodParams());
????????cronTaskRegistrar.removeCronTask(task);
????}
}

return?OperationResUtils.success();

定时任务启动/停止状态切换

if?(existedSysJob.getJobStatus().equals(SysJobStatus.NORMAL.ordinal()))?{
????SchedulingRunnable?task?=?new?SchedulingRunnable(existedSysJob.getBeanName(),?existedSysJob.getMethodName(),?existedSysJob.getMethodParams());
????cronTaskRegistrar.addCronTask(task,?existedSysJob.getCronExpression());
}?else?{
????SchedulingRunnable?task?=?new?SchedulingRunnable(existedSysJob.getBeanName(),?existedSysJob.getMethodName(),?existedSysJob.getMethodParams());
????cronTaskRegistrar.removeCronTask(task);
}

添加实现了CommandLineRunner接口的SysJobRunner类，当spring boot项目启动完成后，加载数据库里状态为正常的定时任务。

@Service
public?class?SysJobRunner?implements?CommandLineRunner?{

????private?static?final?Logger?logger?=?LoggerFactory.getLogger(SysJobRunner.class);

????@Autowired
????private?ISysJobRepository?sysJobRepository;

????@Autowired
????private?CronTaskRegistrar?cronTaskRegistrar;

????@Override
????public?void?run(String...?args)?{
????????//?初始加载数据库里状态为正常的定时任务
????????List<SysJobPO>?jobList?=?sysJobRepository.getSysJobListByStatus(SysJobStatus.NORMAL.ordinal());
????????if?(CollectionUtils.isNotEmpty(jobList))?{
????????????for?(SysJobPO?job?:?jobList)?{
????????????????SchedulingRunnable?task?=?new?SchedulingRunnable(job.getBeanName(),?job.getMethodName(),?job.getMethodParams());
????????????????cronTaskRegistrar.addCronTask(task,?job.getCronExpression());
????????????}

????????????logger.info("定时任务已加载完毕...");
????????}
????}
}

工具类SpringContextUtils，用来从spring容器里获取bean

@Component
public?class?SpringContextUtils?implements?ApplicationContextAware?{

????private?static?ApplicationContext?applicationContext;

????@Override
????public?void?setApplicationContext(ApplicationContext?applicationContext)
????????????throws?BeansException?{
????????SpringContextUtils.applicationContext?=?applicationContext;
????}

????public?static?Object?getBean(String?name)?{
????????return?applicationContext.getBean(name);
????}

????public?static?<T>?T?getBean(Class<T>?requiredType)?{
????????return?applicationContext.getBean(requiredType);
????}

????public?static?<T>?T?getBean(String?name,?Class<T>?requiredType)?{
????????return?applicationContext.getBean(name,?requiredType);
????}

????public?static?boolean?containsBean(String?name)?{
????????return?applicationContext.containsBean(name);
????}

????public?static?boolean?isSingleton(String?name)?{
????????return?applicationContext.isSingleton(name);
????}

????public?static?Class<??extends?Object>?getType(String?name)?{
????????return?applicationContext.getType(name);
????}
}

相关推荐

全球最大的H5网站模板库（h5页面模板下载）

当今社会，互联网迅猛发展，在网络营销中，客户往往通过企业的网站建设留下对该企业的第一印象，一个优秀的企业网站已成为企业发展的重要纽带，嗨创H5，拥有国内外一流的技术团队，潜心专研网站建设6年，是全球最...

wordpress集团公司网站模板:XSgr（wordpress建站公司）

小兽wordpress推出一款高端集团公司主题，打造高品质官网。高端是一种态度和坚持，因为我坚信贴合产品及品牌理念的高端深度定制才能最大化地呈现企业的务实严谨与产品的专业品质相比，某种程度上讲–...

私心推荐，小编酷爱的五款高逼格网站模板

建站宝盒的网站模板上千套之多，各有各的风格色彩，但是，弱水三千，小编我却只取一瓢饮，在这上千套模板之中，小编酷爱的网站模板有五套，让小编私心推荐一下吧！1、茶叶贸易公司网站模板小编对这款网站模板可是一...

「书讯」政府网站用户行为研究与应用

《政府网站用户行为研究与应用》作者:刘合翔著出版日期：2018年6月开本：16开出版社：经济管理出版社小编推荐《政府网站用户行为研究与应用》的主题是关于政府网站用户行为的特征规律及其在政府网站优...

免费服务器-搭建模板网站的操作流程(图文版)

之前发文《创业者的官网：如何搭建免费云服务器及操作面板（图文版）》，因为做了视频才发现，创业者对视频的需求，远远低于对图文解说的需求。因此，补充图文教程，不清楚的看官们，可以直接看视频版本进行细部学...

快收藏这些高逼格H5网站模板吧，不绕弯子直接下载

上面这些响应式H5网站是不是很炫酷，比起那些“在线一键生成”是不是好太多了？关键是，那些一键制作都不会开放源码给你，自定义性也很局限。不过说到底还是难看。今天笔者推荐大家一个模板网站，全都是高质量的响...

如何开发网站建设管理系统模板（如何开发网站建设管理系统模板图片）

根据用户网站需求文档设计美工图，并设计数据库结构，让网站开发人员可以更多地关注前台美工，先对照美工图，编写静态HTML页面，按网站建设管理系统模板语法，修改编写好的静态HTML页面，运行。不再需要对...

C语言的数据类型介绍（c语言的数据类型介绍是什么）

在计算机系统中，数据是放在内存中的，数字、文字、符号、图形、音频、视频等数据都是以二进制形式存储在内存中的，它们并没有本质上的区别，那么0001000该理解为数字8呢，还是图像中某个像素的颜色...

C 语言格式化输出函数中常用的格式符号

在之前介绍输入输出函数的文章中，有提到格式化输入输出函数都有包含一种特殊的符号——格式符号。那篇文章中关于格式符号也只是一笔带过，没有进行深入挖掘。本篇文章主要对输出函数（printf）中的一些常用格...

C#中的类型转换（c#数据转换类）

计算机存储的基本单位：字节我们知道一个字节（Byte）有8个比特(bit)构成，比特是存储的最小单位，表示0和1，但为什么计算机存储的基本单位是字节，而不是比特呢？假设我们要存储数字3（二进制：11...

Java8中String内存空间占用分析（电脑里下载的文件怎样删除才不会占用内存空间）

1.前言分析之前，简单回顾一下对象的内存分布。在HotSpot虚拟机中，对象在堆内存中的存储布局可以划分为三部分：对象头、实例数据和对齐填充。对象头包含两部分内容：MarkWord和类型指针。实例数据...

「每日C语言」数据类型大小和取值范围

对于c语言来说，数据类型是一个很重要的概念和知识点，它涉及到的是内存的空间，这在和硬件交互的时候是非常重要的。K&R给出了7个数据类型相关的关键字，分别是：int、long、short、uns...

【c语言学习笔记】数据类型（c语言里面的数据类型）

c语言学习笔记，欢迎大家能在评论区提出我学习错误的地方方便我进行改正~在计算机中，计算机用二进制来储存数据，在c语言中有许多的数据类型用来存储数据，当然不同的数据类型所用的内存占用也不一样，下面就来用...

关于MySQL varchar类型最大值，原来一直都理解错了

我是架构精进之路，点击上方“关注”，坚持每天为你分享技术干货，私信我回复“01”，送你一份程序员成长进阶大礼包。写在前面关于MySQLvarchar字段类型的最大值计算，也许我们一直都理解错误了，...

C语言数据类型的转换（c语言数据类型的转换方式）

类型转换在C语言程序中，经常需要对不同类型的数据进行运算，为了解决数据类型不一致的问题，需要对数据的类型进行转换。例如一个浮点数和一个整数相加，必须先将两个数转换成同一类型。C语言程序中的类型...

取消回复欢迎 你 发表评论:

一周热门
最近发表
标签列表

Powered By Z-BlogPHP,Theme By 天兴工作室