原创

Spring Boot集成Spring Task Scheduler快速入门demo

1.Spring Task Scheduler介绍

Spring Scheduler里有两个概念：任务（Task）和运行任务的框架（TaskExecutor/TaskScheduler）。TaskExecutor顾名思义，是任务的执行器，允许我们异步执行多个任务。TaskScheduler是任务调度器，来运行未来的定时任务。触发器Trigger可以决定定时任务是否该运行了，最常用的触发器是CronTrigger，具体用法会在下面章节中详细介绍。Spring内置了多种类型的TaskExecutor和TaskScheduler，方便用户根据不同业务场景选择。

开启定时任务

Spring Boot 默认在无任何第三方依赖的情况下使用 spring-context 模块下提供的定时任务工具 Spring Task。我们只需要使用 @EnableScheduling 注解就可以开启相关的定时任务功能。如：

2.各种定时器实现

cron定时器

注解方式

/**
 *  ┌───────────── second (0-59)
 *  │ ┌───────────── minute (0 - 59)
 *  │ │ ┌───────────── hour (0 - 23)
 *  │ │ │ ┌───────────── day of the month (1 - 31)
 *  │ │ │ │ ┌───────────── month (1 - 12) (or JAN-DEC)
 *  │ │ │ │ │ ┌───────────── day of the week (0 - 7)
 *  │ │ │ │ │ │          (0 or 7 is Sunday, or MON-SUN)
 *  │ │ │ │ │ │
 *  * * * * * *
 *
 */
@Scheduled(cron="*/5 * * * * MON-FRI")
public void doSomething() {
    log.info("cron ....");
}

代码方式

public void scheduleCronTrigger() {
    CronTrigger cronTrigger = new CronTrigger("10 * * * * ?");
    taskScheduler.schedule(new RunnableTask("Cron Trigger"), cronTrigger);
}

scheduleWithFixedDelay

注解实现

@Scheduled(initialDelay = 5000, fixedRate = 5000)
public void performTask1() {
    log.info("Task performed at {}", LocalDateTime.now());
}

代码实现

public void scheduleWithFixedDelay() {
    taskScheduler.scheduleWithFixedDelay(new RunnableTask("Fixed 1 second Delay"), 1000);
}

scheduleAtFixedRate

注解方式

@Scheduled(fixedRate = 5000)
public void performTask() {
    log.info("Task performed at {}", LocalDateTime.now());
}

代码实现

public void scheduleAtFixedRate() {
    taskScheduler.scheduleAtFixedRate(new RunnableTask("Fixed Rate of 2 seconds") , 2000);
}

配置定时器线程池

package com.et.scheduler.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;

@Configuration
public class ThreadPoolTaskSchedulerConfig {

    @Bean
    public ThreadPoolTaskScheduler threadPoolTaskScheduler(){
        ThreadPoolTaskScheduler threadPoolTaskScheduler
          = new ThreadPoolTaskScheduler();
        threadPoolTaskScheduler.setPoolSize(5);
        threadPoolTaskScheduler.setThreadNamePrefix(
          "ThreadPoolTaskScheduler");
        return threadPoolTaskScheduler;
    }
}

https://github.com/Harries/springboot-demo

3.局限性

同时运行

同一个task，如果前一个还没跑完后面一个就不会触发，这没有问题。但是不同的task也不能同时运行就不太合理了。不过其实是scheduler的默认线程数为1的缘故。

分布式不支持

scheduler会在多个实例上同时运行。此时可以选择分布式定时任务框架如：xxl-job，quartz等等

4.总结

TaskScheduler是Spring框架中非常有用的一个接口，它可以帮助我们实现定时任务、周期性任务和异步任务等。通过本文的介绍和举例说明，相信读者对TaskScheduler的使用方法有了更深入的了解。在实际项目中，我们可以根据具体需求选择合适的TaskScheduler实现类，并通过注解的方式来配置和使用TaskScheduler，从而更好地管理和执行任务。

正文到此结束