定时任务的实现很是多,JDK的Timer、Spring提供的轻量级的Scheduled Task、QuartZ和Linux Cron等,还有一些分布式的任务调度框架。本文主要介绍Scheduled Task的使用。java
注解@Scheduled
只能用于知足下面两个条件的方法上:数据库
(1)没有返回类型,或者说返回类型为void
;多线程
(2)没有参数;app
开启Spring的Scheduler很是简单,一个注解@EnableScheduling
便可:框架
@Configuration @EnableScheduling public class SchedulingConfig { }
若是是Springboot应用,则直接在启动类上面加上@EnableScheduling
就可使用了。异步
表明下一个任务的开始与上一个任务的结束间隔老是固定的时长,并且老是会等上一个任务完成了,才会开启下一个任务。若是需求是有这样依赖要求的,使用这种模式是很是合适的。代码以下:分布式
@Scheduled(fixedDelay = 1000) public void fixedDelay() { log.info("fixedDelay"); }
参数为1000,表明固定延迟为1000毫秒,即1秒钟,因此输出为:线程
2019-11-19 21:02:43,977 scheduling-1:fixedDelay 2019-11-19 21:02:44,981 scheduling-1:fixedDelay 2019-11-19 21:02:45,983 scheduling-1:fixedDelay 2019-11-19 21:02:46,984 scheduling-1:fixedDelay
定频任务的特性是任务的执行的时间间隔老是同样的。好比每1小时执行一次,就是任务执行开始的时间点的时间间隔为1小时。代码以下:日志
@Scheduled(fixedRate = 2000) public void fixedRate() { log.info("fixedRate"); }
参数为2000,则每2秒执行一次,输出为:code
2019-11-19 21:38:45,073 scheduling-1:fixedRate 2019-11-19 21:38:47,076 scheduling-1:fixedRate 2019-11-19 21:38:49,073 scheduling-1:fixedRate 2019-11-19 21:38:51,075 scheduling-1:fixedRate
须要注意的是它默认是单线程的,不会并行执行。即便是固定频率,但下一次的任务也必须等到上一次任务执行完毕才会开始。下面这个例子能很好说明:
@Scheduled(fixedRate = 1000) public void fixedRateLongTimeTask() throws InterruptedException { log.info("fixedRateLongTimeTask"); Thread.sleep(3000); }
因为任务须要执行3秒才能完成,即便fixedRate
设置为1秒,并不能每一秒执行一次,输出以下:
2019-11-19 21:46:00,108 scheduling-1:fixedRateLongTimeTask 2019-11-19 21:46:03,113 scheduling-1:fixedRateLongTimeTask 2019-11-19 21:46:06,113 scheduling-1:fixedRateLongTimeTask 2019-11-19 21:46:09,117 scheduling-1:fixedRateLongTimeTask
每3次输出一次。
上述问题有办法解决吗?答案是确定的,并且很是简单。只须要加一个注解@Async
就可使任务能异步多线程地执行了,代码以下:
@Async @Scheduled(fixedRate = 1000) public void fixedRateLongTimeTask() throws InterruptedException { log.info("fixedRateLongTimeTask"); Thread.sleep(3000); }
经过日志能够看出是每秒执行一次的,即便前面的任务尚未完成。并且线程名不同,经过多线程来执行,输出结果为:
2019-11-19 21:54:22,261 task-5:fixedRateLongTimeTask 2019-11-19 21:54:23,257 task-6:fixedRateLongTimeTask 2019-11-19 21:54:24,257 task-4:fixedRateLongTimeTask 2019-11-19 21:54:25,257 task-8:fixedRateLongTimeTask 2019-11-19 21:54:26,259 task-1:fixedRateLongTimeTask 2019-11-19 21:54:27,262 task-2:fixedRateLongTimeTask 2019-11-19 21:54:28,260 task-3:fixedRateLongTimeTask
注意:须要指出的是,须要像@EnableScheduling
同样,须要添加配置注解@EnableAsync
来打开这个功能开关。另外,若是任务执行时间很长,例如1分钟,状况又不同。之后再详细介绍@Async
的使用吧。
初始延迟是用initialDelay
来指定的,它能够延迟第一次任务执行的时间。以下例子的参数为30秒,则在启动30秒后,才开始执行第一次。能够减轻项目启动的负担,也能够为任务执行前准备数据。
@Scheduled(fixedDelay = 1000, initialDelay = 30*1000) public void fixedDelayWithIntialDelay() { log.info("fixedDelayWithIntialDelay"); }
输出以下:
2019-11-19 22:10:02,092 main:Tomcat started on port(s): 443 (http) with context path '' 2019-11-19 22:10:02,095 main:Started DemoApplication in 1.272 seconds (JVM running for 1.767) 2019-11-19 22:10:32,063 scheduling-1:fixedDelayWithIntialDelay 2019-11-19 22:10:33,067 scheduling-1:fixedDelayWithIntialDelay 2019-11-19 22:10:34,069 scheduling-1:fixedDelayWithIntialDelay 2019-11-19 22:10:35,069 scheduling-1:fixedDelayWithIntialDelay
能够看出,在项目启动后30秒左右,才开始执行任务。
上述提供的功能并不能知足定时任务调度的全部需求,好比须要每月1号发送短信,每周六作数据分析等。这里Cron表达式就派上用场了。
下面的例子表示每当秒数为06的时候就执行。代码以下:
@Scheduled(cron = "6 * * ? * *") public void cron() { log.info("cron"); }
结果以下:
2019-11-19 22:20:06,003 scheduling-1:cron 2019-11-19 22:21:06,004 scheduling-1:cron 2019-11-19 22:22:06,002 scheduling-1:cron
Cron表达式功能很是强大,网上资料很丰富,这里不展开讲了。
以前的例子都将参数写死在代码上了,若是须要更灵活,其实能够用参数来配置。这样须要修改参数的时候,不用修改代码、编译打包再部署了,直接修改配置文件便可。
代码以下:
@Scheduled(cron = "${pkslow.cron}") public void cronWithConfig() { log.info("cronWithConfig"); }
在application.properties配置以下:
pkslow.cron=* * * ? * *
代码1秒执行一次。
因为Spring的Scheduler默认是单线程的,这样会存在一个问题,若是某个任务执行卡住了,那就没法继续往下执行了。在日志上表现就是忽然消失了。这种状况出现的几率仍是不小的,如操做数据库死锁了,http请求timeout为无限等待,还有其它缘由的死锁等。
当遇到这种状况,应经过命令jstack pid > pid.ThreadDump.txt
获取当前线程状况,而后分析是否真的是卡住了,卡在了哪一个环节,而后再分析具体代码。经过设置超时或重试等方法来解决。
本文主要介绍了Spring的定时任务注解@Scheduled
的使用,讲述了多种方式的使用和配置。它很是方便简洁,对于简单的定时任务足以应对了。
欢迎关注公众号<南瓜慢说>,将持续为你更新...
多读书,多分享;多写做,多整理。