Spring Boot配置動(dòng)態(tài)更新問(wèn)題

更新時(shí)間：2023年09月16日 14:36:40 作者：云原生之家

這篇文章主要介紹了Spring Boot配置動(dòng)態(tài)更新問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

SpringBoot配置動(dòng)態(tài)更新

解釋

配置動(dòng)態(tài)更新在本文中指當(dāng)更改應(yīng)用的配置項(xiàng)后，無(wú)需要重啟應(yīng)用新配置即可生效。

概述

配置動(dòng)態(tài)更新是應(yīng)用的一種通用性需求，很實(shí)現(xiàn) 的方式有很多種，如監(jiān)聽配置文件內(nèi)容變化、使用配置中心等等。

Spring Boot在配置動(dòng)態(tài)更新上本身提供了支持，我們?cè)谖词褂门渲弥行牡那闆r也可以簡(jiǎn)單地實(shí)現(xiàn)配置動(dòng)態(tài)更新。

實(shí)現(xiàn)方式

添加依賴包：spring-boot-starter-actuator、spring-cloud-starter-config，其中spring-boot-starter-actuator為Spring Boot提供的應(yīng)用監(jiān)控與管理模塊，spring-cloud-starter-config提供了refresh端點(diǎn)(endpoint)
使用@Value注解引用配置文件(如application.xml)中配置項(xiàng)
在類或者方法上添加@RefreshScope注解
啟動(dòng)應(yīng)用
在配置文件中添加management.security.enabled=false配置項(xiàng)，用于關(guān)閉管理模塊安全認(rèn)證，否則需要用戶登錄與相關(guān)權(quán)限
更改配置文件(如application.xml)中配置項(xiàng)
向refresh端點(diǎn)(endpoint)發(fā)送post請(qǐng)求，即通過(guò)post訪問(wèn)http://host:port/refresh
訪問(wèn)refresh端點(diǎn)后，Spring Boot會(huì)判斷哪些配置項(xiàng)發(fā)生了更改，添加了·@RefreshScope注解的bean如果引用了被更改配置項(xiàng)則會(huì)重新創(chuàng)建bean實(shí)例。

創(chuàng)建新的bean實(shí)例后再獲取相應(yīng)bean時(shí)，bean中的配置值已動(dòng)態(tài)更新完成。

SpringBoot設(shè)置動(dòng)態(tài)定時(shí)任務(wù)

在不借助Nacos、Apollo等配置中心情況下，實(shí)現(xiàn)動(dòng)態(tài)修改定時(shí)任務(wù)執(zhí)行時(shí)間

實(shí)現(xiàn)

1、配置文件

#每5秒鐘執(zhí)行一次任務(wù)
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、定時(shí)任務(wù)配置類

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;
/**
?* 動(dòng)態(tài)定時(shí)任務(wù)，可即時(shí)修改執(zhí)行時(shí)間
?*
?* @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) {
? ? ? ? // 動(dòng)態(tài)使用cron表達(dá)式設(shè)置循環(huán)間隔
? ? ? ? taskRegistrar.addTriggerTask(
? ? ? ? ? ? ? ? // 需要執(zhí)行的任務(wù)
? ? ? ? ? ? ? ? () -> LOGGER.info("Now time:{}", LocalDateTime.now()),
? ? ? ? ? ? ? ? // 傳入定時(shí)任務(wù)觸發(fā)器的上下文，構(gòu)建一個(gè)新的cron觸發(fā)器對(duì)象，并獲取下次執(zhí)行的時(shí)間
? ? ? ? ? ? ? ? triggerContext -> {
? ? ? ? ? ? ? ? ? ? // 使用CronTrigger觸發(fā)器，可動(dòng)態(tài)修改cron表達(dá)式來(lái)操作循環(huán)規(guī)則
? ? ? ? ? ? ? ? ? ? CronTrigger cronTrigger = new CronTrigger(cronProperties.getCron());
? ? ? ? ? ? ? ? ? ? // 計(jì)算出下次執(zhí)行時(shí)間
? ? ? ? ? ? ? ? ? ? return cronTrigger.nextExecutionTime(triggerContext);
? ? ? ? ? ? ? ? });
? ? ? ? LOGGER.info("init success!");
? ? }
}

非lambda表達(dá)式形式

? ? @Override
? ? public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
? ? ? ? // 需要執(zhí)行的任務(wù)
? ? ? ? Runnable runnable = new Runnable() {
? ? ? ? ? ? @Override
? ? ? ? ? ? public void run() {
? ? ? ? ? ? ? ? LOGGER.info("Now time:{}", LocalDateTime.now());
? ? ? ? ? ? }
? ? ? ? };
? ? ? ? // 構(gòu)建一個(gè)新的cron觸發(fā)器對(duì)象，并獲取下次執(zhí)行的時(shí)間
? ? ? ? Trigger trigger = new Trigger() {
? ? ? ? ? ? @Override
? ? ? ? ? ? public Date nextExecutionTime(TriggerContext triggerContext) {
? ? ? ? ? ? ? ? // 使用CronTrigger觸發(fā)器，可動(dòng)態(tài)修改cron表達(dá)式來(lái)操作循環(huán)規(guī)則
? ? ? ? ? ? ? ? CronTrigger cronTrigger = new CronTrigger(cronProperties.getCron());
? ? ? ? ? ? ? ? // 計(jì)算出下次執(zhí)行時(shí)間
? ? ? ? ? ? ? ? return cronTrigger.nextExecutionTime(triggerContext);
? ? ? ? ? ? }
? ? ? ? };
? ? ? ? taskRegistrar.addTriggerTask(runnable, trigger);
? ? ? ? LOGGER.info("init success!");
? ? }

4、修改cron表達(dá)式的接口

該接口可以的http的也可以是其他形式的，核心邏輯就是修改ScheduleCronProperties 對(duì)象的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表達(dá)式修改
*
* @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 這里可以回寫配置文件或者數(shù)據(jù)庫(kù)
? ? ? ?return JSONObject.toJSONString(scheduleCronProperties);
? ?}
}

測(cè)試

項(xiàng)目啟動(dòng)，自動(dòng)執(zhí)行初始的5秒鐘執(zhí)行一次的任務(wù)，結(jié)果如下：

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

調(diào)用接口修改cron表達(dá)式

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

修改后，任務(wù)執(zhí)行結(jié)果如下：

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