SpringBoot系列之使用Spring Task实现定时任务

定时任务是企业开发中很常用的，比如定时推送一些接口数据，在java中实现定时任务的方法有Spring Task、Quartz等等框架，也有JDK自带的ScheduledExecutorService、Timer

Quartz框架比较复杂，之前我写过一个入门教程，读者可以参考学习： Quartz系列之任务调度框架原理简介

Spring Task是Spring3.0以后自带的task，可以将它看成一个轻量级的Quartz，而且使用起来比Quartz简单许多

二、Spring Task

2.1 SpringTask简介

Spring Task 不是独立的项目，是spring-context 模块下提供的定时任务工具，是Spring3.0以后自带的task，可以将它看成一个轻量级的Quartz

2.2 实验环境准备

• JDK 1.8
• SpringBoot2.2.1
• Maven 3.2+
• 开发工具
  • IntelliJ IDEA
  • smartGit

创建一个SpringBoot Initialize项目，详情可以参考我之前博客： SpringBoot系列之快速创建项目教程

SpringBoot项目引入spring-boot-starter-web既可，因为wen场景启动器会自动引入spring-context依赖：

pom.xml参考

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.1.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.example.springboot</groupId>
    <artifactId>springboot-scheduler-task</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>springboot-scheduler-task</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
    </properties>

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

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

复制代码

2.3 Enable Scheduling

开启Spring Scheduling必须使用@EnableScheduling注解，可以新建一个配置类，然后加上注解

package com.example.springboot.scheduler.configuration;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;

/**
 * <pre>
 *      TaskSchedulerConfiguration
 * </pre>
 *
 * <pre>
 * @author mazq
 * 修改记录
 *    修改后版本:     修改人：  修改日期: 2020/07/20 13:57  修改内容:
 * </pre>
 */
@Configuration
@EnableScheduling
public class TaskSchedulerConfiguration {

}

复制代码

也可以像官网例子一样，加在application类：

2.4 单线程定时任务

Spring Task使用定时任务，只要加上@Scheduled注解，然后也要加到Spring容器中，使用可以加上@Service等注解就可以，Scheduled策略：cron 、fixedDelay、fixedRate 三选一

ok，下面介绍@Scheduled的4个关键属性

• fixedDelay Spring官网 找到API文档：

  

意思是：在上一次调用的结束与下一次调用的开始之间以固定的毫秒数为单位执行带注释的方法。

ps：这种策略比较好理解，意思就是不管任务执行时间，只关注时间间隔就可以，画图表示：

• fixedRate

意思是： 两次调用之间以固定的时间段（以毫秒为单位）执行带注释的方法。

这种策略先预计任务执行时间，fixedRate参数指定，画图描述，如图，fixedRate=10000(10s)：

代码例子：每个任务计划执行5s

@Scheduled( fixedRate = 5000)
    public void testFixedRate() {
        log.info("fixedRate test,thread name:[{}],execute time:[{}]",Thread.currentThread().getName(),
                LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
    }
复制代码

• cron cron参数是用cron表达式的意思，cron表达式含义：

Cron表达式是一个字符串，字符串以5或6个空格隔开，分为6或7个域，每一个域代表一个含义。

用表格表示Cron表达式：

每隔1分钟执行一次：

@Scheduled(cron = "0 0/1 * * * ? ")
    public void testCron(){
        log.info("cron test,thread name:[{}],execute time:[{}]",Thread.currentThread().getName(),
                LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
    
复制代码

• initialDelay initialDelay 初始化延迟时间，也就是标识第一次延迟执行的时间，只能配合 fixedDelay 或 fixedRate 使用

@Scheduled(initialDelay = 5000, fixedRate = 5000)
    public void testFixedRate() {
        log.info("fixedRate test,thread name:[{}],execute time:[{}]",Thread.currentThread().getName(),
                LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
    }
复制代码

2.5 线程池的使用配置

配置文件加上代码，配置线程池

@Bean
    public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
        ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
        threadPoolTaskScheduler.setPoolSize(5);
        threadPoolTaskScheduler.setThreadNamePrefix("ThreadPoolTaskScheduler");
        threadPoolTaskScheduler.setWaitForTasksToCompleteOnShutdown(true);
        threadPoolTaskScheduler.setAwaitTerminationSeconds(60);
        return threadPoolTaskScheduler;
    }
复制代码

也可以在application配置文件，加上：

ps：当然，不做配置也是可以的，因为SpringBoot有做自动配置，自己不改配置的，就全部按照SpringBoot的自动配置(默认)

代码例子下载： code download