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

总结

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

相关文章

  • Maven Settings.xml的基本语法详解

    Maven Settings.xml的基本语法详解

    这篇文章主要为大家介绍了Maven Settings.xml的基本语法详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-11-11
  • Java并发编程之阻塞队列(BlockingQueue)详解

    Java并发编程之阻塞队列(BlockingQueue)详解

    这篇文章主要介绍了详解Java阻塞队列(BlockingQueue)的实现原理,阻塞队列是Java util.concurrent包下重要的数据结构,有兴趣的可以了解一下
    2021-09-09
  • 详解java数组进行翻转的方法有哪些

    详解java数组进行翻转的方法有哪些

    这篇文章主要介绍了详解java数组进行翻转的方法有哪些,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2021-01-01
  • 基于Map的computeIfAbsent的使用场景和使用方式

    基于Map的computeIfAbsent的使用场景和使用方式

    这篇文章主要介绍了基于Map的computeIfAbsent的使用场景和使用方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-09-09
  • Elasticsearch term 查询之精确值搜索功能实现

    Elasticsearch term 查询之精确值搜索功能实现

    term查询是Elasticsearch中用于精确值搜索的一种基本方式,通过了解 term 查询的工作原理和使用方法,你可以更好地利用 Elasticsearch 进行结构化数据的搜索和分析,本文将详细介绍 term 查询的工作原理、使用场景以及如何在 Elasticsearch 中应用它,感兴趣的朋友一起看看吧
    2024-06-06
  • java中response对象用法实例分析

    java中response对象用法实例分析

    这篇文章主要介绍了java中response对象用法,结合实例形式分析了Java中response对象的功能及具体使用技巧,需要的朋友可以参考下
    2015-12-12
  • 解析WeakHashMap与HashMap的区别详解

    解析WeakHashMap与HashMap的区别详解

    本篇文章是对WeakHashMap与HashMap的区别进行了详细的分析介绍,需要的朋友参考下
    2013-05-05
  • MyBatis一次执行多条SQL语句的操作

    MyBatis一次执行多条SQL语句的操作

    这篇文章主要介绍了MyBatis一次执行多条SQL语句的操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-12-12
  • java生成随机数(字符串)示例分享

    java生成随机数(字符串)示例分享

    这篇文章主要介绍了java生成随机数(字符串)示例分享,需要的朋友可以参考下
    2014-03-03
  • spring security需求分析与基础环境准备教程

    spring security需求分析与基础环境准备教程

    这篇文章主要为大家介绍了spring security需求分析与基础环境准备教程,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步
    2022-03-03

最新评论