欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

SpringCloud?Bus組件的使用配置詳解

 更新時(shí)間:2022年03月11日 14:30:12   作者:Arog  
bus稱之為springcloud中消息總線,主要用來(lái)在微服務(wù)系統(tǒng)中實(shí)現(xiàn)遠(yuǎn)端配置更新時(shí)通過(guò)廣播形式通知所有客戶端刷新配置信息,避免手動(dòng)重啟服務(wù)的工作,這篇文章主要介紹了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)目中。或者,在類路徑上找到的任何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)文章

  • 在Action中以Struts2的方式輸出JSON數(shù)據(jù)的實(shí)例

    在Action中以Struts2的方式輸出JSON數(shù)據(jù)的實(shí)例

    下面小編就為大家?guī)?lái)一篇在Action中以Struts2的方式輸出JSON數(shù)據(jù)的實(shí)例。小編覺(jué)得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧
    2016-11-11
  • Java實(shí)現(xiàn)基礎(chǔ)銀行ATM系統(tǒng)

    Java實(shí)現(xiàn)基礎(chǔ)銀行ATM系統(tǒng)

    這篇文章主要為大家詳細(xì)介紹了Java實(shí)現(xiàn)基礎(chǔ)銀行ATM系統(tǒng),文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2022-05-05
  • Java中的接口知識(shí)匯總

    Java中的接口知識(shí)匯總

    本文給大家匯總介紹了在java中的接口知識(shí),包括為什么要使用接口、什么是接口、抽象類和接口的區(qū)別、如何定義接口以及定義接口注意點(diǎn),希望大家能夠喜歡
    2016-04-04
  • Maven scala和java混合打包方式

    Maven scala和java混合打包方式

    這篇文章主要介紹了Maven scala和java混合打包方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2023-06-06
  • java使用計(jì)算md5校驗(yàn)碼方式比較兩個(gè)文件是否相同

    java使用計(jì)算md5校驗(yàn)碼方式比較兩個(gè)文件是否相同

    MD5文件效驗(yàn)碼是一個(gè)判斷文件是否是相同文件的途徑,通過(guò)比較兩個(gè)文件的Md5效驗(yàn)碼是否相同來(lái)精確判斷兩個(gè)文件是否相同
    2014-04-04
  • java寫(xiě)卷積神經(jīng)網(wǎng)絡(luò)(CupCnn簡(jiǎn)介)

    java寫(xiě)卷積神經(jīng)網(wǎng)絡(luò)(CupCnn簡(jiǎn)介)

    這篇文章主要介紹了java寫(xiě)卷積神經(jīng)網(wǎng)絡(luò)(CupCnn簡(jiǎn)介),小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧
    2018-04-04
  • java為移動(dòng)端寫(xiě)接口開(kāi)發(fā)實(shí)例

    java為移動(dòng)端寫(xiě)接口開(kāi)發(fā)實(shí)例

    本篇文章主要介紹了java如何為移動(dòng)端寫(xiě)接口,小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧
    2017-08-08
  • 淺談一下Java中枚舉的用法

    淺談一下Java中枚舉的用法

    這篇文章主要介紹了淺談一下Java中枚舉的用法,枚舉是一個(gè)被命名的整型常數(shù)的集合,用于聲明一組帶標(biāo)識(shí)符的常數(shù),當(dāng)一個(gè)變量有幾種固定可能的取值時(shí),就可以將它定義為枚舉類型,需要的朋友可以參考下
    2023-04-04
  • 基于Hutool的圖片驗(yàn)證碼功能模塊實(shí)現(xiàn)

    基于Hutool的圖片驗(yàn)證碼功能模塊實(shí)現(xiàn)

    為了提高系統(tǒng)的安全性,防止接口被暴力刷新,驗(yàn)證碼是個(gè)好的手段,圖片驗(yàn)證碼沒(méi)有短信驗(yàn)證碼的費(fèi)用,其是個(gè)人開(kāi)發(fā)者學(xué)習(xí)的重點(diǎn),這篇文章主要介紹了基于Hutool的圖片驗(yàn)證碼功能模塊實(shí)現(xiàn),需要的朋友可以參考下
    2022-10-10
  • 5個(gè)主流的Java開(kāi)源IDE工具詳解

    5個(gè)主流的Java開(kāi)源IDE工具詳解

    這篇文章主要介紹了5個(gè)主流的Java開(kāi)源IDE工具,無(wú)論如何,Java在當(dāng)今使用的編程語(yǔ)言中始終排在前三名,在TIOBE索引中涉及700萬(wàn)到1000萬(wàn)的程序員和開(kāi)發(fā)者
    2020-07-07

最新評(píng)論