spring @schedule注解如何动态配置时间间隔
作者:zpzkitt 发布时间:2023-07-29 03:51:14
@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.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;
}
}
上面是实现动态调度的一个简单实例,下面说一下基本原理。
动态调度功能主要是实现SchedulingConfigurer函数式接口,接口中的方法configureTasks的参数是重点。
@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就知道是一个调度任务注册类,调用这个类的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);
}
接口方法参数是一个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("当前时间: " + DateUtil.getNow());
log.info("打印当前时间: {}.", DateUtil.getNow());
}
/*每天四点更新一次*/
@Scheduled(cron = "0 0 4 * * ? ")
public void updateRankLIstToRedis() {
/* redis超时设置 expire多次设置会覆盖 */
List<RankInfoDTO> list = activityService.countRankList(ACTIVITY_WEB);
}
}
很简单,要注意的是 设置时间间隔有两种 corn和fixedRate,一种适用于较长的时间而且能设置特定时间,一种则较短。
cron的话,百度第一个就是傻瓜式工具网页,不用怕不会写。
来源:https://blog.csdn.net/zpzkitt/article/details/99588579
猜你喜欢
- mapper文件使用in("str1","str2")mybatis的xxxMapper.xml文件
- 本文是Neward & Associates的总裁Ted Neward为developerworks独家撰稿“你不知道5个……”系列
- 昨天有朋友在公众号发消息说看不懂await,async执行流,其实看不懂太正常了,因为你没经过社会的毒打,没吃过牢饭就不知道自由有多重要,没
- 引言一个复杂的分布式系统,用户发起一个请求,这个请求可能调用几十到几百个服务,经过很多业务层,而每个业务又是多个机器集群,一个请求具体被随机
- SpringBoot 2.1.4 错误处理机制springboot的自动配置中帮我们配置了相关的错误处理组件,例如访问一个不存在的页面,就会
- 本文实例为大家分享了java实现图片分割指定大小的具体代码,供大家参考,具体内容如下1.使用工具:ThumbnailsThumbnails
- 循环队列结构队列特点队列为一种特殊的线性表,特殊之处在于它只允许在表的前端(front)进行删除操作,而在表的后端(rear)进行插入操作,
- 一、引言Good Good Study,Day Day Up,童鞋点个关注,不迷路,么么哒~~~MP自带的条件构造器虽然很强大,有时候也避免
- 前言链表是一种数据结构,和数组同级。比如,Java中我们使用的ArrayList,其实现原理是数组。而LinkedList的实现原理就是链表
- 一、DMI动态方法调用的其中一种改变form表单中action属性的方式已经讲过了。还有两种,一种是改变struts.xml配置文件中act
- 路径分隔符:Windows下是“\”unix|linux下是“/”考虑到程序的可移植性,创建文件时建议大家选用"/",因
- JAVA中Integer类下的常用方法有哪些?1.进制转换 n进制转10进制 字符串结果Integer.parseInt(String s,
- SpringBoot分离打Jar包的两种方式方式一:基于maven-jar-plugin此方式基于这个小伙伴的配置改的:https://ww
- 最近正式入坑Flutter,首先从环境搭建开始,看了网上好多关于Windows环境搭建的资料,基本都是按官方文档写的,看完的感受是,还不如直
- 前言easyui是一种基于jQuery的用户界面插件集合。easyui为创建现代化,互动,JavaScript应用程序,提供必要的功能。使用
- 咱们废话不多说进入主题、系统主页展示:用户登录后进行系统首页:主要功能模块如下、分角色管理、超级管理员拥有最高权限、可以进行菜单灵活控制、用
- MongoDB是介于关系数据库和非关系数据库之间的一种产品,文件的存储格式为BSON(一种JSON的扩展),这里就主要介绍Java通过使用m
- 想必我们在做项目的时候,都会遇到服务端与客户端交互数据。一般情况下我们都会采用json格式或者xml格式,将服务端的数据转换成这两种格式之一
- 一、简介Android的消息机制主要是指Handler的运行机制,那么什么是Handler的运行机制那?通俗的来讲就是,使用Handler将
- 1、实体类package com.yl.bean;import java.io.Serializable;import java.util.