在日常的业务场景中,我们经常需要让系统在特定的时间去完成某项任务,比如每小时清理一次数据库历史数据、每隔5分钟同步一次数据等等。Spring Task可以帮我们实现这些功能,不仅开箱即用、配置简单,而且功能强大。一起来看下吧!
开始使用创建一个Spring Boot应用,使用@EnableScheduling注解开启定时任务功能
@EnableScheduling
@SpringBootApplication
public class ScheduleDemoApplication {
public static void main(String[] args) {
SpringApplication.run(ScheduleDemoApplication.class, args);
}
}
创建一个自定义的任务类,为方法添加@Scheduled注解
@Component
public class MyTask {
@Scheduled(fixedDelay = 2000)
public void work() {
System.out.println("Start working...");
}
}
本地运行程序,可以看到
每隔2秒钟,控制台就会打印一次“Start working...”,这样一个最简单的定时任务就已经实现了。
@EnableScheduling这个注解用来开启Spring的定时任务功能,开启后应用就会自动检测带有@Scheduled注解的方法,按照制定的触发规则进行方法的调用。如果添加了@EnableScheduling注解,就一定要去实现自定义的任务类(如上的MyTask类)。
@Scheduled在我们实现的自定义任务类中,必须包含一个@Scheduled注解的方法,如果没有,程序会在启动后立即异常退出
@Scheduled用来标注一个要定时运行的方法,它有三个常用的属性
- fixedDelay:固定的时间间隔,单位毫秒,从上次执行结束到下次开始执行之间的时间间隔
- fixedRate:固定的时间频率,单位毫秒,从上次开始执行到下次开始执行之间的时间间隔
- cron:使用cron表达式来描述更复杂的定时运行规则
fixedDelay和fixedRate容易让人搞混,这里用一张图来帮助你理解它们之间的差异
fixedDelay和fixedRate的默认时间单位是毫秒,可以通过timeUnit属性进行设置
@Scheduled(fixedDelay = 1, timeUnit = TimeUnit.SECONDS)
public void work() {
System.out.println("Start working...");
}
@Scheduled还有两个属性,fixedDelayString和fixedRateString,它们支持通过占位符的方式来获取application.yml中配置的属性值
work:
fixedDelay: 2000
@Scheduled(fixedDelayString = "${work.fixedDelay}")
public void work() {
System.out.println("Start working...");
}
假如我们有如下的需求,周一到周五每天的12点进行数据的同步,使用fixedDelay和fixedRate是无法实现的,这里就要用到cron表达式了
@Scheduled(cron="0 0 12 * * MON-FRI")
public void transferData() {
System.out.println("Start transferring data...");
}
cron表达式功能强大,使用简单,我后面再出一期专门介绍cron表达式的文章吧,这里不过多介绍了,也可以使用一些在线生成工具来生成表达式,也是很方便的。
Spring Task简洁、易用、高效,可以满足单机版定时任务的大部分需求。不过面对企业复杂的需求,它还是过于简单了,这时就要用到quartz和xxl-job这种更加强大完善的框架了。下一篇我们将来深入分析quartz的集成使用,有问题可以在评论区交流下,欢迎点赞收藏关注。
,