快捷導(dǎo)航

Springcloud Bus消息總線原理是實(shí)現(xiàn)詳解

更新時(shí)間：2022年09月14日 11:24:58 作者：扎哇太棗糕

Spring Cloud Bus 使用輕量級(jí)的消息代理來連接微服務(wù)架構(gòu)中的各個(gè)服務(wù)，可以將其用于廣播狀態(tài)更改（例如配置中心配置更改）或其他管理指令，本文將對(duì)其用法進(jìn)行詳細(xì)介紹

springcloud Bus

什么是springcloud Bus

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

什么是消息總線

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

Bus實(shí)現(xiàn)自動(dòng)刷新的原理

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

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

RabbitMQ的下載配置

Erlang

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

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

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

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

RabbitMQ

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

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

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

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

rabbitmq-plugins enable rabbitmq_management

第四步：第三部安裝的管理工具會(huì)安裝幾個(gè)RabbitMQ的管理快捷方式，可以點(diǎn)擊win鍵查看，點(diǎn)擊即可執(zhí)行對(duì)應(yīng)操作

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

Bus動(dòng)態(tài)刷新

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

以上兩種思想并不是都有應(yīng)用，而是選擇了第二種，因?yàn)榈谝环N設(shè)計(jì)思想會(huì)使得被選中的服務(wù)端節(jié)點(diǎn)在配置獲取職責(zé)之外新增配置刷新的職責(zé)，這會(huì)打破微服務(wù)的職責(zé)單一性和各節(jié)點(diǎn)之間的對(duì)等性。且一旦被選中的節(jié)點(diǎn)失效，配置刷新也將會(huì)隨之失效，這條總線上的服務(wù)端依舊無法實(shí)時(shí)獲取到最新的配置。

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

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

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

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

spring:
   #rabbitmq相關(guān)配置
   rabbitmq:
   host: localhost
   port: 5672
   username: guest
   password: guest
##rabbitmq相關(guān)配置,暴露bus刷新配置的端點(diǎn) SpringCloud Bus動(dòng)態(tài)刷新全局廣播
management:
endpoints: #暴露bus刷新配置的端點(diǎn)
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相關(guān)配置
   rabbitmq:
   host: localhost
   port: 5672
   username: guest
   password: guest

以3366為例，配置文件的縮進(jìn)如下

server:
port: 3366

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

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