springcloud Bus

什么是springcloud Bus

  上一章的springcloud Bus是對分布式微服務的遠程配置，但是有一個遺留的問題就是，Config客戶端對遠程配置的刷新需要手動使用post請求來完成，這就使得Config客戶端動態(tài)刷新變得十分麻煩。于是消息總線springcloud Bus就是來解決這個問題的

什么是消息總線

  在微服務架構的系統(tǒng)中，通常會使用輕量級的消息代理來構建一個共用的消息主題，并讓系統(tǒng)中所有微服務實例都鏈接上來。由于該主題中產(chǎn)生的消息都會被所有實例監(jiān)聽和消費，所以稱它為消息總線。

Bus實現(xiàn)自動刷新的原理

  所有的Config客戶端都監(jiān)聽MQ中同一個topic（默認是SpringCloudBus）。當一個服務刷新數(shù)據(jù)的時候，它會把這個信息放入到Topic中，這樣其他監(jiān)聽同一Topic的服務就能得到通知，然后去更新自身的配置。

  由于springcloud Bus支持兩種消息的代理(RabbitMQ和kafka)，于是接下來的demo選擇使用RabbitMQ 3.7.14，其他的消息中間件Bus暫不支持

RabbitMQ的下載配置

Erlang

  第一步： 下載安裝Erlang，地址：傳送門，安裝除了自定義安裝路徑外，一路next即可

  第二步： 配置環(huán)境變量，新建一個環(huán)境變量命名為ERLANG_HOME，值為Erlang的安裝路徑

path環(huán)境中添加 %ERLANG_HOME%\bin

  第三步： win + R 輸入cmd回車，鍵入命令erl測試配置是否成功

RabbitMQ

  第一步： 這里以RabbitMQ 3.7.14為例，地址：傳送門，頁面的最下方有下載的地方，安裝除了自定義安裝路徑外，一路next即可

  第二步： 配置環(huán)境變量，新建一個環(huán)境變量命名為RABBITMQ_SERVER，值為RabbitMQ的安裝路徑

path環(huán)境中添加 %RABBITMQ_SERVER%\sbin

  第三步： 安裝管理工具RabbitMQ-Plugins，win + R 輸入cmd回車，鍵入命令

rabbitmq-plugins enable rabbitmq_management

  第四步： 第三部安裝的管理工具會安裝幾個RabbitMQ的管理快捷方式，可以點擊win鍵查看，點擊即可執(zhí)行對應操作

  第五步： 測試是否安裝成功，瀏覽器http://localhost:15672（默認賬號：guest，密碼：guest），登入RabbitMQ的管理頁就表示已經(jīng)安裝成功

Bus動態(tài)刷新

  Bus動態(tài)刷新有兩種設計思想，第一種利用消息總線觸發(fā)一個客戶端的bus/refresh，從而刷新這條總線上的所有客戶端配置；第二種利用消息總線觸發(fā)一個服務端ConfigServer的bus/refresh，從而刷新這個配置中心(服務端)上注冊的所有客戶端配置。

  以上兩種思想并不是都有應用，而是選擇了第二種，因為第一種設計思想會使得被選中的服務端節(jié)點在配置獲取職責之外新增配置刷新的職責，這會打破微服務的職責單一性和各節(jié)點之間的對等性。且一旦被選中的節(jié)點失效，配置刷新也將會隨之失效，這條總線上的服務端依舊無法實時獲取到最新的配置。

全局廣播通知代碼實現(xiàn)

  此時配置相關微服務一共有三個，它們是配置中心服務端3344、客戶端3355、客戶端3366，全局廣播的代碼實現(xiàn)需要對三個微服務都進行配置

  配置中心3344： pom文件和配置文件

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

spring:
    #rabbitmq相關配置
    rabbitmq:
      host: localhost
      port: 5672
      username: guest
      password: guest
##rabbitmq相關配置,暴露bus刷新配置的端點 SpringCloud Bus動態(tài)刷新全局廣播
management:
  endpoints: #暴露bus刷新配置的端點
    web:
      exposure:
        include: 'bus-refresh'

  客戶端3355、3366： pom文件和配置文件

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

spring:
    #rabbitmq相關配置
    rabbitmq:
      host: localhost
      port: 5672
      username: guest
      password: guest

以3366為例，配置文件的縮進如下

server:
  port: 3366

spring:
  application:
    name: config-client
  cloud:
    config:
      uri: http://localhost:3344  #配置中心的地址
      label: master  #分支名稱
      name: config  #配置文件名稱
      profile: dev  #讀取后綴名稱   上述三個綜合http://localhost:3344/master/config-dev.yml
  #rabbitmq相關配置
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest
#服務注冊到eureka地址
eureka:
  client:
    service-url:
      #設置與eureka server交互的地址查詢服務和注冊服務都需要依賴這個地址
      defaultZone: http://localhost:7001/eureka #單機版

# 暴露監(jiān)控端點 否則 curl -X POST "http://localhost:3355/actuator/refresh" 不可使用
management:
  endpoints:
    web:
      exposure:
        include: "*"

  ??值得注意的是，之前rabbitmq的web訪問端口是15672，但是在代碼中連接rabbitmq使用的端口是5672，這里很容易踩坑

  完成前面的配置，使用以下鏈接訪問配置中心服務端3344、客戶端3355、客戶端3366的配置信息

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

  然后修改gitee上的遠程配置，仍然使用上面鏈接訪問，會發(fā)現(xiàn)只有配置中心服務端獲取的配置是最新的，但是配置客戶端的配置還是修改前的，需要使用win+R輸入命令刷新，再訪問的話配置客戶端就是最新的配置了

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

定點通知代碼實現(xiàn)

  bus除了可以一個命令刷新總線上的所有微服務之外，還可以支持定點刷新，命令如下

定點通知一個

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

定點通知多個

curl -X POST "http://localhost:3344/actuator/bus-refresh/{config-client:3355,config-client:3366}"

到此這篇關于Springcloud Bus消息總線原理是實現(xiàn)詳解的文章就介紹到這了,更多相關Springcloud Bus內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

最新評論