使用Spring Cloud Bus刷新配置

在上一节Spring Cloud Config统一配置管理中，我们实现了通过往Config-Client发送/refreshPOST请求来刷新配置。不过这种方式只对单个Config-Client有效（往哪个Config-Client发送刷新请求，哪个配置就得到刷新，剩下的Config-Client获取的仍是旧的配置信息）。当Config-Client实例集群数量较多时，如果都要手动一个一个去刷新配置，不仅麻烦还容易遗漏。值得庆幸的是，我们可以借助Spring Cloud Bus来自动刷新集群的配置信息。

Spring Cloud Bus使用轻量级的消息代理（如RabbitMQ，Kafka）连接分布式系统的节点，可以以广播的形式将一些变更信息（如配置的变更）扩散到分布式链路中去。所以我们可以在Config-Server和Config-Client集群中加入Spring Cloud Bus，然后往某个Config-Server实例发送/refresh请求来刷新集群中所有实例的配置信息。

在引入Spring Cloud Bus之前，我们先来简单验证下开头的结论。我们用上一节的源码为基础，来搭建Eureka-Server、Config-Server和Config-Client的集群。

将这三个项目打成jar包后，分别使用以下命令来启动一个双节点的Eureka-Server集群：

1 2	java -jar Eureka-Service-0.0.1-SNAPSHOT.jar --spring.profiles.active=peer1 java -jar Eureka-Service-0.0.1-SNAPSHOT.jar --spring.profiles.active=peer2

然后分别使用以下命令来启动一个双节点的Config-Server集群：

1 2	java -jar Config-Server-0.0.1-SNAPSHOT.jar --server.port=12579 java -jar Config-Server-0.0.1-SNAPSHOT.jar --server.port=12580

最后分别使用以下命令来启动一个双节点的Config-Client集群：

1 2	java -jar Config-Client-0.0.1-SNAPSHOT.jar --server.port=12581 java -jar Config-Client-0.0.1-SNAPSHOT.jar --server.port=12582

访问http://localhost:8080/查看集群节点是否都启动成功：

这时候我们访问http://localhost:12581/message查看message的值：

接着手动修改Git仓库里的message值为'呵呵呵呵'，并往12581端口的Config-Client发送刷新请求：

1 2	> curl -u mrbird:123456 -X POST http://localhost:12581/refresh ["config.client.version","message"]

再次访问http://localhost:12581/message：

可以看到12581端口的Config-Client获取的配置信息已经得到了更新，那12582端口的Config-Client呢？访问http://localhost:12582/message看看结果：

可看到，其获取的配置仍然是旧的。这也证实了我们一开始的结论。

引入Spring Cloud Bus

Spring Cloud Bus支持RabbitMQ和Kafka等消息中间件，这里只介绍配合RabbitMQ的使用方式。RabbitMQ的安装与启动可以参考https://mrbird.cc/Spring-Cloud-Hystrix-Dashboard.html中的介绍。

在Config-Server和Config-Client的pom中引入spring-cloud-starter-bus-amqp和spring-boot-starter-actuator依赖：

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

其中spring-cloud-starter-bus-amqp是Spring Cloud Bus的RabbitMQ实现，刷新用的端点由spring-boot-starter-actuator提供。

然后在Config-Server和Config-Client的application.yml中引入RabbitMQ的连接信息：

spring:
  rabbitmq:
    # RabbitMQ IP
    host: localhost
    # RabbitMQ Port
    port: 5672
    # default RabbitMQ username
    username: guest
    # default RabbitMQ password
    password: guest