关于Springcloud Bus的使用小结

谁借莪１个温暖的怀抱￠ 2022-10-27 06:19 41阅读 0赞

**目录**

1. Springcloud Bus概述

2. RabbitMQ配置

3. Springcloud Bus动态刷新

3.1 全局广播

3.1.1 设计思想

3.1.2 配置消息总线

3.1.3 配置更新测试

3.2 定点通知

--------------------

# 1. Springcloud Bus概述 #

> Spring Cloud Bus links the nodes of a distributed system with a lightweight message broker. This broker can then be used to broadcast state changes (such as configuration changes) or other management instructions. A key idea is that the bus is like a distributed actuator for a Spring Boot application that is scaled out. However, it can also be used as a communication channel between apps. This project provides starters for either an AMQP broker or Kafka as the transport.

1) 由于Spring Cloud Config更新配置信息的方式不是很方便，所以接下来总结一下[Spring Cloud Bus][]配合Spring Cloud Config使用实现配置的动态刷新。

在微服务架构的系统中，通常会使用轻量级的消息代理，并让系统中所有微服务实例都接上来。由于该主题中产生的消息会被所有实例监听和消费，所以称之为消息总线。

在总线的各个实例，都可以很方便地广播一些需要让其他连接在该主题的实例都知道的信息。

2) 原理：ConfigClient实例都监听MQ中同一个topic（默认是SpringcloudBus），当一个服务刷新数据的时候，它会把这个消息放到topic，然后其他监听同一topic的服务就能得到通知并更新自身的配置。

# 2. RabbitMQ配置 #

1) 先安装[erlang][]下面的otp\_win64\_23.2.exe。

2) 然后安装[rabbitMQ][]下面的rabbitmq-server-3.8.9.exe。

3) 进入RabbitMQ安装目录下的sbin目录，当前cmd**输入**：.\\rabbitmq-plugins.bat enable rabbitmq\_management

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70][]

4) 启动成功后就能访问（输入账号密码都是**guest**）：localhost:15672/

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 1][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 2][]

# 3. Springcloud Bus动态刷新 #

以下案例代码的[Github地址][Github]。

四个modules分别是：cloud-eureka-server7001，cloud-config-center-3344，cloud-config-client-3355，cloud-config-client-3366。

## 3.1 全局广播 ##

### 3.1.1 设计思想 ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 3][]

利用消息总线触发一个服务端ConfigServer，从而刷新所有客户端的配置。

### 3.1.2 配置消息总线 ###

1) cloud-config-center-3344，cloud-config-client-3355，cloud-config-client-3366添加spring-cloud-starter-bus-amqp。

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

2) cloud-config-client-3355，cloud-config-client-3366添加rabbitMQ配置。

rabbitmq:
      host: localhost
      port: 5672
      username: guest
      password: guest
    
    #暴露监控端点
    management:
      endpoints:
        web:
          exposure:
            include: "*"

3) cloud-config-center-3344添加rabbitMQ配置。

rabbitmq:
      host: localhost
      port: 5672
      username: guest
      password: guest
    
    #rabbitmq相关设置 ，暴露 bus刷新配置的端点
    management:
      endpoints:
        web:
          exposure:
            include: 'bus-refresh'

### 3.1.3 配置更新测试 ###

1) 修改Github配置中心的配置文件（**修改版本号**）：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 4][]

配置中心cloud-config-center-3344的即时获取到了最新的配置信息（localhost:3344/main/config-dev.yml）。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 5][]

当前的cloud-config-client-3355和cloud-config-client-3366配置信息还是旧的（localhost:3355/configInfo）。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 6][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 7][]

2) 发送Post请求一次性刷新所有客户端的配置信息。

curl -X POST "http://localhost:3344/actuator/bus-refresh"

![20210204001859978.png][]

这个时候的cloud-config-client-3355和cloud-config-client-3366配置信息都更新了。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 8][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 9][]

**注**：如果返回405，记得检查一下步骤3.1.2的相关依赖是否已经引入，以及与其他依赖的版本是否一致。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 10][]

## 3.2 定点通知 ##

简单来说就是，不想全部通知而只想更新指定实例的配置信息。

1) 修改Github配置中心的配置文件（**修改版本号**）：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 11][]

2) 配置中心cloud-config-center-3344的即时获取到了最新的配置信息（localhost:3344/main/config-dev.yml）。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 12][]

3) 发送Post请求一次性刷新cloud-config-client-3355的配置信息。

![20210204002718869.png][]

curl -X POST "http://localhost:3344/actuator/bus-refresh/config-client:3355"

这个时候只有cloud-config-client-3355的配置信息更新了。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 13][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 14][]

**附**：

1. 关于Springcloud Stream消息驱动可以参考：[关于Springcloud Stream消息驱动的使用小结][Springcloud Stream]。

[Spring Cloud Bus]: https://cloud.spring.io/spring-cloud-bus/reference/html/
[erlang]: https://erlang.org/download/
[rabbitMQ]: https://dl.bintray.com/rabbitmq/all/rabbitmq-server/3.8.9/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70]: /images/20221024/52ff2732f26f40acb844cf954253bdca.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 1]: /images/20221024/1b280b5728a6453e8d18035c340c87bc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 2]: /images/20221024/710149205575471b96ce65af084c2240.png
[Github]: https://github.com/BAStriver/springcloud-test
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 3]: /images/20221024/775d87026b114e81a1471cc4c6562d0d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 4]: /images/20221024/f51e85b165e94514813e52907a4c1c00.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 5]: /images/20221024/a4608b6065af4fff8f3e2399f646c887.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 6]: /images/20221024/391e0dc9620140cca17805ba461df10e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 7]: /images/20221024/0a0e09bb8a7c4e659093cc47b0bbee3e.png
[20210204001859978.png]: /images/20221024/f16090733d954fed80edc1c757524603.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 8]: /images/20221024/4b76820df4ac420d93b6128783251304.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 9]: /images/20221024/53ba1407328d4fc38e4f580ba8fc0796.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 10]: /images/20221024/3183829facc34bc0a942698fca812d37.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 11]: /images/20221024/c5421a22fddf416091298b337877a554.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 12]: /images/20221024/6a12bb83da9f4c0bafab3d4a89591072.png
[20210204002718869.png]: /images/20221024/6f751d08e0854e27bebf02342f429ae2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 13]: /images/20221024/47394dca8dac473eb06aefc419f8cf84.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0JBU3RyaXZlcg_size_16_color_FFFFFF_t_70 14]: /images/20221024/4f945bbe1c0f450b8aa31687c8a6db76.png
[Springcloud Stream]: https://blog.csdn.net/BAStriver/article/details/113665916