SpringBoot最新定时任务的7种实现方案

@EnableScheduling
@SpringBootApplication
public class ScheduledTaskApplication {

    public static void main(String[] args) {
        SpringApplication.run(ScheduledTaskApplication.class, args);
    }

    @Component
    public static class SimpleTask {

        @Scheduled(cron = "0 0/1 * * * ?") // 每分钟执行一次
        public void execute() {
            System.out.println("简单定时任务执行：" + LocalDateTime.now());
        }
    }
}

@Component
public class ExecutorServiceTask {

    private final ScheduledExecutorService executorService = Executors.newScheduledThreadPool(2);

    @PostConstruct
    public void init() {
        executorService.scheduleAtFixedRate(() -> {
            System.out.println("ExecutorService 任务执行：" + LocalDateTime.now());
        }, 0, 1, TimeUnit.MINUTES);
    }
}

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

@Configuration
public class QuartzConfig {

    @Bean
    public JobDetail jobDetail() {
        return JobBuilder.newJob(SampleJob.class)
                .withIdentity("sampleJob")
                .storeDurably()
                .build();
    }

    @Bean
    public Trigger trigger(JobDetail jobDetail) {
        return TriggerBuilder.newTrigger()
                .forJob(jobDetail)
                .withSchedule(CronScheduleBuilder.cronSchedule("0 0/1 * * * ?"))
                .build();
    }

    public static class SampleJob implements Job {
        @Override
        public void execute(JobExecutionContext context) {
            System.out.println("Quartz 任务执行：" + LocalDateTime.now());
        }
    }
}

@Component
public class TaskSchedulerTask {

    @Autowired
    private TaskScheduler taskScheduler;

    @PostConstruct
    public void init() {
        taskScheduler.scheduleAtFixedRate(() -> {
            System.out.println("TaskScheduler 任务执行：" + LocalDateTime.now());
        }, 60000);
    }
}

@Component
public class RedisTask {

    @Autowired
    private StringRedisTemplate redisTemplate;

    @Scheduled(cron = "0 0/1 * * * ?")
    public void execute() {
        String lockKey = "redis_task_lock";
        Boolean lock = redisTemplate.opsForValue().setIfAbsent(lockKey, "lock", 60, TimeUnit.SECONDS);

        if (Boolean.TRUE.equals(lock)) {
            try {
                System.out.println("Redis 分布式任务执行：" + LocalDateTime.now());
            } finally {
                redisTemplate.delete(lockKey);
            }
        }
    }
}

<dependency>
    <groupId>com.xuxueli</groupId>
    <artifactId>xxl-job-core</artifactId>
    <version>2.3.0</version>
</dependency>

@XxlJob("sampleJob")
public void sampleJobHandler() {
    System.out.println("XXL-JOB 任务执行：" + LocalDateTime.now());
}

<dependency>
    <groupId>org.apache.shardingsphere.elasticjob-lite</groupId>
    <artifactId>elasticjob-lite-spring-boot-starter</artifactId>
    <version>3.0.1</version>
</dependency>

@ElasticJobConfiguration(
    cron = "0 0/1 * * * ?",
    jobName = "elasticJobSample",
    shardingTotalCount = 1
)
public class ElasticJobTask implements SimpleJob {

    @Override
    public void execute(ShardingContext shardingContext) {
        System.out.println("Elastic-Job 任务执行：" + LocalDateTime.now());
    }
}