SpringBoot 中实现定时任务的几种方式

左手的ㄟ右手 2023-10-10 21:23 24阅读 0赞

> 定时任务在我们项目开发中也是很重要的，对于某些场景必须要用定时任务 ，如定时发送邮件啊，定时统计数据等，这篇文章主要讲讲项目中实现定时任务的几种方式。

# 一、基于注解 #

这种方式很简单，主要就是先@EnableScheduling开启定时任务功能，然后在相应的方法上添加@Scheduled()中间写上相应的cron表达式即可。示例如下：

schedule.ScheduleTask:

**Cron表达式参数参考：**

*  秒（0~59） 例如0/5表示每5秒
 *  分（0~59）
 *  时（0~23）
 *  日（0~31）的某天，需计算
 *  月（0~11）
 *  周几（ 可填1-7 或 SUN/MON/TUE/WED/THU/FRI/SAT）

建议：直接在线生成Cron表达式比较方便：*www.matools.com/cron/*

@Scheduled：除了支持灵活的参数表达式cron之外，还支持 fixedDelay，fixedRate，initialDelay 这些延时性的操作。

![format_png][]

启动测试就实现了基本的定时任务功能，但是如果我们修改了cron表达式，需要重启整个应用才能生效，不是很方便。想要实现修改cron表达式就生效就需要用到接口的方式来实现定时任务。

# 二、基于接口 #

接口的方式是我们把定时任务的信息放在数据库中，程序从数据库去拉取定时任务的信息如cron表达式来实现实时修改生效等功能。

**1. 首先在数据库中创建一张用来记录定时任务的表**

sql复制代码CREATE TABLE `scheduled` (
      `id` bigint NOT NULL AUTO_INCREMENT,
      `name` varchar(255) NULL,
      `cron` varchar(255) NULL,
      PRIMARY KEY (`id`)
    )
    INSERT INTO `mydb`.`scheduled` (`id`, `name`, `cron`) VALUES (1, '定时任务1', '0/6 * * * * ?')

**2. 在项目中引入mabatis-plus和mysql相应的依赖包**

xml复制代码<dependency>
      <groupId>com.baomidou</groupId>
      <artifactId>mybatis-plus-boot-starter</artifactId>
      <version>3.5.3.1</version>
    </dependency>
    <dependency>
      <groupId>mysql</groupId>
      <artifactId>mysql-connector-java</artifactId>
      <version>8.0.32</version>
    </dependency>

**3. 在application.yml中进行连接数据库相应配置**

yml复制代码spring:
      datasource:
        url: jdbc:mysql://localhost:3306/mydb?characterEncoding=utf-8&serverTimeZone=UTC
        username: root
        password: 123456
        driver-class-name: com.mysql.cj.jdbc.Driver

**4. 定义查询cron表达式的mapper**

mapper.CronMapper:

java复制代码import org.apache.ibatis.annotations.Mapper;
    import org.apache.ibatis.annotations.Select;
    
    @Mapper
    public interface CronMapper {
        @Select("select cron from scheduled where id=#{id}")
        String getCron(Long id);
    }

**5. 实现定时任务**

java复制代码import com.jk.mapper.CronMapper;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.scheduling.annotation.EnableScheduling;
    import org.springframework.scheduling.annotation.SchedulingConfigurer;
    import org.springframework.scheduling.config.ScheduledTaskRegistrar;
    import org.springframework.scheduling.support.CronTrigger;
    import org.springframework.stereotype.Component;
    
    @Component
    @EnableScheduling //开启定时任务
    public class ScheduleTask implements SchedulingConfigurer {
        @Autowired
        private CronMapper cronMapper;
    
        @Override
        public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
            taskRegistrar.addTriggerTask(
                    //添加任务内容
                    () -> process(),
                    //设置执行的周期
                    triggerContext -> {
                        //查询cron表达式
                        String cron = cronMapper.getCron(1L);
                        if (cron.isEmpty()) {
                            System.out.println("cron is null");
                        }
                        return new CronTrigger(cron).nextExecutionTime(triggerContext);
                    });
        }
    
        private void process() {
            System.out.println("基于接口的定时任务");
        }
    }

这种方式需要去实现SchedulingConfigurer接口并重写configureTasks方法，然后设置任务内容和执行周期等，启动测试就实现了基于接口的定时任务，此时我们改动数据库里的cron表达式也会实时生效

![format_png 1][]

# 三、多线程定时任务 #

但上面的方法定义的定时任务会有个问题，就是如果我一个定时任务里面执行了复杂逻辑，导致本身执行花的时间就已经超过了定时任务间隔的时间怎么办呢？这时候定时任务的执行就会出现一定的问题，具体如下，我用线程睡眠的方式模拟处理复杂逻辑

java复制代码import org.springframework.scheduling.annotation.EnableScheduling;
    import org.springframework.scheduling.annotation.Scheduled;
    import org.springframework.stereotype.Component;
    
    import java.time.LocalDateTime;
    
    @Component
    @EnableScheduling //开启定时任务
    public class ScheduleTask {
        @Scheduled(cron = "0/5 * * * * ?") //定时任务注解+cron表达式
        public void testScheduleTask1() throws InterruptedException {
            System.out.println("执行定时任务1 " + LocalDateTime.now());
            Thread.sleep(10 * 1000);
        }
    
        @Scheduled(cron = "0/5 * * * * ?") //定时任务注解+cron表达式
        public void testScheduleTask2() {
            System.out.println("执行定时任务2 " + LocalDateTime.now());
        }
    }

![format_png 2][]

可以看到两个任务的执行时间都被影响了，和我们设置的5秒不对应。此时就可以使用多线程定时任务

java复制代码import org.springframework.scheduling.annotation.Async;
    import org.springframework.scheduling.annotation.EnableAsync;
    import org.springframework.scheduling.annotation.EnableScheduling;
    import org.springframework.scheduling.annotation.Scheduled;
    import org.springframework.stereotype.Component;
    
    import java.time.LocalDateTime;
    
    @Component
    @EnableScheduling //开启定时任务
    @EnableAsync //开启多线程
    public class ScheduleTask {
        @Scheduled(cron = "0/5 * * * * ?") //定时任务注解+cron表达式
        @Async
        public void testScheduleTask1() throws InterruptedException {
            System.out.println("执行定时任务1 " + LocalDateTime.now());
            Thread.sleep(10 * 1000);
        }
    
        @Scheduled(cron = "0/5 * * * * ?") //定时任务注解+cron表达式
        @Async
        public void testScheduleTask2() {
            System.out.println("执行定时任务2 " + LocalDateTime.now());
        }
    }

![format_png 3][]

这样多线程的定时任务就实现了，每个定时任务之间不会互相影响，定时任务执行时间太长也不会影响。

[format_png]: https://img-blog.csdnimg.cn/img_convert/6d82233b09b4fc6e268f592a9f380efa.webp?x-oss-process=image/format,png
[format_png 1]: https://img-blog.csdnimg.cn/img_convert/f8f9799449ae7774de6ff526fbbc0246.webp?x-oss-process=image/format,png
[format_png 2]: https://img-blog.csdnimg.cn/img_convert/7ca5d7d0be71755161e410f88a04f75f.webp?x-oss-process=image/format,png
[format_png 3]: https://img-blog.csdnimg.cn/img_convert/1a2a0249a937ebf75ae69006414a3f6f.webp?x-oss-process=image/format,png