SpringCloud 2020.0.4 系列之 Bus

1. 概述

老話說的好：會休息的人才更會工作，身體是革命的本錢，身體垮了，就無法再工作了。

言歸正傳，之前我們聊了 SpringCloud 的 分布式配置中心 Config，文章裡我們聊了config配置的動态重新整理，但這個動态重新整理，一次隻能重新整理一個 Config Client 節點，如果服務節點少還好，如果業務多了，有成百上千個服務節點，再一台一台重新整理，就不合适了。

是以，今天我們來聊聊 SpringCloud的消息總線元件 Bus，Bus 元件可以借助MQ中間件，向所有的 Config Client 發送重新整理廣播，隻需要調用一個接口，就可以重新整理整個叢集的Config 配置。

我們使用 RabbitMQ 作為中間件，關于 RabbitMQ 叢集的搭建，可參見我的另一篇文章《RabbitMQ 3.9.7 鏡像模式叢集的搭建》（https://www.cnblogs.com/w84422/p/15356202.html）。

閑話不多說，直接上代碼。

2. Git 準備 

1）建立一個 repository，用于放置配置檔案，例如：my-config-repo

2）建立 my-bus-client 檔案夾

3）在 my-bus-client 檔案夾下，建立 my-bus-client-dev.yml 配置檔案，内容如下：

info:
  profile: dev
    
name: zhuifengren
desc: hello dev      

3. Config Server 引入 Bus 元件

3.1 主要依賴

<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</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-bootstrap</artifactId>
            <version>3.0.2</version>
        </dependency>
        <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>      

3.2 application.yml 配置

server:
  port: 42000

spring:
  application:
    name: my-bus-server
  rabbitmq:
    addresses: 192.168.1.22:5672,192.168.1.12:5672,192.168.1.11:5672  # rabbitmq 叢集的位址
    username: guest
    password: guest
    virtual-host: /
    connection-timeout: 16000
  cloud:
    config:
      server:
        git:
          uri: https://github.com/w84422/my-config-repo.git   # git位址
          force-pull: true  # 強制拉取資源檔案
          default-label: main   # 預設拉取的分支
          search-paths: '{application}'      # 将配置檔案放到接入方服務名稱對應的檔案夾下，這種寫法，隻在config元件設定生效

management:
  endpoints:
    web:
      exposure:
        include: '*'
  endpoint:
    health:
      show-details: always

eureka:
  client:
    service-url:
      defaultZone: http://zhuifengren1:35000/eureka/,http://zhuifengren2:35001/eureka/    # Eureka Server的位址      

3.3 啟動類增加注解

@SpringBootApplication
@EnableConfigServer
@EnableDiscoveryClient
public class MyBusServerApplication {

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

3.4 啟動 Config Server

啟動 Config Server

4. Config Client 引入 Bus 元件

4.1 主要依賴

<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.cloud</groupId>
            <artifactId>spring-cloud-starter-config</artifactId>
            <version>3.0.4</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bootstrap</artifactId>
            <version>3.0.2</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <!-- rabbitmq -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
        </dependency>      

4.2 bootstrap.yml 配置

server:
  port: 43000

spring:
  application:
    name: my-bus-client
  rabbitmq:
    addresses: 192.168.1.22:5672,192.168.1.12:5672,192.168.1.11:5672
    username: guest
    password: guest
    virtual-host: /
    connection-timeout: 16000
  cloud:
    config:
      profile: dev  # 拉取的配置檔案
      label: main   # 拉取的分支
      name: my-bus-client  # 指定遠端擷取配置檔案的 application，預設會取 spring.application.name
      discovery:
        enabled: true
        service-id: my-bus-server    # config服務的服務名稱

myDesc: ${desc}

eureka:
  client:
    service-url:
      defaultZone: http://zhuifengren1:35000/eureka/,http://zhuifengren2:35001/eureka/    # Eureka Server的位址

management:
  endpoints:
    web:
      exposure:
        include: '*'
  endpoint:
    health:
      show-details: always      

4.3 啟動類增加注解

@SpringBootApplication
@EnableDiscoveryClient
public class MyBusClientApplication {

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

4.4 增加用于實驗的 Controller 類

@RefreshScope
@RestController
public class MyBusClientRefreshController {

    @Value("${info.profile}")
    private String profile;
    @Value("${name}")
    private String name;
    @Value("${myDesc}")
    private String desc;

    @RequestMapping("/refresh-info")
    public String getInfo() {

        String info = "profile：" + profile + "<br>";
        info += "name：" + name + "<br>";
        info += "desc：" + desc + "<br>";

        return info;
    }
}      

4.5 啟動 Config Client 服務，并進行驗證

4.5.1 啟動 Config Client 服務

啟動兩個或多個 Config Client 服務

4.5.2 通路 Controller 接口，擷取配置資訊

GET http://localhost:43000/refresh-info

4.5.3 修改 Git 上的配置

将 name 改為 zhangsan

4.5.4 執行bus配置重新整理接口

在 Config Server 或 任意 Config Client 節點，執行 bus 配置重新整理接口

POST http://localhost:42000/actuator/busrefresh

4.5.5 在所有 Config Client 節點調用 Controller 接口，重新擷取資訊

5. 綜述

今天聊了一下 SpringCloud 的 Bus 元件，希望可以對大家的工作有所幫助。

歡迎幫忙點贊、評論、轉發、加關注 ：）

關注追風人聊Java，每天更新Java幹貨。

6. 個人公衆号

追風人聊Java，歡迎大家關注