Spring Cloud Bus消息总线

目录

• • 一、概述简介
  • • 1.1. Bus是什么
    • 1.2. Bus能干嘛
    • 1.3. 为何被称为总线
  • 二、RabbitMQ环境配置
  • • 2.1. windows下载与安装
    • 2.2. 使用RabbitMQ
  • 三、Bus动态刷新全局广播
  • • 3.1. Bus设计思想
    • 3.2. 代码实现
    • • 3.2.1. 调整3344config服务端
      • 3.2.2. 调整3355config客户端
      • 3.2.3. 搭建3366config客户端
      • 3.2.4. 测试
      • 3.2.5. Bus动态刷新定点通知
  • 四、其他
  • • 4.1. 疑点
    • 4.2. 自定义主题

一、概述简介

官网：https://docs.spring.io/spring-cloud-bus/docs/current/reference/html/

1.1. Bus是什么

Spring Cloud Bus是用来将分布式系统的节点 与 轻量级消息系统 链接起来的框架。

注意：它不属于消息中间件，他是通过和消息中间件整合，来完成服务之间消息通讯，类似于消息代理。

Spring Clud Bus目前支持RabbitMQ和Kafka。

1.2. Bus能干嘛

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

config教程：https://blog.csdn.net/weixin_43888891/article/details/126454087

1.3. 为何被称为总线

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

基本原理

二、RabbitMQ环境配置

2.1. windows下载与安装

RabbitMQ官网：https://www.rabbitmq.com/

截止到现在RabbitMQ最新版本是3.10.7

RabbitMQ下载地址：https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.10.7/rabbitmq-server-3.10.7.exe

Erlang官网：https://erlang.org/download/otp_versions_tree.html

Erlang下载地址：https://github.com/erlang/otp/releases/download/OTP-25.0.4/otp_win64_25.0.4.exe

2.2. 使用RabbitMQ

rabbitmq-plugins enable rabbitmq_management

访问地址查看是否安装成功:

输入账号密码并登录: guest guest

三、Bus动态刷新全局广播

3.1. Bus设计思想

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

（2）利用消息总线触发一个服务端ConfigServer的/bus/refresh端点，而刷新所有客户端的配置

图二的架构显然更加适合,图一不适合的原因如下：

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

3.2. 代码实现

基于config实现：https://blog.csdn.net/weixin_43888891/article/details/126454087

3.2.1. 调整3344config服务端

1.添加pom

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

2.添加yml配置

##rabbitmq相关配置,暴露bus刷新配置的端点
management:
  endpoints: #暴露bus刷新配置的端点
    web:
      exposure:
        include: 'bus-refresh'

3.2.2. 调整3355config客户端

1.添加pom

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

2.添加yml配置

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

3.2.3. 搭建3366config客户端

1.新建项目
2.添加pom

<properties>
    <maven.compiler.source>8</maven.compiler.source>
    <maven.compiler.target>8</maven.compiler.target>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <springboot.version>2.6.8</springboot.version>
    <springcloud.version>2021.0.3</springcloud.version>
</properties>

<dependencyManagement>
    <dependencies>
        <dependency>
           <groupId>org.springframework.boot</groupId>
           <artifactId>spring-boot-dependencies</artifactId>
           <version>${springboot.version}</version>
           <type>pom</type>
           <scope>import</scope>
       </dependency>
        <dependency>
           <groupId>org.springframework.cloud</groupId>
           <artifactId>spring-cloud-dependencies</artifactId>
           <version>${springcloud.version}</version>
           <type>pom</type>
           <scope>import</scope>
       </dependency>
    </dependencies>
</dependencyManagement>

<dependencies>
    <dependency>
         <groupId>org.springframework.cloud</groupId>
         <artifactId>spring-cloud-starter-config</artifactId>
     </dependency>
     <dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-web</artifactId>
     </dependency>
     <dependency>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-actuator</artifactId>
     </dependency>
     <!--添加消息总线RabbitMQ支持-->
     <dependency>
         <groupId>org.springframework.cloud</groupId>
         <artifactId>spring-cloud-starter-bus-amqp</artifactId>
     </dependency>
     <!--cloud新版本默认将bootstrap移除了，所以需要添加如下依赖-->
     <dependency>
         <groupId>org.springframework.cloud</groupId>
         <artifactId>spring-cloud-starter-bootstrap</artifactId>
     </dependency>
</dependencies>

3.添加bootstrap.yml

server:
  port: 3366

spring:
  application:
    name: config-client
  cloud:
    #Config客户端配置
    config:
      label: master #分支名称
      name: application #配置文件名称
      profile: dev #读取后缀名称   上述3个综合：master分支上config-dev.yml的配置文件被读取http://config-3344.com:3344/master/config-dev.yml
      uri: http://localhost:3344 #配置中心地址k
      request-connect-timeout: 10000 #使用属性配置连接超时
      request-read-timeout: 185000 #使用属性配置读取超时
  #rabbitmq相关配置 15672是Web管理界面的端口；5672是MQ访问的端口
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

4.添加业务类

@RestController
@RefreshScope
public class ConfigClientController {
    @Value("${name}")
    private String name;

    @GetMapping("/configInfo")
    public String getName() {
        return name;
    }
}

3.2.4. 测试

启动3344服务端和3355、3366客户端

当修改git云端配置的时候，通过以下接口来通知其他客户端，就是通过bus来完成通知的，这样config客户端就拿到了最新的配置。

3.2.5. Bus动态刷新定点通知

现在还存在一个问题，假如有多个客户端，我并不想全部通知，想着只通知个别客户端，需要怎么做呢？

公式: http://localhost:配置中心的端口号/actuator/bus-refresh/{destination}

destination参数是spring.application.name + server.port

案例：只通知3355，不通知3306：curl -X POST "http://localhost:3344/actuator/busrefresh/config-client:3355"

其实就是如下图所示的流程：

四、其他

4.1. 疑点

（1）问题一： 既然config的服务端是通过消息总线来通知客户端的，但是我们会发现一个问题，我们在config服务端其实并没有添加rabbitmq相关的连接信息，而只是引入了他的依赖，就完成了客户端通知，这是怎么回事呢？如下请看官网解释：

4.2. 自定义主题

bus的配置属性：https://docs.spring.io/spring-cloud-bus/docs/current/reference/html/appendix.html