spring @schedule注解如何動態(tài)配置時間間隔

更新時間：2021年11月02日 10:14:31 作者：zpzkitt

這篇文章主要介紹了spring @schedule注解如何動態(tài)配置時間間隔，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教

@schedule注解動態(tài)配置時間間隔

動態(tài)配置時間間隔是通過自己實現(xiàn)的任務(wù)注冊到任務(wù)調(diào)度實現(xiàn)的，并在每次調(diào)度的時候更改下次調(diào)度時間間隔，如果任務(wù)阻塞或者掛掉了就不會再被調(diào)度了，如果設(shè)置時間過長，到下次調(diào)度就需要等待很長時間。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.Trigger;
import org.springframework.scheduling.TriggerContext;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import org.springframework.scheduling.support.PeriodicTrigger;
import org.springframework.stereotype.Component; 
import java.util.Date; 
 
@Component
@EnableScheduling
public class DynamicScheduleTaskSecond implements SchedulingConfigurer {
    private static final long WEEK_MILLIS = 604800000;
    private static final long MIN_MILLIS = 1000;
    private static long period = 1000;
    static long l = System.currentTimeMillis();
 
    @Autowired
    SetPeriod setPeriod; 
    public static long getPeriod() {
        return period;
    }
 
    public static void setPeriod(long period) {
        DynamicScheduleTaskSecond.period = period;
    }
 
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.addTriggerTask(new Runnable() {
            @Override
            public void run() {
                try {
                    setPeriod.update(period);
                    System.out.println("abc");
                    Long last = System.currentTimeMillis() - l;
                    l = System.currentTimeMillis();
                    System.out.println(last);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }, new Trigger() {
            @Override
            public Date nextExecutionTime(TriggerContext triggerContext) {
                if (period < MIN_MILLIS || period > WEEK_MILLIS)
                    period = MIN_MILLIS;
                PeriodicTrigger periodicTrigger = new PeriodicTrigger(period);
                Date nextExecDate = periodicTrigger.nextExecutionTime(triggerContext);
                return nextExecDate;
            }
        });
    }
}

  
import org.springframework.stereotype.Component; 
@Component
public class SetPeriod { 
    private static Long maxPeriod = 1000l; 
    public void update(Long period) {
        maxPeriod += 1000;
        setScheduleConfig(maxPeriod);
    }
 
    public boolean setScheduleConfig(Long period) {
        DynamicScheduleTaskSecond.setPeriod(period);
        return true;
    }
}

上面是實現(xiàn)動態(tài)調(diào)度的一個簡單實例，下面說一下基本原理。

動態(tài)調(diào)度功能主要是實現(xiàn)SchedulingConfigurer函數(shù)式接口，接口中的方法configureTasks的參數(shù)是重點。

@FunctionalInterface
public interface SchedulingConfigurer {
 
 /**
  * Callback allowing a {@link org.springframework.scheduling.TaskScheduler
  * TaskScheduler} and specific {@link org.springframework.scheduling.config.Task Task}
  * instances to be registered against the given the {@link ScheduledTaskRegistrar}.
  * @param taskRegistrar the registrar to be configured.
  */
 void configureTasks(ScheduledTaskRegistrar taskRegistrar); 
}

看名字 ScheduledTaskRegistrar就知道是一個調(diào)度任務(wù)注冊類，調(diào)用這個類的addTriggerTask方法需要兩個參數(shù)

    public void addTriggerTask(Runnable task, Trigger trigger) {
        this.addTriggerTask(new TriggerTask(task, trigger));
    }

一個是任務(wù)線程這個最后說，先說一下第二個Trigger，這是一個設(shè)置任務(wù)觸發(fā)時間的接口，具體的實現(xiàn)有兩個類，一個是CronTrigger對應(yīng)的就是cron類型的時間設(shè)置，一個是PeriodicTrigger對應(yīng)的就是FixDelay和FixRate兩種方式的時間設(shè)置，實例中使用的是后者。

public interface Trigger {
    @Nullable
    Date nextExecutionTime(TriggerContext var1);
}

接口方法參數(shù)是一個TriggerContext，這個參數(shù)就是任務(wù)觸發(fā)的上下文，里面保存著上一次任務(wù)開始時間和結(jié)束時間和實際執(zhí)行用時，自己需要實現(xiàn)這個nextExecutionTime方法根據(jù)上一次任務(wù)執(zhí)行時間來返回一個新的Date時間，new一個新的periodicTrigger對象初始化period時間間隔為新的時間間隔用nextExecutionTime方法就可以了根據(jù)上下文時間返回一個新的任務(wù)調(diào)度時間了，但是period的時間不能太長也不能太短最好設(shè)置一個區(qū)間，這樣可以避免很多粗心的錯誤導(dǎo)致的麻煩，到此完美解決動態(tài)設(shè)置任務(wù)調(diào)度時間間隔功能。

再說一下第一個線程任務(wù)中的需要做的事，執(zhí)行的任務(wù)需要在其他的具體類中實現(xiàn)，然后在這個線程中調(diào)用，然后每次在調(diào)度任務(wù)的時候就要根據(jù)時間業(yè)務(wù)重新設(shè)置時間間隔，比如讀配置后改變時間間隔，也就是調(diào)度和具體的任務(wù)形成一個環(huán)，調(diào)度執(zhí)行具體的任務(wù)后，具體的任務(wù)在設(shè)置調(diào)度的時間間隔。

spring 注解式Schedule配置定時任務(wù)

@Component
public class ScheduledTasks {
    @Autowired
    private ActivityService activityService;
//    1000即1s
    @Scheduled(fixedRate = 1000)
    public void reportCurrentTime() {
        System.out.println("當(dāng)前時間: " + DateUtil.getNow());
        log.info("打印當(dāng)前時間: {}.", DateUtil.getNow());
    }
    /*每天四點更新一次*/
    @Scheduled(cron = "0 0 4 * * ? ")
    public void updateRankLIstToRedis() {
        /* redis超時設(shè)置 expire多次設(shè)置會覆蓋 */
        List<RankInfoDTO> list = activityService.countRankList(ACTIVITY_WEB);
    }
}

很簡單，要注意的是設(shè)置時間間隔有兩種 corn和fixedRate，一種適用于較長的時間而且能設(shè)置特定時間，一種則較短。

cron的話，百度第一個就是傻瓜式工具網(wǎng)頁，不用怕不會寫。

以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: