Spring Cloud（十五）Bus 消息总线

r囧r小猫 2022-11-25 13:11 130阅读 0赞

**Table of Contents**

1.Bus 介绍

2.config服务端修改

3.客户端修改

4.POST 请求执行全局通知

5.POST 请求执行定点通知

6.config 本地文系统

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

## 1.Bus 介绍 ##

[https://spring.io/projects/spring-cloud-bus][https_spring.io_projects_spring-cloud-bus]

Spring Cloud Bus将轻量级消息代理程序链接到分布式系统的节点。然后可以将其用于广播状态更改（例如，配置更改）或其他管理指令。支持两种消息代理：**AMQP和Kafka**。另外，在类路径上找到的任何[Spring Cloud Stream][]绑定程序都可以作为传输工具使用。

**总线**  
在微服务架构的系统中,通常会使用轻量级的消息代理来构建一个共用的消息主题,并让系统中所有微服务实例都连接上来。由于该主题中产生的消息会被所有实例监听和消费,所以称它为消息总线。在总线上的各个实例,都可以方便地广播一些需要让其他连接在该主题上的实例都知道的消息。  
**基本原理**  
ConfigClient实例都监听MQ中同一个topic(默认是**springCloudBus**),当一个服务刷新数据的时候,它会把这个信息放入到Topic中,这样其它监听同一Topic的服务就能得到通知,然后去更新自身的配置。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70][]

***[点击 RabbitMQ安装使用][RabbitMQ]***

[http://localhost:15672][http_localhost_15672]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 1][]

## 2.config服务端修改 ##

**config-center-3344**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 2][]

**pom.xml**

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

**yml**

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

## 3.客户端修改 ##

**config-client-3370**

**pom.xml**

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

**yml**

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

**根据 config-client-3370 新建 config-client-3371**

## 4.POST 请求执行**全局通知** ##

curl -X POST "http://localhost:3344/actuator/bus-refresh"

**结果：**3370、3371都已经改变，一次修改、广播通知、到处运行

## 5.POST 请求执行定点**通知** ##

实现方法：cmd 刷新3370

curl -X POST "http://localhost:3344/actuator/bus-refresh/config-client:3370"

## 6.config 本地文系统 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 3][]

spring:
      application:
        name: config-center
      profiles:
        active: native
      cloud:
        config:
          server:
            native:
              search-locations: classpath:/config

修改config文件，重启 **config-center-3344** ，再按照  **5或6的方式** 通知

[https_spring.io_projects_spring-cloud-bus]: https://spring.io/projects/spring-cloud-bus
[Spring Cloud Stream]: https://spring.io/projects/spring-cloud-stream
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70]: /images/20221124/244287297d3447cc89e847ae2cf3113e.png
[RabbitMQ]: https://blog.csdn.net/weixin_42032199/article/details/107526322
[http_localhost_15672]: http://120.25.227.131:15672/#/exchanges
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 1]: /images/20221124/83a524d831e241cbaaaa03d137033fe5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 2]: /images/20221124/f2d1687721814d30b3ea347c68ff78e4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 3]: /images/20221124/cff2affecf7b452a805a7683bac26b01.png