定时任务实现的几种方式:
Timer:这是java自带的java.util.Timer类,这个类允许你调度一个java.util.TimerTask任务。使用这种方式可以让你的程序按照某一个频度执行,但不能在指定时间运行。一般用的较少。
ScheduledExecutorService:也jdk自带的一个类;是基于线程池设计的定时任务类,每个调度任务都会分配到线程池中的一个线程去执行,也就是说,任务是并发执行,互不影响。
Spring Task:Spring3.0以后自带的task,可以将它看成一个轻量级的Quartz,而且使用起来比Quartz简单许多。
Quartz:这是一个功能比较强大的的调度器,可以让你的程序在指定时间执行,也可以按照某一个频度执行,配置起来稍显复杂。
1、使用Timer
这个目前在项目中用的较少,直接贴demo代码。具体的介绍可以查看api
public classTestTimer{
publicstaticvoidmain(String[]args) {
TimerTasktimerTask=newTimerTask() {
@Override
publicvoidrun() {
System.out.println("task run:"+newDate());
}
};
Timertimer=newTimer();
//安排指定的任务在指定的时间开始进行重复的固定延迟执行。这里是每3秒执行一次
timer.schedule(timerTask,10,3000);
}
}
2、使用ScheduledExecutorService
该方法跟Timer类似,直接看demo:
publicclassTestScheduledExecutorService{
publicstaticvoidmain(String[]args) {
ScheduledExecutorServiceservice=Executors.newSingleThreadScheduledExecutor();
// 参数:1、任务体 2、首次执行的延时时间
// 3、任务执行间隔 4、间隔时间单位
service.scheduleAtFixedRate(()->System.out.println("task ScheduledExecutorService "+newDate()),0,3,TimeUnit.SECONDS);
}
}
注意:一二种毕竟比较简单,我们着重介绍三四种;
3、使用Spring Task
3.1 简单的定时任务
在SpringBoot项目中,我们可以很优雅的使用注解来实现定时任务,首先创建项目,导入依赖:
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</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>
</dependency>
</dependencies>
创建任务类:
@Slf4j
@Component
publicclassScheduledService{
@Scheduled(cron="0/5 * * * * *")
publicvoidscheduled(){
log.info("=====>>>>>使用cron {}",System.currentTimeMillis());
}
@Scheduled(fixedRate=5000)
publicvoidscheduled1() {
log.info("=====>>>>>使用fixedRate{}",System.currentTimeMillis());
}
@Scheduled(fixedDelay=5000)
publicvoidscheduled2() {
log.info("=====>>>>>fixedDelay{}",System.currentTimeMillis());
}
}
在主类上使用@EnableScheduling注解开启对定时任务的支持,然后启动项目。
可以看到三个定时任务都已经执行,并且使同一个线程中串行执行,如果只有一个定时任务,这样做肯定没问题,当定时任务增多,如果一个任务卡死,会导致其他任务也无法执行。
3.2 多线程执行
在传统的Spring项目中,我们可以在xml配置文件添加task的配置,而在SpringBoot项目中一般使用config配置类的方式添加配置,所以新建一个AsyncConfig类:
@Configuration
@EnableAsync
publicclassAsyncConfig{
/*
此处成员变量应该使用@Value从配置中读取
*/
privateintcorePoolSize=10;
privateintmaxPoolSize=200;
privateintqueueCapacity=10;
@Bean
publicExecutortaskExecutor() {
ThreadPoolTaskExecutorexecutor=newThreadPoolTaskExecutor();
executor.setCorePoolSize(corePoolSize);
executor.setMaxPoolSize(maxPoolSize);
executor.setQueueCapacity(queueCapacity);
executor.initialize();
returnexecutor;
}
}
@Configuration:表明该类是一个配置类 @EnableAsync:开启异步事件的支持
然后在定时任务的类或者方法上添加@Async 。最后重启项目,每一个任务都是在不同的线程中
4 整合Quartz
如果SpringBoot版本是2.0.0以后的,则在spring-boot-starter中已经包含了quart的依赖,则可以直接使用spring-boot-starter-quartz依赖:
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-quartz</artifactId>
</dependency>
如果是1.5.9则要使用以下添加依赖:
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.3.0</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
</dependency>
这里我使用SpringBoot版本是2.0.0.BUILD-SNAPSHOT ,该版本开始集成了Quartz,所以事实现起来很方便。其它好像比较麻烦,这里就不介绍,以后有时间再详细深入了解Quartz。
· 创建任务类TestQuartz,该类主要是继承了QuartzJobBean
publicclassTestQuartzextendsQuartzJobBean{
/**
* 执行定时任务
* @param jobExecutionContext
* @throws JobExecutionException
*/
@Override
protectedvoidexecuteInternal(JobExecutionContextjobExecutionContext)throwsJobExecutionException{
System.out.println("quartz task "+newDate());
}
}
· 创建配置类QuartzConfig
@Configuration
publicclassQuartzConfig{
@Bean
publicJobDetailteatQuartzDetail(){
returnJobBuilder.newJob(TestQuartz.class).withIdentity("testQuartz").storeDurably().build();
}
@Bean
publicTriggertestQuartzTrigger(){
SimpleScheduleBuilderscheduleBuilder=SimpleScheduleBuilder.simpleSchedule()
.withIntervalInSeconds(10)//设置时间周期单位秒
.repeatForever();
returnTriggerBuilder.newTrigger().forJob(teatQuartzDetail())
.withIdentity("testQuartz")
.withSchedule(scheduleBuilder)
.build();
}
}
启动项目,运行结果:
5 最后
上面都是简单的介绍了关于SpringBoot定时任务的处理,直接使用SpringTask注解的方式应该是最方便的,而使用Quartz从2.0开始也变得很方便。对于这两种方式,应该说各有长处吧,按需选择。
6 说明
由于网上说SpringBoot原生Task存在诸多缺点,如:
缺点:
` 单线程
` 不支持分布式部署
` 不支持动态配置定时任务
` 不支持持久化
下一章我会对于原生Task的各种缺点详细讲解以及解决方案代码实现。