Spring Cloud Bus消息总线

一、概述简介

官网：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能管理和传播分布式系统间的消息，就像一个分布式执行器，可用于广播状态更改、事件推送等，也可以当作微服务间的通信通道。

提到bus我们第一印象是config+bus结合 完成动态获取配置的功能，config配置中心有 个弊端，就是假如配置文件有修改，config客户端需要通过调用一个接口来告诉客户端，配置文件变了你需要重新拉去配置文件。假如微服务特别多的情况下，无疑是一件烦心事，bus可以完成微服务之间的通信，如下图所示：

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

上图当中应该很明显了，其中/bus/refresh就是动态刷新的接口。也就是通过这个接口为触发条件，告诉config服务端，他收到之后，通过消息总线通知所有连接他的客户端。

1.3. 为何被称为总线

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

基本原理

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

二、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

官网明确表示要想安装windows版的RabbitMQ就必须要安装Erlang，如果电脑没有安装Erlang，在安装RabbitMQ时候直接会报错！

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

关于Erlang和RabbitMQ安装，直接傻瓜式下一步即可，安装地址可以自己定。

2.2. 使用RabbitMQ

rabbitmq-plugins enable rabbitmq_management
1

这样就添加了rabbitmq界面,只要启动rabbitmq,然后在浏览器输入http://127.0.0.1:15672/就可以访问了

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

注意：有时候可能上面显示启动好了，但是还没启动完，所以访问的时候会访问不到，需要稍微等一会。

输入账号密码并登录: 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

<dependency>
    <groupId>org.springframework.cloudgroupId>
    <artifactId>spring-cloud-starter-bus-amqpartifactId>
dependency>
<dependency>
    <groupId>org.springframework.bootgroupId>
    <artifactId>spring-boot-starter-actuatorartifactId>
dependency>
1
2
3
4
5
6
7
8
9

2.添加yml配置

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

3.2.2. 调整3355config客户端

1.添加pom

<dependency>
    <groupId>org.springframework.cloudgroupId>
    <artifactId>spring-cloud-starter-bus-amqpartifactId>
dependency>
<dependency>
    <groupId>org.springframework.bootgroupId>
    <artifactId>spring-boot-starter-actuatorartifactId>
dependency>
1
2
3
4
5
6
7
8
9

2.添加yml配置

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

3.2.3. 搭建3366config客户端

搭建3366主要是为了演示多客户端的情况

1.新建项目
2.添加pom

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

<dependencyManagement>
    <dependencies>
        <dependency>
           <groupId>org.springframework.bootgroupId>
           <artifactId>spring-boot-dependenciesartifactId>
           <version>${springboot.version}version>
           <type>pomtype>
           <scope>importscope>
       dependency>
        <dependency>
           <groupId>org.springframework.cloudgroupId>
           <artifactId>spring-cloud-dependenciesartifactId>
           <version>${springcloud.version}version>
           <type>pomtype>
           <scope>importscope>
       dependency>
    dependencies>
dependencyManagement>

<dependencies>
    <dependency>
         <groupId>org.springframework.cloudgroupId>
         <artifactId>spring-cloud-starter-configartifactId>
     dependency>
     <dependency>
         <groupId>org.springframework.bootgroupId>
         <artifactId>spring-boot-starter-webartifactId>
     dependency>
     <dependency>
         <groupId>org.springframework.bootgroupId>
         <artifactId>spring-boot-starter-actuatorartifactId>
     dependency>
     
     <dependency>
         <groupId>org.springframework.cloudgroupId>
         <artifactId>spring-cloud-starter-bus-amqpartifactId>
     dependency>
     
     <dependency>
         <groupId>org.springframework.cloudgroupId>
         <artifactId>spring-cloud-starter-bootstrapartifactId>
     dependency>
dependencies>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

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
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

4.添加业务类

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

    @GetMapping("/configInfo")
    public String getName() {
        return name;
    }
}
1
2
3
4
5
6
7
8
9
10
11

3.2.4. 测试

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

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

假如cloud用的H老版本使用：curl -X POST "http://localhost:3344/actuator/bus-refresh"
假如cloud用的新版本使用：curl -X POST "http://localhost:3344/actuator/busrefresh"
这块需要注意一下，要不然访问会报以下错误！

这块记住访问接口他会刷新所有客户端，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