这篇文章给大家分享的是有关如何解决Springboot定时任务遇到的问题的内容。小编觉得挺实用的,因此分享给大家做个参考。一起跟随小编过来看看吧。
前言:在使用Springboot整合定时任务,发现当某个定时任务执行出现执行时间过长的情况时会阻塞其他定时任务的执行。
问题定位
后续通过翻查Springboot的文档以及打印日志(输出当前线程信息)得知问题是由于Springboot默认使用只要1个线程处理定时任务。
问题复盘
需要注意示例的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
...
由运行结果可以看出:
scheduling-1
这个线程处理simpleTask
被overtimeTask
阻塞导致了运行间隔变成了10
秒后面通过查阅Springboot
的文档也得知了定时任务默认最大运行线程数为1
。
由于使用的Springboot
版本为2.1.3.RELEASE
,所以有两种方法解决这个问题
在配置文件中可以配置定时任务可用的线程数:
## 配置可用线程数为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;
}
}
感谢各位的阅读!关于如何解决Springboot定时任务遇到的问题就分享到这里了,希望以上内容可以对大家有一定的帮助,让大家可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到吧!
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。