欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

SpringBoot?ScheduledTaskRegistrar解決動態(tài)定時任務(wù)思路詳解

 更新時間:2023年02月01日 09:28:07   作者:Apluemxa  
本文將從問題出發(fā),詳細介紹ScheduledTaskRegistrar類是如何解決動態(tài)調(diào)整定時任務(wù)的思路,并給出關(guān)鍵的代碼示例,幫助大家快速地上手學習

前言

在做SpringBoot項目的過程中,有時客戶會提出按照指定時間執(zhí)行一次業(yè)務(wù)的需求。

如果客戶需要改動業(yè)務(wù)的執(zhí)行時間,即動態(tài)地調(diào)整定時任務(wù)的執(zhí)行時間,那么可以采用SpringBoot自帶的ScheduledTaskRegistrar類作為解決方案來實現(xiàn)。

在單一使用ScheduledTaskRegistrar類解決定時任務(wù)問題的時候,可能會達不到預期的動態(tài)調(diào)整定時任務(wù)的效果。

如果靈活配合使用對應(yīng)的工具類(ThreadPoolTaskScheduler類),則可以方便地對動態(tài)調(diào)整定時任務(wù)進行管理。

本文會從問題出發(fā),詳細介紹ScheduledTaskRegistrar類是如何解決動態(tài)調(diào)整定時任務(wù)的思路,并給出關(guān)鍵的代碼示例,幫助大家快速地上手學習。

一、問題背景

在指定的某一時刻執(zhí)行業(yè)務(wù);

可以手動地更改執(zhí)行時間。

在實際項目中,很少會有傻瓜式地去指定某一時間就觸發(fā)某個業(yè)務(wù)的場景,執(zhí)行業(yè)務(wù)的時間不是一成不變的,而是動態(tài)地隨著客戶所指定的時間進行調(diào)整的。

二、痛點所在

如果單一地使用SpringBoot自帶的ScheduledTaskRegistrar去實現(xiàn),那么可能會有以下問題:

  • 只能按照指定的時間去執(zhí)行,更改執(zhí)行時間需要重啟服務(wù);
  • 無法刪除該定時任務(wù),或者刪除后無法再啟動新的定時任務(wù)。
  • 業(yè)務(wù)邏輯與觸發(fā)器的代碼耦合度太高,無法將業(yè)務(wù)代碼從ScheduledTaskRegistrar類中抽離出去。
/**
 * @author Created by zhuzqc on 2023/1/30 15:28
 */
@Slf4j
@Component
@EnableScheduling
public class ScheduleTaskDemo implements SchedulingConfigurer {

    private Logger logger = LoggerFactory.getLogger(this.getClass());

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {

        //Runnable線程注冊任務(wù)
        Runnable taskOne = () -> {
            //需要執(zhí)行的業(yè)務(wù)邏輯,一般會在這里封裝好
            logger.info("----------業(yè)務(wù)執(zhí)行結(jié)束----------");
        };
        //任務(wù)的觸發(fā)時間,一般使用 cron 表達式
        Trigger triggerOne = triggerContext -> {
            Date nextExecTime = null;
            try {
                // 此處指定 cron 表達式
                String cron = "0 00 12 ? * *";
                if (StringUtils.isBlank(cron)) {
                    // 提示參數(shù)為空
                    logger.info("trigger定時器的 cron 參數(shù)為空!");
                    // 如果為空則賦默認值,每天中午12點
                    cron = "0 00 12 ? * *";
                }
                logger.info("---------->定時任務(wù)執(zhí)行中<---------");
                CronTrigger cronTrigger = new CronTrigger(cron);
                nextExecTime = cronTrigger.nextExecutionTime(triggerContext);
            } catch (Exception e) {
                e.printStackTrace();
                log.info(e.getMessage());
            }
            return nextExecTime;
        };
        taskRegistrar.addTriggerTask(taskOne, triggerOne);
    }
}

上述代碼只能實現(xiàn)在指定的時間去觸發(fā)定時任務(wù),無法對 cron 表達式進行更改,如果更改則需要重新啟動服務(wù),非常地“傻瓜”。

而在實際的編碼過程中,業(yè)務(wù)邏輯代碼需要單獨地剝離開(解耦),如何做到業(yè)務(wù)邏輯代碼和觸發(fā)器代碼都能訪問到外部業(yè)務(wù)數(shù)據(jù),是設(shè)計過程中需要考慮到的關(guān)鍵。

三、解決思路

  • TODO:如果要在此處將業(yè)務(wù)邏輯和時間觸發(fā)器進行捆綁,那么在這個實現(xiàn)類中無法獲取到來自該類外部的業(yè)務(wù)數(shù)據(jù);
  • TODO:要解決這樣的問題,就要找到一個辦法:既能將兩者抽離,又能實現(xiàn)靈活觸發(fā)定時任務(wù)。

在這里介紹一個名為ThreadPoolTaskScheduler類,通過源碼得知,該類實現(xiàn)了SchedulingTaskExecutor和TaskScheduler接口。

該類中schedule(Runnable task, Trigger trigger)方法,通過分別傳入線程任務(wù)(業(yè)務(wù)邏輯)Trigger觸發(fā)器對象作為參數(shù),支持動態(tài)創(chuàng)建指定 cron 表達式的定時任務(wù)

該方法源碼如下:

 	@Override
	@Nullable
	public ScheduledFuture<?> schedule(Runnable task, Trigger trigger) {
		ScheduledExecutorService executor = getScheduledExecutor();
		try {
			ErrorHandler errorHandler = this.errorHandler;
			if (errorHandler == null) {
				errorHandler = TaskUtils.getDefaultErrorHandler(true);
			}
			return new ReschedulingRunnable(task, trigger, this.clock, executor, errorHandler).schedule();
		}
		catch (RejectedExecutionException ex) {
			throw new TaskRejectedException("Executor [" + executor + "] did not accept task: " + task, ex);
		}
	}

以下部分是對該方法的具體使用,核心思路如下 :

  • 實例化ThreadPoolTaskScheduler類對象;
  • 實例化ScheduledFuture類對象,用于初始化調(diào)用schedule()后的值。
  • 將攜帶有Runnable和Trigger的ScheduledFuture類對象作為Map的value進行裝配。
  • 根據(jù)Map的key對定時任務(wù)進行管理,達到添加和刪除的目的。

四、代碼示例

代碼示例分為兩部分:

第一部分是關(guān)于ThreadPoolTaskScheduler類和schedule()方法的使用;

/**
 * @author @author Created by zhuzqc on 2023/1/30 15:39
 * 任務(wù)線程池管理工具
 */
public class TaskSchedulerUtil {

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

    /**
     * 線程調(diào)度工具對象,作為該類的成員變量
     */
    private static ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();

    /**
     *初始化 map 對象,裝配 schedule 方法的返回對象為 value 值
     */
    private static Map<String, ScheduledFuture<?>> scheduledFutureMap = new HashMap<String, ScheduledFuture<?>>();

    static {
        threadPoolTaskScheduler.initialize();
    }

    /**
     * 將Runnable對象和Trigger對象作為參數(shù)傳入該靜態(tài)方法
     * @param runnable
     * @param trigger
     * @param 定時任務(wù)id
     */
    public static void put(Runnable runnable, Trigger trigger, String id) {
        // 將攜帶有Runnable和Trigger的ScheduledFuture類對象作為 Map 的 value 進行裝配
        ScheduledFuture<?> scheduledFuture = threadPoolTaskScheduler.schedule(runnable, trigger);
        // 放入 Map 中作為 value
        scheduledFutureMap.put(id, scheduledFuture);
        logger.info("---添加定時任務(wù)--->" + id);
    }

    /**
     * 通過上述 put 方法的參數(shù)id(定時任務(wù)id)標識,將定時任務(wù)移除出 map
     * @param id
     */
    public static void delete(String id) {
        ScheduledFuture<?> scheduledFuture = scheduledFutureMap.get(id);
        // 條件判斷
        if (scheduledFuture != null && scheduledFuture.isCancelled()) {
            scheduledFuture.cancel(true);
        }
        scheduledFutureMap.remove(id);
        logger.info("---取消定時任務(wù)--->" + id);
    }
}

第二部分是關(guān)于結(jié)合實際業(yè)務(wù),引入實際業(yè)務(wù)數(shù)據(jù)的代碼demo。

/**
 * @author Created by zhuzqc on 2023/1/30 15:58
 */
@Slf4j
@Component
@EnableScheduling
public class TaskScheduleDemo{

    @Resource
    private AAAMapper aaaMapper;
    @Resource
    private BBBService bbbService;

    private Logger logger = LoggerFactory.getLogger(this.getClass());

    // 引入外部的業(yè)務(wù)數(shù)據(jù)對象
    public void putHiredTask(CCCEntity cccEntity){
        //TODO: 將業(yè)務(wù)線程和定時觸發(fā)器交由線程池工具管理:創(chuàng)建業(yè)務(wù)線程對象,并對屬性賦初始化值(有參構(gòu)造)
        TaskSchedulerUtil.put(new TaskThreadDemo(cccEntity,aaaMapper,bbbService), new Trigger() {
            @Override
            public Date nextExecutionTime(TriggerContext triggerContext) {
                //獲取定時觸發(fā)器,這里可以獲取頁面的更新記錄,實現(xiàn)定時間隔的動態(tài)調(diào)整
                Date nextExecTime = TaskTransUtils.StringToDateTime(cccEntity.getSendTime());
                //cron 表達式轉(zhuǎn)換工具類
                String cron = TaskTransUtils.getDateCronTime(nextExecTime);
                try {
                    if (StringUtils.isBlank(cron)) {
                        // 提示參數(shù)為空
                        logger.info("trackScheduler定時器的 cron 參數(shù)為空!");
                        // 如果為空則賦默認值,每天早上9:00
                        cron = "0 00 09 ? * *";
                    }
                    logger.info("-------定時任務(wù)執(zhí)行中:" + cron + "--------");
                    CronTrigger cronTrigger = new CronTrigger(cron);
                    nextExecTime = cronTrigger.nextExecutionTime(triggerContext);
                } catch (Exception e) {
                    e.printStackTrace();
                    log.info(e.getMessage());
                }
                return nextExecTime;
            }
        },"該定時任務(wù)的id");
    }
}

五、文章小結(jié)

動態(tài)定時任務(wù)的總結(jié)如下:

  • 單一使用ScheduledTaskRegistrar類,無法達到預期動態(tài)調(diào)整定時任務(wù)的效果;
  • 實際的開發(fā)場景中,需要業(yè)務(wù)邏輯代碼和觸發(fā)器代碼都能訪問到外部業(yè)務(wù)數(shù)據(jù);
  • 配合ThreadPoolTaskScheduler類和該類中的schedule()方法可以達到動態(tài)調(diào)整定時任務(wù)的效果。

以上就是SpringBoot ScheduledTaskRegistrar解決動態(tài)定時任務(wù)思路詳解的詳細內(nèi)容,更多關(guān)于SpringBoot ScheduledTaskRegistrar的資料請關(guān)注腳本之家其它相關(guān)文章!

相關(guān)文章

  • 淺談一下Servlet的定義以及運行原理

    淺談一下Servlet的定義以及運行原理

    相信有很多剛?cè)胄械呐笥褧苫骃ervlet到底是個什么意思,那么這篇文章就來淺談一下到底什么是Servlet,以及Servlet的原理與如何寫一個Servlet,,需要的朋友可以參考下
    2023-03-03
  • Springboot解決跨域問題方案總結(jié)(包括Nginx,Gateway網(wǎng)關(guān)等)

    Springboot解決跨域問題方案總結(jié)(包括Nginx,Gateway網(wǎng)關(guān)等)

    跨域問題是瀏覽器為了保護用戶的信息安全,實施了同源策略(Same-Origin?Policy),即只允許頁面請求同源(相同協(xié)議、域名和端口)的資源,本文給大家總結(jié)了Springboot解決跨域問題方案包括Nginx,Gateway網(wǎng)關(guān)等),需要的朋友可以參考下
    2024-03-03
  • 使用 Java 類 實現(xiàn)Http協(xié)議

    使用 Java 類 實現(xiàn)Http協(xié)議

    這篇文章主要介紹了用幾個Java類簡單的實現(xiàn)了Http協(xié)議相關(guān)資料,感興趣的的朋友可以參考下面具體的文章內(nèi)容
    2021-09-09
  • springboot實用配置詳細圖文教程

    springboot實用配置詳細圖文教程

    SpringBoot從本質(zhì)上來說就是Spring,它通過了一些自己的特性幫助我們簡化了Spring應(yīng)用程序的開發(fā),下面這篇文章主要給大家介紹了關(guān)于springboot實用配置的相關(guān)資料,文中通過圖文介紹的非常詳細,需要的朋友可以參考下
    2023-05-05
  • JAVA 多態(tài)操作----父類與子類轉(zhuǎn)換問題實例分析

    JAVA 多態(tài)操作----父類與子類轉(zhuǎn)換問題實例分析

    這篇文章主要介紹了JAVA 多態(tài)操作----父類與子類轉(zhuǎn)換問題,結(jié)合實例形式分析了JAVA 多態(tài)操作中父類與子類轉(zhuǎn)換問題相關(guān)原理、操作技巧與注意事項,需要的朋友可以參考下
    2020-05-05
  • java內(nèi)存模型jvm虛擬機簡要分析

    java內(nèi)存模型jvm虛擬機簡要分析

    Java 內(nèi)存模型的主要目的是定義程序中各種變量的訪問規(guī)則, 關(guān)注在虛擬機中把變量值存儲到內(nèi)存和從內(nèi)存中取出變量值這樣的底層細節(jié)
    2021-09-09
  • mybatis in查詢條件過長的解決方案

    mybatis in查詢條件過長的解決方案

    這篇文章主要介紹了mybatis in查詢條件過長的解決方案,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2021-10-10
  • 在Mac OS上安裝Java以及配置環(huán)境變量的基本方法

    在Mac OS上安裝Java以及配置環(huán)境變量的基本方法

    這篇文章主要介紹了在Mac OS上安裝Java以及配置環(huán)境變量的基本方法,包括查看所安裝Java版本的方法,需要的朋友可以參考下
    2015-10-10
  • 詳解Spring Data JPA動態(tài)條件查詢的寫法

    詳解Spring Data JPA動態(tài)條件查詢的寫法

    本篇文章主要介紹了Spring Data JPA動態(tài)條件查詢的寫法 ,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-06-06
  • Java中Object類的理解和使用

    Java中Object類的理解和使用

    Object類是java.lang包下的核心類,Object類是所有類的父類,何一個類時候如果沒有明確的繼承一個父類的話,那么它就是Object的子類,本文將通過代碼示例詳細介紹一下Java中Object類的理解和使用,需要的朋友可以參考下
    2023-06-06

最新評論