SpringCloud?Bus組件的使用配置詳解
什么是Bus
0.解釋
- https://spring.io/projects/spring-cloud-bus
- springcloudbus使用輕量級(jí)消息代理將分布式系統(tǒng)的節(jié)點(diǎn)連接起來(lái)。然后，可以使用它來(lái)廣播狀態(tài)更改（例如配置更改）或其他管理指令。AMQP和Kafka broker實(shí)現(xiàn)包含在項(xiàng)目中。或者，在類(lèi)路徑上找到的任何springcloudstream綁定器都可以作為傳輸使用。
- 通俗定義: bus稱之為springcloud中消息總線,主要用來(lái)在微服務(wù)系統(tǒng)中實(shí)現(xiàn)遠(yuǎn)端配置更新時(shí)通過(guò)廣播形式通知所有客戶端刷新配置信息,避免手動(dòng)重啟服務(wù)的工作
實(shí)現(xiàn)配置刷新原理
搭建RabbitMQ服務(wù)
0.下載rabbitmq安裝包 [可以直接使用docker安裝更方便] 官方安裝包下載:https://www.rabbitmq.com/install-rpm.html#downloads
[注意:][這里安裝包只能用于centos7.x系統(tǒng)]
1.將rabbitmq安裝包上傳到linux系統(tǒng)中
erlang-22.0.7-1.el7.x86_64.rpm rabbitmq-server-3.7.18-1.el7.noarch.rpm
2.安裝Erlang依賴包
rpm -ivh erlang-22.0.7-1.el7.x86_64.rpm
3.安裝RabbitMQ安裝包(需要聯(lián)網(wǎng))
yum install -y rabbitmq-server-3.7.18-1.el7.noarch.rpm 注意:默認(rèn)安裝完成后配置文件模板在:/usr/share/doc/rabbitmq-server-3.7.18/rabbitmq.config.example目錄中,需要將配置文件復(fù)制到/etc/rabbitmq/目錄中,并修改名稱為rabbitmq.config
4.復(fù)制配置文件
cp /usr/share/doc/rabbitmq-server-3.7.18/rabbitmq.config.example /etc/rabbitmq/rabbitmq.config
5.查看配置文件位置
ls /etc/rabbitmq/rabbitmq.config
6.修改配置文件(參見(jiàn)下圖:)
vim /etc/rabbitmq/rabbitmq.config
將上圖中配置文件中紅色部分去掉%%,以及最后的,逗號(hào) 修改為下圖:
7.執(zhí)行如下命令,啟動(dòng)rabbitmq中的插件管理
rabbitmq-plugins enable rabbitmq_management 出現(xiàn)如下說(shuō)明: Enabling plugins on node rabbit@localhost: rabbitmq_management The following plugins have been configured: rabbitmq_management rabbitmq_management_agent rabbitmq_web_dispatch Applying plugin configuration to rabbit@localhost... The following plugins have been enabled: rabbitmq_management rabbitmq_management_agent rabbitmq_web_dispatch set 3 plugins. Offline change; changes will take effect at broker restart.
8.啟動(dòng)RabbitMQ的服務(wù)
systemctl start rabbitmq-server systemctl restart rabbitmq-server systemctl stop rabbitmq-server
9.查看服務(wù)狀態(tài)(見(jiàn)下圖:)
systemctl status rabbitmq-server
● rabbitmq-server.service - RabbitMQ broker
Loaded: loaded (/usr/lib/systemd/system/rabbitmq-server.service; disabled; vendor preset: disabled)
Active: active (running) since 三 2019-09-25 22:26:35 CST; 7s ago
Main PID: 2904 (beam.smp)
Status: “Initialized”
CGroup: /system.slice/rabbitmq-server.service
├─2904 /usr/lib64/erlang/erts-10.4.4/bin/beam.smp -W w -A 64 -MBas ageffcbf -MHas ageffcbf -
MBlmbcs…
├─3220 erl_child_setup 32768
├─3243 inet_gethost 4
└─3244 inet_gethost 4
…
10.關(guān)閉防火墻服務(wù)
systemctl disable firewalld Removed symlink /etc/systemd/system/multi-user.target.wants/firewalld.service. Removed symlink /etc/systemd/system/dbus-org.fedoraproject.FirewallD1.service. systemctl stop firewalld
11.訪問(wèn)web管理界面
http://10.15.0.8:15672/
12.登錄管理界面
username: guest password: guest
13.MQ服務(wù)搭建成功
實(shí)現(xiàn)自動(dòng)配置刷新
1.在所有項(xiàng)目中引入bus依賴
<!--引入bus依賴--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-bus-amqp</artifactId> </dependency>
2.配置統(tǒng)一配置中心連接到mq
spring.rabbitmq.host=localhost #連接主機(jī) spring.rabbitmq.port=5672 #連接mq端口 spring.rabbitmq.username=user #連接mq用戶名 spring.rabbitmq.password=password #連接mq密碼
3.遠(yuǎn)端配置中加入連接mq配置
4.啟動(dòng)統(tǒng)一配置中心服務(wù) 正常啟動(dòng)
5.啟動(dòng)客戶端服務(wù) 加入bus組件之后客戶端啟動(dòng)報(bào)錯(cuò)原因springcloud中默認(rèn)鏈接不到遠(yuǎn)程服務(wù)器不會(huì)報(bào)錯(cuò),但是在使用bus消息總線時(shí)必須開(kāi)啟連接遠(yuǎn)程服務(wù)失敗報(bào)錯(cuò)
spring.cloud.config.fail-fast=true
6.修改遠(yuǎn)程配置后在配置中心服務(wù)通過(guò)執(zhí)行post接口刷新配置 curl -X POST http://localhost:7878/actuator/bus-refresh
7.通過(guò)上述配置就實(shí)現(xiàn)了配置統(tǒng)一刷新
指定服務(wù)刷新配置
1.說(shuō)明
- 默認(rèn)情況下使用curl -X POST http://localhost:7878/actuator/bus-refresh 這種方式刷新配置是全部廣播形式,也就是所有的微服務(wù)都能接收到刷新配置通知,但有時(shí)我們修改的僅僅是某個(gè)服務(wù)的配置,這個(gè)時(shí)候?qū)τ谄渌?wù)的通知是多余的,因此就需要指定服務(wù)進(jìn)行通知
2.指定服務(wù)刷新配置實(shí)現(xiàn)
- 指定端口刷新某個(gè)具體服務(wù): curl -X POST http://localhost:7878/actuator/bus-refresh/configclient:9090
- 指定服務(wù)id刷新服務(wù)集群節(jié)點(diǎn): curl -X POST http://localhost:7878/actuator/bus-refresh/configclient
[注意:][configclient代表刷新服務(wù)的唯一標(biāo)識(shí)]
集成webhook實(shí)現(xiàn)自動(dòng)刷新
1.配置webhooks
- 添加webhooks
- 在webhooks中添加刷新配置接口
內(nèi)網(wǎng)穿透可以使用natapp進(jìn)行穿透，本地一個(gè)穿透免費(fèi)穿透，https://natapp.cn/ 步驟非常簡(jiǎn)單。然后將穿透的地址放入到所需地址欄即可。
2.解決400錯(cuò)誤問(wèn)題
- 在配置中心服務(wù)端加入過(guò)濾器進(jìn)行解決(springcloud中一個(gè)坑)
@Component
public class UrlFilter implements Filter {
@Override
public void init(FilterConfig filterConfig) throws ServletException {
}
public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
HttpServletRequest httpServletRequest = (HttpServletRequest)request;
HttpServletResponse httpServletResponse = (HttpServletResponse)response;
String url = new String(httpServletRequest.getRequestURI());
//只過(guò)濾/actuator/bus-refresh請(qǐng)求
if (!url.endsWith("/bus-refresh")) {
chain.doFilter(request, response);
return;
}
//獲取原始的body
String body = readAsChars(httpServletRequest);
System.out.println("original body: "+ body);
//使用HttpServletRequest包裝原始請(qǐng)求達(dá)到修改post請(qǐng)求中body內(nèi)容的目的
CustometRequestWrapper requestWrapper = new CustometRequestWrapper(httpServletRequest);
chain.doFilter(requestWrapper, response);
public void destroy() {
private class CustometRequestWrapper extends HttpServletRequestWrapper {
public CustometRequestWrapper(HttpServletRequest request) {
super(request);
@Override
public ServletInputStream getInputStream() throws IOException {
byte[] bytes = new byte[0];
ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bytes);
return new ServletInputStream() {
@Override
public boolean isFinished() {
return byteArrayInputStream.read() == -1 ? true:false;
}
public boolean isReady() {
return false;
public void setReadListener(ReadListener readListener) {
public int read() throws IOException {
return byteArrayInputStream.read();
};
public static String readAsChars(HttpServletRequest request)
{
BufferedReader br = null;
StringBuilder sb = new StringBuilder("");
try
{
br = request.getReader();
String str;
while ((str = br.readLine()) != null)
{
sb.append(str);
}
br.close();
catch (IOException e)
e.printStackTrace();
finally
if (null != br)
try
{
br.close();
catch (IOException e)
e.printStackTrace();
return sb.toString();
}
到此這篇關(guān)于SpringCloud Bus組件的使用的文章就介紹到這了,更多相關(guān)SpringCloud Bus組件內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
Java中的this、super、final關(guān)鍵字詳解
這篇文章主要介紹了Java中的this、super、final關(guān)鍵字詳解,它在方法內(nèi)部使用,表示這個(gè)方法所屬對(duì)象的引用,它在構(gòu)造器內(nèi)部使用,表示該構(gòu)造器正在初始化的對(duì)象,this 可以調(diào)用類(lèi)的屬性、方法和構(gòu)造器,需要的朋友可以參考下2023-09-09
這篇文章主要介紹了Spring容器注入bean的幾種方式詳解,@Configuration用來(lái)聲明一個(gè)配置類(lèi),然后使用 @Bean 注解,用于聲明一個(gè)bean,將其加入到Spring容器中,這種方式是我們最常用的一種,需要的朋友可以參考下2024-01-01
利用Java搭建個(gè)簡(jiǎn)單的Netty通信實(shí)例教程
這篇文章主要給大家介紹了關(guān)于如何利用Java搭建個(gè)簡(jiǎn)單的Netty通信，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家學(xué)習(xí)或者使用Java具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-05-05
Java實(shí)現(xiàn) 基于密度的局部離群點(diǎn)檢測(cè)------lof算法
這篇文章主要介紹了Java實(shí)現(xiàn) 基于密度的局部離群點(diǎn)檢測(cè)------lof算法,本文通過(guò)算法概述,算法Java源碼,測(cè)試結(jié)果等方面一一進(jìn)行說(shuō)明,以下就是詳細(xì)內(nèi)容,需要的朋友可以參考下2021-07-07
springmvc＋spring＋mybatis實(shí)現(xiàn)用戶登錄功能(上)
這篇文章主要為大家詳細(xì)介紹了springmvc＋spring＋mybatis實(shí)現(xiàn)用戶登錄功能，比較基礎(chǔ)的學(xué)習(xí)教程，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-07-07
本文主要介紹了Java中ArrayList線程不安全怎么辦，主要有三種解決的方法，文中通過(guò)示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2021-08-08
Java微信小程序醫(yī)院掛號(hào)系統(tǒng)
這篇文章主要介紹了基于Java微信小程序醫(yī)院掛號(hào)系統(tǒng),可以實(shí)現(xiàn)遠(yuǎn)程處理事務(wù),遠(yuǎn)程提交工作和隨時(shí)追蹤工作的狀態(tài),文中提供了解決思路和部分實(shí)現(xiàn)代碼,需要的朋友可以參考下2023-03-03
Java多線程中wait?notify等待喚醒機(jī)制詳解
這篇文章主要介紹了Java多線程中wait?notify等待喚醒機(jī)制,由于線程之間是搶占式執(zhí)行的,因此線程的執(zhí)行順序難以預(yù)知,但是實(shí)際開(kāi)發(fā)中有時(shí)候我們希望合理的協(xié)調(diào)多個(gè)線程之間的執(zhí)行先后順序,所以這里我們來(lái)介紹下等待喚醒機(jī)制,需要的朋友可以參考下2024-10-10
SpringBoot如何優(yōu)雅的實(shí)現(xiàn)重試功能
這篇文章主要詳細(xì)介紹了SpringBoot如何優(yōu)雅的實(shí)現(xiàn)重試功能的步驟詳解，文中有詳細(xì)的代碼示例，具有一定的參考價(jià)值，感興趣的同學(xué)可以借鑒閱讀2023-06-06
詳解Idea SpringBoot搭建SpringCloud的準(zhǔn)備工作(推薦)
這篇文章主要介紹了Idea SpringBoot搭建SpringCloud的準(zhǔn)備工作(推薦),本文通過(guò)圖文并茂的形式給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2020-10-10