溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點(diǎn)擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》

SpringBoot如何創(chuàng)建定時任務(wù)

發(fā)布時間:2021-07-08 10:37:38 來源:億速云 閱讀:166 作者:小新 欄目:編程語言

這篇文章主要介紹SpringBoot如何創(chuàng)建定時任務(wù),文中介紹的非常詳細(xì),具有一定的參考價值,感興趣的小伙伴們一定要看完!

一、靜態(tài)定時任務(wù)(基于注解)

基于注解來創(chuàng)建定時任務(wù)非常簡單,只需幾行代碼便可完成。

@Scheduled 除了支持靈活的參數(shù)表達(dá)式cron之外,還支持簡單的延時操作,例如 fixedDelay ,fixedRate 填寫相應(yīng)的毫秒數(shù)即可。

@Configuration //1.主要用于標(biāo)記配置類,兼?zhèn)銫omponent的效果。
@EnableScheduling // 2.開啟定時任務(wù)
public class SimpleScheduleConfig {
  //3.添加定時任務(wù)
  @Scheduled(cron = "0/5 * * * * ?")
  private void configureTasks() {
    System.err.println("執(zhí)行定時任務(wù)1: " + LocalDateTime.now());
  }
}

Cron表達(dá)式參數(shù)分別表示:

秒(0~59) 例如0/5表示每5秒
分(0~59)
時(0~23)
月的某天(0~31) 需計(jì)算
月(0~11)
周幾( 可填1-7 或 SUN/MON/TUE/WED/THU/FRI/SAT)

啟動應(yīng)用,可以看到控制臺的信息如下:

SpringBoot如何創(chuàng)建定時任務(wù)

誠然,使用Scheduled 確實(shí)很方便,但缺點(diǎn)是當(dāng)我們調(diào)整了執(zhí)行周期的時候,需要重啟應(yīng)用才能生效,這多少有些不方便。為了達(dá)到實(shí)時生效的效果,可以使用接口來完成定時任務(wù)。

二、動態(tài)定時任務(wù)(基于接口)

為了演示效果,這里選用 Mysql數(shù)據(jù)庫 和 Mybatis 來查詢和調(diào)整定時任務(wù)的執(zhí)行周期,然后觀察定時任務(wù)的執(zhí)行情況。

1.引入依賴

  <!--依賴管理 -->
  <dependencies>
    <dependency><!--添加Web依賴 -->
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency><!--添加Mybatis依賴 -->
      <groupId>org.mybatis.spring.boot</groupId>
      <artifactId>mybatis-spring-boot-starter</artifactId>
      <version>1.3.1</version>
    </dependency>
    <dependency><!--添加MySql依賴 -->
      <groupId>mysql</groupId>
      <artifactId>mysql-connector-java</artifactId>
      <scope>runtime</scope>
    </dependency>
    <dependency><!--添加Test依賴 -->
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
    </dependency>
  </dependencies>

2.添加數(shù)據(jù)庫記錄

在Navicat 連接本地?cái)?shù)據(jù)庫,隨便打開查詢窗口,然后執(zhí)行腳本內(nèi)容,如下:

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

SpringBoot如何創(chuàng)建定時任務(wù)

然后在項(xiàng)目中的application.yml 添加數(shù)據(jù)源:

#application.yml 配置如下:

spring:
 datasource:
  url: jdbc:mysql://localhost:3306/socks?useSSL=false
  username: root
  password: root

3.創(chuàng)建定時器

數(shù)據(jù)庫準(zhǔn)備好數(shù)據(jù)之后,我們編寫定時任務(wù),注意這里添加的是TriggerTask,目的是循環(huán)讀取我們在數(shù)據(jù)庫設(shè)置好的執(zhí)行周期,以及執(zhí)行相關(guān)定時任務(wù)的內(nèi)容。具體代碼如下:

@Configuration
@EnableScheduling
public class CompleteScheduleConfig implements SchedulingConfigurer {

  @Mapper
  public interface CronMapper {
    @Select("select cron from cron limit 1")
    String getCron();
  }

  @Autowired
  @SuppressWarnings("all")
  CronMapper cronMapper;

  /**
   * 執(zhí)行定時任務(wù).
   */
  @Override
  public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
    taskRegistrar.addTriggerTask(
        //1.添加任務(wù)內(nèi)容(Runnable)
        () -> System.out.println("執(zhí)行定時任務(wù)2: " + LocalDateTime.now().toLocalTime()),
        //2.設(shè)置執(zhí)行周期(Trigger)
        triggerContext -> {
          //2.1 從數(shù)據(jù)庫獲取執(zhí)行周期
          String cron = cronMapper.getCron();
          //2.2 合法性校驗(yàn).
          if (StringUtils.isEmpty(cron)) {
            // Omitted Code ..
          }
          //2.3 返回執(zhí)行周期(Date)
          return new CronTrigger(cron).nextExecutionTime(triggerContext);
        }
    );
  }

}

4. 動態(tài)修改執(zhí)行周期

啟動應(yīng)用后,查看控制臺,打印時間是我們預(yù)期的每5秒一次:

SpringBoot如何創(chuàng)建定時任務(wù)

這時候打開Navicat ,將執(zhí)行周期修改為每1秒執(zhí)行一次,然后觀察控制臺打印效果:

SpringBoot如何創(chuàng)建定時任務(wù)

可以清楚看到執(zhí)行周期已經(jīng)改變,并且不需要我們重啟應(yīng)用,十分方便。

以上是“SpringBoot如何創(chuàng)建定時任務(wù)”這篇文章的所有內(nèi)容,感謝各位的閱讀!希望分享的內(nèi)容對大家有幫助,更多相關(guān)知識,歡迎關(guān)注億速云行業(yè)資訊頻道!

向AI問一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI