Spring Boot配置动态更新问题

 更新时间:2023年09月16日 14:36:40   作者:云原生之家  
这篇文章主要介绍了Spring Boot配置动态更新问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

SpringBoot配置动态更新

解释

配置动态更新在本文中指当更改应用的配置项后,无需要重启应用新配置即可生效。

概述

配置动态更新是应用的一种通用性需求,很实现 的方式有很多种,如监听配置文件内容变化、使用配置中心等等。

Spring Boot在配置动态更新上本身提供了支持,我们在未使用配置中心的情况也可以简单地实现配置动态更新。

实现方式

  • 添加依赖包:spring-boot-starter-actuator、spring-cloud-starter-config,其中spring-boot-starter-actuator为Spring Boot提供的应用监控与管理模块,spring-cloud-starter-config提供了refresh端点(endpoint)
  • 使用@Value注解引用配置文件(如application.xml)中配置项
  • 在类或者方法上添加@RefreshScope注解
  • 启动应用
  • 在配置文件中添加management.security.enabled=false配置项,用于关闭管理模块安全认证,否则需要用户登录与相关权限
  • 更改配置文件(如application.xml)中配置项
  • 向refresh端点(endpoint)发送post请求,即通过post访问http://host:port/refresh
  • 访问refresh端点后,Spring Boot会判断哪些配置项发生了更改,添加了·@RefreshScope注解的bean如果引用了被更改配置项则会重新创建bean实例。

创建新的bean实例后再获取相应bean时,bean中的配置值已动态更新完成。

SpringBoot设置动态定时任务

在不借助Nacos、Apollo等配置中心情况下,实现动态修改定时任务执行时间

实现

1、配置文件

#每5秒钟执行一次任务
print.time.cron=0/5 * * * * ?

2、配置类

package com.schedule.demo.config;
import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;
/**
 * @author zhangy
 * @date 2022/10/12 21:05
 */
@Data
@Configuration
public class ScheduleCronProperties {
    @Value("${print.time.cron}")
    private String cron;
}

3、定时任务配置类

package com.schedule.demo.task;
import com.schedule.demo.config.ScheduleCronProperties;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import org.springframework.scheduling.support.CronTrigger;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
/**
 * 动态定时任务,可即时修改执行时间
 *
 * @author zhangy
 * @date 2022/10/12 21:04
 */
@Component
public class DynamicScheduleTask implements SchedulingConfigurer {
    private static final Logger LOGGER = LoggerFactory.getLogger(DynamicScheduleTask.class);
    @Autowired
    private ScheduleCronProperties cronProperties;
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        // 动态使用cron表达式设置循环间隔
        taskRegistrar.addTriggerTask(
                // 需要执行的任务
                () -> LOGGER.info("Now time:{}", LocalDateTime.now()),
                // 传入定时任务触发器的上下文,构建一个新的cron触发器对象,并获取下次执行的时间
                triggerContext -> {
                    // 使用CronTrigger触发器,可动态修改cron表达式来操作循环规则
                    CronTrigger cronTrigger = new CronTrigger(cronProperties.getCron());
                    // 计算出下次执行时间
                    return cronTrigger.nextExecutionTime(triggerContext);
                });
        LOGGER.info("init success!");
    }
}

非lambda表达式形式

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        // 需要执行的任务
        Runnable runnable = new Runnable() {
            @Override
            public void run() {
                LOGGER.info("Now time:{}", LocalDateTime.now());
            }
        };
        // 构建一个新的cron触发器对象,并获取下次执行的时间
        Trigger trigger = new Trigger() {
            @Override
            public Date nextExecutionTime(TriggerContext triggerContext) {
                // 使用CronTrigger触发器,可动态修改cron表达式来操作循环规则
                CronTrigger cronTrigger = new CronTrigger(cronProperties.getCron());
                // 计算出下次执行时间
                return cronTrigger.nextExecutionTime(triggerContext);
            }
        };
        taskRegistrar.addTriggerTask(runnable, trigger);
        LOGGER.info("init success!");
    }

4、修改cron表达式的接口

该接口可以的http的也可以是其他形式的,核心逻辑就是修改ScheduleCronProperties 对象的cron属性

package com.schedule.demo.controller;
import com.alibaba.fastjson.JSONObject;
import com.schedule.demo.config.ScheduleCronProperties;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* cron表达式修改
*
* @author zhangY
* @date 2021-07-15 20:24:19
*/
@RestController
@RequestMapping("/cron")
public class CronController {
   private static final Logger LOGGER = LoggerFactory.getLogger(CronController.class);
   @Autowired
   private ScheduleCronProperties scheduleCronProperties;
   @GetMapping("/get")
   public String get() {
       return JSONObject.toJSONString(scheduleCronProperties);
   }
   @GetMapping("/update")
   public String update(String newCron) {
       String oldCron = scheduleCronProperties.getCron();
       LOGGER.info("update cron, old:[{}] new:[{}]", oldCron, newCron);
       scheduleCronProperties.setCron(newCron);
       //TODO 这里可以回写配置文件或者数据库
       return JSONObject.toJSONString(scheduleCronProperties);
   }
}

测试

项目启动,自动执行初始的5秒钟执行一次的任务,结果如下:

Now time:2022-10-12T22:11:35
Now time:2022-10-12T22:11:40
Now time:2022-10-12T22:11:45
Now time:2022-10-12T22:11:50
Now time:2022-10-12T22:11:55

调用接口修改cron表达式

http://127.0.0.1:8080/cron/update?newCron=0/3 * * * * ?

修改后,任务执行结果如下:

Now time:2022-10-12T22:13:25
Now time:2022-10-12T22:13:27
Now time:2022-10-12T22:13:30
Now time:2022-10-12T22:13:33
Now time:2022-10-12T22:13:36
Now time:2022-10-12T22:13:39

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • JDK数组阻塞队列源码深入分析总结

    JDK数组阻塞队列源码深入分析总结

    在这篇文章当中,我们将通过源码仔细为大家介绍一下JDK具体是如何实现数组阻塞队列的,文中的示例代码讲解详细,感兴趣的可以了解一下
    2022-08-08
  • java15新功能的详细讲解

    java15新功能的详细讲解

    这篇文章主要介绍了java15的新功能,虽然java15并不是长期支持的版本,但是很多新功能还是很有用的。感兴趣的小伙伴可以参考一下
    2021-08-08
  • Java线程池获取池中所有线程列表的方法总结

    Java线程池获取池中所有线程列表的方法总结

    在Java中,获取线程池中所有线程列表并不是一个直接支持的功能,因为线程池的设计通常是为了隐藏和管理底层的线程细节,从而提供更高层次的抽象和并发控制能力,本文给大家介绍了Java线程池获取池中所有线程列表的方法,需要的朋友可以参考下
    2024-10-10
  • 关于@ApiModel和@ApiModelProperty的使用

    关于@ApiModel和@ApiModelProperty的使用

    这篇文章主要介绍了关于@ApiModel和@ApiModelProperty的使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-11-11
  • Java设计模式之命令模式详细解析

    Java设计模式之命令模式详细解析

    这篇文章主要介绍了Java设计模式之命令模式详细解析,命令模式将请求封装成对象,以便使用不同的请求、队列或者日志来参数化其他对象,同时也支持可撤销的操作,需要的朋友可以参考下
    2024-01-01
  • JAVA多线程处理for循环数据详细讲解

    JAVA多线程处理for循环数据详细讲解

    这篇文章主要给大家介绍了关于JAVA多线程处理for循环数据的相关资料,我们在代码中经常需要使用for循环这个操作来达到目的,而当for循环的次数过多时我们会发现执行效率会变的很低,整体耗时非常多,需要的朋友可以参考下
    2023-07-07
  • 详解Spring不同数据库异常如何抽象的

    详解Spring不同数据库异常如何抽象的

    根据spring-jdbc中的定义,所有的数据操作异常都会转换为 DataAccessException,下面这篇文章主要给大家介绍了关于Spring不同数据库异常如何抽象的相关资料,需要的朋友可以参考下
    2021-09-09
  • Android 屏幕分辨率的整理

    Android 屏幕分辨率的整理

    这篇文章主要介绍了Android 屏幕分辨率的整理的相关资料,这里整理了常见的分辨率希望能帮助到大家,需要的朋友可以参考下
    2017-08-08
  • 基于IDEA2018卡死不动的解决方式(好用)

    基于IDEA2018卡死不动的解决方式(好用)

    这篇文章主要介绍了基于IDEA2018卡死不动的解决方式,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2021-02-02
  • Java 动态模拟操作系统进程调度算法

    Java 动态模拟操作系统进程调度算法

    这篇文章主要介绍了采用java语言编程模拟N个进程采用动态高优先权优先进程调度算法。文中代码具有一定的学习价值,感兴趣的小伙伴可以了解一下
    2021-12-12

最新评论