本片要點

• 簡要介紹總線的概念，以及分布式系統解決的問題。
• 介紹Docker安裝RabbitMQ的基本命令。
• SpringCloud Bus+ RabbitMQ實現全局動態刷新。

Spring Cloud Bus簡介

https://spring.io/projects/spring-cloud-bus

概述

SpringCloud Bus是將分布式系統的節點與輕量級消息系統鏈接起來的框架，它整合了Java的事件處理機制和消息中間件的功能。目前支持RabbitMQ和Kafka。【本篇文章使用RabbitMQ作為消息代理】

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

SpringCloud Bus可以配合SpringCloud Config實現配置的動態刷新。

什么是總線

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

基本原理

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

Docker安裝RabbitMQ

可以參考：SpringBoot整合RabbitMQ以及Rabbit隊列學習

$ docker pull rabbitmq:3-management # management帶web界面管理
$ docker images  # 查看image ID

$ docker run -d --name myrabbit -p 5672:5672 -p 15672:15672 cc86ffa2f398 #啟動  最后跟著 image ID

$ systemctl status firewalld #查看防火墻的狀態【(running)意思是打開，我們需要設置開放的端口】
$ firewall-cmd --list-ports #查看防火墻開放的端口
$ firewall-cmd --zone=public --add-port=15672/tcp --permanent # 開放15672,15672是Web管理界面的端口
$ firewall-cmd --zone=public --add-port=5672/tcp --permanent # 開放5672,5672是MQ訪問的端口
$ firewall-cmd --reload # 使修改生效

訪問15672端口即可進入RabbitMQ的web管理界面，賬號密碼默認都是guest。

演示動態刷新全局廣播前置準備

前提條件：RabbitMQ環境已成功安裝。

接下來，仿照3355結構，再新建一個3366。

新建模塊，引入依賴

        <!--添加消息總線RabbitMQ支持-->
        <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>

配置bootstrap.yml

server:
  port: 3366

spring:
  application:
    name: config-client
  cloud:
    #Config客戶端配置
    config:
      label: master #分支名稱
      name: config #配置文件名稱
      profile: dev #讀取后綴名稱   
      uri: http://localhost:3344 #配置中心地址

  #rabbitmq相關配置 15672是Web管理界面的端口；5672是MQ訪問的端口
  rabbitmq:
    host: [your hostname]
    port: 5672
    username: guest
    password: guest

#服務注冊到eureka地址
eureka:
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka

# 暴露監控端點
management:
  endpoints:
    web:
      exposure:
        include: "*"

編寫主啟動類

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

編寫接口

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

    @Value("${config.info}")
    private String configInfo;

    @GetMapping("/configInfo")
    public String configInfo() {
        return "serverPort: " + serverPort + "\t\n\n configInfo: " + configInfo;
    }
}

設計思想

設計思想主要是以下兩種：

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

二、利用消息總線觸發一個服務端ConfigServer的/bus/refresh，而刷新所有客戶端的配置。

相比之下，圖二的架構【通知服務端ConfigServer】更加合理，圖一不合理的原因如下：

1. 打破了微服務的職責單一性，微服務本身為業務模塊，不應該擔任刷新配置的職責。
2. 破壞了微服務各節點的對等性。
3. 存在局限，如微服務遷移時，網絡地址時常發生變化，這時如果希望自動刷新，會作更多的修改。

開始演示動態刷新全局廣播

前提：前置準備已經完成，此時擁有3344ConfigServer，3355和3366Client，和Eureka配置中心7001。

為三個模塊都添加消息總線支持

        <!--添加消息總線RabbitMQ支持-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
        </dependency>

為三個模塊配置yml

#rabbitmq相關配置
  rabbitmq:
    host: [your hostname]
    port: 5672
    username: guest
    password: guest

為ConfigServer配置yml

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

為ConfigClient配置yml

# 暴露監控端點
management:
  endpoints:
    web:
      exposure:
        include: "*"

測試

依次啟動7001，3344，3355，3366模塊，進行測試，依次訪問：

• http://localhost:3344/master/config-dev.yml
• http://localhost:3355/configInfo
• http://localhost:3366/configInfo

暫時是沒有任何問題的，配置信息能夠成功從Gitee上獲取得到。

此時改變配置信息的版本號，并向ConfigServer發送一次POST請求：

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

再次測試3355和3366config client，已經成功實現一次通知，處處更新。

原理回顧

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

動態刷新定點通知

我們已經通過Spring Cloud Bus + RabbitMQ實現了一處通知，全局廣播，處處更新。那，如果我只想通知其中某個client更新呢？如何定點通知只指定某個實例生效呢？

我們可以通過通知的url指定實例的destination：http://localhost:3344/actuator/bus-refresh/{destination}，此時bus/refresh通知會通過destination參數類指定需要更新配置的服務或實例。

比如，只通知3355可以發送下面這個請求：

$ curl -X POST "http://localhost:3344/actuator/bus-refresh/config-client:3355"

• config-client為spring.application.name。
• 3355為對應的端口號。

源碼下載

本系列文章為《尚硅谷SpringCloud教程》的學習筆記【版本稍微有些不同，后續遇到bug再做相關說明】，主要做一個長期的記錄，為以后學習的同學提供示例，代碼同步更新到Gitee：https://gitee.com/tqbx/spring-cloud-learning，并且以標簽的形式詳細區分每個步驟，這個系列文章也會同步更新。