中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

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

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

spring boot task實現動態創建定時任務的方法

發布時間:2020-09-26 03:51:17 來源:腳本之家 閱讀:279 作者:centychen 欄目:編程語言

在Spring Boot項目中,通過@EnableScheduling可啟用Spring自帶的定時任務支持,在通過@Scheduled注解定義定時任務,但是通過注解只能編寫固定時間的定時任務,無法動態調整定時間隔,可通過實現SchedulingConfigurer接口實現動態定時任務注冊。

對比Quartz的優缺點

優點:配置非常簡單
缺點:

  • 不支持分布式部署
  • 不支持動態配置定時任務
  • 不支持持久化

其實這幾個缺點歸根結底都是因為不支持持久化,所以如果項目需要持久化定時任務,還是要選擇Quartz比較好。

參考代碼:

package org.cent.demo.scanner.schedule;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
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.util.Arrays;
import java.util.List;

/**
 * @author: cent
 * @email: 292462859@qq.com
 * @date: 2019/1/16.
 * @description:
 */
@Configuration
@EnableScheduling
@Slf4j
public class DynamicSchedule implements SchedulingConfigurer {

 /**
 * 測試數據,實際可從數據庫獲取
 */
 private List<Task> tasks = Arrays.asList(
  new Task(1, "任務1", "*/30 * * * * *"),
  new Task(2, "任務2", "*/30 * * * * *"),
  new Task(3, "任務3", "*/30 * * * * *"),
  new Task(4, "任務4", "*/30 * * * * *"),
  new Task(5, "任務5", "*/30 * * * * *"),
  new Task(6, "任務6", "*/30 * * * * *"),
  new Task(7, "任務7", "*/30 * * * * *"),
  new Task(8, "任務8", "*/30 * * * * *"),
  new Task(9, "任務9", "*/30 * * * * *"),
  new Task(10, "任務10", "*/30 * * * * *")
 );

 @Override
 public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
 tasks.forEach(task -> {
  //任務執行線程
  Runnable runnable = () -> log.info("execute task {}", task.getId());

  //任務觸發器
  Trigger trigger = triggerContext -> {
  //獲取定時觸發器,這里可以每次從數據庫獲取最新記錄,更新觸發器,實現定時間隔的動態調整
  CronTrigger cronTrigger = new CronTrigger(task.getCron());
  return cronTrigger.nextExecutionTime(triggerContext);
  };

  //注冊任務
  scheduledTaskRegistrar.addTriggerTask(runnable, trigger);
 });

 }

 @Data
 @AllArgsConstructor
 static class Task {
 /**
  * 主鍵ID
  */
 private int id;
 /**
  * 任務名稱
  */
 private String name;
 /**
  * cron表達式
  */
 private String cron;
 }
}

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持億速云。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

仁怀市| 仲巴县| 黔西| 鸡东县| 高州市| 博兴县| 中牟县| 共和县| 扶风县| 平阳县| 习水县| 永济市| 唐河县| 通道| 建德市| 精河县| 辽中县| 谷城县| 嵩明县| 唐海县| 东至县| 政和县| 庆云县| 武夷山市| 卫辉市| 德清县| 海盐县| 浦江县| 阿拉善左旗| 柯坪县| 昭平县| 丰镇市| 吴堡县| 宿松县| 偏关县| 洪雅县| 东丰县| 阳城县| 寿宁县| 赤水市| 徐水县|