美文网首页
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