说明
之前我们知道了如何使用spring cloud config 进行统一配置，但是，当配置发生了变化的时候，需要服务自行去刷新才能更新。在实际的使用场景中这是一个可怕的工作量，并且容易出错误。这里有一个通用的解决方案，使用spring cloud bus结合消息中间件，通过消息通知的方式进行配置的刷新。
整体架构图
当有配置信息发生变化的时候，会有如下的方式完成配置的刷新和通知
- 向配置中心发送刷新请求 POST /bus/refresh
- 配置中心向消息总线发送消息
- 所有的服务接收消息总线的消息
- 服务向配置中心获取最新的配置信息从而完成配置的刷新工作
使用和验证步骤
- 使用eureka注册服务
- 修改配置中心应用，提供spring cloud bus的支持：演示项目源码
- 修改各个服务，提供spring cloud bus的支持：演示项目源码
- 修改配置文件，并提交到git服务器
- 向配置中心提交 POST /bus/refresh
- 查看各个服务的配置信息，正常情况下应该配置生效
配置中心改造
- 修改pom.xml增加依赖，这里使用RabbitMq作为消息中间件，遵循amqp标准
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
- 配置文件中增加RabbitMq的配置
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
#spring.rabbitmq.username=linxm
#spring.rabbitmq.password=111111
# 打开安全控制，通过/refresh刷新数据
management.security.enabled=false
endpoints.enabled=false
endpoints.refresh.enabled=true
- 正确启动之后，可以发送 POST /bus/refresh 进行验证
服务的改造
与配置中心的改造方法完全一样！
然后就可以启动服务进行验证了！
注意：
我们可以指定刷新范围：通过使用destination参数
- 刷新具体服务
/bus/refresh?destination=mybusservice1:1811
- 刷新某种服务
/bus/refresh?destination=mybusservice1:**
使用kafka做消息中间件
逻辑上与RabbitMq的方法没有区别
- 增加pom.xml依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-bus-kafka</artifactId>
</dependency>
- 修改配置文件
# Kafka的服务端列表，默认值localhost
spring.cloud.stream.kafka.binder.brokers=master,backup
# Kafka服务端的默认端口，当brokers属性中没有配置端口信息时，就会使用这个默认端口
spring.cloud.stream.kafka.binder.defaultBrokerPort=9092
# Kafka服务端连接的ZooKeeper节点列表
spring.cloud.stream.kafka.binder.zkNodes=localhost
# ZooKeeper节点的默认端口，当zkNodes属性中没有配置端口信息时，就会使用这个默认端口
spring.cloud.stream.kafka.binder.defaultZkPort=2181
