Spring Cloud Bus 將分布式的節點用輕量的消息代理連接起來。它可以用于廣播配置文件的更改或者服務之間的通訊，也可以用于監控。本文要講述的是用Spring Cloud Bus實現通知微服務架構的配置文件的更改。Java版本多用戶B2B2C商城源碼
一、準備工作
二、改造config-client
<?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><groupId>com.forezp</groupId><artifactId>config-client</artifactId><version>0.0.1-SNAPSHOT</version><packaging>jar</packaging><name>config-client</name><description>Demo project
for Spring Boot</description><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>1.5.2.RELEASE</version><relativePath/> <!-- lookup parent from repository --></parent><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version></properties><dependencies><dependency><groupId>org.springframework.retry</groupId><artifactId>spring-retry</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-config</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-aop</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-eureka</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>
test </scope></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></dependencies><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>Dalston.RC1</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><repositories><repository><id>spring-milestones</id><name>Spring Milestones</name><url>https://repo.spring.io/milestone</url><snapshots><enabled>
false </enabled></snapshots></repository></repositories>
</project>
復制代碼 在配置文件application.properties中加上RabbitMq的配置，包括RabbitMq的地址、端口，用戶名、密碼，代碼如下：
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
復制代碼 如果rabbitmq有用戶名密碼，輸入即可。
依次啟動eureka-server、confg-cserver,啟動兩個config-client，端口為：8881、8882。
訪問http://localhost:8881/hi 或者http://localhost:8882/hi 瀏覽器顯示：
foo version 3
復制代碼 這時我們去代碼倉庫將foo的值改為“foo version 4”，即改變配置文件foo的值。如果是傳統的做法，需要重啟服務，才能達到配置文件的更新。此時，我們只需要發送post請求：http://localhost:8881/bus/refresh，你會發現config-client會重新讀取配置文件
重新讀取配置文件：
這時我們再訪問http://localhost:8881/hi 或者http://localhost:8882/hi 瀏覽器顯示：
foo version 4
復制代碼 另外，/bus/refresh接口可以指定服務，即使用”destination”參數，比如 “/bus/refresh?destination=customers:**” 即刷新服務名為customers的所有服務，不管ip。
架構代碼如下:
資料和源碼來源地址
Spring Cloud大型企業分布式微服務云構建的B2B2C電子商務平臺源碼請加企鵝求求：一零三八七七四六二六
轉載于:https://juejin.im/post/5c6501f26fb9a049cb1941cf
總結
以上是生活随笔 為你收集整理的Java版本多用户B2B2C商城源码-（八）消息总线(Spring Cloud Bus) 的全部內容，希望文章能夠幫你解決所遇到的問題。
如果覺得生活随笔 網站內容還不錯，歡迎將生活随笔 推薦給好友。
