Spring Boot系列之使用@Scheduled实现定时任务-阿里云开发者社区

开发者社区> 冯文议> 正文

Spring Boot系列之使用@Scheduled实现定时任务

简介: 假设,我们有一个数据同步的需求:每隔5秒执行一次数据同步。那么我们该如何实现这个数据同步任务呢?
+关注继续查看

假设,我们有一个数据同步的需求:每隔5秒执行一次数据同步。那么我们该如何实现这个数据同步任务呢?

哈喽,大家好,我是小冯。

今天给分享在Spring Boot项目中使用@Scheduled实现定时任务。

快速开始

我们就上面的需求,基于Spring Boot框架,搭建一个简单的数据同步调度任务。

Demo如下。

创建工程

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
    </dependency>
</dependencies>

因为我们是基于Spring Boot开发,所以不需要其他依赖。

package com.fengwenyi.demospringbootscheduled;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * @author <a href="https://www.fengwenyi.com">Erwin Feng</a>
 * @since 2021-09-29
 */
@SpringBootApplication
public class DemoSpringBootScheduledApplication {

    public static void main(String[] args) {
        SpringApplication.run(DemoSpringBootScheduledApplication.class, args);
    }

}

启用调度注解

package com.fengwenyi.demospringbootscheduled.config;

import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;

/**
 * @author <a href="https://www.fengwenyi.com">Erwin Feng</a>
 * @since 2021-09-29
 */
@Configuration
@EnableScheduling
public class ScheduledConfiguration {

}

数据同步任务

package com.fengwenyi.demospringbootscheduled.task;

import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.util.concurrent.TimeUnit;

/**
 * @author <a href="https://www.fengwenyi.com">Erwin Feng</a>
 * @since 2021-10-21
 */
@Component
@Slf4j
public class DemoTask {

    @Scheduled(initialDelay = 5, fixedRate = 5, timeUnit = TimeUnit.SECONDS)
    public void dataSynchronizationTask() {
        log.info("开始执行数据同步任务");
    }

}

执行

通过意思步骤,我们的demo就搭建好了,跑一下,控制台打印日志如下:

2021-10-21 21:44:55.711  INFO 10320 --- [   scheduling-1] c.f.d.task.DemoTask                      : 开始执行数据同步任务
2021-10-21 21:45:00.705  INFO 10320 --- [   scheduling-1] c.f.d.task.DemoTask                      : 开始执行数据同步任务
2021-10-21 21:45:05.715  INFO 10320 --- [   scheduling-1] c.f.d.task.DemoTask                      : 开始执行数据同步任务
2021-10-21 21:45:10.710  INFO 10320 --- [   scheduling-1] c.f.d.task.DemoTask                      : 开始执行数据同步任务

通过打印日志,我们指定,没间隔5秒,就会自动执行“数据同步任务”,这样就简单实现了任务调度。

@Scheduled参数详解

下面我们对 @Scheduled 注解提供配置,做一个说明。

cron

spring-boot-scheduled-cron.png

先看一个例子:每5秒执行一次任务。

@Scheduled(cron = "0/5 * * * * ? ")
public void testCron01() {
    log.info("test cron 01 exec");
}

执行:

2021-10-23 02:31:50.030  INFO 18872 --- [   scheduling-1] c.f.d.task.ScheduledTask                 : test cron 1 exec
2021-10-23 02:31:55.009  INFO 18872 --- [   scheduling-1] c.f.d.task.ScheduledTask                 : test cron 1 exec
2021-10-23 02:32:00.005  INFO 18872 --- [   scheduling-1] c.f.d.task.ScheduledTask                 : test cron 1 exec

关于cron表达式,下面要做几点说明:

1、结构

 ┌───────────── second (0-59)
 │ ┌───────────── minute (0 - 59)
 │ │ ┌───────────── hour (0 - 23)
 │ │ │ ┌───────────── day of the month (1 - 31)
 │ │ │ │ ┌───────────── month (1 - 12) (or JAN-DEC)
 │ │ │ │ │ ┌───────────── day of the week (0 - 7)
 │ │ │ │ │ │          (0 or 7 is Sunday, or MON-SUN)
 │ │ │ │ │ │
 * * * * * *

spring支持的cron表达式,由6位构成,分别表示:

  • 分钟
  • 小时
  • 天(月)
  • 天(星期)

2、Cron表达式示例

通过阅读一些cron示例,更能理解cron表达式的具体含义,我们就以spring官方文档中的示例进行学习。

官方文档:https://docs.spring.io/spring-framework/docs/current/reference/html/integration.html#scheduling-cron-expression

spring-boot-scheduled-cron-examples.png

星号(*)和问号(?)都表示通配符,其中,?可以用在 天(月)天(星期)上,即第4位和第6位。

L,表示最后,比如一月最后一个星期天。

W,表示工作日(周一到周五)。

#,表示每月中的第几个星期几。5#2:表示每月第2个星期五。MON#1:表示每月第1个星期一。

3、Macros

spring-boot-scheduled-cron-macros.png

spring为我们提供了几个特别的cron表达式(整年,整月,整周,整天或者整夜,整小时),我们可以直接用。

@Scheduled(cron = "@hourly")
public void testCron02() {
    log.info("test cron 02 exec");
}

zone

时区

fixedDelay

固定间隔,参数类型为long。

fixedDelayString

固定间隔,参数类型为String,同fixedDelay。

fixedRate

固定速率,参数类型为long。

fixedRateString

固定速率,参数类型为long,同fixedRate。

timeUnit

时间单位,从 5.3.10开始

spring boot 2.5.5开始

initialDelay

第一次延时时间,参数类型为long。

initialDelayString

第一次延时时间,参数类型为String。

fixedDelay与fixedRate

区别

fixedDelay,间隔时间,以任务结束时间算起。

fixedRate,间隔时间,以任务开始时间算起。

间隔时间大于任务执行时间

比如一个任务,间隔时间为5秒,任务执行时间是2秒。

假设fixedDelay在第5秒执行第一次,那么第二次会在12秒执行。

而fixedRate在第5秒执行第一次,那么第二次会在10秒执行。

间隔时间小于任务执行时间

比如一个任务,间隔时间为2秒,任务执行时间是5秒。

假设fixedDelay在第2秒执行第一次,那么第二次会在9秒执行。

而fixedRate在第2秒执行第一次,那么第二次会在7秒执行。

配置文件

在实际项目中,执行时间一般写在配置文件中,方便修改,不然,如果要修改,还要改代码。

关于如何写在配置文件中,相信你一定遇到过这个问题。

这部分我们解决这样一个问题,并进行总结。

cron

@Scheduled(cron = "${erwin.cron:0/2 * * * * ?}")
public void cronTaskYmlDemo() {
    log.info("cron yml demo");
}

配置:

erwin:
  cron: 0/10 * * * * ?

如果配置文件没有配,就会使用默认的值。

请注意,值为空,不等于没有配。

fixedDelay

在上面参数解释的时候,我们指定,这个接收的是一个整数,那该如何将解决这个问题。

相信聪明的你,一定也是猜到了。

对,没错,就是它。

@Scheduled(initialDelay = 5, fixedDelayString = "${erwin.fixed-delay:2}", timeUnit = TimeUnit.SECONDS)
public void fixedDelayTaskYmlDemo() {
    log.info("fixedDelay yml demo");
}

配置:

erwin:
  fixed-delay: 5

简单解释一下,如果在配置文件中没有配置,则每隔2秒执行一次,如果配置了,就每隔5秒执行一次。initialDelay 表示,项目启动后,5秒开始执行第一次任务。

值得注意的是,${erwin.fixed-delay:2},冒号前后不能有空格。

fixedRate

有了上面的经验,相信你一定学会了。我们一起来看示例吧。

@Scheduled(initialDelay = 5, fixedRateString = "${erwin.fixed-rate:2}", timeUnit = TimeUnit.SECONDS)
public void fixedRateTaskYmlDemo() {
    log.info("fixedRate yml demo");
}

配置:

erwin:
  fixed-rate: 5

执行示例:

2021-10-25 20:41:57.394  INFO 19368 --- [   scheduling-1] c.f.d.task.DemoTask                      : fixedRate yml demo
2021-10-25 20:41:59.394  INFO 19368 --- [   scheduling-1] c.f.d.task.DemoTask                      : fixedRate yml demo
2021-10-25 20:42:01.394  INFO 19368 --- [   scheduling-1] c.f.d.task.DemoTask                      : fixedRate yml demo

最后的最后,还有一个问题,先看图。

spring-boot-scheduled-yml-no-tip.png

发现问题了吗?

我们在写配置的时候,没有提示,并且这种看上去,也不友好。

那要怎么解决呢?

先引入依赖:

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-configuration-processor</artifactId>
    <optional>true</optional>
</dependency>

我们不妨写一个属性配置类。

@Getter
@Setter
@Configuration
@ConfigurationProperties("erwin")
public class ErwinProperties {

    private String cron;

    private Long fixedDelay;

    private Long fixedRate;

}

你注意到 erwin 这个了吗?

刚开始写示例的时候,你是不是很好奇,为什么会有这个前缀

哈哈,其实我们早已埋下了伏笔。

最后,再来看看吧。

spring-boot-scheduled-yml-tip.png

同时,这时候,你再写配的时候,就会有提示了。

今天分享的内容,就是这些了,咱们下期再见!

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
CCTMXTiledMap的使用
 1 CCTMXTiledMap的使用 TileMap.h #ifndef __T23TileMap_H__ #define __T23TileMap_H__   #include "cocos2d.h" USING_NS_CC;   class TileMap :public
1012 0
使用 Date 和 SimpleDateFormat 类表示时间
使用 Date 和 SimpleDateFormat 类表示时间 在程序开发中,经常需要处理日期和时间的相关数据,此时我们可以使用 java.util 包中的 Date 类。这个类最主要的作用就是获取当前时间,我们来看下 Date 类的使用: 使用 Date ...
930 0
怎么设置阿里云服务器安全组?阿里云安全组规则详细解说
阿里云服务器安全组设置规则分享,阿里云服务器安全组如何放行端口设置教程
6903 0
史上最快! 10小时大数据入门实战(八)- Hadoop 集成 Spring 的使用
目录 https://spring.io/projects/spring-hadoop 1 Spring Hadoop 开发环境搭建及访问 HDFS 文件系统 ...
1096 0
使用SQL Server 2005作业设置定时任务
原文:使用SQL Server 2005作业设置定时任务 公司有一个老项目由于直接把终端拍摄的图片以二进制的形式保存到数据库中,数据库比较大所以需要经常删除这些冗余数据,手动删除费时费力,项目组长让我把这些操作变成自动的,每天执行一次,只保留最近两个月的图片数据。
619 0
如何使用Redis让周期异步任务变得Fault-tolerant且Dynamic
        Python技术栈的同学一定都非常了解Celery——基于消息队列的分布式任务调度系统。(具体用法介绍不在此赘述)。通过Celery可以快速高效的将大规模的任务实时分发到众多的不同的机器上,让用户只关注每个单独任务的处理,而非调度分配任务本身。
723 0
+关注
冯文议
Java开发者,专注程序设计与开发
19
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
文娱运维技术
立即下载
《SaaS模式云原生数据仓库应用场景实践》
立即下载
《看见新力量:二》电子书
立即下载