spring@schedule注解如何动态配置时间间隔
⽬录
@schedule注解动态配置时间间隔
spring 注解式Schedule配置定时任务
@schedule注解动态配置时间间隔
动态配置时间间隔是通过⾃⼰实现的任务注册到任务调度实现的，并在每次调度的时候更改下次调度时间间隔，如果任务阻塞或者挂掉了就不会再被调度了，如果设置时间过长，到下次调度就需要等待很长时间。
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.fig.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 = ExecutionTime(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;
}
}
上⾯是实现动态调度的⼀个简单实例，下⾯说⼀下基本原理。
动态调度功能主要是实现SchedulingConfigurer函数式接⼝，接⼝中的⽅法configureTasks的参数是重点。
@FunctionalInterface
public interface SchedulingConfigurer {
/**
* Callback allowing a {@link org.springframework.scheduling.TaskScheduler
* TaskScheduler} and specific {@link org.fig.Task Task}
* instances to be registered against the given the {@link ScheduledTaskRegistrar}.
* @param taskRegistrar the registrar to be configured.
*/
void configureTasks(ScheduledTaskRegistrar taskRegistrar);
}
看名字 ScheduledTaskRegistrar就知道是⼀个调度任务注册类，调⽤这个类的addTriggerTask⽅法需要两个参数
public void addTriggerTask(Runnable task, Trigger trigger) {
this.addTriggerTask(new TriggerTask(task, trigger));
}
⼀个是任务线程这个最后说，先说⼀下第⼆个Trigger，这是⼀个设置任务触发时间的接⼝，具体的实现有两个类，⼀个是CronTrigger对应的就是cron类型的时间设置，⼀个是PeriodicTrigger对应的就是FixDelay和FixRate两种⽅式的时间设置，实例中使⽤的是后者。
public interface Trigger {
@Nullable
Date nextExecutionTime(TriggerContext var1);
}
spring framework需要下载吗接⼝⽅法参数是⼀个TriggerContext，这个参数就是任务触发的上下⽂，⾥⾯保存着上⼀次任务开始时间和结束时间和实际执⾏⽤时，⾃⼰需要实现这个nextExecutionTime⽅法根据上⼀次任务执⾏时间来返回⼀个新的Date时间，new⼀个新的periodicTrigger对象初始化period时间间隔为新的时间间隔⽤nextExecutionTime⽅法就可以了根据上下⽂时间返回⼀个新的任务调度时间了，但是period的时间不能太长也不能太短最好设置⼀个区间，这样可以避免很多粗⼼的错误导致的⿇烦，到此完美解决动态设置任务调度时间间隔功能。
再说⼀下第⼀个线程任务中的需要做的事，执⾏的任务需要在其他的具体类中实现，然后在这个线程中
调⽤，然后每次在调度任务的时候就要根据时间业务重新设置时间间隔，⽐如读配置后改变时间间隔，也就是调度和具体的任务形成⼀个环，调度执⾏具体的任务后，具体的任务在设置调度的时间间隔。
spring 注解式Schedule配置定时任务
@Component
public class ScheduledTasks {
@Autowired
private ActivityService activityService;
// 1000即1s
@Scheduled(fixedRate = 1000)
public void reportCurrentTime() {
System.out.println("当前时间: " + Now());
log.info("打印当前时间: {}.", Now());
}
/*每天四点更新⼀次*/
@Scheduled(cron = "0 0 4 * * ? ")
public void updateRankLIstToRedis() {
/* redis超时设置 expire多次设置会覆盖 */
List<RankInfoDTO> list = untRankList(ACTIVITY_WEB);
}
}
很简单，要注意的是设置时间间隔有两种 corn和fixedRate，⼀种适⽤于较长的时间⽽且能设置特定时间，⼀种则较短。cron的话，百度第⼀个就是傻⽠式⼯具⽹页，不⽤怕不会写。
以上为个⼈经验，希望能给⼤家⼀个参考，也希望⼤家多多⽀持。
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。
发表评论