1. 概述

Spring Cloud Bus 配合 Spring Cloud Config 使用可以實現配置的動態刷新。

Spring Cloud Bus 是用來將分布式系統的節點與輕量級消息系統鏈接起來的框架，它整合了 Java 的事件處理機制和消息中間件的功能。

Spring Clud Bus目前支持 RabbitMQ 和 Kafka。

 

Spring Cloud Bus 能管理和傳播分布式系統間的消息,就像一個分布式執行器， 可用于廣 播狀態更改、事件推送等，也可以當作微服務間的通信通道
 

 

什么是總線：

在微服務架構的系統中，通常會使用輕量級的消息代理來構建一個共用的消息主題， 并讓系統中所有微服務實例都連接上來。由于該主題中產生的消息會被所有實例監聽和消費，所以稱它為消息總線。在總線上的各個實例，都可以方便地廣播一些需要讓其他連接在該主題上的實例都知道的消息。

基本原理：

ConfigClient 實例都監聽MQ中同一個topic(默認是springCloudBus)。當一個服務刷新數據的時候，它會把這個信息放入到Topic中,這樣其它監聽同一Topic的服務就能得到通知，然后去更新自身的配置。
 

2. 動態刷新全局廣播

2.1  設計思路

 思路一：利用消息總線觸發一個客戶端/bus/refresh，而刷新所有客戶端的配置（圖1 模式）

思路二：利用消息總線觸發一個服務端 ConfigServer 的 /bus/refresh 端點，而刷新所有客戶端的配置（圖2模式）

思路一打破了微服務的職責單一性，因為微服務本身是業務模塊，它本不應該承擔配置刷新職責，破壞了微服務各節點的對等性。所以選用思路二。

2.2 實現

準備三個微服務（一個服務端3344，兩個客戶端3355、3366）。

2.2.1 服務端

pom:

<dependencies>
	<!--添加消息總線支持-->
	<dependency>
		<groupId>org.springframework.cloud</groupId>
		<artifactId>spring-cloud-starter-bus-amqp</artifactId>
	</dependency>
	<!--分布式配置支持-->
	<dependency>
		<groupId>org.springframework.cloud</groupId>
		<artifactId>spring-cloud-config-server</artifactId>
	</dependency>
	<dependency>
		<groupId>org.springframework.cloud</groupId>
		<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
	</dependency>
	<dependency>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-web</artifactId>
	</dependency>
	<!--監控支持-->
	<dependency>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-actuator</artifactId>
	</dependency>
</dependencies>

application.yml:

server:
  port: 3344
spring:
  application:
    name: cloud-config-center
  cloud:
    config:
      server:
        git:
          uri:  [email protected]:Zhangtao153/springcloud-config.git
          search-paths:
            - springcloud-config
      label: master
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

eureka:
  client:
    service-url:
      defaultZone:  http://localhost:7001/eureka

# 暴露 bus 刷新配置的端點
management:
  endpoints:
    web:
      exposure:
        include: 'bus-refresh'

啟動類：

@SpringBootApplication
@EnableConfigServer
public class ConfigCenterMain3344 {
    public static void main(String[] args){
        SpringApplication.run(ConfigCenterMain3344.class,args);
    }
}

2.2.2 客戶端

pom:

<dependencies>
	<dependency>
		<groupId>org.springframework.cloud</groupId>
		<artifactId>spring-cloud-starter-bus-amqp</artifactId>
	</dependency>
	<dependency>
		<groupId>org.springframework.cloud</groupId>
		<artifactId>spring-cloud-starter-config</artifactId>
	</dependency>
	<dependency>
		<groupId>org.springframework.cloud</groupId>
		<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
	</dependency>
	<dependency>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-web</artifactId>
	</dependency>
	<dependency>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-actuator</artifactId>
	</dependency>
</dependencies>

bootstrap.yml:

server:
  port: 3355

spring:
  application:
    name: config-client
  cloud:
    config:
      label: master  # 分支
      name: config   # 配置文件名
      profile: dev   # 環境
      uri: http://localhost:3344
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest
eureka:
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka

management:
  endpoints:
    web:
      exposure:
        include: "*"

啟動類：

@SpringBootApplication
public class ConfigClientMain3355 {
    public static void main(String[] args){
        SpringApplication.run(ConfigClientMain3355.class,args);
    }
}

業務類：

@RestController
@RefreshScope
public class ConfigClientController {
    @Value("${server.port}")
    private String serverPort;

    @Value("${config.info}")
    private String configInfo;
    
    @GetMapping("/configInfo")
    public String getConfigInfo(){
        return "serverPort:"+serverPort+"\t\n\n configInfo: "+configInfo;
    }
}

2.2.3 測試

修改 github 配置文件

發送 post 請求： curl -X POST "http://localhost:3344/actuator/bus-refresh"

配置中心：http://localhost:3344/master/config-dev.yml

客戶端： http://localhost:3355/configInfo

http://localhost:3366/configInfo 

3. 動態刷新定點通知

指定具體某一個實例生效而不是全部。比如只通知 3355，不通知3366。

通知方式：

http://localhost:配置中心的端口號/actuator/bus-refresh/{destination}

/bus/refresh 請求不再發送到具體的服務實例上，而是發給config server并通過destination參數類指定需要更新配置的服務或實例。

3.1 案例

通知 3355而不通知 3366。

修改 github 配置文件。

發送 post 請求： curl -X POST "http://localhost:3344/actuator/bus-refresh/config-client:3355"

 

配置中心：http://localhost:3344/master/config-dev.yml    已更新

客戶端： http://localhost:3355/configInfo   已更新

http://localhost:3366/configInfo   未更新