Spring Cloud Bus 服务总线，实现全局广播/定点通知

淡淡的烟草味﹌ 2022-12-06 12:41 199阅读 0赞

> 转载声明 : 该文章出处为 [扛麻袋的少年][Link 1]

### 本文目录： ###

*   *  写在开头
     *  环境说明
     *  1.了解 Spring Cloud Bus
     *   *   *  2.1 Bus 何方神圣 (Bus 是什么)
             *  2.2 Bus 原理
     *  2.Bus的两种设计思想
     *   *   *  2.1 触发客户端
             *  2.2 触发服务端
             *  2.3 如何选型
     *  3.环境搭建
     *  4.Bus 动态刷新全局广播配置
     *   *   *  4.1 集群版客户端组建
             *  4.2 服务端配置中心/客户端 pom 引入Bus总线依赖
             *  4.3 服务端配置中心 application.yml 修改 (添加 rabbitmq 相关配置)
             *  4.4 客户端 application.yml 修改 (同样添加 rabbitmq 相关配置)
             *  4.5 启动模块，开始测试
     *  5. Bus 动态刷新定点通知配置

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

## 写在开头 ##

接上一篇文章：[Spring Cloud Config 实现分布式配置中心、动态刷新机制配置][Spring Cloud Config]。针对 Spring Cloud Config 存在的问题：

1.  **`无法真正实现：一处通知、处处生效；`**
2.  **`无法实现精确通知,只通知集群中的某些服务(精确通知，比如有100台机器，只通知前98台)`**

带着上面这两个问题，我们来聊聊 Spring Cloud Bus 服务总线。

## 环境说明 ##

1.  `Config Server` 服务端配置中心，端口号：3344
2.  客户端，端口号：3355、3366，(采用集群模式，演示精确通知)
3.  **Tips：**环境相关配置，可以参考上一篇文章：[Spring Cloud Config 实现分布式配置中心、动态刷新机制配置][Spring Cloud Config]

## 1.了解 Spring Cloud Bus ##

附送直达飞机票：[Spring Cloud Bus 官网][Spring Cloud Bus]

#### 2.1 Bus 何方神圣 (Bus 是什么) ####

在微服务架构的系统中，通常会使用 轻量级的消息代理 来构建一个共用的消息主题，并让系统中所有的微服务示例都连接上来。由于 该主题中产生的消息会被所有实例监听和消费，所以称它为**消息总线**。在总线上的各个实例，都可以方便的广播一些需要让其他连接在该主题上的实例都知道的消息。

Spring Cloud Bus 是用来将 `分布式系统的节点`与 `轻量级消息系统`连接起来的框架，它整合了 Java 的事件处理机制和消息中间件的功能。**`Spring Cloud Bus 目前仅支持 RabbitMQ 和 Kafka。`**

#### 2.2 Bus 原理 ####

Config 客户端示例，都去监听 MQ 中的同一个 topic（默认是 **`springCloudBus`**）。当一个服务刷新数据的时候，它会把这个消息放入到 Topic 中，这样其他监听同一 Topic 的服务就能够得到通知，然后去更新自身的配置。**`就是通过 MQ 消息队列的 Topic 机制，达到广播的效果。`**

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

## 2.Bus的两种设计思想 ##

选用 Spring Cloud Bus 进行 Topic 消息的发送，在技术选型上共有两种设计思想：

#### 2.1 触发客户端 ####

利用消息总线，触发一个**客户端** 的 **`/bus/refresh`** 端点。通过客户端向 Bus 总线发送消息，实现刷新所有客户端的配置。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x6YjM0ODExMDE3NQ_size_16_color_FFFFFF_t_70 1]

#### 2.2 触发服务端 ####

利用消息总线，触发一个**服务端** 的 **`/bus/refresh`** 端点。通过Config Server 服务端向 Bus 总线发送消息，实现刷新所有客户端的配置。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x6YjM0ODExMDE3NQ_size_16_color_FFFFFF_t_70 2]

#### 2.3 如何选型 ####

根据架构图显然 **`图二`** 更加合适，所以推荐使用 **`触发服务端 Config Server`** 的方式。**`图一触发客户端方式`** 不适合的原因如下：

1.  利用消息总线触发客户端方式，`打破了微服务的职责单一性`，因为微服务本身是业务模块，它本不应该承担配置刷新的职责；
2.  触发客户端方式，`破坏了微服务各个节点之间的对等性`（比如说：3355/3366/3377 集群方式提供服务，此时 3355 还需要消息通知，影响节点的对等性）
3.  `有一定的局限性。`当微服务迁移时，网络地址会经常发生变化，如果此时需要做到自动刷新，则会增加更多的修改。

## 3.环境搭建 ##

**`Spring Cloud Bus 目前仅支持 RabbitMQ 和 Kafka。`** 此处选型 RabbitMQ，Rabbit MQ 需要 Erlang 环境。所以我们先来安装 Erlang 和 Rabbit MQ

Erlang 下载地址：[http://erlang.org/download/otp\_win64\_21.3.exe][http_erlang.org_download_otp_win64_21.3.exe]；  
  RabbitMQ 下载地址：[https://dl.bintray.com/rabbitmq/all/rabbitmq-server/3.7.14/rabbitmq-server-3.7.14.exe][https_dl.bintray.com_rabbitmq_all_rabbitmq-server_3.7.14_rabbitmq-server-3.7.14.exe]

下载过慢的话，你也可以来这里，我都帮你们下载好了。地址：[https://pan.baidu.com/s/16m20KfU4x6nkCYXz-L\_c5Q][https_pan.baidu.com_s_16m20KfU4x6nkCYXz-L_c5Q] （提取码：yevm）

此处下载的是 Window 版，傻瓜式安装，**`下一步`** → **`下一步`→`完成`**，OK 搞定。如需 Linux 版，请自行了解安装。此时cmd 命令行进入 Rabbit MQ 安装目录 sbin 下，使用命令：**`rabbitmq-plugins enable rabbitmq_management`** 启动 RabbitMQ的同时，添加了 Rabbit 的可视化插件。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x6YjM0ODExMDE3NQ_size_16_color_FFFFFF_t_70 3]  
**补：初次启动图**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x6YjM0ODExMDE3NQ_size_16_color_FFFFFF_t_70 4]

这样在浏览器输入 **`http://localhost:15672`** 便能够访问 Rabbit MQ 的可视化界面了。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x6YjM0ODExMDE3NQ_size_16_color_FFFFFF_t_70 5]

## 4.Bus 动态刷新全局广播配置 ##

根据上文：[Spring Cloud Config 实现分布式配置中心、动态刷新机制配置][Spring Cloud Config]，根据 **`cloud-config-center-3355`** 来配置一个一模一样的客户端 **`cloud-config-center-3366`**。与 3355 组成集群模式，方便接下来 Bus **`定点通知`** 效果的演示。

#### 4.1 集群版客户端组建 ####

**`cloud-config-center-3366`** 请参考 3355，此处不再介绍。

#### 4.2 服务端配置中心/客户端 pom 引入Bus总线依赖 ####

在`服务端`配置中心 Config Server (3344)、客户端集群(3355/3366) 中引入 Bus 总线依赖

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

#### 4.3 服务端配置中心 application.yml 修改 (添加 rabbitmq 相关配置) ####

#添加rabbitmq相关支持（新加）
    spring:
      rabbitmq:
        host: localhost
        port: 5672
        username: guest
        password: guest
    #rabbitmq相关配置，暴露bus舒心配置的端点
    management:
      endpoints:
        web:
          exposure:
            include: 'bus-refresh'  #为什么配置 bus-refresh，看传染病那张图

#### 4.4 客户端 application.yml 修改 (同样添加 rabbitmq 相关配置) ####

#添加rabbitmq相关支持
    spring:
      rabbitmq:
        host: localhost
        port: 5672
        username: guest
        password: guest
    #暴露监控端点
    management:
      endpoints:
        web:
          exposure:
            include: "*"  #此处有很多选项可以配置，为了省事 ,直接配置 *

#### 4.5 启动模块，开始测试 ####

启动：服务端配置中心 Config Server (3344)、客户端集群(3355/3366)、Eureka Server(7001)。修改 GitHub 参数配置，然后向 **`服务端`** 发送 Post 请求，命令：**`curl -X POST "http://localhost:3344/actuator/bus-refresh"`**，

当向 Config Server 发送 Post 请求后，总线上的各个实例(客户端 3355/3366 )都能够及时 **`监听和消费`** 配置的变更。使用广播的方式，真正的实现 **`一处通知，处处生效`**。测试如图所示：  
![在这里插入图片描述][20200717154009561.gif]  
  使用 MQ 广播的方式，实现 **`一处通知，处处生效`** 的效果。此时我们登陆 Rabbit MQ 客户端，在 **`Exchanges`** 模块，就能够看到一个叫做 **`springCloudBus`** 的 Topic。

与本文 **`2.2 Bus 原理`** 中介绍吻合：Config 客户端示例，都去监听 MQ 中的同一个 topic（默认是 `springCloudBus`）。当一个服务刷新数据的时候，它会把这个消息放入到 Topic 中，这样其他监听同一 Topic 的服务就能够得到通知，然后去更新自身的配置。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x6YjM0ODExMDE3NQ_size_16_color_FFFFFF_t_70 6]

## 5. Bus 动态刷新定点通知配置 ##

如果需要 **`差异化通知`**，并不想进行全局广播，此时就用到了 Bus 的 **`定点通知`** 功能。

此次我们通过客户端集群(3344/3355)演示。GitHub 远程配置修改后 ，进行差异化定点通知，只通知 3355，不通知 3366。此处命令和全局广播有点不同，命令为：**`http://配置中心IP:配置中心的端口号/actuator/bus-refresh/{destination}`**

通过指定 **`/bus/refresh请求`** 不再发送到具体的服务实例上，而是发给 Config Server 并通过 **`{destination} 参数`** 来指定需要更新配置的服务或实例。

**`{destination} 参数`** = **微服务名 ：端口号**。3355 微服务名为：**`config-client`**。此处最终发送的 Post 请求命令为：**`curl -X POST http://localhost:3344/actuator/bus-refresh/config-client:3355`**，真正的实现 **`精确通知`** 功能。测试如图所示：  
![在这里插入图片描述][20200717161926670.gif]

> 本文代码同 Spring Cloud Config 整合打包，**代码下载地址：**[Spring Cloud Config + Spring Cloud Bus 实现统一服务配置、一处通知处处生效、精确通知功能][https_pan.baidu.com_s_16m20KfU4x6nkCYXz-L_c5Q] （提取码：yevm）  
>    
> 下一篇：[Spring Cloud Stream 消息驱动，MQ之间交流更轻松][Spring Cloud Stream _MQ]

[Link 1]: https://blog.csdn.net/lzb348110175/article/details/107732513
[Spring Cloud Config]: https://blog.csdn.net/lzb348110175/article/details/107387510
[Spring Cloud Bus]: https://cloud.spring.io/spring-cloud-static/spring-cloud-bus/2.2.1.RELEASE/reference/html/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x6YjM0ODExMDE3NQ_size_16_color_FFFFFF_t_70]: /images/20221123/80cc49bdcafc41a69d23ff8a3abbc683.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x6YjM0ODExMDE3NQ_size_16_color_FFFFFF_t_70 1]: /images/20221123/cbb9eaf5f8b74f349416eec8a9aa078a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x6YjM0ODExMDE3NQ_size_16_color_FFFFFF_t_70 2]: /images/20221123/6abdfc84634d4324844501c57e764cf0.png
[http_erlang.org_download_otp_win64_21.3.exe]: http://erlang.org/download/otp_win64_21.3.exe
[https_dl.bintray.com_rabbitmq_all_rabbitmq-server_3.7.14_rabbitmq-server-3.7.14.exe]: https://dl.bintray.com/rabbitmq/all/rabbitmq-server/3.7.14/rabbitmq-server-3.7.14.exe
[https_pan.baidu.com_s_16m20KfU4x6nkCYXz-L_c5Q]: https://pan.baidu.com/s/16m20KfU4x6nkCYXz-L_c5Q
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x6YjM0ODExMDE3NQ_size_16_color_FFFFFF_t_70 3]: /images/20221123/2868cccba6044df0a8f6c4013a4efeed.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x6YjM0ODExMDE3NQ_size_16_color_FFFFFF_t_70 4]: /images/20221123/d5cd2f345d164714bd58d47c4c43342b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x6YjM0ODExMDE3NQ_size_16_color_FFFFFF_t_70 5]: /images/20221123/722664bc2ed946209009f44e2ad6dfdd.png
[20200717154009561.gif]: /images/20221123/92635c48b7564727962be2655b28a4af.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2x6YjM0ODExMDE3NQ_size_16_color_FFFFFF_t_70 6]: /images/20221123/541dfb222bc9433794d49bdc3819cb03.png
[20200717161926670.gif]: /images/20221123/17478338eb7c4526a6a91facc7666fd4.png
[Spring Cloud Stream _MQ]: https://blog.csdn.net/lzb348110175/article/details/107425554