SpringCloud微服务之Bus消息总线

83 阅读 0 评论 55 点赞

我是靠谱客的博主淡定纸飞机，最近开发中收集的这篇文章主要介绍SpringCloud微服务之Bus消息总线，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

文章目录

- 一。概念
- - 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/，选择自己的版本号进行下载，我这里选择的是windows 64位的：

在这里插入图片描述
2.下载完成后打开安装包，一直跟着下一步安装即可：

在这里插入图片描述
3.安装完成后添加系统变量ERLANG_HOME，值为安装目录：

在这里插入图片描述
4.编辑Path变量，新增值为%ERLANG_HOME%bin：

在这里插入图片描述
5.打开命令行，输入erl，出现对应的版本号则说明安装成功：

在这里插入图片描述

2.安装RabbitMQ

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

在这里插入图片描述
2.下载完成后打开安装包，一直跟着下一步安装即可：

在这里插入图片描述
3.安装完成后进入安装目录的sbin目录，在地址栏输出cmd，回车，以命令行的方式进入该目录下：

在这里插入图片描述

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

在这里插入图片描述
5.下载完成后，将出现以下三个插件：

在这里插入图片描述
6.访问网址：http://localhost:15672/，默认用户名：guest，密码：guest

在这里插入图片描述

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

在这里插入图片描述

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

1.设计思想

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

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

在这里插入图片描述

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

在这里插入图片描述

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

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

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

2.实现过程

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

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

<!-- 添加消息总线RabbitMQ支持 -->
        <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'

注意配置添加位置：

在这里插入图片描述

3.在configclient-3355，以及configclient-3366客户端的pom.xml文件中添加以下依赖：

<!-- 添加消息总线RabbitMQ支持 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
        </dependency>

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

 #rabbit相关配置 15672是web管理界面的端口，5672是MQ访问的端口
spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

#暴露监控端点
management:
  endpoints:
    web:
      exposure:
        include: "*"