Bus实现配置自动刷新

Bus实现配置自动刷新 本节内容

加入Bus配合RabbitMQ实现Config配置的动态刷新

改造配置中心

pom

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


	org.springframework.boot
	spring-boot-starter-actuator

配置文件

server:
  port: ${port:9004}
spring:
  application:
    name: configServer
  cloud:
    config:
      server:
        git: # git地址
          uri: https://gitee.com/zxing2021/spring-cloud-config-test.git
  rabbitmq:
    host: localhost
    port: 15672
    username: root
    password: manage
management:
  endpoints:
    web:
      exposure:
        include: "bus-refresh"

改造配置客户端

pom

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

配置文件

server:
  port: ${port:9005}
spring:
  cloud:
    config:
      name: application # 文件名
      profile: test # profile
      label: master # 分支
      uri: http://localhost:9004 # 配置中心地址
  rabbitmq:
    host: localhost
    port: 15672
    username: root
    password: manage
management:
  endpoints:
    web:
      exposure:
        include: "*"

测试全部更新

初始值：2




改成20：




可以看到，此时客户端还没有更新

向配置中心发送一次post请求：



可以看到，两个客户端都更新了。

成功！

测试局部更新

客户端配置文件，加上应用名

spring:
  application:
    name: configClient

初始值：20




修改为2：

向配置中心发送post请求



成功！