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

本文主要是介绍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 {@Beanpublic 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，从而更好地管理和执行任务。    

这篇关于Spring Boot集成Spring Task Scheduler快速入门demo的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---