Spring Cloud教程 第十二弹 Spring Cloud Config整合Spring Cloud Bus实现配置动态刷新
admin
2024-04-15 13:14:35

Spring Cloud Config整合Spring Cloud Bus

  • 1、回顾
  • 2、手动刷新
  • 3、Spring Cloud Bus动态刷新配置

1、回顾

在上一弹:Spring Cloud教程 第十一弹 Spring Cloud Config连接git和数据库 中介绍了spring cloud config的基本使用,但是配置无法动态刷新,也就是说如果我更改了git或数据库中的配置,项目必须重新启动才能使新配置生效。

注意:

  • 更新配置后,调用config server的HTTP接口是可以获取到新配置的,这是因为config server会实时请求git或数据库,配置当然是最新的,但是config client是感知不到的

下面介绍两种不重启项目便可以刷新配置的方式:

  1. 手动刷新
  2. 整合Spring Cloud Bus实现动态刷新

2、手动刷新

步骤如下。

  1. config client项目的pom.xml中引入spring-boot-starter-actuator依赖,如下所示:
org.springframework.bootspring-boot-starter-actuator

  1. config client配置端点,如下所示:
management:endpoints:web:exposure:include: "*"
  1. 在需要动态刷新的Bean上打@RefreshScope,如下所示:
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
@RefreshScope
public class DynamicRefreshController {@Value("${stuName:\"\"}")private String stuName;@GetMapping("/config")public void init(){System.out.println("stuName="+stuName);}
}
  1. 当修改git、数据库配置时,POST请求config client路径/actuator/refresh,即可手动刷新

3、Spring Cloud Bus动态刷新配置

Spring Cloud Bus 实现配置的动态刷新步骤:

  1. 当git中的配置发生改变后,向config server发送一个 POST请求,请求路径为/actuator/bus-refresh
  2. config server接收到请求后,会将该请求转发给服务总线Spring Cloud Bus
  3. Spring Cloud Bus接到消息后,生成Topic然后会通知给所有config client
  4. config client接收到通知,请求config server拉取最新配置

Spring Cloud Bus需要引入RabbitMQ或Kafka作为消息传输的媒介。

与手动刷新不同,动态刷新的改造主要在config server项目中。

步骤如下:

  1. config server项目中的pom.xml引入依赖,如下所示:
org.springframework.cloudspring-cloud-starter-bus-amqp

org.springframework.bootspring-boot-starter-actuator

  1. config server配置端点,如下所示:
management:endpoints:web:exposure:include: "*"
  1. 安装并运行RabbitMQ
    参考文章:RabbitMQ入门教程
  2. config server配置RabbitMQ
spring:rabbitmq:host: localhostport: 5672username: guestpassword: guest

5.config client引入依赖:

org.springframework.cloudspring-cloud-starter-bus-amqp

  1. config client配置RabbitMQ
spring:rabbitmq:host: localhostport: 5672username: guestpassword: guest

bus-refresh端点原理:

  • /actuator/bus-refresh端点清除RefreshScope缓存并且重新绑定@ConfigurationProperties

相关内容

热门资讯

原创 广... 地处东江上游、坐拥万绿湖的广东河源,是客家美食的天然宝库。这里的味道不追求花哨,只讲究鲜、香、朴、实...
6天假期要来了!可以开始想去哪... 2026年政府工作报告提出 支持有条件的地方推广中小学春秋假 落实职工带薪错峰休假制度 今年2月,苏...
2026年西北大环线无人机指南... 你是不是也和我一样,一想到西北的壮阔,就想带上无人机,把上帝视角的美景统统装进镜头里? 但现实往往很...
迪拜机场传出爆炸声?一北京起飞... 今天稍早前,央视新闻消息 阿联酋迪拜国际机场传出爆炸声 候机楼内部分旅客 被要求紧急疏散至地下一层避...
广州水上游轮票务有限公司:夜游... 在繁华的广州,夜游珠江已成为一道独特的风景线,吸引着无数游客与市民的目光。而在这片璀璨的水域之上,广...