SpringCloudBus--动态刷新全局广播、动态刷新定点通知

悠悠 2021-08-28 01:35 463阅读 0赞

### 动态刷新全局广播 ###

**设计思想：**

1.  利用消息总线触发一个客户端/bus/refresh，而刷新所有客户端的配置  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70]
2.  利用消息总线触发一个服务端ConfigServer的/bus/refresh端点，而刷新所有客户端的配置  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 1]

**方式二更加合适，方式一不合适的原因如下：**

*  打破了微服务的职责单一性，因为微服务本身是业务模块，它本不该承担配置刷新的职责。
 *  破坏了微服务各个节点的对等性。
 *  有一定的局限性。例如，微服务在迁移时，它的网络地址常常会发生变化，此时如果想要做到自动刷新，那就会增加更多的修改。

**给cloud-config-center-3344配置中心服务端添加消息总线支持：**

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

配置：

server:
      port: 3344
    
    spring:
      application:
        name: cloud-config-center #注册进eureka的微服务名
      cloud:
        config:
          server:
            git:
              uri: https://github.com/ActonZhang1024/springcloud-config.git
              search-paths:
                - springcloud-config #指定搜索目录
          label: master #读取分支
    
    eureka:
      client:
        service-url:
          defaultZone: http://localhost:7001/eureka
    
    #rabbitmq相关配置 15672是web管理界面端口， 5672是MQ访问端口
      rabbitmq:
        host: localhost
        port: 5672
        username: guest
        password: guest
    
    #暴露bus刷新配置的端点
    management:
      endpoints:
        web:
          exposure:
            include: 'bus-refresh'

**给cloud-config-client3355和3366添加消息总线支持：**

配置:bootstrap.yml

server:
      port: 3366
    
    spring:
      application:
        name: config-client
    
      cloud:
        config: #Config客户端配置
          label: master #分支名称
          name: config #配置文件名称
          profile: dev #读取后缀
          uri: http://localhost:3344 #配置中心地址
    
      #rabbitmq相关配置 15672是web管理界面端口， 5672是MQ访问端口
      rabbitmq:
        host: localhost
        port: 5672
        username: guest
        password: guest
    
    
    eureka:
      client:
        service-url:
          defaultZone: http://localhost:7001/eureka
    
    #暴露监控端点
    management:
      endpoints:
        web:
          exposure:
            include: "*"

**测试：**  
启动eureka，3344配置中心，3355和3366客户端.

访问：`localhost:3355/configInfo`和`localhost:3366/configInfo`:  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 2]  
修改配置文件config-dev.yml的version=5，并提交到仓库。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 3]  
![在这里插入图片描述][20200319235548508.png]

访问总线3344：`localhost:3344/config-dev.yml`,获取成功  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 4]  
访问3355客户端：`localhost:3355/configInfo`,失败，并未刷新  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 5]  
访问3366客户端：`localhost:3366/configInfo`,失败，并未刷新  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 6]  
此时，向3344配置中心发送POST请求刷新  
![在这里插入图片描述][20200320000323328.png]  
此时，配置中心会通过BUS总线通知3355和3366客户端：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 7]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 8]

### 动态刷新的定点通知 ###

公式如下：

http://localhost:配置中心端口/actuator/bus-refresh/`{destination}`

destination就是：`微服务名:端口号`

/bus/refresh请求不再发送到具体的服务实例上，而是发给config server并通过destination参数类指定需要更新配置的服务或实例。

**示例：只通知3355，不通知3366。**

修改配置文件config-dev.yml的version=6，并提交到仓库。

发送POST请求刷新：  
![在这里插入图片描述][20200320001843908.png]  
访问3355：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 9]  
访问3366：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 10]  
定点刷新成功！  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 11]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70]: /images/20210813/23f1314295f64283b9512e4461891269.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 1]: /images/20210813/5fe0950cf58645fdae836500f8f85009.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 2]: /images/20210813/f05227a3ab924cb19e5daa5367c39d6a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 3]: /images/20210813/1a6e222f875e4986a04518c53d5c0880.png
[20200319235548508.png]: /images/20210813/7f8fe8ce18a34b119c0d47747c9a1cba.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 4]: /images/20210813/9e0b9f869d5747b4a7e40500a4858e6d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 5]: /images/20210813/d86ce46d31444ef0b6eafb691de09992.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 6]: /images/20210813/f521b66e28a64b36a4382fe2ec0fdff7.png
[20200320000323328.png]: /images/20210813/1b310227416b460d8e27d0ca68dbc2de.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 7]: /images/20210813/98ee886ee39a4a7f92f54f6ceadb0744.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 8]: /images/20210813/1933bb4a1d784eecba0ef34b48cdb4f4.png
[20200320001843908.png]: /images/20210813/96520ee33de44216a67f81acc6ee4401.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 9]: /images/20210813/39eef1969dd34835926cad7eaac0a66e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 10]: /images/20210813/3799c3929b374dfca7529ee7b7dc7c3a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 11]: /images/20210813/b56c2ae0733c4552aa4e21ba00cc197d.png