SpringBoot 設(shè)置動態(tài)定時任務(wù)

IT那活兒發(fā)布于2023-01-11 13:19 / 1626人閱讀

點擊上方“IT那活兒”公眾號，關(guān)注后了解更多內(nèi)容，不管IT什么活兒，干就完了?。?！

在我們平時開發(fā)的過程中，定時任務(wù)的使用很常見，SpringBoot 定時任務(wù)是SpringBoot框架自帶而且很容易上手的。一般cron表達式都是在配置文件中配置或者直接寫死，這樣就會顯得比較死板，那么我分享一下我最近學(xué)到的動態(tài)使用SpringBoot 定時任務(wù)。

這里我們直接上代碼，在配置文件application.yml中配置好初始cron表達式。

讓定時任務(wù)跑起來，下圖可以看出定時任務(wù)是我們正常配置的10s跑一次。

動態(tài)配置定時任務(wù)--CronTrigger

下面我們開始進行動態(tài)配置定時任務(wù)，上代碼：

package com.shsnc.test;

import lombok.Data;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.Trigger;
import org.springframework.scheduling.TriggerContext;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import org.springframework.scheduling.support.CronTrigger;
import org.springframework.scheduling.support.PeriodicTrigger;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;
import java.util.Date;

/**
* @Author: duanxichao
* @CreateTime: 2022-10-20 10:38
* @Description: TODO
*/
@Data
@Component
public class TestScheduleTask implements SchedulingConfigurer {

   private static final Logger logger = LoggerFactory.getLogger(SchedulingConfigurer.class);

   @Value("${scheduled.testCron}")
   private String cron;

   private Long timer = 10000L;

   @Override
   public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
       // 動態(tài)使用cron表達式設(shè)置循環(huán)間隔
       taskRegistrar.addTriggerTask(new Runnable() {
           @Override
           public void run() {
               logger.info("Current time：{}", LocalDateTime.now());
           }
       }, new Trigger() {
           @Override
           public Date nextExecutionTime(TriggerContext triggerContext) {
               // 使用CronTrigger觸發(fā)器，可動態(tài)修改cron表達式來操作循環(huán)規(guī)則
               CronTrigger cronTrigger = new CronTrigger(cron);
               Date nextExecutionTime = cronTrigger.nextExecutionTime(triggerContext);

               // 使用不同的觸發(fā)器，為設(shè)置循環(huán)時間的關(guān)鍵，區(qū)別于CronTrigger觸發(fā)器，該觸發(fā)器可隨意設(shè)置循環(huán)間隔時間，單位為毫秒
// PeriodicTrigger periodicTrigger = new PeriodicTrigger(timer);
// Date nextExecutionTime = periodicTrigger.nextExecutionTime(triggerContext);
               return nextExecutionTime;
           }
       });
   }
}

以上是第一種動態(tài)配置定時任務(wù)代碼，使用的是CronTrigger觸發(fā)器。

下面寫一個接口測試一下效果：

接口如圖：

此上圖我們可以看出定時任務(wù)已經(jīng)從最開始的10s執(zhí)行一次變成了20s執(zhí)行一次。這樣我們就完成了定時任務(wù)時間的修改。

動態(tài)配置定時任務(wù)--PeriodicTrigger

還以一種方式可以通過時間去修改的，可以不使用cron表達式，下面上代碼：

package com.shsnc.test;

import lombok.Data;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.Trigger;
import org.springframework.scheduling.TriggerContext;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import org.springframework.scheduling.support.CronTrigger;
import org.springframework.scheduling.support.PeriodicTrigger;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;
import java.util.Date;

/**
* @Author: duanxichao
* @CreateTime: 2022-10-20 10:38
* @Description: TODO
*/
@Data
@Component
public class TestScheduleTask implements SchedulingConfigurer {

   private static final Logger logger = LoggerFactory.getLogger(SchedulingConfigurer.class);

   @Value("${scheduled.testCron}")
   private String cron;

   private Long timer = 10000L;

   @Override
   public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
       // 動態(tài)使用cron表達式設(shè)置循環(huán)間隔
       taskRegistrar.addTriggerTask(new Runnable() {
           @Override
           public void run() {
               logger.info("Current time：{}", LocalDateTime.now());
           }
       }, new Trigger() {
           @Override
           public Date nextExecutionTime(TriggerContext triggerContext) {
               // 使用CronTrigger觸發(fā)器，可動態(tài)修改cron表達式來操作循環(huán)規(guī)則
// CronTrigger cronTrigger = new CronTrigger(cron);
// Date nextExecutionTime = cronTrigger.nextExecutionTime(triggerContext);

               // 使用不同的觸發(fā)器，為設(shè)置循環(huán)時間的關(guān)鍵，區(qū)別于CronTrigger觸發(fā)器，該觸發(fā)器可隨意設(shè)置循環(huán)間隔時間，單位為毫秒
               PeriodicTrigger periodicTrigger = new PeriodicTrigger(timer);
               Date nextExecutionTime = periodicTrigger.nextExecutionTime(triggerContext);
               return nextExecutionTime;
           }
       });
   }
}