SpringBoot的定时任务-linux运维-PHP中文网

SpringBoot的定时任务

絕刀狂花

发布： 2025-07-15 08:26:13

原创

751人浏览过

大家好，我是你们的老朋友全栈君。我们又见面了。

一、基于注解(@Scheduled)的定时任务

使用SpringBoot的@Scheduled注解来创建定时任务非常简单，只需几行代码就能实现。然而，@Scheduled默认是单线程运行，这意味着当启动多个任务时，一个任务的执行时间可能会影响到下一个任务的执行时间。

1、创建定时器

使用SpringBoot和基于注解的方法来创建一个简单的定时任务，只需如下代码：

@Component
@Configuration      // 1.主要用于标记配置类，兼备Component的效果。
@EnableScheduling   // 2.开启定时任务
public class SaticScheduleTask {
    // 3.添加定时任务
    @Scheduled(cron = "0/5 * * * * ?")
    // 或者直接指定时间间隔，例如：5秒
    //@Scheduled(fixedRate=5000)
    private void configureTasks() {
        System.err.println("执行静态定时任务时间: " + LocalDateTime.now());
    }
}

登录后复制

Cron表达式参数的含义如下：

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

@Scheduled注解除了支持Cron表达式，还支持简单的延时操作，例如使用fixedDelay或fixedRate，并指定相应的毫秒数。

2、启动测试

启动应用后，您将在控制台看到如下信息：

SpringBoot的定时任务

显然，使用@Scheduled注解非常方便，但有一个缺点：当我们调整执行周期时，需要重启应用才能生效，这多少有些不便。为了实现实时生效的效果，可以考虑使用基于接口的方法来完成定时任务。

二、基于接口（SchedulingConfigurer）的定时任务

大家可能对基于注解的定时任务已经很熟悉了，但在实际应用中，我们常常希望从数据库中动态读取执行时间来执行定时任务，这时候基于接口的定时任务就显得非常有用。

1、导入依赖包：

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter</artifactId>
    <version>2.0.4.RELEASE</version>
</parent>
<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
    </dependency>
    <dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter</artifactId>
        <version>1.3.1</version>
    </dependency>
    <dependency>
        <groupId>org.mybatis</groupId>
        <artifactId>mybatis</artifactId>
        <version>3.4.5</version>
        <scope>compile</scope>
    </dependency>
</dependencies>

登录后复制

2、添加数据库记录：

启动本地MySQL数据库，在查询窗口中执行以下脚本：

DROP DATABASE IF EXISTS `socks`;
CREATE DATABASE `socks`;
USE `SOCKS`;
DROP TABLE IF EXISTS `cron`;
CREATE TABLE `cron`  (
  `cron_id` varchar(30) NOT NULL PRIMARY KEY,
  `cron` varchar(30) NOT NULL
);
INSERT INTO `cron` VALUES ('1', '0/5 * * * * ?');

登录后复制

SpringBoot的定时任务

然后在项目的application.yml文件中添加数据源配置：

spring:
  datasource:
    url: jdbc:mysql://localhost:3306/socks
    username: root
    password: 123456

登录后复制

3、创建定时器

准备好数据库数据后，我们可以编写定时任务。注意，这里我们使用TriggerTask来循环读取数据库中设置的执行周期，并执行相关的定时任务。具体代码如下：

@Component
@Configuration      // 1.主要用于标记配置类，兼备Component的效果。
@EnableScheduling   // 2.开启定时任务
public class DynamicScheduleTask implements SchedulingConfigurer {
    @Mapper
    public interface CronMapper {
        @Select("select cron from cron limit 1")
        public String getCron();
    }
<pre class="brush:php;toolbar:false;"><code>@Autowired      // 注入mapper
@SuppressWarnings("all")
CronMapper cronMapper;

/**
 * 执行定时任务.
 */
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
    taskRegistrar.addTriggerTask(
        // 1.添加任务内容(Runnable)
        () -> System.out.println("执行动态定时任务: " + 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);
        }
    );
}

登录后复制

}

稿定AI绘图

稿定推出的AI绘画工具

查看详情

4、启动测试

启动应用后，查看控制台，打印时间符合我们预期的每10秒一次：

SpringBoot的定时任务

然后使用Navicat将执行周期修改为每6秒执行一次，如下图所示：

SpringBoot的定时任务

查看控制台，发现执行周期已经改变，并且无需重启应用，非常方便。如下图所示：

SpringBoot的定时任务

注意：如果在数据库修改时格式出现错误，定时任务会停止，即使重新修改正确也需要重新启动项目才能恢复。

三、基于注解设定多线程定时任务

基于注解设定多线程定时任务

1、创建多线程定时任务

//@Component注解用于对那些比较中立的类进行注释；
//相对与在持久层、业务层和控制层分别采用 @Repository、@Service 和 @Controller 对分层中的类进行注释
@Component
@EnableScheduling   // 1.开启定时任务
@EnableAsync        // 2.开启多线程
public class MultithreadScheduleTask {
@Async
@Scheduled(fixedDelay = 1000)  //间隔1秒
public void first() throws InterruptedException {
System.out.println("第一个定时任务开始 : " + LocalDateTime.now().toLocalTime() + "\r\n线程 : " + Thread.currentThread().getName());
System.out.println();
Thread.sleep(1000 * 10);
}</p><pre class="brush:php;toolbar:false;"><code>@Async
@Scheduled(fixedDelay = 2000)
public void second() {
    System.out.println("第二个定时任务开始 : " + LocalDateTime.now().toLocalTime() + "\r\n线程 : " + Thread.currentThread().getName());
    System.out.println();
}

登录后复制

}

注：这里的@Async注解非常关键。

2、启动测试

启动应用后，查看控制台：

SpringBoot的定时任务