当前位置：首页 > article >正文

Spring Task定时任务完全指南

article 2025/2/19 16:01:23

一、定时任务的应用场景

数据统计报表生成（每日/每周/每月）
缓存数据定期刷新
订单状态超时处理
日志文件归档清理
系统健康状态检查

二、Spring Task核心注解

1. 启用定时任务

@SpringBootApplication
@EnableScheduling // 启用定时任务支持
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

2. 创建定时任务

@Component
public class ScheduledTasks {
    
    // 每5秒执行一次
    @Scheduled(fixedRate = 5000)
    public void reportCurrentTime() {
        // ...业务逻辑...
    }

    // 每天凌晨执行
    @Scheduled(cron = "0 0 0 * * ?")
    public void dailyCleanup() {
        // ...数据清理操作...
    }
}

三、@Scheduled参数详解

参数	说明
cron	UNIX cron表达式（支持到秒级）
zone	指定时区（默认服务器时区）
fixedDelay	固定间隔（上次任务结束到下次任务开始）
fixedRate	固定频率（以任务启动时间计算）
initialDelay	首次执行延迟时间

四、线程池配置

# application.properties
spring.task.scheduling.pool.size=5
spring.task.scheduling.thread-name-prefix=scheduled-task-
spring.task.scheduling.shutdown.await-termination=true
spring.task.scheduling.shutdown.await-termination-period=60s

五、动态定时任务实现

@Configuration
@EnableScheduling
public class DynamicScheduleConfig implements SchedulingConfigurer {

    @Autowired
    private TaskConfigRepository configRepository;

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.addTriggerTask(
            () -> System.out.println("动态任务执行: " + new Date()),
            triggerContext -> {
                String cron = configRepository.findLatestCron();
                return new CronTrigger(cron).nextExecutionTime(triggerContext);
            }
        );
    }
}

六、最佳实践建议

异常处理：在任务方法内添加try-catch块

@Scheduled(fixedRate = 30000)
public void safeTask() {
    try {
        // 业务代码
    } catch (Exception e) {
        logger.error("定时任务执行异常", e);
    }
}

避免长时间阻塞：使用异步执行

@Async
@Scheduled(cron = "0 0 2 * * ?")
public void asyncTask() {
    // 长时间执行的任务
}

分布式环境：配合分布式锁使用

@Scheduled(cron = "0 */5 * * * ?")
public void distributedTask() {
    if(redisLock.tryLock("cleanup-task", 60)) {
        try {
            // 执行任务
        } finally {
            redisLock.unlock("cleanup-task");
        }
    }
}

七、调试技巧

使用ConditionalOnProperty控制任务开关

@Scheduled(fixedRate = 5000)
@ConditionalOnProperty(name = "task.enabled", havingValue = "true")
public void conditionalTask() {
    // 可配置启停的任务
}

通过Actuator端点监控任务

management.endpoint.scheduledtasks.enabled=true
management.endpoints.web.exposure.include=scheduledtasks

八、性能优化

任务执行时间监控

@Around("@annotation(scheduled)")
public Object monitorTask(ProceedingJoinPoint pjp, Scheduled scheduled) {
    long start = System.currentTimeMillis();
    try {
        return pjp.proceed();
    } finally {
        long duration = System.currentTimeMillis() - start;
        monitor.recordExecutionTime(pjp.getSignature().getName(), duration);
    }
}