SpringSchedule定时功能

痛定思痛。 2023-10-03 11:19 13阅读 0赞

# 1.1.简介 #

spring自带的定时任务框架的有点：简单，拆箱即用

spring自带的定时任务框架的缺点：

1.  不支持集群：为避免重复执行的问题
2.  不支持生命周期统一管理：不重启服务情况下关闭，启动任务
3.  不支持分片任务：处理有序数据时，多机器分片执行任务处理不同数据
4.  不支持动态调整：不重启服务的情况下修改任务参数
5.  无报警机制：任务失败之后没有报警机制
6.  不支持失败重试：出现异常后任务中介，不能根据执行状态控制任务重新执行
7.  任务数据统计难以统计：任务数据量大时，对于任务执行情况无法高效的统计执行情况

一些单机任务的情况比较适合，因为拆箱即用，但是我还是推荐国产的[轻量级的定时任务框架xxl-job][xxl-job]

SpringBoot中已经默认对Spring的Schedule实现了自动配置，使用时只需要简单注解和部分属性设置即可。

# 1.2.入门案例 #

使用Spring的 initializr来搭建项目：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgxMTA1Nw_size_16_color_FFFFFF_t_70]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgxMTA1Nw_size_16_color_FFFFFF_t_70 1]  
选择依赖  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgxMTA1Nw_size_16_color_FFFFFF_t_70 2]

# 1.2.2.开启定时任务 #

要开启定时任务功能，只需要在启动类上加载一个@EnableScheduling注解即可：

package com.springshedule.demo;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.scheduling.annotation.EnableScheduling;
    
    @SpringBootApplication
    @EnableScheduling
    public class DemoApplication {
        
    
        public static void main(String[] args) {
        
            SpringApplication.run(DemoApplication.class, args);
        }
    
    }

# 1.2.3.定义任务 #

定义任务，需要三步：

*  声明类，通过@Component注解注册到Spring容器
 *  类中定义方法，方法内部编写任务逻辑
 *  方法上添加注解@Scheduled(fixedRate = 1000)来定义任务执行频率，
    
     *  这里的fiexRate=1000，代表是每隔1000毫秒执行一次

package com.springshedule.demo.job;
    
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.scheduling.annotation.Scheduled;
    import org.springframework.stereotype.Component;
    
    
    @Slf4j
    @Component
    public class HelloJob {
        
    
        @Scheduled(fixedRate = 1000)
        public void hello(){
        
            log.info("hello spring schedule!");
        }
    }

## 1.2.4.启动测试 ##

启动项目，可以在控制台看到任务执行情况：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgxMTA1Nw_size_16_color_FFFFFF_t_70 3]

# 1.3.配置 #

定时任务有许多可以自定义的配置属性：

## 1.3.1.任务线程池大小 ##

默认情况下，定时任务的线程池大小只有1，当任务较多执行频繁时，会出现阻塞等待的情况，任务调度器就会出现时间漂移，任务执行时间将不确定。

为了避免这样的情况发生，我们需要自定义线程池的大小：

修改application.yml即可实现：

spring:
      task:
        scheduling:
          pool:
            size: 10

重启项目后测试：![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgxMTA1Nw_size_16_color_FFFFFF_t_70 4]

## 1.3.2.定时策略 ##

在方法上添加注解@Scheduled可以控制定时执行的频率，有三种策略：

*  fixedRate：按照固定时间频率执行，单位毫秒，即每xx毫秒执行一次。
    
     *  如果上一个任务阻塞导致任务积压，则会在当前任务执行后，一次把多个积压的任务都执行完成
     *  举例：假如任务执行每秒1次，而第一个任务执行耗时4秒，会导致4个任务积压，在第一个任务执行后，积压的4个任务会立即执行，不再等待
 *  fixedDelay：固定延迟执行，单位毫秒，即前一个任务执行结束后xx毫秒执行第二个任务。
    
     *  如果上一个任务阻塞导致任务积压，则会在当前任务执行后xx毫秒执行下一个任务
 *  cron：知名的cron表达式，使用表达式规则来定义任务执行策略，与fixedDelay类似的。  
    1.4.3.cron表达式

什么是cron表达式呢？

Cron表达式是一个字符串，字符串包含6或7个域，每一个域代表一个含义，例如秒、分。域和域之间以空格隔开，有如下两种语法格式：

*  Seconds Minutes Hours DayofMonth Month DayofWeek Year
 *  Seconds Minutes Hours DayofMonth Month DayofWeek

cron表达式规则：

域                 允许值                       允许的特殊字符                 
      秒（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               	,   -   *   /

每个域上一般都是数字，或者指定允许的特殊字符：

特殊字符 说明

*   	表示匹配该域的任意值。假如在Minutes域使用, 即表示每分钟都会触发事件  
      ?   	只能用在DayofMonth和DayofWeek两个域中的一个。它表示不确定的值
      -   	表示范围。例如在Hours域使用5-8，表示从5点、6点、7点、8点各执行一次 
      ,   	表示列出枚举值。例如：在week域使用FRI,SUN，表示星期五和星期六执行  
      /   	一般用法：x/y，从x开始，每次递增y。如果放在minutes域，5/15，表示每小时的5分钟开始，每隔15分钟一次，即：5分钟、20分钟、35分钟、50分钟时执行
      L   	表示最后，只能出现在DayofWeek和DayofMonth域。如果在DayOfMonth中，代表每个月的最后一天。如果是在DayOfWeek域，表示每周最后一天（周六），但是如果是：数字+L，如6L表示每月的 最后一个周五
      W   	表示最近的有效工作日(周一到周五),只能出现在DayofMonth域，系统将在离指定日期的最近的有效工作日触发事件。例如：在 DayofMonth使用5W，如果5日是星期六，则将在最近的工作日：星期五，即4日触发。如果5日是星期天，则在6日(周一)触发；如果5日在星期一到星期五中的一天，则就在5日触发。另外一点，W的最近寻找不会跨过月份 。
      LW  	两个字符可以连用，表示在某个月最后一个工作日，即最后一个星期五         
      #   	用在DayOfMonth中，确定每个月第几个星期几。例如在4#2，表示某月的第二个星期三（2表示当月的第二周，4表示这周的第4天，即星期三）。

示例：

表达式                     	含义                               
      0 0 2 1 * ?  *          	表示在每月的1日的凌晨2点执行任务                
      0 15 10 ?  * MON-FRI    	表示周一到周五每天上午10:15执行作              
      0 15 10 ? * 6L 2002-2006	表示2002-2006年的每个月的最后一个星期五上午10:15执行
      0 0 9-21 * * 2-7        	996

我们把代码修改一下：

package com.springshedule.demo.job;
    
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.scheduling.annotation.Scheduled;
    import org.springframework.stereotype.Component;
    
    
    @Slf4j
    @Component
    public class HelloJob {
        
    
        //    @Scheduled(fixedRate = 1000)
        @Scheduled(cron = "0/2 * * * * ?")
        public void hello() {
        
            log.info("hello spring schedule!");
        }
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgxMTA1Nw_size_16_color_FFFFFF_t_70 5]

[xxl-job]: https://blog.csdn.net/weixin_43811057/article/details/115803428?ops_request_misc=&request_id=e76371ac9b3c4f6f8260035ad87bb865&biz_id=&utm_medium=distribute.pc_search_result.none-task-blog-2~blog~koosearch~default-1-115803428-null-null.268%5Ev1%5Econtrol&utm_term=xxljob&spm=1018.2226.3001.4450
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgxMTA1Nw_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20210718161133298.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgxMTA1Nw==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgxMTA1Nw_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20210718161243510.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgxMTA1Nw==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgxMTA1Nw_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20210718161318798.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgxMTA1Nw==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgxMTA1Nw_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20210718162024508.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgxMTA1Nw==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgxMTA1Nw_size_16_color_FFFFFF_t_70 4]: https://img-blog.csdnimg.cn/20210718162250238.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgxMTA1Nw==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgxMTA1Nw_size_16_color_FFFFFF_t_70 5]: https://img-blog.csdnimg.cn/20210718163037488.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgxMTA1Nw==,size_16,color_FFFFFF,t_70