12.统一配置中心Config自动刷新组件之Bus

偏执的太偏执、 2023-01-24 02:12 115阅读 0赞

### 统一配置中心Config自动刷新组件之Bus ###

*   *  前言
     *  什么是Bus
     *  刷新原理
     *  刷新实现
     *   *  安装RabbitMQ
         *  Config Server端配置
         *   *  1.pom.xml
             *  2.application.properties
             *  3.重新启动Config Server
         *  Config Client端配置
         *   *  1.pom.xml
             *  2.修改配置文件
             *  3.bootstrap.properties
             *  4.测试
         *  开启Server端的web端点暴露
         *   *  1.application.properties
             *  2.重新启动Config Server
             *  3.执行POST接口
             *  4.测试
         *  WebHook实现自动刷新
         *   *  什么 WebHook?
             *  实现步骤
             *   *  1.新增webHook
                 *  2.测试webHook
                 *  3.解决方案
                 *  5.测试webHook
                 *  6.测试自动刷新

## 前言 ##

在上一节[11.Config统一配置中心之手动刷新][11.Config]中我们是现在手动刷新获取远端Git仓库的配置文件。我们也知道了手动刷新这种方式的诸多问题。这一节我们将要学习springcloud官方提供的自动刷新组件–[spring-cloud-bus][]，以下简称**Bus**

## 什么是Bus ##

Spring Cloud Bus links nodes of a distributed system with a lightweight message broker. This can then be used to broadcast state changes (e.g. configuration changes) or other management instructions. AMQP and Kafka broker implementations are included with the project. Alternatively, any [Spring Cloud Stream][] binder found on the classpath will work out of the box as a transport.

官网给出了这么一大坨解释，具体是什么意思呢？

Bus称之为SpringCloud中的消息总线，主要用来在微服务系统中实现远端配置更新时通过广播形式通知所有客户端刷新配置信息，避免手动重启服务的工作。

> Bus利用轻量级消息中间件将分布式系统中所有的服务连接到一起
> 
> 当配置文件（当前状态）发生改变时，Bus利用消息中间件的广播特性通知响应的关联服务更新自身配置（当前状态）

## 刷新原理 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70]

## 刷新实现 ##

### 安装RabbitMQ ###

上面我们说了Bus的工作原理是利用了**轻量级消息中间件**将分布式系统中所有的服务连接到一起。这里我们的消息中间件选择RabbitMQ。

RabbitMQ的具体安装教程参考文章[RabbitMQ入门之基础理论][RabbitMQ]

从上面的原理图上我们能够看到不论是Config Server还是Config Client都需要连接上RabbitMQ，下面我们先看下Config Server。

### Config Server端配置 ###

#### 1.pom.xml ####

首先我们需要在pom.xml文件中引入bus的依赖

<?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">
        <parent>
            <artifactId>springcloud_parent</artifactId>
            <groupId>com.christy</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>07.springcloud_config_server</artifactId>
    
        <properties>
            <maven.compiler.source>8</maven.compiler.source>
            <maven.compiler.target>8</maven.compiler.target>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-consul-discovery</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-config-server</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-bus-amqp</artifactId>
            </dependency>
        </dependencies>
    </project>

#### 2.application.properties ####

server.port=8910
    spring.application.name=CONFIGSERVER
    
    #注册服务中心
    spring.cloud.consul.host=localhost
    spring.cloud.consul.port=8500
    
    # 配置远程仓库
    # 指定仓库的url
    spring.cloud.config.server.git.uri=https://gitee.com/tide001/config-server.git
    # 指定访问的分支
    spring.cloud.config.server.git.default-label=master
    
    # 如果是私有仓库 需要配置用户名和密码
    #spring.cloud.config.server.git.username=
    #spring.cloud.config.server.git.password=
    
    # 配置RabbitMQ
    spring.rabbitmq.host=localhost
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=guest
    spring.rabbitmq.password=guest
    spring.rabbitmq.virtual-host=/

#### 3.重新启动Config Server ####

上面两步配置完毕后Config Server端的配置就算是结束了，现在我们重启Config Server。重启完Server端以后我们可以看到在RabbitMQ的Queue里面多了一个名字为`Queue springCloudBus.anonymous.frByGl79R7y0HX0RSHMggg`的队列

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 1]

### Config Client端配置 ###

#### 1.pom.xml ####

<?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">
        <parent>
            <artifactId>springcloud_parent</artifactId>
            <groupId>com.christy</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>07.springcloud_config_client</artifactId>
    
        <properties>
            <maven.compiler.source>8</maven.compiler.source>
            <maven.compiler.target>8</maven.compiler.target>
        </properties>
    
        <dependencies>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-consul-discovery</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-config</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-bus-amqp</artifactId>
            </dependency>
        </dependencies>
    </project>

> 这个bus依赖在所有需要自动刷新的节点上都需要配置

#### 2.修改配置文件 ####

client端的配置文件仍需要配置RabbitMQ，只不过这个我们需要配置在远端git仓库中的配置文件configclient.properties中

server.port=8911
    spring.application.name=CONFIGCLIENT
    
    # spring.profile.active=dev
    
    # 配置RabbitMQ
    spring.rabbitmq.host=localhost
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=guest
    spring.rabbitmq.password=guest
    spring.rabbitmq.virtual-host=/

> client端在上述两步完成后仍然不能重亲启动，否则会报以下错误
> 
> ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 2]

> **这个是什么原因导致的呢？**
> 
> `我们在引入bus组件后，在项目(系统)启动的时候会去加载RabbitMQ的配置以启动并连接消息中间件。这个时候我们从远端仓库中加载的配置文件尚未拿到，所以报了这个错`
> 
> **解决方案**
> 
> 在bootstrap.properties中新增`spring.cloud.config.fail-fast=true`，意思是在启动时还没有拉取远端配置完成时的失败都是允许的

#### 3.bootstrap.properties ####

# 配置注册中心
    spring.cloud.consul.host=localhost
    spring.cloud.consul.port=8500
    
    # 告诉当前Config Client统一配置中心在注册中心的服务id
    spring.cloud.config.discovery.service-id=CONFIGSERVER
    # 开启当前Config Client 根据服务id去注册中心获取
    spring.cloud.config.discovery.enabled=true
    
    # 获取那个配置文件 1.确定分支  2.确定文件名  3.确定环境
    spring.cloud.config.label=master
    spring.cloud.config.name=configclient
    spring.cloud.config.profile=dev
    
    management.endpoints.web.exposure.include=*
    
    # 在启动时还没有拉取远端配置完成时的失败都是允许的
    spring.cloud.config.fail-fast=true

#### 4.测试 ####

现在我们重新启动Config Client，发现这次是可以正常启动的。我们修改远端的配置文件如下：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 3]

此时我们去访问`http://localhost:8911/test/hello`，发现结果并不是我们修改的结果

![在这里插入图片描述][20210716114432266.png]

这是因为我们在Config Server端的配置少了一步：通过执行post接口刷新配置。通过上一篇文章[11.Config统一配置中心之手动刷新][11.Config]我们知道想要执行post接口刷新配置必须开启web端点暴露

> 这里需要注意：
> 
> 上一篇手动刷新配置是在Client端执行post接口进行刷新配置
> 
> 而本节说的自动刷新配置执行post接口是在Server端执行post接口进行刷新配置，这相较于Client端节省了大量的工作

### 开启Server端的web端点暴露 ###

#### 1.application.properties ####

#### 2.重新启动Config Server ####

#### 3.执行POST接口 ####

我们这里直接在命令行的方式来执行，小伙伴们也可以在Postman中执行。打开命令行输入`curl -X POST http://localhost:8910/actuator/bus-refresh`

![在这里插入图片描述][2021071611444789.png]

#### 4.测试 ####

我们再次在浏览器中输入`http://localhost:8911/test/hello`，发现结果已经更新

![在这里插入图片描述][2021071611450158.png]

> `curl -X POST http://localhost:8910/actuator/bus-refresh`这种方式是通过广播的方式通知所有连接到RabbitMQ的微服务同时更新，这显然是不合理而且浪费资源的。我们可以在上述命令的后面追加SERVER-ID来通过Config Server通知指定的SERVER刷新自身的配置：`curl -X POST http://localhost:8910/actuator/bus-refresh/SERVER-ID`

### WebHook实现自动刷新 ###

上面我们实现了配置的自动刷新，但是依然存问题：在Config Server端我们仍然需要手动执行POST访问，有没有更好的办法来自动执行Server端的POST访问？这就是我们下面要提到的webhook

#### 什么 WebHook? ####

**hook**就是钩子，**WebHooks**是git(gitee|github)提供的一项功能，可以添加多个webHook

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 4]

webHook能够根据仓库的触发事件去执行对应的操作。比如当我们修改了远程git仓库中的配置文件，当我们点击提交的时候它会自动发送一个POST的web请求，如果我们将该请求的url设置成Config Server的地址这就实现了自动执行Server端的POST访问，从而实现自动刷新的功能。

#### 实现步骤 ####

##### 1.新增webHook #####

点击`添加webHook`，按照下图填写相关信息，点击`添加`即可

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 5]

> 上图中的url是使用内网穿透映射的外网地址，具体的使用方法见文章[natapp内网穿透速学教程][natapp]

##### 2.测试webHook #####

添加完毕后我们点击测试，发现返回400。如下图

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 6]

##### 3.解决方案 #####

想要解决步骤2中的400，我们需要在Config Server中添加一个UrlFilter，如下

import org.springframework.stereotype.Component;
    
    import javax.servlet.*;
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletRequestWrapper;
    import javax.servlet.http.HttpServletResponse;
    import java.io.BufferedReader;
    import java.io.ByteArrayInputStream;
    import java.io.IOException;
    
    @Component
    public class UrlFilter  implements Filter { 
        @Override
        public void init(FilterConfig filterConfig) throws ServletException { 
     
        }
     
        @Override
        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);
        }
     
        @Override
        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;
                    }
     
                    @Override
                    public boolean isReady() { 
                        return false;
                    }
     
                    @Override
                    public void setReadListener(ReadListener readListener) { 
     
                    }
     
                    @Override
                    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();
        }
    }

##### 5.测试webHook #####

我们重启Config Server，然后测试我们上面添加的webHook，结果正常

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 7]

##### 6.测试自动刷新 #####

我们启动Config Client，浏览器访问`http://localhost:8911/test/hello`，结果如下  
![在这里插入图片描述][20210716114603474.png]  
此时，我们去git远程仓库修改配置文件如下  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 8]  
浏览器再次访问`http://localhost:8911/test/hello`，结果如下  
![在这里插入图片描述][20210716114622338.png]  
从上面的结果可以看到我们已经成功使用webHook实现了通过Config Server自动执行POST请求实现Config Client配置文件的自动刷新O(∩\_∩)O哈哈~

> 本系列专题源码已经上传至gitee：https://gitee.com/tide001/springcloud\_parent，欢迎下载交流

[11.Config]: https://blog.csdn.net/bbxylqf126com/article/details/118723551
[spring-cloud-bus]: https://spring.io/projects/spring-cloud-bus
[Spring Cloud Stream]: https://spring.io/projects/spring-cloud-stream
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70]: /images/20221004/9ee08d4c8a6c4e8f992cff92777105a4.png
[RabbitMQ]: https://blog.csdn.net/bbxylqf126com/article/details/110943608
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 1]: /images/20221004/2f9dca688ceb4922a0fa2fa3011cbcc6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 2]: /images/20221004/1b4ae04dc22d465eabd538ad43624e19.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 3]: /images/20221004/1e7eb71bc52f4b2dbb146e56a9b250e6.png
[20210716114432266.png]: /images/20221004/67a0f18136354cce8a6382244535a721.png
[2021071611444789.png]: /images/20221004/18098b1119e74268a091c14afc5e1202.png
[2021071611450158.png]: /images/20221004/6c6419ab1a804f8d95574e738186826d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 4]: /images/20221004/a550afb1ae2a48f0a2e7cc53238b621a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 5]: /images/20221004/6c57831591a843719141136115b8db26.png
[natapp]: https://blog.csdn.net/bbxylqf126com/article/details/118786653
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 6]: /images/20221004/907df733154449448234c1ee1eb690fe.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 7]: /images/20221004/70faf2d74d5d497eb9b5ef990fcc1c6f.png
[20210716114603474.png]: /images/20221004/ff40d45be7844a2282a9da75049d1c08.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 8]: /images/20221004/8bafb85e5804497bb6435c08bf8dde8a.png
[20210716114622338.png]: /images/20221004/88140d4aeaf74ba1a4e912c31796223b.png