spring boot 使用 @Scheduled 注解和 TaskScheduler 接口实现定时任务
作者：orton777
这篇文章主要介绍了spring boot 使用 @Scheduled 注解和 TaskScheduler 接口实现定时任务,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
在 Spring Boot 中，可以使用 @Scheduled 注解和 TaskScheduler 接口来实现定时任务。以下是关于如何在 Spring Boot 中创建定时任务的详细说明：
- 添加依赖
在 pom.xml 文件中添加 spring-boot-starter 依赖：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>- 启用定时任务
在 Spring Boot 主类上添加 @EnableScheduling 注解，以启用定时任务支持：
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;
@SpringBootApplication
@EnableScheduling
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}- 创建定时任务
使用 @Scheduled 注解创建定时任务。以下是一个简单的定时任务示例：
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
@Component
public class ScheduledTask {
@Scheduled(fixedRate = 5000)
public void fixedRateTask() {
System.out.println("Fixed rate task executed at " + LocalDateTime.now());
}
@Scheduled(fixedDelay = 5000)
public void fixedDelayTask() {
System.out.println("Fixed delay task executed at " + LocalDateTime.now());
}
@Scheduled(cron = "0 * * * * ?")
public void cronTask() {
System.out.println("Cron task executed at " + LocalDateTime.now());
}
}在这个示例中，我们创建了三个定时任务：
fixedRateTask：使用fixedRate属性，每隔 5000 毫秒（5 秒）执行一次。fixedDelayTask：使用fixedDelay属性，在上一次任务完成后等待 5000 毫秒（5 秒）再执行。cronTask：使用cron属性，根据 Cron 表达式执行任务。在这个例子中，任务将在每分钟的整数秒执行。
- 使用
TaskScheduler接口
除了使用 @Scheduled 注解，你还可以使用 TaskScheduler 接口来创建定时任务。以下是一个使用 TaskScheduler 的示例：
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import java.time.LocalDateTime;
@Configuration
public class SchedulerConfig {
@Bean
public TaskScheduler taskScheduler() {
ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
taskScheduler.setPoolSize(5);
return taskScheduler;
}
@Bean
public Runnable exampleTask() {
return () -> System.out.println("Task executed at " + LocalDateTime.now());
}
@Bean
public ScheduledTaskRegistrar scheduledTaskRegistrar(TaskScheduler taskScheduler, Runnable exampleTask) {
ScheduledTaskRegistrar taskRegistrar = new ScheduledTaskRegistrar();
taskRegistrar.setTaskScheduler(taskScheduler);
taskRegistrar.addFixedRateTask(exampleTask, 5000);
return taskRegistrar;
}
}在这个示例中，我们创建了一个 TaskScheduler Bean，配置了一个线程池大小为 5 的 ThreadPoolTaskScheduler。然后，我们创建了一个简单的 Runnable 任务，并使用 ScheduledTaskRegistrar 将任务注册到 TaskScheduler。这个任务将以固定的速率（每隔 5000 毫秒）执行。
这就是在 Spring Boot 中创建定时任务的详细说明。你可以根据自己的需求调整任务的执行频率和逻辑。
到此这篇关于spring boot 使用 @Scheduled 注解和 TaskScheduler 接口实现定时任务的文章就介绍到这了,更多相关spring boot 定时任务内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！