zoukankan      html  css  js  c++  java
  • SpringBoot 定时任务 || cron表达式

     

     

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

    • Timer:这是java自带的java.util.Timer类,这个类允许你调度一个java.util.TimerTask任务。使用这种方式可以让你的程序按照某一个频度执行,但不能在指定时间运行。一般用的较少。
    • ScheduledExecutorService:也jdk自带的一个类;是基于线程池设计的定时任务类,每个调度任务都会分配到线程池中的一个线程去执行,也就是说,任务是并发执行,互不影响。
    • Spring Task:Spring3.0以后自带的task,可以将它看成一个轻量级的Quartz,而且使用起来比Quartz简单许多。
    • Quartz:这是一个功能比较强大的的调度器,可以让你的程序在指定时间执行,也可以按照某一个频度执行,配置起来稍显复杂。

    Timer与ScheduledExecutorService有篇已经介绍到了,这里不在做介绍。

    使用Spring Task

    ##简单的定时任务

    在SpringBoot项目中,我们可以很优雅的使用注解来实现定时任务,首先创建项目,导入依赖:

    复制代码
     1 <dependencies>
     2 <dependency>
     3 <groupId>org.springframework.boot</groupId>
     4 <artifactId>spring-boot-starter-web</artifactId>
     5 </dependency>
     6 <dependency>
     7 <groupId>org.springframework.boot</groupId>
     8 <artifactId>spring-boot-starter</artifactId>
     9 </dependency>
    10 <dependency>
    11 <groupId>org.projectlombok</groupId>
    12 <artifactId>lombok</artifactId>
    13 <optional>true</optional>
    14 </dependency>
    15 <dependency>
    16 <groupId>org.springframework.boot</groupId>
    17 <artifactId>spring-boot-starter-test</artifactId>
    18 <scope>test</scope>
    19 </dependency>
    20 </dependencies>
    复制代码

    创建任务类:

    复制代码
     1 @Slf4j
     2 @Component
     3 public class ScheduledService {
     4     @Scheduled(cron = "0/5 * * * * *")
     5     public void scheduled(){
     6         log.info("=====>>>>>使用cron  {}",System.currentTimeMillis());
     7     }
     8     @Scheduled(fixedRate = 5000)
     9     public void scheduled1() {
    10         log.info("=====>>>>>使用fixedRate{}", System.currentTimeMillis());
    11     }
    12     @Scheduled(fixedDelay = 5000)
    13     public void scheduled2() {
    14         log.info("=====>>>>>fixedDelay{}",System.currentTimeMillis());
    15     }
    16 }
    复制代码

    在主类上使用@EnableScheduling注解开启对定时任务的支持,然后启动项目创建任务类:

    按 Ctrl+C 复制代码
    按 Ctrl+C 复制代码

    运行结果:

    可以看到三个定时任务都已经执行,并且使同一个线程中串行执行,如果只有一个定时任务,这样做肯定没问题,当定时任务增多,如果一个任务卡死,会导致其他任务也无法执行。

    多线程执行

    在传统的Spring项目中,我们可以在xml配置文件添加task的配置,而在SpringBoot项目中一般使用config配置类的方式添加配置,所以新建一个AsyncConfig类

    复制代码
     1 @Configuration
     2 @EnableAsync
     3 public class AsyncConfig {
     4 /*
     5 此处成员变量应该使用@Value从配置中读取
     6 */
     7 private int corePoolSize = 10;
     8 private int maxPoolSize = 200;
     9 private int queueCapacity = 10;
    10 @Bean
    11 public Executor taskExecutor() {
    12 ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    13 executor.setCorePoolSize(corePoolSize);
    14 executor.setMaxPoolSize(maxPoolSize);
    15 executor.setQueueCapacity(queueCapacity);
    16 executor.initialize();
    17 return executor;
    18 }
    19 }
    复制代码

    @Configuration:表明该类是一个配置类 

    @EnableAsync:开启异步事件的支持

    然后在定时任务的类或者方法上添加@Async 。最后重启项目,每一个任务都是在不同的线程中

    执行时间的配置

    在上面的定时任务中,我们在方法上使用@Scheduled注解来设置任务的执行时间,并且使用三种属性配置方式:

    1. fixedRate:定义一个按一定频率执行的定时任务
    2. fixedDelay:定义一个按一定频率执行的定时任务,与上面不同的是,改属性可以配合initialDelay, 定义该任务延迟执行时间。
    3. cron:通过表达式来配置任务执行时间

    cron表达式详解

    Cron表达式是一个字符串,字符串以5或6个空格隔开,分为6或7个域,每一个域代表一个含义,Cron有如下两种语法格式:

      (1) Seconds Minutes Hours DayofMonth Month DayofWeek Year

      (2)Seconds Minutes Hours DayofMonth Month DayofWeek

      

      一、结构

      corn从左到右(用空格隔开):秒 分 小时 月份中的日期 月份 星期中的日期 年份

      二、各字段的含义

     
    字段 允许值 允许的特殊字符
    秒(Seconds) 0~59的整数 , - * /    四个字符
    分(Minutes 0~59的整数 , - * /    四个字符
    小时(Hours 0~23的整数 , - * /    四个字符
    日期(DayofMonth 1~31的整数(但是你需要考虑你月的天数) ,- * ? / L W C     八个字符
    月份(Month 1~12的整数或者 JAN-DEC , - * /    四个字符
    星期(DayofWeek 1~7的整数或者 SUN-SAT (1=SUN) , - * ? / L C #     八个字符
    年(可选,留空)(Year 1970~2099 , - * /    四个字符

    注意事项:

      每一个域都使用数字,但还可以出现如下特殊字符,它们的含义是:

      (1)*:表示匹配该域的任意值。假如在Minutes域使用*, 即表示每分钟都会触发事件。

      (2)?:只能用在DayofMonth和DayofWeek两个域。它也匹配域的任意值,但实际不会。因为DayofMonth和DayofWeek会相互影响。例如想在每月的20日触发调度,不管20日到底是星期几,则只能使用如下写法: 13 13 15 20 * ?, 其中最后一位只能用?,而不能使用*,如果使用*表示不管星期几都会触发,实际上并不是这样。

      (3)-:表示范围。例如在Minutes域使用5-20,表示从5分到20分钟每分钟触发一次 

      (4)/:表示起始时间开始触发,然后每隔固定时间触发一次。例如在Minutes域使用5/20,则意味着5分钟触发一次,而25,45等分别触发一次. 

      (5),:表示列出枚举值。例如:在Minutes域使用5,20,则意味着在5和20分每分钟触发一次。 

      (6)L:表示最后,只能出现在DayofWeek和DayofMonth域。如果在DayofWeek域使用5L,意味着在最后的一个星期四触发。 

      (7)W:表示有效工作日(周一到周五),只能出现在DayofMonth域,系统将在离指定日期的最近的有效工作日触发事件。例如:在 DayofMonth使用5W,如果5日是星期六,则将在最近的工作日:星期五,即4日触发。如果5日是星期天,则在6日(周一)触发;如果5日在星期一到星期五中的一天,则就在5日触发。另外一点,W的最近寻找不会跨过月份 。

      (8)LW:这两个字符可以连用,表示在某个月最后一个工作日,即最后一个星期五。 

      (9)#:用于确定每个月第几个星期几,只能出现在DayofMonth域。例如在4#2,表示某月的第二个星期三。

      三、常用表达式例子

      (1)0 0 2 1 * ? *   表示在每月的1日的凌晨2点调整任务

      (2)0 15 10 ? * MON-FRI   表示周一到周五每天上午10:15执行作业

      (3)0 15 10 ? 6L 2002-2006   表示2002-2006年的每个月的最后一个星期五上午10:15执行作

      (4)0 0 10,14,16 * * ?   每天上午10点,下午2点,4点 

      (5)0 0/30 9-17 * * ?   朝九晚五工作时间内每半小时 

      (6)0 0 12 ? * WED    表示每个星期三中午12点 

      (7)0 0 12 * * ?   每天中午12点触发 

      (8)0 15 10 ? * *    每天上午10:15触发 

      (9)0 15 10 * * ?     每天上午10:15触发 

      (10)0 15 10 * * ? *    每天上午10:15触发 

      (11)0 15 10 * * ? 2005    2005年的每天上午10:15触发 

      (12)0 * 14 * * ?     在每天下午2点到下午2:59期间的每1分钟触发 

      (13)0 0/5 14 * * ?    在每天下午2点到下午2:55期间的每5分钟触发 

      (14)0 0/5 14,18 * * ?     在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发 

      (15)0 0-5 14 * * ?    在每天下午2点到下午2:05期间的每1分钟触发 

      (16)0 10,44 14 ? 3 WED    每年三月的星期三的下午2:10和2:44触发 

      (17)0 15 10 ? * MON-FRI    周一至周五的上午10:15触发 

      (18)0 15 10 15 * ?    每月15日上午10:15触发 

      (19)0 15 10 L * ?    每月最后一日的上午10:15触发 

      (20)0 15 10 ? * 6L    每月的最后一个星期五上午10:15触发 

      (21)0 15 10 ? * 6L 2002-2005   2002年至2005年的每月的最后一个星期五上午10:15触发 

      (22)0 15 10 ? * 6#3   每月的第三个星期五上午10:15触发

      

      注:

      (1)有些子表达式能包含一些范围或列表

      例如:子表达式(天(星期))可以为 “MON-FRI”,“MON,WED,FRI”,“MON-WED,SAT”

    “*”字符代表所有可能的值

      因此,“*”在子表达式(月)里表示每个月的含义,“*”在子表达式(天(星期))表示星期的每一天


      “/”字符用来指定数值的增量 
      例如:在子表达式(分钟)里的“0/15”表示从第0分钟开始,每15分钟 
    在子表达式(分钟)里的“3/20”表示从第3分钟开始,每20分钟(它和“3,23,43”)的含义一样


      “?”字符仅被用于天(月)和天(星期)两个子表达式,表示不指定值 
      当2个子表达式其中之一被指定了值以后,为了避免冲突,需要将另一个子表达式的值设为“?”

      “L” 字符仅被用于天(月)和天(星期)两个子表达式,它是单词“last”的缩写 
      但是它在两个子表达式里的含义是不同的。 
      在天(月)子表达式中,“L”表示一个月的最后一天 
      在天(星期)自表达式中,“L”表示一个星期的最后一天,也就是SAT

      如果在“L”前有具体的内容,它就具有其他的含义了

      例如:“6L”表示这个月的倒数第6天,“FRIL”表示这个月的最一个星期五 
      注意:在使用“L”参数时,不要指定列表或范围,因为这会导致问题

    整合Quartz

    • 添加依赖

    如果SpringBoot版本是2.0.0以后的,则在spring-boot-starter中已经包含了quart的依赖,则可以直接使用spring-boot-starter-quartz依赖:

    1 <dependency>
    2     <groupId>org.springframework.boot</groupId>
    3     <artifactId>spring-boot-starter-quartz</artifactId>
    4 </dependency>

    如果是1.5.9则要使用以下添加依赖:

    复制代码
    1 <dependency>
    2   <groupId>org.quartz-scheduler</groupId>
    3   <artifactId>quartz</artifactId>
    4   <version>2.3.0</version>
    5 </dependency>
    6 <dependency>
    7   <groupId>org.springframework</groupId>
    8   <artifactId>spring-context-support</artifactId>
    9 </dependency>
    复制代码

    这里我使用SpringBoot版本是2.0.0.BUILD-SNAPSHOT ,该版本开始集成了Quartz,所以事实现起来很方便。其它好像比较麻烦,这里就不介绍,以后有时间再详细深入了解Quartz。

    创建任务类TestQuartz,该类主要是继承了QuartzJobBean

    • 复制代码
       1 public class TestQuartz extends QuartzJobBean {
       2     /**
       3      * 执行定时任务
       4      * @param jobExecutionContext
       5      * @throws JobExecutionException
       6      */
       7     @Override
       8     protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
       9         System.out.println("quartz task "+new Date());
      10     }
      11 }
      复制代码


    创建配置类QuartzConfig

    复制代码
     1 @Configuration
     2 public class QuartzConfig {
     3     @Bean
     4     public JobDetail teatQuartzDetail(){
     5         return JobBuilder.newJob(TestQuartz.class).withIdentity("testQuartz").storeDurably().build();
     6     }
     7 
     8     @Bean
     9     public Trigger testQuartzTrigger(){
    10         SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule()
    11                 .withIntervalInSeconds(10)  //设置时间周期单位秒
    12                 .repeatForever();
    13         return TriggerBuilder.newTrigger().forJob(teatQuartzDetail())
    14                 .withIdentity("testQuartz")
    15                 .withSchedule(scheduleBuilder)
    16                 .build();
    17     }
    18 }
    复制代码
    • 启动项目

    参考

     http://www.wanqhblog.top/2018/02/01/SpringBootTaskSchedule/

  • 相关阅读:
    深入浅出AQS之组件概览
    深入浅出AQS之条件队列
    深入浅出AQS之共享锁模式
    深入浅出AQS之独占锁模式
    Android中RecyclerView用法,一步一步教你如何使用RecyclerView以及带你走过编码中可能会出现的坑~
    检测jquery是否正确引入
    对于使用JDBC连接mysql数据时The server time zone value '¤¤°ê¼Ð·Ç®É¶¡'...的异常问题解决。
    MYSQL8.0以上版本ROOT密码报错及修改
    MYSQL安装教程
    linux centos安装nginx1.7.4
  • 原文地址:https://www.cnblogs.com/hanwuxing/p/11288480.html
Copyright © 2011-2022 走看看