Spring Boot 如何實現定時任務

在現代的微服務架構中，定時任務是一個常見的需求。無論是數據定時同步、定時清理緩存，還是定時發送通知，Spring Boot 提供了非常強大且靈活的定時任務支持。本文將詳細介紹如何在 Spring Boot 中實現定時任務，包括使用 @Scheduled 注解和集成 Quartz 調度框架的兩種方式。

一、使用 @Scheduled 注解實現定時任務

Spring Boot 提供了內置的 @Scheduled 注解，可以非常方便地實現簡單的定時任務。這種方式適合輕量級的定時任務，且不需要復雜的調度邏輯。

1.1 添加依賴

在 Spring Boot 項目中，@Scheduled 注解是內置支持的，因此不需要額外添加依賴。

1.2 啟用定時任務支持

在主類或配置類上添加 @EnableScheduling 注解，啟用定時任務支持。

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;@SpringBootApplication
@EnableScheduling
public class MySpringBootApplication {public static void main(String[] args) {SpringApplication.run(MySpringBootApplication.class, args);}
}

1.3 定義定時任務

在任意的 @Component 或 @Service 類中，使用 @Scheduled 注解定義定時任務。

import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;@Component
public class MyScheduledTasks {// 每兩小時運行一次@Scheduled(cron = "0 0 0/2 * * ?")public void runTask() {System.out.println("任務執行了！當前時間：" + new java.util.Date());}
}

1.4 常見的 Cron 表達式

• 0 0/30 * * * ?：每30分鐘執行一次。
• 0 0 9-17 * * ?：每天的9點到17點之間，每小時執行一次。
• 0 0 8,14 * * ?：每天的8點和14點各執行一次。
• 0 0-5 14 * * ?：在每天14點的第0分鐘至第5分鐘的每分鐘執行一次。
• 0 0-5 14,18 * * ?：在每天14點和18點的第0分鐘至第5分鐘的每分鐘執行一次。

1.5 注意事項

• 線程池配置：默認情況下，Spring 的 @Scheduled 使用單線程執行任務。如果任務較多或任務執行時間較長，可能會導致任務延遲。可以通過配置 ThreadPoolTaskExecutor 來指定線程池大小：

  import org.springframework.context.annotation.Bean;
  import org.springframework.context.annotation.Configuration;
  import org.springframework.scheduling.annotation.SchedulingConfigurer;
  import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
  import org.springframework.scheduling.config.ScheduledTaskRegistrar;@Configuration
  public class SchedulingConfig implements SchedulingConfigurer {@Overridepublic void configureTasks(ScheduledTaskRegistrar taskRegistrar) {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setCorePoolSize(10); // 設置線程池大小executor.setThreadNamePrefix("scheduled-task-");executor.initialize();taskRegistrar.setTaskExecutor(executor);}
  }
  

• 任務執行時間：@Scheduled 的任務執行時間是基于服務器的系統時間，因此需要確保服務器時間準確。

二、使用 Quartz 調度框架實現定時任務

對于更復雜的調度需求，如任務持久化、任務恢復、任務分組等，Quartz 是一個強大的調度框架。Spring Boot 提供了對 Quartz 的集成支持。

2.1 添加依賴

在 pom.xml 文件中添加 Quartz 和 Spring Boot 的集成依賴：

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-quartz</artifactId>
</dependency>

2.2 配置 Quartz

在 application.properties 文件中配置 Quartz 的相關參數：

# 配置Quartz的調度器名稱
spring.quartz.scheduler.name=myScheduler
# 配置線程池大小
spring.quartz.scheduler.thread-count=10
# 配置任務存儲類型為內存
spring.quartz.job-store.type=memory
# 配置任務存儲的數據庫連接（如果使用數據庫存儲任務）
# spring.quartz.job-store.driver-class-name=com.mysql.cj.jdbc.Driver
# spring.quartz.job-store.url=jdbc:mysql://localhost:3306/quartz_db
# spring.quartz.job-store.user=root
# spring.quartz.job-store.password=root

2.3 定義任務類

創建一個實現 Job 接口的任務類：

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;public class MyJob implements Job {@Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {System.out.println("任務執行了！當前時間：" + new java.util.Date());}
}

2.4 配置任務和觸發器

在配置類中定義任務和觸發器：

import org.quartz.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class QuartzConfig {@Beanpublic JobDetail myJobDetail() {return JobBuilder.newJob(MyJob.class).withIdentity("myJob", "group1").build();}@Beanpublic Trigger myJobTrigger() {return TriggerBuilder.newTrigger().withIdentity("myTrigger", "group1").startNow().withSchedule(CronScheduleBuilder.cronSchedule("0 0 0/2 * * ?")).forJob(myJobDetail()).build();}
}

2.5 注意事項

• 任務持久化：Quartz 支持將任務存儲在數據庫中，即使應用重啟，任務也可以繼續執行。需要配置數據庫連接信息。
• 任務分組：可以通過 withIdentity 方法為任務和觸發器指定分組，方便管理。
• 任務恢復：Quartz 支持任務恢復，即使任務在執行過程中應用崩潰，任務也可以在應用重啟后繼續執行。

三、總結

Spring Boot 提供了兩種實現定時任務的方式：@Scheduled 注解和 Quartz 調度框架。@Scheduled 適合簡單的定時任務，而 Quartz 提供了更強大的功能，適合復雜的調度需求。根據實際需求選擇合適的方式即可。

• 如果任務簡單且不需要復雜的調度邏輯，推薦使用 @Scheduled。
• 如果需要任務持久化、任務恢復或復雜的調度策略，推薦使用 Quartz。