为什么定时任务到时间不执行?带你深入源码找答案
yuyutoo 2024-12-25 16:33 9 浏览 0 评论
前言
早上研发经理给我分配了一个开发任务:每5秒统计一次APP在线人数,并问我啥时能上线?
我心想这需求用Spring的定时任务完美解决啊!作为一个萌新正好借此机会在经理面前表现一番,于是我拍着胸脯跟经理说半小时就能做好。
不曾想在做的过程中遇到大坑,花了半天才搞好。在这里友情提醒一下广大程序员小伙伴们开发估时间有一定要给自己留点余地,千万不想学我(此刻我已流下悔恨的泪水~)
目录
- 定时任务怎么不执行了?
- 深入源码中找原因
- 3种解决方案对比,谁最简单?
- 定时任务你真的会用吗?
- Quartz——更好的任务调度框架
定时任务怎么不执行了?
要想让Spring Boot项目支持定时任务,我们需要做一些准备工作:
首先,在启动入口类上加上@EnableScheduling注解,开始定时任务支持;
下面来看一下我的定时任务(为了方便演示,具体逻辑已略去);
没什么难的,按照我的预想项目启动之后应该是每5秒输出一次日志的,大概是这样:
敲完定时任务最后一行代码,一看时间才过去10分钟,心想就我这速度也是没谁了,经理肯定得夸我呀!
你以为我会立刻就向经理报告吗?错!作为一个具备专业素养的程序员,肯定得自己测试完再向经理报告啦。
OK,启动项目测试下任务执行情况,看到控制台输出的结果之后我是虎躯一震,发现事情并没有那么简单,先来看输出结果:
我写的定时任务规则明明是每5秒执行一次,可这实际执行时间一会间隔6秒、一会间隔4秒、一会又间隔5秒,完全不按套路出牌啊!啥情况?
深入源码找原因
代码报错你们觉得我会很慌?错!我会感到浑身兴奋(实则内心慌的一批~)
报错是好事,毕竟我是要成为“Debug小王子”的男人!
从哪开始Debug呢?既然我是使用@EnableScheduling注解开启定时任务支持的,那就从它开始吧;
这个注解的代码真是太太太简洁了,简洁到啥都没有,主要就是通过@Import导入了一个SchedulingConfiguration配置类。
好吧,在下佩服!
继续跟进:
没想到的是SchedulingConfiguration配置类里面也仅仅定义了一个ScheduledAnnotationBeanPostProcessor类型的bean。
这家伙隐藏够深的啊!继续跟进,终于让我发现了点东西:
首先,ScheduledAnnotationBeanPostProcessor实现了ApplicationListener接口;
这个接口有啥用呢?
实现了这个接口,我们就可以监听到Spring Boot在启动过程的不同周期的回调事件,这里监听的是ApplicationContext的刷新事件。
也就是说,在Spring Boot启动过程中,当容器上下文ApplicationContext刷新结束后会回调ScheduledAnnotationBeanPostProcessor当中的onApplicationEvent方法:
onApplicationEvent方法里又调用了finishRegistration方法;
这finishRegistration方法比较长就不贴图了,反正里面主要就做了一件事:加载一个叫taskScheduler的bean。
直觉告诉我这个bean肯定是Spring Boot自动装载的(用飘柔就是这么自信!哎~ 别打我……)。
我们来验证一下这个大胆的猜想,打开Spring Boot的自动装载清单文件spring.factories:
果然发现了一个TaskSchedulingAutoConfiguration配置类,是不是已经开始有点崇拜我了!
进去看一下:
是不是有个叫taskScheduler的bean?这个taskScheduler的类型是ThreadPoolTaskScheduler,ThreadPool?一看名字就知道是使用线程池实现的,果然下面的taskSchedulerBuilder方法里就有设置池子的大小的方法。
最终的线索指向了TaskSchedulingProperties这个属性类,我们来看一下它里面有什么秘密:
它里面默认的线程池大小就是1。
明白了,这下全明白了!
让我们从头来捋一遍整个逻辑:
- 当我们使用注解开启定时任务支持时,Spring Boot在启动过程中会去找一个叫taskScheduler的bean当作整个应用的任务调度器;
- 这个taskScheduler默认是由Spring Boot自动加载的,它里面有一个执行定时任务的线程池,默认大小就是1;
也就是说所有任务都只能由这一个线程来执行,如果有多个定时任务需要执行,那也只能排队顺序执行;
这时我正好想到项目里正好还有几个其他的定时任务在跑,各个任务执行时间点、耗费时间都不一样;
因为只有一个线程来执行所有任务,那么当有一个定时任务要耗费很长时间时,那么其他定时任务即使到了执行时间点也只能继续等待了?
接下来我用两个定时任务来测试一下,看看它们的线程名是不是一样?
改造一下两个定时任务的逻辑:
- 首先任务一每5秒执行一次、每次耗时4秒,任务二每3秒执行一次;
- 其次两个任务里都将打印当前执行任务线程名;
来看一下执行结果:
可以看到2个定时任务的执行线程名是一样的;仔细看一下任务2的执行时间点,原本应该1秒执行一次,现在却执行的毫无规律可言。
3种解决方案对比,谁最简单?
我总结了一下发现网上主要有2种解决方案。
方法一:
实现SchedulingConfigurer接口,提供一个自定义的TaskScheduler;
方法二:
首先提供一个自定义的线程池,并使用@EnableAsync注解开启异步支持:
再在定时任务方法上加上@Async注解启用异步执行;
首先,经过我实际测试,两种方法都能解决问题。
但是在我看来这2中办法都太笨重,又是要新建配置类、又要另外使用一个注解,简直不能忍(主要是我懒~)!
下面我来提供一下最简单的解决方案,还记得在源码中我们最终找到的TaskSchedulingProperties这个属性类吗?
这个配置类通过注解绑定了项目配置文件中以spring.task.scheduling开头的配置属性,所以我们只需要在application.properties文件中提供一个spring.task.scheduling.pool.size属性就能改变线程池的带下了;
是不是比上面2种解决方法更简单?自己找到的解决方法就是好用!
定时任务你真的会用吗?
是不是感觉自己对定时任务好像也没那么了解了?下面顺道来复习一下吧。
首先来看一下@Scheduled注解:
可以看到@Scheduled注解中有多个配置元素:
- cron表达式,可以灵活指定任务执行时间,几乎可以实现任何你想要的时间点与周期;
- zone时区,默认当前时区,一般不会用到;
- fixedDelay,表示自上一次任务执行完成后延迟多久再次执行,参数为long类型,单位毫秒;
- fixedDelayString,同fixedDelay,只是参数类型变为String;
- fixedRate,表示任务将按照固定的频率执行,参数为long类型,单位毫秒;
- fixedRateString,同fixedRate,只是参数类型变为String;
- initialDelay,表示应用启动后将会延迟多久才会第一次执行任务,参数为long类型,单位毫秒;
- initialDelayString,同initialDelay,只是参数类型变为String;
接下来重点说一下cron表达式吧。
cron表达式共有7位域(Spring当中只需6位域),从左到右分别代表:
秒 分 小时 日期 月份 星期 年份(可省略)
其中:
- *字符表示所有的值,用在秒域表示每秒钟、用在分钟域表示每分钟;
- -字符表示一个范围区间,例如5-10,用在秒域表示从第5秒开始到第10秒结束、每秒执行一次,用在分钟域则表示从第5分钟开始到第10分钟结束、每分钟执行一次。
- ,字符表示指定的值,l例如10,15,20用在分钟域表示只在第10分钟、第15分钟、第20分钟各执行一次;
- /字符表示指定步长,例如0/15用在秒域表示从第0秒开始、每15秒执行一次,用在分钟域表示从第0分钟开始、每15分钟执行一次;
- ?字符只能用在日期和星期两个域,表示不明确的值。日期和星期是一一对应关系,如果设置了日期,那么可在星期域使用?代替明确的星期值;
- L字符只能用在日期和星期两个域,表示最后一天。单独用在日期域表示一个月的最后一天,单独用在星期域表示一个星期的最后一天(星期六),另外当L用在星期域时可以和数字组合使用,例如5L表示在一个月的最后一个星期四执行(5代表星期四);
- W字符只能用在日期域,表示任务将在离指定日期的最近的一个工作日(周一到周五)执行。例如我在日期域写上15W,那代表任务将在离15号最近的一个工作日执行,如果15号正好是周六、那么任务会提前在14号触发,如果15号是周日则任务会在16号触发;
- L和W字符可组合使用、但只能用在日期域,表示一个月的最后一个工作日(最后一个星期五);
- #字符只能用在星期域,用于指定一个月的第几个星期几。例如7#3表示一个月的第三周的星期六(7代表星期六,3代表第三周);
- 至于C字符,网上都说是要根据指定日历计算执行时间,至于怎么指定日历的压根不提,我也是醉了!这个我真不知道怎么使用;
Quartz——更好的任务调度框架
Spring的定时任务虽然使用起来很方便,但我在实际应用中发现存在以下几个问题:
- 不支持高可用,当项目需要发新版时,需要停止应用进程,那么定时任务也会停止导致数据缺失。
- 不支持分布式,当项目需要上集群或者负载均衡时,一个任务会被多次执行导致数据错乱。
- 不支持动态操作,当需要修改某个任务执行时间、或者停止/启动某个定时任务时,我们只能修改代码重新发布。
作为一个有理想有抱负的程序员,我是绝对不允许项目中存在这种问题的。
经过我的一番搜寻,终于找到了Quartz这个开源任务调度框架,它不仅可以动态添加删除任务,还支持手动开启或停止任务;最关键的是它支持分布式部署,可以保证任务不漏跑不重跑,还能将任务分散到不同的机器同步执行。
这是我们公司内部在用的基于Quartz框架实现的一套可以动态管理定时任务的系统:
鉴于篇幅有限,在这就不展开介绍了,后续有机会在单独写一篇详细介绍一下Quartz框架的用法。
“分享干货,收获快乐”
我是一名程序员,喜欢我的文章欢迎 关注 及 转发,我会经常与大家分享工作当中的实用技巧与经验。
相关推荐
- 墨尔本一华裔男子与亚裔男子分别失踪数日 警方寻人
-
中新网5月15日电据澳洲新快网报道,据澳大利亚维州警察局网站消息,22岁的华裔男子邓跃(Yue‘Peter’Deng,音译)失踪已6天,维州警方于当地时间13日发布寻人通告,寻求公众协助寻找邓跃。华...
- 网络交友须谨慎!美国犹他州一男子因涉嫌杀害女网友被捕
-
伊森·洪克斯克(图源网络,侵删)据美国广播公司(ABC)25日报道,美国犹他州一名男子于24日因涉嫌谋杀被捕。警方表示,这名男子主动告知警局,称其杀害了一名在网络交友软件上认识的25岁女子。雷顿警...
- 一课译词:来龙去脉(来龙去脉 的意思解释)
-
Mountainranges[Photo/SIPA]“来龙去脉”,汉语成语,本指山脉的走势和去向,现比喻一件事的前因后果(causeandeffectofanevent),可以翻译为“i...
- 高考重要考点:range(range高考用法)
-
range可以用作动词,也可以用作名词,含义特别多,在阅读理解中出现的频率很高,还经常作为完形填空的选项,而且在作文中使用是非常好的高级词汇。...
- C++20 Ranges:现代范围操作(现代c++白皮书)
-
1.引言:C++20Ranges库简介C++20引入的Ranges库是C++标准库的重要更新,旨在提供更现代化、表达力更强的方式来处理数据序列(范围,range)。Ranges库基于...
- 学习VBA,报表做到飞 第二章 数组 2.4 Filter函数
-
第二章数组2.4Filter函数Filter函数功能与autofilter函数类似,它对一个一维数组进行筛选,返回一个从0开始的数组。...
- VBA学习笔记:数组:数组相关函数—Split,Join
-
Split拆分字符串函数,语法Split(expression,字符,Limit,compare),第1参数为必写,后面3个参数都是可选项。Expression为需要拆分的数据,“字符”就是以哪个字...
- VBA如何自定义序列,学会这些方法,让你工作更轻松
-
No.1在Excel中,自定义序列是一种快速填表机制,如何有效地利用这个方法,可以大大增加工作效率。通常在操作工作表的时候,可能会输入一些很有序的序列,如果一一录入就显得十分笨拙。Excel给出了一种...
- Excel VBA入门教程1.3 数组基础(vba数组详解)
-
1.3数组使用数组和对象时,也要声明,这里说下数组的声明:'确定范围的数组,可以存储b-a+1个数,a、b为整数Dim数组名称(aTob)As数据类型Dimarr...
- 远程网络调试工具百宝箱-MobaXterm
-
MobaXterm是一个功能强大的远程网络工具百宝箱,它将所有重要的远程网络工具(SSH、Telnet、X11、RDP、VNC、FTP、MOSH、Serial等)和Unix命令(bash、ls、cat...
- AREX:携程新一代自动化回归测试工具的设计与实现
-
一、背景随着携程机票BU业务规模的不断提高,业务系统日趋复杂,各种问题和挑战也随之而来。对于研发测试团队,面临着各种效能困境,包括业务复杂度高、数据构造工作量大、回归测试全量回归、沟通成本高、测试用例...
- Windows、Android、IOS、Web自动化工具选择策略
-
Windows平台中应用UI自动化测试解决方案AutoIT是开源工具,该工具识别windows的标准控件效果不错,但是当它遇到应用中非标准控件定义的UI元素时往往就无能为力了,这个时候选择silkte...
- python自动化工具:pywinauto(python快速上手 自动化)
-
简介Pywinauto是完全由Python构建的一个模块,可以用于自动化Windows上的GUI应用程序。同时,它支持鼠标、键盘操作,在元素控件树较复杂的界面,可以辅助我们完成自动化操作。我在...
- 时下最火的 Airtest 如何测试手机 APP?
-
引言Airtest是网易出品的一款基于图像识别的自动化测试工具,主要应用在手机APP和游戏的测试。一旦使用了这个工具进行APP的自动化,你就会发现自动化测试原来是如此简单!!连接手机要进行...
- 【推荐】7个最强Appium替代工具,移动App自动化测试必备!
-
在移动应用开发日益火爆的今天,自动化测试成为了确保应用质量和用户体验的关键环节。Appium作为一款广泛应用的移动应用自动化测试工具,为测试人员所熟知。然而,在不同的测试场景和需求下,还有许多其他优...
你 发表评论:
欢迎- 一周热门
- 最近发表
- 标签列表
-
- mybatis plus (70)
- scheduledtask (71)
- css滚动条 (60)
- java学生成绩管理系统 (59)
- 结构体数组 (69)
- databasemetadata (64)
- javastatic (68)
- jsp实用教程 (53)
- fontawesome (57)
- widget开发 (57)
- vb net教程 (62)
- hibernate 教程 (63)
- case语句 (57)
- svn连接 (74)
- directoryindex (69)
- session timeout (58)
- textbox换行 (67)
- extension_dir (64)
- linearlayout (58)
- vba高级教程 (75)
- iframe用法 (58)
- sqlparameter (59)
- trim函数 (59)
- flex布局 (63)
- contextloaderlistener (56)