Spring Cloud Bus实现配置的动态更新

Spring Cloud Bus通过轻量消息代理连接各个分布的节点。它可用在广播状态的变化或者其他的消息指令。Spring Cloud Bus的一个核心思想是通过分布式的启动器对Spring Boot 应用进行扩展，也可以用来建立一个多个应用之间的通信频道。

 

Spring Cloud Bus整合java的事件处理机制和消息中间件消息的发送和接收，主要由发送端、接收端和事件组成。针对不同的业务需求，可以设置不同的事件，发送端发送事件，接收端接收相应的事件，并进行相应的处理。

 

本文章介绍使用Spring Cloud Bus与Spring Cloud Config的整合，并以RabbitMQ作为消息代理，实现应用配置的动态更新。

 

 动态更新配置的处理过程描述如下：

        1、将最新的配置文件push到git服务器

        2、利用git仓库的Webhook机制监听push事件，事件捕获后，执行配置好的Payload URL地址（此处为配置中心的/actuator/bus-refresh端点）。通过git仓库的 Settings > Webhooks > Add webhook 可以创建Webhook。

        3、配置中心从git获取最新的配置信息，并发送消息到RabbitMQ

        4、微服务节点订阅和接收RabbitMQ消息，接收到消息后，从配置中心获取最新的配置信息

 

 RabbitMQ的安装和配置请自行准备，此处不再介绍。

 

创建配置中心工程config-center：

       在《Spring Cloud Config分布式配置中心》这篇文章的基础上，完善工程的配置。

       在pom.xml文件添加依赖：

<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>

 

       application.properties文件添加配置：

spring.rabbitmq.host=192.168.134.134
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

management.endpoints.web.exposure.include=*
#management.endpoints.web.exposure.include=health,info,refresh,bus-refresh

 

创建消费配置的微服务工程config-consumer工程：

       在《使用配置中心的配置信息》这篇文章的基础上，完善工程的配置。

       在pom.xml文件添加依赖：

<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>

 

      application.properties文件添加配置：

spring.rabbitmq.host=192.168.134.134
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

management.endpoints.web.exposure.include=*
#management.endpoints.web.exposure.include=health,info,refresh,bus-refresh

 

刷新配置

      全量刷新：

             以POST方式请求配置中心的 http://localhost:4001/actuator/bus-refresh 端点

      刷新某个微服务实例的配置：

            http://localhost:4001/actuator/bus-refresh/小写的服务应用名:端口号

            http://localhost:4001/actuator/bus-refresh/config-consumer2:4322

      刷新某个微服务所有实例的配置

            http://localhost:4001/actuator/bus-refresh/小写的服务应用名:**

            http://localhost:4001/actuator/bus-refresh/config-consumer2:**

 

       创建git仓库的Webhook时，Payload URL填写配置中心的 http://localhost:4001/actuator/bus-refresh 端点地址即可。

 

 跟踪总线事件

        如果想知道 Spring Cloud Bus 事件传播的细节，可以跟踪总线事件（RemoteApplicationEvent 的子类都是总线事件）。

        在/actuator/bus-refresh端点被请求后，访问/actuator/httptrace端点即可获得传播的详细信息。