SpringCloud微服务之Bus消息总线

谁借莪１个温暖的怀抱￠ 2022-12-20 11:30 202阅读 0赞

### 文章目录 ###

*   *  一。概念
     *   *  1.SpringCloud Bus是什么？
         *  2.SpringCloud Bus能干什么？
         *  3.为什么被称为总线？
     *  二。RabbitMQ环境配置
     *   *  1.安装Erlang
         *  2.安装RabbitMQ
     *  三。SpringCloud Bus动态刷新全局广播
     *   *  1.设计思想
         *  2.实现过程
         *  3.修改配置文件并测试
     *  四。SpringCloud Bus动态刷新定点刷新
     *   *  1.应用场景
         *  2.实现过程
         *  3.总结

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

## 一。概念 ##

### 1.SpringCloud Bus是什么？ ###

Spring Cloud Bus是用来将分布式系统的节点与轻量级消息系统链接起来的框架，它整合了整合 java的事件处理机制和消息中间件消息的发送和接受，主要由发送端、接收端和事件组成。针对不同的业务需求，可以设置不同的事件，发送端发送事件，接收端接受相应的事件，并进行相应的处理。Spring Cloud Bus目前支持**RabbitMQ**和**Kafka**.

### 2.SpringCloud Bus能干什么？ ###

SpringCloud Bus能管理和传播分布式系统间的消息，就像一个分布式执行器，可用于广播状态更改、事件推送等，也可以当作微服务间的通信通道。

### 3.为什么被称为总线？ ###

**什么是总线？**

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

**基本原理**

ConfigClient实例都监听MQ中同一个topic(默认是springCloudBus)。当一个服务刷新数据的时候，它会把这个信息放入到Topic中，这样其它监听同一Topic的服务就能得到通知，然后去更新自身的配置。

## 二。RabbitMQ环境配置 ##

RabbitMQ的安装需要有Elang环境的支持，所以我们需要先安装Elang

### 1.安装Erlang ###

1.官方地址：[https://www.erlang.org/][https_www.erlang.org]，选择自己的版本号进行下载，我这里选择的是windows 64位的：

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

### 2.安装RabbitMQ ###

官方地址：[https://github.com/rabbitmq/rabbitmq-server/releases/v3.8.3/][https_github.com_rabbitmq_rabbitmq-server_releases_v3.8.3]，选择自己的版本号进行下载，我这里选择的是3.8.3：

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

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

4.执行命令`rabbitmq-plugins enable rabbitmq_management`，安装三个插件：（由于我之前安装好了，所以没有重新下载）

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

7.登录成功出现RabbitMQ管控台，说明RabbitMQ安装成功：

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

## 三。SpringCloud Bus动态刷新全局广播 ##

### 1.设计思想 ###

设计思想主要分为以下两种：

1.  利用消息总线触发一个客户端/bus/refresh，从而刷新所有客户端配置：

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

1.  利用消息总线触发一个服务端ConfigServer/bus/refresh，从而刷新所有客户端配置：

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

**第二种架构显然更加合适，原因如下：**

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

**所以本篇博客都以第二种架构来实现！**

### 2.实现过程 ###

**注意**：这里最主要说的是Bus消息总线的新增配置，若对原有配置有疑问的，可以看看我的另外一篇博客：[SpringCloud微服务之分布式配置中心][SpringCloud]

1.在configserver-3344服务端的pom.xml文件中添加以下依赖：

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

2.在application.yml配置文件中，添加以下配置：

#rabbit相关配置 15672是web管理界面的端口，5672是MQ访问的端口
    spring:
      rabbitmq:
        host: localhost
        port: 5672
        username: guest
        password: guest
    
    
    #RabbitMQ相关配置，暴露bus刷新配置的端点
    management:
      endpoints:
        web:
          exposure:
            include: 'bus-refresh'

注意配置添加位置：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 15]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 16]  
3.在configclient-3355，以及configclient-3366客户端的pom.xml文件中添加以下依赖：

4.在bootstrap.yml配置文件中，添加以下配置：

#rabbit相关配置 15672是web管理界面的端口，5672是MQ访问的端口
    spring:
      rabbitmq:
        host: localhost
        port: 5672
        username: guest
        password: guest
    
    #暴露监控端点
    management:
      endpoints:
        web:
          exposure:
            include: "*"

5.配置完成后，启动eureka注册中心，再启动配置服务端3344，最后启动配置客户端3355，3366：

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

### 3.修改配置文件并测试 ###

1.依次访问[http://localhost:3344/master/application-dev.yml][http_localhost_3344_master_application-dev.yml]、[http://localhost:3355/configInfo][http_localhost_3355_configInfo]、[http://localhost:3366/configInfo][http_localhost_3366_configInfo]  
发现github上配置文件最初版本号为5.0：

![在这里插入图片描述][20201112114325173.png_pic_center]  
![在这里插入图片描述][20201112114328715.png_pic_center]

![在这里插入图片描述][20201112114332880.png_pic_center]

2.修改github上配置文件内容，把版本号改为6.0：

![在这里插入图片描述][20201112114516529.png_pic_center]

![在这里插入图片描述][2020111211453179.png_pic_center]

![在这里插入图片描述][20201112114543314.png_pic_center]

**至此，SpringCloud Bus动态刷新全局广播成功实现**

## 四。SpringCloud Bus动态刷新定点刷新 ##

### 1.应用场景 ###

解决不想全局通知，只想定点通知，精确打击的问题

*  指定具体某一个实例生效而不是全部
 *  http://localhost:配置中心端口号/actuator/bus-refresh/\{destination\}
 *  /bus/refresh请求不再发送到具体的服务实例上，而是发给config server并通过destination参数类指定需要更新配置的服务或者实例

### 2.实现过程 ###

案例：我们修改配置文件版本号为7.0，只通知3355，而不通知3366。

1.修改github配置文件内容，把版本号修改为7.0：

3.不重启的情况下，重新刷新各个网址，发现只有3344服务端和3355客户端读取的版本号发生改变，变为了7.0，而3366客户端读取的版本号还是6.0，没有发生任何改变：

![在这里插入图片描述][20201112115404946.png_pic_center]

![在这里插入图片描述][20201112115408738.png_pic_center]

![在这里插入图片描述][20201112115412856.png_pic_center]  
**至此，SpringCloud Bus动态刷新定点刷新成功实现**

### 3.总结 ###

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

[https_www.erlang.org]: https://www.erlang.org/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/a41bb2a6415c4044b7aa25145a8dcd2c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221120/577db528b2154265b3995dda546ea6ee.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221120/900aa86b154047e8ac0c546a8030458e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 3]: /images/20221120/51a19e64f8d0419992edbfab5df0e569.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 4]: /images/20221120/6197b3ad8f0045019504f64a25ab645d.png
[https_github.com_rabbitmq_rabbitmq-server_releases_v3.8.3]: https://github.com/rabbitmq/rabbitmq-server/releases/v3.8.3/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 5]: /images/20221120/a638e32b1edb4f3783298f85e650135d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 6]: /images/20221120/a821740d7e594209add2f4192901ac6b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 7]: /images/20221120/45377445b3f042f39ec0c5a0b7d6560c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 8]: /images/20221120/8ea966d159814fc5ac7ad1b9a4c32978.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 9]: /images/20221120/0974a57d8f6d4c94a752e20e8192315b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 10]: /images/20221120/aaf8010221704540aae15895d12d1fd2.png
[http_localhost_15672]: http://localhost:15672/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 11]: /images/20221120/132c8100557740298a5ac6ff1b3d25f5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 12]: /images/20221120/0ea7e8f1022b48afa9371aa2928c7d68.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 13]: /images/20221120/1edb2eb6d7d744e4b4d9285acaefcc78.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 14]: /images/20221120/b859d82998364ce19f81155df725432b.png
[SpringCloud]: https://blog.csdn.net/weixin_44009447/article/details/109502765
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 15]: /images/20221120/d4929a1fc0ee45fc9487aeca121568de.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 16]: /images/20221120/2c6d86c44f1b46e28a90ac57d93a7807.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 17]: /images/20221120/4c2a060cbe5d448ca0b2bc554cf521e4.png
[http_localhost_3344_master_application-dev.yml]: http://localhost:3344/master/application-dev.yml
[http_localhost_3355_configInfo]: http://localhost:3355/configInfo
[http_localhost_3366_configInfo]: http://localhost:3366/configInfo
[20201112114325173.png_pic_center]: /images/20221120/c3592174232541a2bcbf163210e9a49b.png
[20201112114328715.png_pic_center]: /images/20221120/331e7e44556b48aa9945f2e67dcdb6f6.png
[20201112114332880.png_pic_center]: /images/20221120/f5045f693e3442ff93fafd75126a62f9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 18]: /images/20221120/731ca7d7fb7847acaa0328be6b7e449a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 19]: /images/20221120/d03dd0e493064b0b98f8ed89e4b5eb03.png
[20201112114516529.png_pic_center]: /images/20221120/43b93cef0f0c4a409d97bc9f78d51170.png
[2020111211453179.png_pic_center]: /images/20221120/b3a48773b33e4b859fd576778185009d.png
[20201112114543314.png_pic_center]: /images/20221120/71e70868ab784932a7f706076a05d125.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 20]: /images/20221120/00c51933a4ea4143906ea56fdd948f41.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 21]: /images/20221120/55f0b58e15104236aeeab57f104d68a2.png
[20201112115404946.png_pic_center]: /images/20221120/01481357fb7b4ce2a0c7f3f0df938cb8.png
[20201112115408738.png_pic_center]: /images/20221120/bbfb64afd05d47b890e0944f35bfdef4.png
[20201112115412856.png_pic_center]: /images/20221120/b19772cfd8e34a95976077a13a564f52.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDAwOTQ0Nw_size_16_color_FFFFFF_t_70_pic_center 22]: /images/20221120/61b282338be04bc9bb00f45133401aca.png