一、概述

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

2、Bus支持兩種消息代理：RabbitMQ和Kafka

3、作用

4、為何被稱為總線

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

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

二、 RabbitMQ環境配置

1、安裝Erlang

下載地址http://erlang.org/download/otp_win64_21.3.exe

2、安裝RabbitMQ

下載地址https://dl.bintray.com/rabbitmq/all/rabbitmq-server/3.7.14/rabbitmq-server-3.7.14.exe

3、進入RabbitMQ安裝目錄下的sbin目錄

4、輸入以下命令啟動管理功能

rabbitmq-plugins enable rabbitmq_management

可視化插件

5、訪問地址查看是否安裝成功

http://localhost:15672/

6、輸入賬號密碼并登錄: guest guest

三、SpringCloud Bus動態刷新全局廣播

1、演示廣播效果，增加復雜度，再以3355為模板再制作一個3366

2、設計思想

① 利用消息總線觸發一個客戶端/bus/refresh,而刷新所有客戶端的配置

② 利用消息總線觸發一個服務端ConfigServer的/bus/refresh端點,而刷新所有客戶端的配置（更加推薦）

③ 圖二的架構顯然更加合適，圖一不適合的原因如下

• 打破了微服務的職責單一性，因為微服務本身是業務模塊，它本不應該承擔配置刷新職責
• 破壞了微服務各節點的對等性
• 有一定的局限性。例如，微服務在遷移時，它的網絡地址常常會發生變化，此時如果想要做到自動刷新，那就會增加更多的修改

3、給cloud-config-center-3344配置中心服務端添加消息總線支持

① POM

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

② YML

server:
  port: 3344
spring:
  application:
    name: cloud-config-center
  cloud:
    config:
      server:
        git:
          uri: https://github.com/radish15/sprincloud-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

management:
  endpoints:
    web:
      exposure:
        include: 'bus-refresh'

4、給cloud-config-center-3355客戶端添加消息總線支持

① POM

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

② 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://eureka7001.com:7001/eureka

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

5、給cloud-config-center-3366客戶端添加消息總線支持

同上

6、測試

① 修改Github上配置文件增加版本號

② 發送Post請求

curl -X POST "http://localhost:3344/actuator/bus-refresh"

③ 測試

一次修改，廣播通知，處處生效

四、SpringCloud Bus動態刷新定點通知

1、不想全部通知，只想定點通知

2、簡單一句話

① 指定具體某一個實例生效而不是全部

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

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

④ 我們這里以刷新運行在3355端口上的config-client為例

只通知3355，不通知3366
curl -X POST “http://localhost:3344/actuator/bus-refresh/config-client:3355”

⑤ 測試

⑥ 通知總結All