如何解決Springboot定時(shí)任務(wù)遇到的問題

這篇文章給大家分享的是有關(guān)如何解決Springboot定時(shí)任務(wù)遇到的問題的內(nèi)容。小編覺得挺實(shí)用的，因此分享給大家做個(gè)參考。一起跟隨小編過來看看吧。

前言：在使用Springboot整合定時(shí)任務(wù)，發(fā)現(xiàn)當(dāng)某個(gè)定時(shí)任務(wù)執(zhí)行出現(xiàn)執(zhí)行時(shí)間過長的情況時(shí)會(huì)阻塞其他定時(shí)任務(wù)的執(zhí)行。

問題定位

后續(xù)通過翻查Springboot的文檔以及打印日志（輸出當(dāng)前線程信息）得知問題是由于Springboot默認(rèn)使用只要1個(gè)線程處理定時(shí)任務(wù)。

問題復(fù)盤

需要注意示例的Springboot版本為2.1.3.RELEASE。

關(guān)鍵pom文件配置

    <!--繼承父項(xiàng)目-->
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.3.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    
    ...省略非關(guān)鍵配置
    
    <!-- 引入依賴-->
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

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

定時(shí)任務(wù)

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

/**
 * 定時(shí)任務(wù)
 * @author RJH
 * create at 2019-03-29
 */
@Component
public class SimpleTask {

    private static Logger logger= LoggerFactory.getLogger(SimpleTask.class);

    /**
     * 執(zhí)行會(huì)超時(shí)的任務(wù)，定時(shí)任務(wù)間隔為5000ms(等價(jià)于5s)
     */
    @Scheduled(fixedRate = 5000)
    public void overtimeTask(){
        try {
            logger.info("current run by overtimeTask");
            //休眠時(shí)間為執(zhí)行間隔的2倍
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    /**
     * 正常的定時(shí)任務(wù)
     */
    @Scheduled(fixedRate = 5000)
    public void simpleTask(){
        logger.info("current run by simpleTask");
    }
}

啟動(dòng)類

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;

@SpringBootApplication
@EnableScheduling
public class TaskDemoApplication {

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

}

運(yùn)行結(jié)果

...省略非關(guān)鍵信息
2019-03-29 21:22:38.410  INFO 59731 --- [   scheduling-1] com.rjh.task.SimpleTask                  : current run by simpleTask
2019-03-29 21:22:38.413  INFO 59731 --- [   scheduling-1] com.rjh.task.SimpleTask                  : current run by overtimeTask
2019-03-29 21:22:48.413  INFO 59731 --- [   scheduling-1] com.rjh.task.SimpleTask                  : current run by simpleTask
2019-03-29 21:22:48.414  INFO 59731 --- [   scheduling-1] com.rjh.task.SimpleTask                  : current run by overtimeTask
2019-03-29 21:22:58.418  INFO 59731 --- [   scheduling-1] com.rjh.task.SimpleTask                  : current run by simpleTask
2019-03-29 21:22:58.418  INFO 59731 --- [   scheduling-1] com.rjh.task.SimpleTask                  : current run by overtimeTask
2019-03-29 21:23:08.424  INFO 59731 --- [   scheduling-1] com.rjh.task.SimpleTask                  : current run by simpleTask
2019-03-29 21:23:08.424  INFO 59731 --- [   scheduling-1] com.rjh.task.SimpleTask                  : current run by overtimeTask
2019-03-29 21:23:18.425  INFO 59731 --- [   scheduling-1] com.rjh.task.SimpleTask                  : current run by simpleTask
2019-03-29 21:23:18.426  INFO 59731 --- [   scheduling-1] com.rjh.task.SimpleTask                  : current run by overtimeTask
...

結(jié)果分析

由運(yùn)行結(jié)果可以看出：

1. 每次定時(shí)任務(wù)的運(yùn)行都是由scheduling-1這個(gè)線程處理
2. 正常運(yùn)行的simpleTask被overtimeTask阻塞導(dǎo)致了運(yùn)行間隔變成了10秒

后面通過查閱Springboot的文檔也得知了定時(shí)任務(wù)默認(rèn)最大運(yùn)行線程數(shù)為1。

解決方案

由于使用的Springboot版本為2.1.3.RELEASE，所以有兩種方法解決這個(gè)問題

使用Springboot配置

在配置文件中可以配置定時(shí)任務(wù)可用的線程數(shù)：

## 配置可用線程數(shù)為10
spring.task.scheduling.pool.size=10

自定義定時(shí)任務(wù)的線程池

使用自定義的線程池代替默認(rèn)的線程池

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

/**
 * 定時(shí)任務(wù)配置類
 * @author RJH
 * create at 2019-03-29
 */
@Configuration
public class ScheduleConfig {

    /**
     * 此處方法名為Bean的名字，方法名無需固定
     * 因?yàn)槭前碩askScheduler接口自動(dòng)注入
     * @return
     */
    @Bean
    public TaskScheduler taskScheduler(){
        // Spring提供的定時(shí)任務(wù)線程池類
        ThreadPoolTaskScheduler taskScheduler=new ThreadPoolTaskScheduler();
        //設(shè)定最大可用的線程數(shù)目
        taskScheduler.setPoolSize(10);
        return taskScheduler;
    }
}

感謝各位的閱讀！關(guān)于如何解決Springboot定時(shí)任務(wù)遇到的問題就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，讓大家可以學(xué)到更多知識(shí)。如果覺得文章不錯(cuò)，可以把它分享出去讓更多的人看到吧！