BiuBiu

# 整合定时任务

创建一个web项目，引入web,mysql,mybatis-plus框架，作为基础实例项目

# 静态定时任务，基于注解

@Scheduled

  1. cron: 表达式，指定任务在特定时间执行
  2. fixedDelay：表示上一次任务执行完成后多久再次执行，参数类型为long，单位ms；
  3. fixedDelayString：与fixedDelay含义一样，只是参数类型变为String；
  4. fixedRate：表示按一定的频率执行任务，即每次开始执行的时间间隔一致，参数类型为long，单位ms；
  5. fixedRateString: 与fixedRate的含义一样，只是将参数类型变为String；
  6. initialDelay：表示延迟多久再第一次执行任务，参数类型为long，单位ms；
  7. initialDelayString：与initialDelay的含义一样，只是将参数类型变为String；
  8. zone：时区，默认为当前时区。
@Component
@EnableScheduling
public class ScheduleConfig {

    @Scheduled(cron = "0/5 * * * * ?")
    public void task() {
        System.out.println("执行定时任务1：" + LocalDateTime.now());
    }

}

// 下面是效果 @Scheduled(cron = "0/5 * * * * ?")
//...
//执行定时任务1：2022-02-27T15:53:30.001983400
//执行定时任务1：2022-02-27T15:53:35.004437600
//执行定时任务1：2022-02-27T15:53:40.001887600
//执行定时任务1：2022-02-27T15:53:45.002347900
//...
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

cron表达式

cron表达式是一个字符串，以空格分开共6个域

  1. 结构：
  • 标准的corn从左到右（用空格隔开）：秒 分 小时 月份中的日期 月份 星期中的日期 年份
  • spring自带的定时任务cron表达式不支持年，如@Scheduled(cron = "0/5 * * * * ?") 每隔5s
  • [秒] [分] [时] [日] [月] [周]
  1. 各字段含义
域 必填 允许值 允许的特殊字符
秒（seconds） 是 0-59整数 , - * / 四个字符
分（minutes） 是 0-59整数 , - * / 四个字符
时（hours） 是 0-23整数 , - * / 四个字符
日（daysOfMonth） 是 1-31整数（需要考虑月的天数） ,- * ? / L W C 八个字符
月（months）） 是 1-12整数 或 JAN-DEC , - * ? / L C # 八个字符
周 （daysOfWeek） 是 1-7整数 或 SUN-SAT , - * / 四个字符
年 （Year） Spring不支持 是 1970~2099 Spring不支持 , - * / 四个字符 Spring不支持
  1. 通配符说明
  • * 表示匹配该域的任意值。在minutes域使用 * 表示每分钟。在months里表示每个月。在daysOfWeek域表示一周的每一天
  • ? 只能用在daysofMonth和daysofWeek两个域，表示不指定值，当两个子表达式其中之一被指定了值以后，为了避免冲突，需要将另一个子表达式的值设为 ？。因为daysofMonth和daysofWeek会相互影响。例如想在每月的2号触发调度，不管2号是周几，则只能使用如下写法：0 0 0 2 * ?, 其中最后一位只能用?，而不能使用*，如果使用*表示不管周几都会触发。
  • - 表示范围。例如在minutes域使用5-20，表示从5分到20分钟每分钟触发一次
  • / 表示起始时间开始触发，然后每隔固定时间触发一次。例如在minutes域使用5/20，则意味着从当前小时的第5分钟开每20分钟触发一次
  • , 表示列出枚举值。例如：在minutes域使用5,20，则意味着在5分和20分时各触发一次
  • L 表示最后，是单词“last”的缩写，只能出现在daysofWeek和dayofMonth域。在daysofWeek域使用5L意思是在指定月的最后的一个星期四触发。在dayofMonth域使用5L或者FRIL意思是在指定月的倒数第5天触发。在使用L参数时，不要指定列表或范围。
  • W 表示有效工作日(周一到周五),只能出现在daysofMonth域，系统将在离指定日期的最近的有效工作日触发事件。例如：在daysofMonth使用5W，如果5号是周六，则将在最近的工作日周五，即4号触发。如果5号是周日，则在6日(周一)触发。如果5日在星期一到星期五中的一天，则就在5日触发。另外，W的最近寻找不会跨过月份
  • LW 这两个字符可以连用，表示指定月的最后一个工作日。
  • # 用于确定每个月第几个周几，只能出现在daysofMonth域。例如在4#2，表示某月的第二个周三
  1. 常用表达式实例
  • 0 0 2 1 * ? * 表示在每月的1日的凌晨2点调整任务
  • 0/2 * * * * ? 表示每2秒 执行任务
  • 0 0/2 * * * ? 表示每2分钟 执行任务
  • 0 15 10 ? * MON-FRI 表示周一到周五每天上午10:15执行作业
  • 0 0 10,14,16 * * ? 每天上午10点，下午2点，4点
  • 0 0 12 ? * WED 表示每个星期三中午12点
  • 0 0 12 * * ? 每天中午12点触发
  • 0 15 10 ? * * 每天上午10:15触发
  • 0 15 10 * * ? 每天上午10:15触发
  • 0 15 10 * * ? * 每天上午10:15触发
  • 0 15 10 ? * MON-WED,SAT 周一至周三和周六的上午10:15触发

# 动态定时任务，基于接口

  1. 准备好web项目
  2. 准备数据库
DROP TABLE IF EXISTS `tb_cron`;
CREATE TABLE `tb_cron`  (
  `cron_id` varchar(30),
  `cron` varchar(30) 
);
INSERT INTO `tb_cron` VALUES ('1', '0/5 * * * * ?');
1
2
3
4
5
6
  1. 配置数据库
spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://127.0.0.1:3306/biubiu?useUnicode=true&characterEncoding=UTF-8&useSSL=true
    username: root
    password: root
mybatis-plus:
  mapper-locations: classpath:mapper/*Mapper.xml
  configuration:
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
1
2
3
4
5
6
7
8
9
10
  1. 创建定时器 数据库准备好数据之后，我们编写定时任务，注意这里添加的是TriggerTask，目的是循环读取我们在数据库设置好的执行周期，以及执行相关定时任务的内容。具体代码如下：
@Component
@EnableScheduling
public class MyScheduleConfig implements SchedulingConfigurer {

    @Resource
    private CronMapper cronMapper;

    /**
     * 执行定时任务.
     */
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.addTriggerTask(
                //1.添加任务内容(Runnable)
                () -> System.out.println("执行定时任务2: " + LocalDateTime.now().toLocalTime()),
                //2.设置执行周期(Trigger)
                triggerContext -> {
                    //2.1 从数据库获取执行周期
                    String cron = cronMapper.getCron();
                    //2.2 参数校验.
                    if (StringUtils.isEmpty(cron)) {
                        // Omitted Code ..
                    }
                    //2.3 返回执行周期(Date)
                    return new CronTrigger(cron).nextExecutionTime(triggerContext);
                });
    }


    /**
     * mybatis不想分包了，就写在这里了
     */
    @Mapper
    public interface CronMapper {
        @Select("select cron from tb_cron limit 1")
        String getCron();
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
  1. 启动项目查看控制台，修改数据库cron表达式再看看控制台

MySQl数据库可以换成配置中心，例如Apollo，nacos等

← SpringBoot WebSocket →