前言:
Spring Cloud Bus 將分布式的節(jié)點(diǎn)用輕量的消息代理連接起來(lái)。
它可以用于廣播配置文件的更改或者服務(wù)之間的通訊，也可以用于監(jiān)控。
本文要講述的是用Spring Cloud Bus實(shí)現(xiàn)通知微服務(wù)架構(gòu)的配置文件的更改。

一、準(zhǔn)備工作

本文還是基于上一篇文章來(lái)實(shí)現(xiàn)。按照官方文檔，我們只需要在配置文件中配置 spring-cloud-starter-bus-amqp ；這就是說(shuō)我們需要裝rabbitMq，點(diǎn)擊rabbitmq官網(wǎng)下載也可用我的下載好的。至于怎么使用 rabbitmq，可以參考我的操作文檔。

Erlang：
鏈接：https://pan.baidu.com/s/1JevmH4MyAII1tIjzfUKx_Q
提取碼：h9g2

Rabbitmq：
鏈接：https://pan.baidu.com/s/1dbK7PL6FHD4qO2KY9qXigA
提取碼：s2bo

Rabbitmq操作手冊(cè)：
RabbitMQ基本概念(二)：windows下安裝

創(chuàng)建父工程并引入依賴：

<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.0.3.RELEASE</version><relativePath/></parent><modules><module>config-server</module><module>eureka-server</module><module>config-client</module></modules><groupId>com.gblfy</groupId><artifactId>sc-f-chapter8</artifactId><version>0.0.1-SNAPSHOT</version><packaging>pom</packaging><name>sc-f-chapter8</name><description>Demo project for Spring Boot</description><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version><spring-cloud.version>Finchley.RELEASE</spring-cloud.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

二、改造config-client

第1步：在pom文件加上spring-cloud-starter-bus-amqp起步依賴，如下：

<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>

第2步：在配置文件bootstrap.yml中加上RabbitMq的配置+打開自動(dòng)刷新

RabbitMq的地址localhost

用戶名	guest
密碼	guest
端口	5672

包括RabbitMq的地址，用戶名、密碼、端口。并需要加上spring.cloud.bus的三個(gè)配置，具體如下：

eureka:client:service-url:defaultZone: http://localhost:8761/eureka server:port: 8881 spring:application:name: config-clientcloud:config:discovery:enabled: trueservice-id: CONFIG-SERVERprofile: devbus:enabled: truetrace:enabled: falserabbitmq:host: localhostusername: guestpassword: guestport: 5672 #打開自動(dòng)刷新 management:endpoints:web:exposure:include: bus-refresh

第3步：ConfigClientApplication啟動(dòng)類代碼如下：

@SpringBootApplication @EnableEurekaClient @EnableDiscoveryClient public class ConfigClientApplication {public static void main(String[] args) {SpringApplication.run(ConfigClientApplication.class, args);}// 測(cè)試鏈接:curl -v -X POST "http://localhost:8882/actuator/bus-refresh" // 在命令行執(zhí)行以上命令即可 }

第4步：在配置類GirlConfig上面添加@RefreshScope注解

@Data @Component @ConfigurationProperties(prefix = "girl") @RefreshScope public class GirlConfig {private String name;private Integer age; }

第5步：web訪問(wèn)類GirlController

@RestController @RequestMapping("/girl") public class GirlController {@Autowiredprivate GirlConfig girlConfig;@GetMapping("/info")public String getGirlInfo() {return "name:" + girlConfig.getName() + ",age:" + girlConfig.getAge();} }

第6步：依次啟動(dòng)

• eureka-server
• config-server
• 啟動(dòng)兩個(gè)config-client實(shí)例
• 端口為：8881、8882

訪問(wèn)http://localhost:8881/girl/info 或者h(yuǎn)ttp://localhost:8882/girl/info

瀏覽器顯示：

name:yuxin age:1

第7步：這時(shí)我們登錄遠(yuǎn)程代碼倉(cāng)庫(kù)將girl.name的值和girl.age的值分別修改為yuxin2，age2( 即改變配置文件name和age的值)。

如果是傳統(tǒng)的做法，需要重啟服務(wù)，才能達(dá)到配置文件的更新。

第8步：我們只需要發(fā)送post請(qǐng)求：http://localhost:8881/actuator/bus-refresh或者h(yuǎn)ttp://localhost:8882/actuator/bus-refresh

溫馨提示：

在測(cè)試之前請(qǐng)先把config-server和config-client的控制臺(tái)清空

通過(guò)postman或者命令窗口的方式進(jìn)行http請(qǐng)求

你會(huì)發(fā)現(xiàn)config-client會(huì)重新讀取配置文件

第9步：這時(shí)我們?cè)僭L問(wèn)：http://localhost:8881/girl/info或者h(yuǎn)ttp://localhost:8882/girl/info

• 瀏覽器顯示：

name:yuxin2 age:2

三、此時(shí)的架構(gòu)：

流程簡(jiǎn)述：

當(dāng)git文件更改的時(shí)候

通過(guò)pc端用post 向端口為8882的config-client發(fā)送請(qǐng)求/bus/refresh／

客戶端8882接收到請(qǐng)求從Server端更新配置并且發(fā)送給Spring Cloud Bus

Spring Cloud bus接到消息并通知給其它客戶端

其它客戶端接收到通知，請(qǐng)求Server端獲取最新配置

全部客戶端均獲取到最新的配置，從而使整個(gè)微服務(wù)集群都達(dá)到更新配置文件。

架構(gòu)演進(jìn)優(yōu)化：

根據(jù)此圖我們可以看出利用Spring Cloud Bus做配置更新的步驟:

1.提交代碼觸發(fā)post給客戶端A發(fā)送bus/refresh
2. 客戶端A接收到請(qǐng)求從Server端更新配置并且發(fā)送給Spring Cloud Bus
3. Spring Cloud bus接到消息并通知給其它客戶端
4. 其它客戶端接收到通知，請(qǐng)求Server端獲取最新配置
5. 全部客戶端均獲取到最新的配置，從而使整個(gè)微服務(wù)集群都達(dá)到更新配置文件。

本文源碼下載：

dev分支(最新企業(yè)實(shí)戰(zhàn)版本):
https://github.com/gb-heima/springcloud-practical-column/tree/dev/sc-f-chapter8

master分支(入門版本):
https://github.com/gb-heima/springcloud-practical-column/tree/master/sc-f-chapter8

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎(jiǎng)勵(lì)來(lái)咯，堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎(jiǎng)

總結(jié)

以上是生活随笔為你收集整理的第八篇: 消息总线(Spring Cloud Bus)(Finchley版本)V2.0_dev的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。