SpringBoot中的定时调度服务使用详解
更新时间：2026年04月03日 08:56:17 作者：志哥聊技术
本文介绍了SpringBoot中定时任务的实践应用,包括pom包配置、启动类启用定时调度、创建定时任务、异步执行定时任务、自定义任务线程池等内容,SpringBoot内置的@Scheduled注解可以满足大部分业务需求
一、背景介绍
在实际的业务开发过程中，我们经常会需要定时任务来帮助我们完成一些工作，例如每天早上 6 点生成销售报表、每晚 23 点清理脏数据等等。
如果你当前使用的是 SpringBoot 来开发项目，那么完成这些任务会非常容易！
SpringBoot 默认已经帮我们完成了相关定时任务组件的配置，我们只需要添加相应的注解@Scheduled就可以实现任务调度！
二、方案实践
2.1、pom 包配置
pom包里面只需要引入Spring Boot Starter包即可！
<dependencies>
<!--spring boot核心-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<!--spring boot 测试-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>2.2、启动类启用定时调度
在启动类上面加上@EnableScheduling即可开启定时
@SpringBootApplication
@EnableScheduling
public class ScheduleApplication {
public static void main(String[] args) {
SpringApplication.run(ScheduleApplication.class, args);
}
}
2.3、创建定时任务
Spring Scheduler支持四种形式的任务调度！
- fixedRate：固定速率执行，例如每5秒执行一次
- fixedDelay：固定延迟执行，例如距离上一次调用成功后2秒执行
- initialDelay：初始延迟任务，例如任务开启过5秒后再执行，之后以固定频率或者间隔执行
- cron：使用 Cron 表达式执行定时任务
2.3.1、固定速率执行
你可以通过使用fixedRate参数以固定时间间隔来执行任务，示例如下：
@Component
public class SchedulerTask {
private static final Logger log = LoggerFactory.getLogger(SchedulerTask.class);
private static final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
/**
* fixedRate：固定速率执行。每5秒执行一次。
*/
@Scheduled(fixedRate = 5000)
public void runWithFixedRate() {
log.info("Fixed Rate Task，Current Thread : {}，The time is now : {}", Thread.currentThread().getName(), dateFormat.format(new Date()));
}
}
运行ScheduleApplication主程序，即可看到控制台输出效果：
Fixed Rate Task，Current Thread : scheduled-thread-1，The time is now : 2020-12-15 11:46:00 Fixed Rate Task，Current Thread : scheduled-thread-1，The time is now : 2020-12-15 11:46:10 ...
2.3.2、固定延迟执行
你可以通过使用fixedDelay参数来设置上一次任务调用完成与下一次任务调用开始之间的延迟时间，示例如下：
@Component
public class SchedulerTask {
private static final Logger log = LoggerFactory.getLogger(SchedulerTask.class);
private static final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
/**
* fixedDelay：固定延迟执行。距离上一次调用成功后2秒后再执行。
*/
@Scheduled(fixedDelay = 2000)
public void runWithFixedDelay() {
log.info("Fixed Delay Task，Current Thread : {}，The time is now : {}", Thread.currentThread().getName(), dateFormat.format(new Date()));
}
}
控制台输出效果：
Fixed Delay Task，Current Thread : scheduled-thread-1，The time is now : 2020-12-15 11:46:00 Fixed Delay Task，Current Thread : scheduled-thread-1，The time is now : 2020-12-15 11:46:02 ...
2.3.3、初始延迟任务
你可以通过使用initialDelay参数与fixedRate或者fixedDelay搭配使用来实现初始延迟任务调度。
@Component
public class SchedulerTask {
private static final Logger log = LoggerFactory.getLogger(SchedulerTask.class);
private static final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
/**
* initialDelay:初始延迟。任务的第一次执行将延迟5秒，然后将以5秒的固定间隔执行。
*/
@Scheduled(initialDelay = 5000, fixedRate = 5000)
public void reportCurrentTimeWithInitialDelay() {
log.info("Fixed Rate Task with Initial Delay，Current Thread : {}，The time is now : {}", Thread.currentThread().getName(), dateFormat.format(new Date()));
}
}
控制台输出效果：
Fixed Rate Task with Initial Delay，Current Thread : scheduled-thread-1，The time is now : 2020-12-15 11:46:05 Fixed Rate Task with Initial Delay，Current Thread : scheduled-thread-1，The time is now : 2020-12-15 11:46:10 ...
2.3.4、使用 Cron 表达式
Spring Scheduler同样支持Cron表达式，如果以上简单参数都不能满足现有的需求，可以使用 cron 表达式来定时执行任务。
关于cron表达式的具体用法，可以点击参考这里： https://cron.qqe2.com/
@Component
public class SchedulerTask {
private static final Logger log = LoggerFactory.getLogger(SchedulerTask.class);
private static final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
/**
* cron：使用Cron表达式。每6秒中执行一次
*/
@Scheduled(cron = "*/6 * * * * ?")
public void reportCurrentTimeWithCronExpression() {
log.info("Cron Expression，Current Thread : {}，The time is now : {}", Thread.currentThread().getName(), dateFormat.format(new Date()));
}
}
控制台输出效果：
Cron Expression，Current Thread : scheduled-thread-1，The time is now : 2020-12-15 11:46:06 Cron Expression，Current Thread : scheduled-thread-1，The time is now : 2020-12-15 11:46:12 ...
2.4、异步执行定时任务
在介绍异步执行定时任务之前，我们先看一个例子！
在下面的示例中，我们创建了一个每隔2秒执行一次的定时任务，在任务里面大概需要花费 3 秒钟，猜猜执行结果如何？
@Component
public class AsyncScheduledTask {
private static final Logger log = LoggerFactory.getLogger(AsyncScheduledTask.class);
private static final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@Scheduled(fixedRate = 2000)
public void runWithFixedDelay() {
try {
TimeUnit.SECONDS.sleep(3);
log.info("Fixed Delay Task, Current Thread : {} : The time is now {}", Thread.currentThread().getName(), dateFormat.format(new Date()));
} catch (InterruptedException e) {
log.error("错误信息",e);
}
}
}
控制台输入结果：
Fixed Delay Task, Current Thread : scheduling-1 : The time is now 2020-12-15 17:55:26 Fixed Delay Task, Current Thread : scheduling-1 : The time is now 2020-12-15 17:55:31 Fixed Delay Task, Current Thread : scheduling-1 : The time is now 2020-12-15 17:55:36 Fixed Delay Task, Current Thread : scheduling-1 : The time is now 2020-12-15 17:55:41 ...
很清晰的看到，任务调度频率变成了每隔5秒调度一次！
这是为啥呢？
从Current Thread : scheduling-1输出结果可以很看到，任务执行都是同一个线程！默认的情况下，@Scheduled任务都在 Spring 创建的大小为 1 的默认线程池中执行！
更直观的结果是，任务都是串行执行！
下面，我们将其改成异步线程来执行，看看效果如何？
@Component
@EnableAsync
public class AsyncScheduledTask {
private static final Logger log = LoggerFactory.getLogger(AsyncScheduledTask.class);
private static final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@Async
@Scheduled(fixedDelay = 2000)
public void runWithFixedDelay() {
try {
TimeUnit.SECONDS.sleep(3);
log.info("Fixed Delay Task, Current Thread : {} : The time is now {}", Thread.currentThread().getName(), dateFormat.format(new Date()));
} catch (InterruptedException e) {
log.error("错误信息",e);
}
}
}
控制台输出结果：
Fixed Delay Task, Current Thread : SimpleAsyncTaskExecutor-1 : The time is now 2020-12-15 18:55:26 Fixed Delay Task, Current Thread : SimpleAsyncTaskExecutor-2 : The time is now 2020-12-15 18:55:28 Fixed Delay Task, Current Thread : SimpleAsyncTaskExecutor-3 : The time is now 2020-12-15 18:55:30 ...
任务的执行频率不受方法内的时间影响，以并行方式执行！
2.5、自定义任务线程池
虽然默认的情况下，@Scheduled任务都在 Spring 创建的大小为 1 的默认线程池中执行，但是我们也可以自定义线程池，只需要实现SchedulingConfigurer类即可！
自定义线程池示例如下：
@Configuration
public class SchedulerConfig implements SchedulingConfigurer {
@Override
public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
//线程池大小为10
threadPoolTaskScheduler.setPoolSize(10);
//设置线程名称前缀
threadPoolTaskScheduler.setThreadNamePrefix("scheduled-thread-");
//设置线程池关闭的时候等待所有任务都完成再继续销毁其他的Bean
threadPoolTaskScheduler.setWaitForTasksToCompleteOnShutdown(true);
//设置线程池中任务的等待时间，如果超过这个时候还没有销毁就强制销毁，以确保应用最后能够被关闭，而不是阻塞住
threadPoolTaskScheduler.setAwaitTerminationSeconds(60);
//这里采用了CallerRunsPolicy策略，当线程池没有处理能力的时候，该策略会直接在 execute 方法的调用线程中运行被拒绝的任务；如果执行程序已关闭，则会丢弃该任务
threadPoolTaskScheduler.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
threadPoolTaskScheduler.initialize();
scheduledTaskRegistrar.setTaskScheduler(threadPoolTaskScheduler);
}
}
我们启动服务，看看cron任务示例调度效果：
Cron Expression，Current Thread : scheduled-thread-1，The time is now : 2020-12-15 20:46:00 Cron Expression，Current Thread : scheduled-thread-2，The time is now : 2020-12-15 20:46:06 Cron Expression，Current Thread : scheduled-thread-3，The time is now : 2020-12-15 20:46:12 Cron Expression，Current Thread : scheduled-thread-4，The time is now : 2020-12-15 20:46:18 ....
当前线程名称已经被改成自定义scheduled-thread的前缀！
三、总结
本文主要围绕Spring scheduled应用实践进行分享，如果是单体应用，使用SpringBoot内置的@scheduled注解可以解决大部分业务需求，上手非常容易！
项目源代码地址：spring-boot-example-schedule
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
Spring Boot整合ElasticSearch实现多版本兼容的方法详解
简单说，ElasticSearch（简称 ES）是搜索引擎，是结构化数据的分布式搜索引擎。下面这篇文章主要给大家介绍了关于Spring Boot整合ElasticSearch实现多版本兼容的相关资料，需要的朋友可以参考借鉴，下面来一起看看吧2018-05-05
Java Agent 是 Java 1.5 版本之后引⼊的特性，其主要作⽤是在class被加载之前对其拦截，这篇文章主要介绍了agent的简单使用，需要的可以参考下2023-05-05
本文介绍在java中IP地址转换十进制数及把10进制再转换成IP地址的方法及实例参考，晒出来和大家分享一下2012-12-12
Spring的出现是为了简化 Java 程序开发,而 SpringBoot 的出现是为了简化 Spring 程序开发，这篇文章主要介绍了SpringBoot项目创建使用+配置文件+日志文件,需要的朋友可以参考下2023-02-02
Java虚拟机（Java Virtual Machine,JVM）是Java程序的运行环境,它是一个抽象的计算机模型,通过解释和执行Java字节码来运行Java程序,本将大家深入了解JVM(Java虚拟机)内存结构,需要的朋友可以参考下2023-08-08
详解@Autowired(required=false)注入注意的问题
这篇文章主要介绍了@Autowired(required=false)注入注意的问题,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-04-04
这篇文章主要介绍了Spring@Value使用获取配置信息为null的操作，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-07-07
SpringBoot+JSON+AJAX+ECharts+Fiddler实现前后端分离开发可视化
这篇文章主要介绍了SpringBoot+JSON+AJAX+ECharts+Fiddler实现前后端分离开发可视化,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2022-06-06
这篇文章主要介绍了Python文件高级操作函数之文件信息获取与目录操作,在Python中，内置了文件（File）对象。在使用文件对象时，首先需要通过内置的open()方法创建一个文件对象，然后通过该对象提供的方法进行一些基本文件操作,需要的朋友可以参考下2023-05-05
Spring Kafka提供了全面的错误处理机制,通过灵活的重试策略和死信队列处理,下面就来介绍一下,具有一定的参考价值,感兴趣的可以了解一下2025-04-04
最新评论