SpringBoot 任務(wù)調(diào)度動態(tài)設(shè)置方式(不用重啟服務(wù))

更新時間：2021年11月01日 11:02:08 作者：飛飛吹泡泡

這篇文章主要介紹了SpringBoot 任務(wù)調(diào)度動態(tài)設(shè)置方式(不用重啟服務(wù))，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教

SpringBoot 任務(wù)調(diào)度動態(tài)設(shè)置

1.初始化入口(注解 @PostConstruct)

@PostConstruct
private void initTimedTask() {
    //初始化任務(wù)調(diào)度器cron，可以從數(shù)據(jù)庫中查詢到cron值
    List<Tweek> tweeks=tweekService.listAll(new Tweek());
    String cron=tweeks.get(0).getCron();
    if("".equals(cron)){
    }else{
        //啟動
        setTaskTimedCron(cron);
    }
}
TimedTask taskt;
public void setTaskTimedCron(String cron) {
    if (null == taskt) {
        taskt= new TimedTask ();
    }
    taskt.restart(cron);
}

2.任務(wù)調(diào)度類

public class TimedTask implements Runnable{
    Logger logger = Logger.getLogger(TimedTask .class);
    private ThreadPoolTaskScheduler threadPoolTaskScheduler;
    @Override
    public void run() {
    
        logger.info("每月最后一天定時發(fā)送彩信任務(wù)啟動準(zhǔn)備發(fā)送!");
        //業(yè)務(wù)邏輯
    }
    /**
     * 設(shè)置cron并啟動
     * @param  cron值
     */
    public void restart(String cron) {
        if (null != this.threadPoolTaskScheduler) {
            ScheduledExecutorService scheduledExecutorService = this.threadPoolTaskScheduler.getScheduledExecutor();
            if (!scheduledExecutorService.isShutdown()) {
                scheduledExecutorService.shutdownNow();
            }
            this.threadPoolTaskScheduler.destroy();
        }
        if (null != cron&& cron.trim().length() > 0) {
            this.threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
            this.threadPoolTaskScheduler.setThreadNamePrefix("timedTask ");
            this.threadPoolTaskScheduler.initialize();
            this.threadPoolTaskScheduler.schedule(this, new CronTrigger(cron));
        }
    }
}

SpringBoot 調(diào)度任務(wù)

1.首先需要用@EnableScheduling

注解到*applicatin.java，用來檢測是否有調(diào)度任務(wù)。

2.@Scheduled 注解用于標(biāo)注

這個方法是一個定時任務(wù)的方法。Spring會自動掃描這個注解，啟動調(diào)度任務(wù)。

package com.david.translate.quartz;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import com.david.translate.service.SysUserService;
@Component
public class TimeQuartz {
    @Autowired
    private SysUserService userService;
    /**
     * 一分鐘執(zhí)行一次
     */
    @Scheduled(cron="0 0/1 * * * ?") 
    public void executeFileDownLoadTask() {
        System.out.println(">>>>>>>>>>>>>>>>>>>任務(wù)執(zhí)行 "+userService.findAll().size());
    }
}

調(diào)度任務(wù)的時間配置用的是cron表達(dá)式，推薦一個在線生成表達(dá)式的網(wǎng)站，如果自己不會寫或者不愿意自己寫，可以用這個網(wǎng)站直接生成：