我們在Spring Boot專案中，可以通過@EnableScheduling在啟用Spring自帶的定時任務支持，在通過@Scheduled注解定義定時任務，但是通過注解只能撰寫固定時間的定時任務，無法動態調整定時間隔，可通過實作SchedulingConfigurer介面實作動態定時任務注冊，
參考代碼：
package com.environmentCheck.schedule;
import com.environmentCheck.entity.Task;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.quartz.CronExpression;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.Trigger;
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 java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
/**
* @author:z
* @description:任務調度配置類ScheduleConfig
* @Date: 2021/12/15 14:19
* @Param
* @Return
*/
@Configuration
@EnableScheduling
public class CheckDynamicTask implements SchedulingConfigurer {
private static final Logger logger = LoggerFactory.getLogger(CheckDynamicTask.class);
public CheckDynamicTask() {
}
/**
* 執行定時任務.
*
* @param scheduledTaskRegistrar
*/
@Override
public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
//獲取資料庫所有的core運算式
List<Task> taskList = getTask();
if (CollectionUtils.isEmpty(taskList)) {
return;
}
xspTaskList.forEach(task -> {
//1.添加任務內容(Runnable)
Runnable runnable = () -> {
System.out.println("執行定時任務: " + LocalDateTime.now().toLocalTime() + ";" + task.getTaskName());
};
// 2.設定執行周期(Trigger)
Trigger trigger = triggerContext -> {
String cron = task.getTaskCore();
if (StringUtils.isEmpty(cron)) {
logger.error(task.getTaskName()+"cron值為空");
}
if (!CronExpression.isValidExpression(cron)) {
logger.error(task.getTaskName()+"cron合法性校驗不通過");
}
return new CronTrigger(cron).nextExecutionTime(triggerContext);
};
scheduledTaskRegistrar.addTriggerTask(runnable, trigger);
});
}
/**
* 獲取資料庫所有的core運算式
*
* @return
*/
public List<Task> getTask() {
List<Task> taskList = new ArrayList<>();
Task task = new Task();
task.setTaskCore("");
task.setTaskName("");
taskList.add(task);
return taskList;
}
}
@Data
public class Task {
private String taskName;//任務名稱
private String taskCore;//core運算式
}轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/396546.html
標籤：其他
上一篇：會話跟蹤技術