springboot定時任務(wù)的原理是什么

這期內(nèi)容當(dāng)中小編將會給大家?guī)碛嘘P(guān)springboot定時任務(wù)的原理是什么，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

一、基于注解（靜態(tài)）

1、pom 包配置

pom 包里面只需要引入 Spring Boot Starter 包即可

 <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter</artifactId>
 </dependency>
 <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-test</artifactId>
   <scope>test</scope>
 </dependency>

2、創(chuàng)建定時任務(wù)實(shí)現(xiàn)類

定時任務(wù)1：

@Configuration
@EnableScheduling
public class SchedulerTask {

  private int count=0;

  @Scheduled(cron="*/6 * * * * ?")
  private void process(){
    System.out.println("this is scheduler task runing "+(count++));
  }

}

定時任務(wù)2：

@Configuration
@EnableScheduling
public class Scheduler2Task {

  private static final SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");

  @Scheduled(fixedRate = 6000)
  public void reportCurrentTime() {
    System.out.println("現(xiàn)在時間：" + dateFormat.format(new Date()));
  }

}

結(jié)果如下：

this is scheduler task runing 0
現(xiàn)在時間：09:44:17
this is scheduler task runing 1
現(xiàn)在時間：09:44:23
this is scheduler task runing 2
現(xiàn)在時間：09:44:29
this is scheduler task runing 3
現(xiàn)在時間：09:44:35

參數(shù)說明

@Configuration用于標(biāo)記配置類，兼?zhèn)銫omponent的效果。

@EnableScheduling表示開啟定時任務(wù)

@Scheduled 參數(shù)可以接受兩種定時的設(shè)置，一種是我們常用的cron="*/6 * * * * ?",一種是 fixedRate = 6000，兩種都表示每隔六秒打印一下內(nèi)容。

fixedRate 說明

@Scheduled(fixedRate = 6000) ：上一次開始執(zhí)行時間點(diǎn)之后6秒再執(zhí)行

@Scheduled(fixedDelay = 6000) ：上一次執(zhí)行完畢時間點(diǎn)之后6秒再執(zhí)行

@Scheduled(initialDelay=1000, fixedRate=6000) ：第一次延遲1秒后執(zhí)行，之后按 fixedRate 的規(guī)則每6秒執(zhí)行一次

cron屬性，通過表達(dá)式形式指定任務(wù)執(zhí)行規(guī)則，同樣也是從上一次任務(wù)執(zhí)行完畢開始計(jì)時。表達(dá)式規(guī)則如下：

每個位置的規(guī)則如下：

備注：

• 星號(*)：可用在所有字段中，表示對應(yīng)時間域的每一個時刻，例如，*在分鐘字段時，表示“每分鐘”。

• 問號（?）：該字符只在日期和星期字段中使用，它通常指定為“無意義的值”，相當(dāng)于占位符。

• 減號(-)：表達(dá)一個范圍，如在小時字段中使用“10-12”，則表示從10到12點(diǎn)，即10,11,12。

• 逗號(,)：表達(dá)一個列表值，如在星期字段中使用“MON,WED,FRI”，則表示星期一，星期三和星期五。

• 斜杠(/)：x/y表達(dá)一個等步長序列，x為起始值，y為增量步長值。如在秒數(shù)字段中使用0/15，則表示為0,15,30和45秒，而5/15在分鐘字段中表示5,20,35,50，你也可以使用*/y，它等同于0/y。

• L：該字符只在日期和星期字段中使用，代表“Last”的意思，但它在兩個字段中意思不同。L在日期字段中，表示這個月份的最后一天，如一月的31號，非閏年二月的28號；如果L用在星期中，則表示星期六，等同于7。但是，如果L出現(xiàn)在星期字段里，而且在前面有一個數(shù)值X，則表示“這個月的最后X天”，例如，6L表示該月的最后星期五。

• W：該字符只能出現(xiàn)在日期字段里，是對前導(dǎo)日期的修飾，表示離該日期最近的工作日。例如15W表示離該月15號最近的工作日，如果該月15號是星期六，則匹配14號星期五；如果15日是星期日，則匹配16號星期一；如果15號是星期二，那結(jié)果就是15號星期二。但必須注意關(guān)聯(lián)的匹配日期不能夠跨月，如你指定1W，如果1號是星期六，結(jié)果匹配的是3號星期一，而非上個月最后的那天。W字符串只能指定單一日期，而不能指定日期范圍。

• LW組合：在日期字段可以組合使用LW，它的意思是當(dāng)月的最后一個工作日。

• 井號(#)：該字符只能在星期字段中使用，表示當(dāng)月某個工作日。如6#3表示當(dāng)月的第三個星期五(6表示星期五，#3表示當(dāng)前的第三個)，而4#5表示當(dāng)月的第五個星期三，假設(shè)當(dāng)月沒有第五個星期三，忽略不觸發(fā)。

• C：該字符只在日期和星期字段中使用，代表“Calendar”的意思。它的意思是計(jì)劃所關(guān)聯(lián)的日期，如果日期沒有被關(guān)聯(lián)，則相當(dāng)于日歷中所有日期。例如5C在日期字段中就相當(dāng)于日歷5日以后的第一天。1C在星期字段中相當(dāng)于星期日后的第一天。

• cron表達(dá)式對大小寫不敏感。
  

二、基于接口（動態(tài)）

1、pom包配置

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter</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.springframework.boot</groupId>
  <artifactId>spring-boot-starter-test</artifactId>
</dependency>

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

開啟本地數(shù)據(jù)庫mysql，隨便打開查詢窗口，然后執(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) NOT NULL PRIMARY KEY,
 `cron` varchar(30) NOT NULL 
);
INSERT INTO `cron` VALUES ('1', '0/5 * * * * ?');

然后在application.properties文件添加數(shù)據(jù)源

spring.datasource.url=jdbc:mysql://127.0.0.1:3306/socks?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=UTF-8&useSSL=false
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

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

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

package com.cn.service;

import com.cn.dao.CronMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
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.util.StringUtils;

import java.time.LocalDateTime;

@Configuration   //1.主要用于標(biāo)記配置類，兼?zhèn)銫omponent的效果。
@EnableScheduling  // 2.開啟定時任務(wù)
public class DynamicScheduleTask implements SchedulingConfigurer {

  @Autowired
  private CronMapper cronMapper;

  /**
   * 執(zhí)行定時任務(wù).
   */
  @Override
  public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {

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

}

4、啟動測試

然后打開Navicat ，將執(zhí)行周期修改為每10秒執(zhí)行一次，查看控制臺，發(fā)現(xiàn)執(zhí)行周期已經(jīng)改變，并且不需要我們重啟應(yīng)用，十分方便。如圖：

三、Quartz

Quartz是OpenSymphony開源組織在Job scheduling領(lǐng)域又一個開源項(xiàng)目，它可以與J2EE與J2SE應(yīng)用程序相結(jié)合也可以單獨(dú)使用。Quartz可以用來創(chuàng)建簡單或?yàn)檫\(yùn)行十個，百個，甚至是好幾萬個Jobs這樣復(fù)雜的程序。

1.添加依賴

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

2、編寫任務(wù)類

package com.cn.service;
 
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.quartz.QuartzJobBean;

public class MyQuartz extends QuartzJobBean {
 
  private final Logger log = LoggerFactory.getLogger(MyQuartz.class);
 
  @Override
  protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
    log.info("hello quartz");
  }
 
}

3、編寫配置類

package com.cn.config;

import com.cn.service.MyQuartz;
import org.quartz.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
@Configuration
public class QuartzConfig {
 
  @Bean
  public JobDetail myQuartz() {
    return JobBuilder.newJob(MyQuartz.class).withIdentity("MyQuartz").storeDurably().build();
  }
 
  @Bean
  public Trigger studentRankQuartzTrigger() {
    return TriggerBuilder.newTrigger().forJob(myQuartz())
        .withIdentity("MyQuartz")
        .withSchedule(DailyTimeIntervalScheduleBuilder.dailyTimeIntervalSchedule().withInterval(5,		
         DateBuilder.IntervalUnit.SECOND))
        .build();
  }
}

4、啟動項(xiàng)目

每隔5秒打印一次"hello quartz"

上述就是小編為大家分享的springboot定時任務(wù)的原理是什么了，如果剛好有類似的疑惑，不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識，歡迎關(guān)注億速云行業(yè)資訊頻道。