Springboot 예약 작업에서 발생한 문제 해결

이 기사의 내용은 Springboot 예약 작업에서 발생하는 문제를 해결하는 내용입니다. 필요한 친구가 참고할 수 있기를 바랍니다.

서문: Springboot를 사용하여 예약된 작업을 통합할 때 예약된 작업을 실행하는 데 너무 오랜 시간이 걸리면 예약된 다른 작업의 실행이 차단된다는 사실을 발견했습니다.

문제 위치

Springboot의 문서를 확인하고 로그를 인쇄(현재 스레드 정보 출력)한 결과, Springboot에서는 기본적으로 예약된 작업을 처리하기 위해 하나의 스레드만 사용하기 때문에 문제가 발생한다는 것을 알게 되었습니다.

문제 검토

예제의 Springboot 버전은 2.1.3.RELEASE라는 점에 유의해야 합니다.

주요 pom 파일 구성

    <!--继承父项目-->
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.3.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    
    ...省略非关键配置
    
    <!-- 引入依赖-->
    <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>

예약된 작업

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

/**
 * 定时任务
 * @author RJH
 * create at 2019-03-29
 */
@Component
public class SimpleTask {

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

    /**
     * 执行会超时的任务，定时任务间隔为5000ms(等价于5s)
     */
    @Scheduled(fixedRate = 5000)
    public void overtimeTask(){
        try {
            logger.info("current run by overtimeTask");
            //休眠时间为执行间隔的2倍
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    /**
     * 正常的定时任务
     */
    @Scheduled(fixedRate = 5000)
    public void simpleTask(){
        logger.info("current run by simpleTask");
    }
}

시작 클래스

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);
    }

}

실행 결과

...省略非关键信息
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
...

결과 분석

실행 결과에서 확인할 수 있습니다.

1. 모든 예약된 작업은 스케줄링에 의해 실행됩니다. -1이 스레드가 처리합니다
scheduling-1这个线程处理
2. 正常运行的simpleTask被overtimeTask阻塞导致了运行间隔变成了10秒

后面通过查阅Springboot的文档也得知了定时任务默认最大运行线程数为1。

解决方案

由于使用的Springboot版本为2.1.3.RELEASE정상적으로 실행되는 simpleTask가 overtimeTask에 의해 차단되어 실행 간격이 10이 됩니다. >초

나중에 Springboot 문서를 참조하여 예약된 작업에 대해 기본 최대 실행 스레드 수가 1이라는 것도 알게 되었습니다. .

해결책

사용된 Springboot 버전은 2.1.3.RELEASE이므로 이 문제를 해결하는 방법에는 두 가지가 있습니다

Springboot 구성 사용

구성 파일에서 예약된 작업에 사용할 수 있는 스레드 수를 구성할 수 있습니다.

## 配置可用线程数为10
spring.task.scheduling.pool.size=10

예약된 작업에 대한 스레드 풀 사용자 지정

기본 스레드 풀 대신 사용자 지정 스레드 풀 사용

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

/**
 * 定时任务配置类
 * @author RJH
 * create at 2019-03-29
 */
@Configuration
public class ScheduleConfig {

    /**
     * 此处方法名为Bean的名字，方法名无需固定
     * 因为是按TaskScheduler接口自动注入
     * @return
     */
    @Bean
    public TaskScheduler taskScheduler(){
        // Spring提供的定时任务线程池类
        ThreadPoolTaskScheduler taskScheduler=new ThreadPoolTaskScheduler();
        //设定最大可用的线程数目
        taskScheduler.setPoolSize(10);
        return taskScheduler;
    }
}

이 문서는 여기에 있습니다. 더 흥미로운 내용이 궁금하시다면 PHP 중국어 홈페이지의 🎜Java Video Tutorial🎜 칼럼을 주목해주세요! 🎜

위 내용은 Springboot 예약 작업에서 발생한 문제 해결의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!