SpringCloud配置中心--svn（五）配置中心和消息总线【完结】

电玩女神 2021-11-16 15:04 420阅读 0赞

我们在[SpringCloud配置中心–svn（三）refresh][SpringCloud_svn_refresh]中讲到，如果需要客户端获取到最新的配置信息需要执行refresh，但是当客户端越来越多的时候，需要每个客户端都执行一遍，这种方案就不太适合了。使用Spring Cloud Bus可以完美解决这一问题。

## Spring Cloud Bus ##

Spring cloud bus通过轻量消息代理连接各个分布的节点。这会用在广播状态的变化（例如配置变化）或者其他的消息指令。Spring bus的一个核心思想是通过分布式的启动器对spring boot应用进行扩展，也可以用来建立一个多个应用之间的通信频道。目前唯一实现的方式是用AMQP消息代理作为通道，同样特性的设置（有些取决于通道的设置）在更多通道的文档中。

Spring cloud bus被国内很多都翻译为消息总线，也挺形象的。大家可以将它理解为管理和传播所有分布式项目中的消息既可，其实本质是利用了MQ的广播机制在分布式的系统中传播消息，目前常用的有Kafka和RabbitMQ。利用bus的机制可以做很多的事情，其中配置中心客户端刷新就是典型的应用场景之一，我们用一张图来描述bus在配置中心使用的机制。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70]  
根据此图我们可以看出利用Spring Cloud Bus做配置更新的步骤:

1、提交代码触发post给客户端A发送bus/refresh  
2、客户端A接收到请求从Server端更新配置并且发送给Spring Cloud Bus  
3、Spring Cloud bus接到消息并通知给其它客户端  
4、其它客户端接收到通知，请求Server端获取最新配置  
5、全部客户端均获取到最新的配置  
项目示例

我们选择前二篇文章[SpringCloud配置中心–svn（四）服务化和高可用][SpringCloud_svn]版本的示例代码来改造,MQ我们使用RabbitMQ来做示例。

RabbitMQ安装见：[RabbitMQ安装教程][RabbitMQ]

客户端spring-cloud-config-client改造  
**1、添加依赖**

<dependency>
    	    <groupId>org.springframework.cloud</groupId>
    	    <artifactId>spring-cloud-starter-bus-amqp</artifactId>
    </dependency>

需要多引入spring-cloud-starter-bus-amqp包，增加对消息总线的支持

**2、配置文件**  
**application.properties** 添加以下配置

# 开启消息跟踪 #

spring.cloud.bus.trace.enabled=true
    
    spring.rabbitmq.host=localhost
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=guest
    spring.rabbitmq.password=guest

配置文件需要增加RebbitMq的相关配置和开启消息跟踪配置，这样客户端代码就改造完成了。

**3、测试**

依次启动spring-cloud-eureka、spring-cloud-config-server、spring-cloud-config-client项目，在启动spring-cloud-config-client项目的时候我们会发现启动日志会输出这样的一条记录。

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

说明客户端已经具备了消息总线通知的能力了，为了更好的模拟消息总线的效果，我们更改客户端spring-cloud-config-client项目的端口为8003、8004依次启动，这样测试环境就准备好了。启动后eureka后台效果图如下：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 2]

我们先分别测试一下服务端和客户端是否正确运行，  
访问：[http://localhost:8001/client8002/client8002-config-dev.properties][http_localhost_8001_client8002_client8002-config-dev.properties]  
返回信息：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 3]

说明server端正常读取到了配置信息。

在依次访问：  
[http://localhost:8002/hello][http_localhost_8002_hello]  
[http://localhost:8003/hello][http_localhost_8003_hello]  
[http://localhost:8004/hello][http_localhost_8004_hello]  
返回

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 4]  
说明客户端都已经读取到了server端的内容

**现在我们更新**  
client8002-config-dev.properties  
client8003-config-dev.properties  
client8004-config-dev.properties  
**中hello的值分别为**  
springCloud-8002 update  
springCloud-8003 update  
springCloud-8004 update  
并提交SVN  
访问：[http://localhost:8002/hello][http_localhost_8002_hello]  
依然返回：**springCloud-8002**

我们对端口为8002的客户端发送一个/bus/refresh的post请求。  
打开cmd 运行  
curl -X POST [http://localhost:8002/bus/refresh][http_localhost_8002_bus_refresh]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 5]

执行完成后，依次访问：  
[http://localhost:8002/hello][http_localhost_8002_hello]  
[http://localhost:8003/hello][http_localhost_8003_hello]  
[http://localhost:8004/hello][http_localhost_8004_hello]  
返回  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 6]

说明三个客户端均已经拿到了最新的配置文件信息，这样我们就实现了一个客户端刷新，所有客户端同步更新配置的功能，也就是图一的示例。

## 改进版本 ##

在上面的流程中，我们已经到达了利用消息总线触发一个客户端bus/refresh,而刷新所有客户端的配置的目的。但这种方式并不优雅。原因如下：

打破了微服务的职责单一性。微服务本身是业务模块，它本不应该承担配置刷新的职责。  
破坏了微服务各节点的对等性。  
有一定的局限性。例如，微服务在迁移时，它的网络地址常常会发生变化，此时如果想要做到自动刷新，那就不得不修改WebHook的配置。  
因此我们将上面的架构模式稍微改变一下

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

这时Spring Cloud Bus做配置更新步骤如下:

1、提交代码触发post请求给bus/refresh  
2、server端接收到请求并发送给Spring Cloud Bus  
3、Spring Cloud bus接到消息并通知给其它客户端  
4、其它客户端接收到通知，请求Server端获取最新配置  
5、全部客户端均获取到最新的配置  
这样的话我们在server端的代码做一些改动，来支持bus/refresh

**1、添加依赖**

<dependency>
    
    	<groupId>org.springframework.cloud</groupId>
    
    	<artifactId>spring-cloud-starter-bus-amqp</artifactId>
    
    </dependency>

需要多引入spring-cloud-starter-bus-amqp包，增加对消息总线的支持

**2、配置文件**  
**application.yml**

server:
    
      port: 8001
    
    spring:
    
      cloud:
    
        config:
    
          server:
    
            svn:
    
              uri: file:///D:/svn-repository/trunk
    
              username: chenqi
    
              password: 123456
    
            default-label: client8002,client8003,client8004
    
      profiles:
    
        active: subversion
    
      application:
    
        name: spring-cloud-config-server
    
        
    
      rabbitmq:
    
        host: localhost
    
        port: 5672
    
        username: guest
    
        password: guest
    
    eureka:
    
      client:
    
        serviceUrl:
    
          defaultZone: http://localhost:8080/eureka/   ## 注册中心eurka地址
    
    management:
    
      security:
    
         enabled: false

配置文件增加RebbitMq的相关配置，关闭安全验证。这样server端代码就改造完成了。

**3、测试**  
启动spring-cloud-config-server

按照上面的测试方式，访问server端和三个客户端测试均可以正确返回信息。  
同样修改  
client8002-config-dev.properties  
client8003-config-dev.properties  
client8004-config-dev.properties  
中hello的值分别为  
springCloud-8002 update 222  
springCloud-8003 update 333  
springCloud-8004 update 444  
并提交SVN  
在win下使用下面命令来模拟webhook触发server端bus/refresh.  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 8]

说明三个客户端均已经拿到了最新配置文件的信息，这样我们就实现了上图中的示例。  
至此，一个完整的springCloud配置中心案例基本完成。

ps:文中部分原理说明和图片来源于网络，如有侵权请联系本人删除。

[SpringCloud_svn_refresh]: https://blog.csdn.net/weixin_40623736/article/details/97294083
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70]: /images/20211116/f1201fe840014275827eb7d2361faff8.png
[SpringCloud_svn]: https://blog.csdn.net/weixin_40623736/article/details/97416539
[RabbitMQ]: https://blog.csdn.net/weixin_40623736/article/details/97545691
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 1]: /images/20211116/b655966b9bd3419ea5182dd9727b27bf.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 2]: /images/20211116/d9ede95ee9f7430385a41e18c6627d6e.png
[http_localhost_8001_client8002_client8002-config-dev.properties]: http://localhost:8001/client8002/client8002-config-dev.properties
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 3]: /images/20211116/edaabfd6d54b4d7b9aa20cbde9d6b4b2.png
[http_localhost_8002_hello]: http://localhost:8002/hello
[http_localhost_8003_hello]: http://localhost:8003/hello
[http_localhost_8004_hello]: http://localhost:8004/hello
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 4]: /images/20211116/eb8238686784487196bd90b0611ada71.png
[http_localhost_8002_bus_refresh]: http://localhost:8002/bus/refresh
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 5]: /images/20211116/f91e624d32d244db9f93677820c9ef21.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 6]: /images/20211116/798114816e7a4202972f881554d948be.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 7]: /images/20211116/edf2931764684bcaaa57da9c9d5ea6ee.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 8]: /images/20211116/3dbfa4f3c9b94455b93ec2062422da4d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDYyMzczNg_size_16_color_FFFFFF_t_70 9]: /images/20211116/dd478df632b440a6a4189f22f1b36075.png