一、SpringCloud Bus消息總線簡介

在微服務架構體系中，我們通常會使用輕量級的消息代理（MQ）來構建一個共用的消息系統，讓所有的微服務節點都連上來。由于該系統中的話題會被所有微服務節點訂閱和消費，因此成為：消息總線。

可以利用消息總線方便的實現統一的配置管理和配置動態刷新。

目前，SpringCloud中的SpringCloud Bus技術就實現了消息總線的功能，其底層默認是采用RabbitMQ和Kafka來作為消息代理。

利用SpringCloudBus來實現配置動態刷新的流程圖：

二、手動刷新

1、安裝mq（docker中）

拉取鏡像

docker pull rabbitmq:3-management

創建容器

docker run \
 -e RABBITMQ_DEFAULT_USER=guest \
 -e RABBITMQ_DEFAULT_PASS=guest \
 --name mq \
 --hostname mq1 \
 -p 15672:15672 \
 -p 5672:5672 \
 -id \
 rabbitmq:management

2、在ConfigServer的pom.xml中引入依賴

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-bus</artifactId>
</dependency>
<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
</dependency>
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

3、修改ConfigServer的application.yml文件

添加兩部分內容：

• RabbitMQ地址
• 開啟refresh端口

server:
  port: 12580
spring:
  application:
    name: config-server
  cloud:
    config:
      server:
        git:
          uri: https://gitee.com/Rrx-w/cloud-config.git  # git倉庫地址
#          username:   # 如果有用戶名和密碼需要加上
#          password:
  rabbitmq:
    host: 192.168.200.150
    username: guest
    password: guest
    port: 5672
eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:10086/eureka  # eureka地址
management:
  endpoints:
    web:
      exposure:
        include: bus-refresh

4、配置ConfigClient

在user-service的pom.xml中引入依賴

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-bus</artifactId>
</dependency>
<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
</dependency>
<!-- 如果之前沒有引過， 也要引入監控依賴 -->
 <dependency>
     <groupId>org.springframework.boot</groupId>
     <artifactId>spring-boot-starter-actuator</artifactId>
 </dependency>

修改user-service的bootstrap.yml文件，添加MQ地址后

eureka:
  client:
    service-url:
      #      defaultZone: http://localhost:10086/eureka,http://localhost:10087/eureka
      defaultZone: http://localhost:10086/eureka
spring:
  application:
    name: user-service
  cloud:
    config:
      name: userservice  # 配置文件的應用名稱
      label: master   # 配置文件的分支名稱
      profile: dev   # 環境名稱
      discovery:
        enabled: true  # 開啟從注冊中心獲取配置中心地址
        service-id: config-server # 配置中心的服務名稱
  rabbitmq:
    host: 192.168.200.150
management:
  endpoints:
    web:
      exposure:
        include: "*" # 暴露refresh接口  會對外暴露一個接口：/actuator/refresh，調用該接口即可刷新配置
server:
  port: 8081

測試

1. 重啟 config-server和user-service服務

2. 修改Git倉庫中的master分支下的userservice-dev.yml
   

3. 在postMan工具中訪問ConfigServer的刷新接口：http://localhost:12580/actuator/bus-refresh
   

4. 訪問接口：http://localhost:8081/hello/prop
   

三、自動刷新

gitee.com或者github.com這樣的遠程倉庫，都提供了web hook功能，允許我們配置一個地址，當有代碼提交時，遠程庫會向配置的地址發送一個POST請求

1、內網穿透

2、配置gitee中webHooks

這樣直接添加會出錯

設置內網穿透

3、提交修改文件測試

在configserver中添加一個過濾器，提前將request消息體的參數讀取出來

4、測試

修改gitee中的配置文件

刷新測試