解析Spring Cloud Bus消息總線
更新時間：2021年10月31日 12:00:44 作者：一代健客
這篇文章主要介紹了Spring Cloud Bus消息總線的介紹及使用，本文通過實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
概念
我們使用配置中心時，當配置中心的配置發(fā)生了變化，我們就要發(fā)送一個post請求給客戶端，讓它重新去拉取新的的配置。當客戶端有很多時，并且還是使用同一份配置文件，這樣當配置中心的配置發(fā)生改變，我們就得逐個發(fā)送post請求通知，這樣無疑是很浪費人力物力的。
Bus消息總線組件就幫我們解決了這個問題。他的工作流程是這樣的，當配置中心的配置發(fā)生了變化時，我們給其中一個客戶端發(fā)送post請求，然后client將請求的信息發(fā)送到rabbitmq隊列中，然后消息隊列將消息發(fā)送給別的隊列。
使用
準備工作
項目基于Spring Cloud 第七章的項目改造。
改造config-client 添加相應坐標
<dependencies> <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.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </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>
在啟動類中添加@RefreshScope注解
@RefreshScope注解只需要寫在需要刷新配置文件的地方，不一定非要在啟動類中
@SpringBootApplication
@EnableEurekaClient
@EnableDiscoveryClient
@RestController
@RefreshScope
public class ConfigClientApplication {
/**
* http://localhost:8881/actuator/bus-refresh
*/
public static void main(String[] args) {
SpringApplication.run(ConfigClientApplication.class, args);
}
@Value("${foo}")
String foo;
@RequestMapping(value = "/hi")
public String hi(){
return foo;
}
}
配置相關配置
spring.rabbitmq.host=localhost spring.rabbitmq.port=5672 spring.rabbitmq.username=guest spring.rabbitmq.password=guest spring.cloud.bus.enabled=true spring.cloud.bus.trace.enabled=true management.endpoints.web.exposure.include=bus-refresh management.security.enabled=false //報錯加上
- 依次啟動eureka-server、confg-cserver,啟動兩個config-client，端口為：8881、8882。
- 訪問http://localhost:8881/hi 或者http://localhost:8882/hi 瀏覽器顯示：
foo version 3
- 這時我們去代碼倉庫將foo的值改為“foo version 4”，即改變配置文件foo的值。如果是傳統(tǒng)的做法，需要重啟服務，才能達到配置文件的更新。此時，我們只需要發(fā)送post請求：http://localhost:8881/actuator/bus-refresh，你會發(fā)現(xiàn)config-client會重新讀取配置文件
- 1.5版本的post請求http://localhost:8881/bus/refresh
- 2.0版本的post請求http://localhost:8881/actuator/bus-refresh
- 這時我們再訪問http://localhost:8881/hi 或者http://localhost:8882/hi 瀏覽器顯示：
foo version 4
另外，/actuator/bus-refresh接口可以指定服務，即使用"destination"參數(shù)，比如 “/actuator/bus-refresh?destination=customers:**” 即刷新服務名為customers的所有服務。 原理圖
當git文件更改的時候，通過pc端用post 向端口為8882的config-client發(fā)送請求/bus/refresh／；此時8882端口會發(fā)送一個消息，由消息總線向其他服務傳遞，從而使整個微服務集群都達到更新配置文件。
相關文章
JMM要求保證可見性、原子性、有序性，volatile可以保證其中的兩個，本篇文章具體驗證volatile的可見性，不原子性和禁重排，同時解決volatile的不保證原子性，讓代碼具有原子性2022-12-12
本篇總結的是Spring框架相關的面試題，后續(xù)會持續(xù)更新，希望我的分享可以幫助到正在備戰(zhàn)面試的實習生或者已經(jīng)工作的同行，如果發(fā)現(xiàn)錯誤還望大家多多包涵，不吝賜教，謝謝2021-07-07
WebSocket實現(xiàn)數(shù)據(jù)庫更新時前端頁面刷新
這篇文章主要為大家詳細介紹了WebSocket實現(xiàn)數(shù)據(jù)庫更新時前端頁面刷新，具有一定的參考價值，感興趣的小伙伴們可以參考一下2019-04-04
本文介紹了如何通過Maven配置依賴,創(chuàng)建前端登錄和注冊頁面,并實現(xiàn)后端邏輯,詳細步驟包括配置文件、創(chuàng)建User類、配置中文過濾器及DispatcherServlet,并使用Spring?MVC和JQuery處理前端請求,需要的朋友可以參考下2024-11-11
Maven是一個能使我們的java程序開發(fā)節(jié)省時間和精力,是開發(fā)變得相對簡單,還能使開發(fā)規(guī)范化的工具,下面這篇文章主要給大家介紹了關于IDEA項目中配置Maven鏡像源(下載源)的詳細過程,需要的朋友可以參考下2024-02-02
淺析Spring容器原始Bean是如何創(chuàng)建的
這篇文章主要是想和小伙伴們一起聊聊?Spring?容器創(chuàng)建?Bean?最最核心的?createBeanInstance?方法，文中的示例代碼講解詳細，需要的可以參考一下2023-08-08
本文主要介紹了SpringBoot集成Nacos的項目實踐，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2023-07-07
下面小編就為大家?guī)硪黄獪\談java常用的幾種線程池比較。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-01-01
MyBatis是支持普通SQL查詢，存儲過程和高級映射的優(yōu)秀持久層框架。MyBatis消除了幾乎所有的JDBC代碼和參數(shù)的手工設置以及結果集的檢索。想要學好它，那就要從MyBatis基礎知識學起，下面跟著小編一起來看下吧2017-03-03
Spring源碼解析之循環(huán)依賴的實現(xiàn)流程
這篇文章主要介紹了Spring源碼解析之循環(huán)依賴的實現(xiàn)流程，文章基于Java的相關內容展開循環(huán)依賴的實現(xiàn)流程，需要的小伙伴可以參考一下2022-07-07