SpringTask快速入门最佳实践记录

<!-- Spring Boot 基础依赖 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter</artifactId>
    <version>2.7.0</version> <!-- 根据实际版本选择 -->
</dependency>

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;
@SpringBootApplication
@EnableScheduling // 关键注解：开启定时任务支持
public class TaskDemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(TaskDemoApplication.class, args);
    }
}

import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
@Component
public class FirstTask {
    // 每 2 秒执行一次
    @Scheduled(fixedRate = 2000)
    public void simpleTask() {
        System.out.println("定时任务执行时间：" + LocalDateTime.now() + "，线程名称：" + Thread.currentThread().getName());
    }
}

// 上一次任务结束后，延迟 1 秒执行下一次
@Scheduled(fixedDelay = 1000) // 单位：毫秒
public void fixedDelayTask() {
    System.out.println("固定延迟任务执行：" + LocalDateTime.now());
    try {
        // 模拟任务执行耗时
        Thread.sleep(500);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}

// 每 3 秒执行一次（无论上一次是否完成）
@Scheduled(fixedRate = 3000)
public void fixedRateTask() {
    System.out.println("固定频率任务执行：" + LocalDateTime.now());
    try {
        Thread.sleep(1000); // 模拟耗时
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}

// 项目启动后延迟 5 秒执行第一次，之后每 4 秒执行一次
@Scheduled(initialDelay = 5000, fixedRate = 4000)
public void initialDelayTask() {
    System.out.println("初始延迟任务执行：" + LocalDateTime.now());
}

// 每分钟的第 0 秒执行（即每分钟执行一次）
@Scheduled(cron = "0 * * * * *")
public void cronTask() {
    System.out.println("Cron 任务执行：" + LocalDateTime.now());
}

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
@Configuration
public class TaskConfig {
    @Bean
    public ThreadPoolTaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.setPoolSize(5); // 线程池大小
        scheduler.setThreadNamePrefix("task-scheduler-"); // 线程名称前缀
        scheduler.setAwaitTerminationSeconds(60); // 关闭时等待时间
        scheduler.setWaitForTasksToCompleteOnShutdown(true); // 关闭时等待任务完成
        return scheduler;
    }
}

@Scheduled(fixedRate = 2000)
public void taskWithException() {
    try {
        // 业务逻辑
    } catch (Exception e) {
        // 异常处理：日志记录、告警等
        log.error("任务执行异常", e);
    }
}