美文网首页
SpringBoot定时任务的四种实现方式

SpringBoot定时任务的四种实现方式

作者: 渡劫CD | 来源:发表于2018-11-15 00:41 被阅读0次

定时任务实现的几种方式:

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 。最后重启项目,每一个任务都是在不同的线程中

cron表达式详解地址

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的各种缺点详细讲解以及解决方案代码实现。

原文引用:https://blog.csdn.net/wqh8522/article/details/79224290

相关文章

网友评论

      本文标题:SpringBoot定时任务的四种实现方式

      本文链接:https://www.haomeiwen.com/subject/mfcefqtx.html