Spring Boot 定時任務完整配置指南：從入門到並行異步進階

前言

Spring Boot 內建 @Scheduled 提供輕量級定時任務支援，無需引入 Quartz 即可滿足大多數場景。本文系統梳理配置方式、執行模式、並行與異步進階技巧。

定時任務實現方式對比

基礎配置三步驟

1. 啟用排程支援

@SpringBootApplication
@EnableScheduling  // 關鍵：掃描 @Scheduled 註解
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

2. 建立定時任務元件

@Component
public class ScheduledTasks {
    
    private static final Logger log = LoggerFactory.getLogger(ScheduledTasks.class);
    
    // 每 2 分鐘執行一次
    @Scheduled(cron = "0 0/2 * * * ?")
    public void executeTask() {
        Thread current = Thread.currentThread();
        log.info("定時任務執行 - Thread ID: {}, Name: {}", current.getId(), current.getName());
        // 業務邏輯...
    }
    
    // 固定頻率：上次開始後 5 秒執行
    @Scheduled(fixedRate = 5000)
    public void fixedRateTask() { /* ... */ }
    
    // 固定延遲：上次結束後 3 秒執行
    @Scheduled(fixedDelay = 3000)
    public void fixedDelayTask() { /* ... */ }
    
    // 初始延遲 10 秒，之後固定頻率
    @Scheduled(initialDelay = 10000, fixedRate = 5000)
    public void delayedTask() { /* ... */ }
}

3. Cron 表達式詳解

┌───────────── 秒 (0-59)
│ ┌───────────── 分 (0-59)
│ │ ┌───────────── 時 (0-23)
│ │ │ ┌───────────── 日 (1-31)
│ │ │ │ ┌───────────── 月 (1-12)
│ │ │ │ │ ┌───────────── 星期 (0-7) (0或7=星期日)
│ │ │ │ │ │
*  *  *  *  *  *

常用範例：

• 0 0 2 * * ?：每天凌晨 2 點
• 0 0/5 * * * ?：每 5 分鐘
• 0 0 0 * * MON：每週一午夜
• 0 0 0 1 * ?：每月 1 號午夜

執行模式：串行 vs 並行

預設行為：單執行緒串行

Spring Boot 預設使用單一 TaskScheduler，所有任務共用一個執行緒，按提交順序串行執行。長時間任務會阻塞後續任務。

並行配置：實作 SchedulingConfigurer

@Configuration
@EnableScheduling
public class ScheduleConfig implements SchedulingConfigurer {
    
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.setScheduler(taskExecutor());
    }
    
    @Bean(destroyMethod = "shutdown")
    public Executor taskExecutor() {
        return Executors.newScheduledThreadPool(10); // 10 條執行緒池
    }
}

進階異步並行：@EnableAsync + ThreadPoolTaskScheduler

@Configuration
@EnableScheduling
@EnableAsync  // 啟用異步支援
public class AsyncScheduleConfig implements SchedulingConfigurer, AsyncConfigurer {
    
    @Bean
    public ThreadPoolTaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.setPoolSize(20);
        scheduler.setThreadNamePrefix("scheduled-task-");
        scheduler.setAwaitTerminationSeconds(60);
        scheduler.setWaitForTasksToCompleteOnShutdown(true);
        return scheduler;
    }
    
    @Override
    public Executor getAsyncExecutor() {
        return taskScheduler(); // 異步任務同用此執行緒池
    }
    
    @Override
    public void configureTasks(ScheduledTaskRegistrar registrar) {
        registrar.setTaskScheduler(taskScheduler());
    }
}

啟動類整合範例

@SpringBootApplication
public class Application {
    public static void main(String[] args) throws Exception {
        // 標準啟動
        SpringApplication.run(Application.class, args);
        
        // 若使用 AnnotationConfigApplicationContext 手動裝配
        AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext();
        context.register(AsyncScheduleConfig.class);
        context.refresh();
    }
}

實戰最佳實踐

1. 任務冪等性設計

@Scheduled(cron = "0 0 2 * * ?")
public void dailyReport() {
    String lockKey = "dailyReport:" + LocalDate.now();
    if (redisTemplate.opsForValue().setIfAbsent(lockKey, "1", Duration.ofHours(24))) {
        try {
            // 生成報表邏輯
        } finally {
            redisTemplate.delete(lockKey);
        }
    }
}

2. 異常處理與監控

@Component
public class MonitoredTasks {
    
    @Scheduled(cron = "0 0/10 * * * ?")
    public void criticalTask() {
        try {
            // 核心業務
            metrics.increment("task.success");
        } catch (Exception e) {
            metrics.increment("task.failure");
            log.error("關鍵任務失敗", e);
            alertService.sendAlert("定時任務異常: " + e.getMessage());
        }
    }
}

3. 動態調整排程（配合資料庫/配置中心）

@Component
public class DynamicScheduledTask implements SchedulingConfigurer {
    
    @Value("${task.cron:0 0 2 * * ?}")
    private String cronExpression;
    
    @Override
    public void configureTasks(ScheduledTaskRegistrar registrar) {
        registrar.addTriggerTask(
            () -> executeBusinessLogic(),
            triggerContext -> {
                CronTrigger trigger = new CronTrigger(cronExpression);
                return trigger.nextExecutionTime(triggerContext);
            }
        );
    }
    
    // 配合 @RefreshScope 實現熱更新
    public void updateCron(String newCron) {
        this.cronExpression = newCron;
    }
}

常見坑點避雷

總結

Spring Boot @Scheduled 以輕量級姿態解決 80% 定時任務需求。掌握「啟用 → 定義 → 並行優化 → 監控治理」完整鏈路，即可構建穩健可維運的排程系統。複雜場景（持久化、叢集、動態排程）可平滑遷移至 Quartz 或 XXL-JOB。