SpringCloud?Bus組件如何使用

本文小編為大家詳細介紹“SpringCloud Bus組件如何使用”，內容詳細，步驟清晰，細節處理妥當，希望這篇“SpringCloud Bus組件如何使用”文章能幫助大家解決疑惑，下面跟著小編的思路慢慢深入，一起來學習新知識吧。

什么是Bus

0.解釋

• https://spring.io/projects/spring-cloud-bus

• springcloudbus使用輕量級消息代理將分布式系統的節點連接起來。然后，可以使用它來廣播狀態更改（例如配置更改）或其他管理指令。AMQP和Kafka broker實現包含在項目中。或者，在類路徑上找到的任何springcloudstream綁定器都可以作為傳輸使用。

• 通俗定義: bus稱之為springcloud中消息總線,主要用來在微服務系統中實現遠端配置更新時通過廣播形式通知所有客戶端刷新配置信息,避免手動重啟服務的工作

實現配置刷新原理

搭建RabbitMQ服務

0.下載rabbitmq安裝包 [可以直接使用docker安裝更方便] 官方安裝包下載:https://www.rabbitmq.com/install-rpm.html#downloads
[注意:][這里安裝包只能用于centos7.x系統]

1.將rabbitmq安裝包上傳到linux系統中

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安裝包(需要聯網)

yum install -y rabbitmq-server-3.7.18-1.el7.noarch.rpm
	注意:默認安裝完成后配置文件模板在:/usr/share/doc/rabbitmq-server-3.7.18/rabbitmq.config.example目錄中,需要將配置文件復制到/etc/rabbitmq/目錄中,并修改名稱為rabbitmq.config

4.復制配置文件

cp /usr/share/doc/rabbitmq-server-3.7.18/rabbitmq.config.example /etc/rabbitmq/rabbitmq.config

5.查看配置文件位置

ls /etc/rabbitmq/rabbitmq.config

6.修改配置文件(參見下圖:)

vim /etc/rabbitmq/rabbitmq.config

將上圖中配置文件中紅色部分去掉%%,以及最后的,逗號 修改為下圖:

7.執行如下命令,啟動rabbitmq中的插件管理

rabbitmq-plugins enable rabbitmq_management

出現如下說明:
	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.啟動RabbitMQ的服務

systemctl start rabbitmq-server
systemctl restart rabbitmq-server
systemctl stop rabbitmq-server

9.查看服務狀態(見下圖:)

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.關閉防火墻服務

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.訪問web管理界面

http://10.15.0.8:15672/    

12.登錄管理界面

username:  guest
password:  guest
![](https://img-blog.csdnimg.cn/8e49b6d997cd47ef8e79128841f08321.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAQXJvZw==,size_20,color_FFFFFF,t_70,g_se,x_16)

13.MQ服務搭建成功

實現自動配置刷新

1.在所有項目中引入bus依賴

<!--引入bus依賴-->
<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>

2.配置統一配置中心連接到mq

spring.rabbitmq.host=localhost											#連接主機
spring.rabbitmq.port=5672														#連接mq端口
spring.rabbitmq.username=user												#連接mq用戶名
spring.rabbitmq.password=password										#連接mq密碼

3.遠端配置中加入連接mq配置

4.啟動統一配置中心服務 正常啟動

5.啟動客戶端服務 加入bus組件之后客戶端啟動報錯原因springcloud中默認鏈接不到遠程服務器不會報錯,但是在使用bus消息總線時必須開啟連接遠程服務失敗報錯

spring.cloud.config.fail-fast=true

6.修改遠程配置后在配置中心服務通過執行post接口刷新配置 curl -X POST http://localhost:7878/actuator/bus-refresh

7.通過上述配置就實現了配置統一刷新

指定服務刷新配置

1.說明

• 默認情況下使用curl -X POST http://localhost:7878/actuator/bus-refresh這種方式刷新配置是全部廣播形式,也就是所有的微服務都能接收到刷新配置通知,但有時我們修改的僅僅是某個服務的配置,這個時候對于其他服務的通知是多余的,因此就需要指定服務進行通知

2.指定服務刷新配置實現

• 指定端口刷新某個具體服務: curl -X POST http://localhost:7878/actuator/bus-refresh/configclient:9090

• 指定服務id刷新服務集群節點: curl -X POST http://localhost:7878/actuator/bus-refresh/configclient

[注意:][configclient代表刷新服務的唯一標識]

集成webhook實現自動刷新

1.配置webhooks

• 添加webhooks

• 在webhooks中添加刷新配置接口

內網穿透可以使用natapp進行穿透，本地一個穿透免費穿透，https://natapp.cn/ 步驟非常簡單。然后將穿透的地址放入到所需地址欄即可。

2.解決400錯誤問題

• 在配置中心服務端加入過濾器進行解決(springcloud中一個坑)

@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());
        //只過濾/actuator/bus-refresh請求
        if (!url.endsWith("/bus-refresh")) {
            chain.doFilter(request, response);
            return;
        }
        //獲取原始的body
        String body = readAsChars(httpServletRequest);
        System.out.println("original body:   "+ body);
        //使用HttpServletRequest包裝原始請求達到修改post請求中body內容的目的
        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();
}

讀到這里，這篇“SpringCloud Bus組件如何使用”文章已經介紹完畢，想要掌握這篇文章的知識點還需要大家自己動手實踐使用過才能領會，如果想了解更多相關內容的文章，歡迎關注億速云行業資訊頻道。