Spring定时任务skill从入门到精通：原理、实战与避坑指南

2次阅读

没有评论

共计 2020 个字符，预计需要花费 6 分钟才能阅读完成。

在 Java 开发中，定时任务是常见的需求，Spring 框架提供了 @Scheduled 注解来简化定时任务的开发。然而，很多开发者在初次使用时容易遇到以下问题：

单线程阻塞问题：默认情况下，Spring 的定时任务使用单线程执行，如果某个任务执行时间过长，会导致其他任务被阻塞。
异常处理不当：任务执行过程中如果抛出异常，默认情况下任务会终止，且没有明确的日志记录。
分布式环境重复执行：在微服务或分布式环境中，多个实例可能同时执行同一个定时任务，导致数据重复处理。

在选择定时任务方案时，常见的选项包括 Spring Task、Quartz 和 XXL-JOB。以下是它们的适用场景对比：

Spring Task：轻量级，适合简单的单机定时任务，集成简单，但功能相对有限。
Quartz：功能强大，支持复杂的调度需求（如任务依赖、集群调度），但配置较为复杂。
XXL-JOB：分布式任务调度平台，适合大规模分布式环境，提供任务管理和监控功能。

@Scheduled注解支持多种定时表达式，最常用的是 cron 表达式。以下是一个简单的示例：

@Scheduled(cron = "0 0/5 * * * ?")
public void executeTask() {// 任务逻辑}

为了避免单线程阻塞问题，可以通过配置 ThreadPoolTaskScheduler 实现多线程调度：

@Configuration
@EnableScheduling
public class SchedulerConfig {

    @Bean
    public TaskScheduler taskScheduler() {ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.setPoolSize(5);
        scheduler.setThreadNamePrefix("scheduled-task-");
        return scheduler;
    }
}

为了确保任务异常时能够记录日志并继续执行，可以在任务方法中添加异常处理逻辑：

@Scheduled(cron = "0 0/5 * * * ?")
public void executeTask() {
    try {// 任务逻辑} catch (Exception e) {log.error("定时任务执行异常", e);
    }
}

在分布式环境中，可以通过 Redis 锁防止任务重复执行：

@Scheduled(cron = "0 0/5 * * * ?")
public void executeDistributedTask() {
    String lockKey = "task:lock:executeDistributedTask";
    try {boolean locked = redisTemplate.opsForValue().setIfAbsent(lockKey, "locked", 30, TimeUnit.SECONDS);
        if (locked) {// 任务逻辑}
    } finally {redisTemplate.delete(lockKey);
    }
}

可以通过 AOP 或自定义注解监控任务的执行时间，便于后续优化：

@Aspect
@Component
public class TaskMonitorAspect {@Around("@annotation(org.springframework.scheduling.annotation.Scheduled)")
    public Object monitorTask(ProceedingJoinPoint joinPoint) throws Throwable {long startTime = System.currentTimeMillis();
        Object result = joinPoint.proceed();
        long endTime = System.currentTimeMillis();
        log.info("任务 {} 执行耗时: {} ms", joinPoint.getSignature().getName(), endTime - startTime);
        return result;
    }
}