首页 > 软件编程 > java > SpringBoot配置动态更新

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

总结

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

Spring Boot配置动态更新问题