SpringCloud BUS 消息总线协调微服务配置与服务消息同步

矫情吗；* 2023-01-17 14:50 193阅读 0赞

**目录**

Spring Cloud Bus简介

config-server添加消息总线支持

config-client添加消息总线支持

动态刷新配置演示

参考文章

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

##  Spring Cloud Bus简介 ##

Spring Cloud config配置中心可以实现配置修改在不重启服务的情况下进行更新，但是每次更新属性还要去一个一个访问接口，太麻烦了，这个时候我们就要象到发布-订阅模型，让所有服务去订阅这个事件（配置文件发生改变），当配置文件改变时，去通知所有服务更新配置，Bus消息总线就可以完成这样的功能。Spring Cloud Bus除了支持RabbitMQ之外，还支持现在被广泛应用的Kafka，本文中使用kafka做消息总线，另外spring boot版本是2.1.3和1.x的版本不同。

我们通常会使用消息代理来构建一个主题，然后把微服务架构中的所有服务都连接到这个主题上去，当我们向该主题发送消息时，所有订阅该主题的服务都会收到消息并进行消费。使用 Spring Cloud Bus 可以方便地构建起这套机制，所以 Spring Cloud Bus 又被称为消息总线。Spring Cloud Bus 配合 Spring Cloud Config 使用可以实现配置的动态刷新。目前  Spring Cloud Bus 支持两种消息代理：RabbitMQ 和 Kafka，下面以 RabbitMQ 为例来演示下使用Spring Cloud Bus 动态刷新配置的功能。

![c853dd685530f03762c28de12c323e96.png][]

服务间消息同步模型：

![3f0c52b72981557d6caf3b4eb2acf9ac.png][]

![ce0c3211cde327d787ee64405aee53a2.png][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Jvb255YQ_size_16_color_FFFFFF_t_70][]

下面是config-server和config-clinet配置集成spring cloud bus的过程。

## config-server添加消息总线支持 ##

*  在pom.xml中添加相关依赖：

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

*  添加配置文件application-amqp.yml，主要是添加了RabbitMQ的配置及暴露了刷新配置的Actuator端点；

server:
      port: 8904
    spring:
      application:
        name: config-server
      cloud:
        config:
          server:
            git:
              uri: https://gitee.com/macrozheng/springcloud-config.git
              username: macro
              password: 123456
              clone-on-start: true # 开启启动时直接从git获取配置
      rabbitmq: #rabbitmq相关配置
        host: localhost
        port: 5672
        username: guest
        password: guest
    eureka:
      client:
        service-url:
          defaultZone: http://localhost:8001/eureka/
    management:
      endpoints: #暴露bus刷新配置的端点
        web:
          exposure:
            include: 'bus-refresh'

## config-client添加消息总线支持 ##

*  在pom.xml中添加相关依赖：

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

*  添加配置文件bootstrap-amqp1.yml及bootstrap-amqp2.yml用于启动两个不同的config-client，两个配置文件只有端口号不同；

server:
      port: 9004
    spring:
      application:
        name: config-client
      cloud:
        config:
          profile: dev #启用环境名称
          label: dev #分支名称
          name: config #配置文件名称
          discovery:
            enabled: true
            service-id: config-server
      rabbitmq: #rabbitmq相关配置
        host: localhost
        port: 5672
        username: guest
        password: guest
    eureka:
      client:
        service-url:
          defaultZone: http://localhost:8001/eureka/
    management:
      endpoints:
        web:
          exposure:
            include: 'refresh'

## 动态刷新配置演示 ##

*  我们先启动相关服务，启动eureka-server，以application-amqp.yml为配置启动config-server，以bootstrap-amqp1.yml为配置启动config-client，以bootstrap-amqp2.yml为配置再启动一个config-client，启动后注册中心显示如下：

![edaac451bff70c942af65a883022588b.png][]

*  启动所有服务后，我们登录RabbitMQ的控制台可以发现Spring Cloud Bus 创建了一个叫springCloudBus的交换机及三个以 springCloudBus.anonymous开头的队列：

![1a7361465cd2f7e2c81ec59b7ac33e1e.png][]

![77f6acf6b3db18ea2f34665c7ea7f3e8.png][]

*  我们先修改Git仓库中dev分支下的config-dev.yml配置文件：

# 修改前信息
    config:
      info: "config info for dev(dev)"
    # 修改后信息
    config:
      info: "update config info for dev(dev)"

*  调用注册中心的接口刷新所有配置：[http://localhost:8904/actuator/bus-refresh][http_localhost_8904_actuator_bus-refresh]

![4e6dcbf2da36cfbb504b7cf253bb54b1.png][]

*  刷新后再分别调用[http://localhost:9004/configInfo][http_localhost_9004_configInfo] 和 [http://localhost:9005/configInfo][http_localhost_9005_configInfo] 获取配置信息，发现都已经刷新了；

update config info for dev(dev)

*  如果只需要刷新指定实例的配置可以使用以下格式进行刷新：[http://localhost:8904/actuator/bus-refresh/\{destination\}][http_localhost_8904_actuator_bus-refresh_destination] ，我们这里以刷新运行在9004端口上的config-client为例[http://localhost:8904/actuator/bus-refresh/config-client:9004][http_localhost_8904_actuator_bus-refresh_config-client_9004]。

注意：有持续集成要求的情况下，一般根据设置hooks(钩子)进行持续集成和部署过程。

## 参考文章 ##

[Bus消息总线][Bus]

[Spring Cloud Bus：消息总线][Spring Cloud Bus]

[消息总线Bus基本概念与实操配置][Bus 1]

[干货｜Spring Cloud Bus 消息总线介绍][Spring Cloud Bus 1]

[实战SpringCloud微服务从青铜到王者][SpringCloud]

[c853dd685530f03762c28de12c323e96.png]: /images/20221021/1fe711a110fa4086851a10e604186040.png
[3f0c52b72981557d6caf3b4eb2acf9ac.png]: /images/20221021/044ea958cc9544888d43a35f8a628294.png
[ce0c3211cde327d787ee64405aee53a2.png]: /images/20221021/0fb5146978174b31963704cbf8ec18c4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2Jvb255YQ_size_16_color_FFFFFF_t_70]: /images/20221021/aee36b214734480cbc0b401a1fbdc5ba.png
[edaac451bff70c942af65a883022588b.png]: /images/20221021/9db89f780c704a80a8ef441dde4ea7cc.png
[1a7361465cd2f7e2c81ec59b7ac33e1e.png]: /images/20221021/5eeecfdde3cc4d37a269df1a1224e97e.png
[77f6acf6b3db18ea2f34665c7ea7f3e8.png]: /images/20221021/2e6b25013e5e47abb3dba9d24f91e43e.png
[http_localhost_8904_actuator_bus-refresh]: http://localhost:8904/actuator/bus-refresh
[4e6dcbf2da36cfbb504b7cf253bb54b1.png]: /images/20221021/65c3bec13cb24342b994119f919255f3.png
[http_localhost_9004_configInfo]: http://localhost:9004/configInfo
[http_localhost_9005_configInfo]: http://localhost:9005/configInfo
[http_localhost_8904_actuator_bus-refresh_destination]: http://localhost:8904/actuator/bus-refresh/%7Bdestination%7D
[http_localhost_8904_actuator_bus-refresh_config-client_9004]: http://localhost:8904/actuator/bus-refresh/config-client:9004
[Bus]: https://www.pianshen.com/article/7832289980/
[Spring Cloud Bus]: https://www.imooc.com/article/293842
[Bus 1]: https://blog.csdn.net/weixin_43842853/article/details/108627472
[Spring Cloud Bus 1]: http://blog.itpub.net/69915408/viewspace-2641677/
[SpringCloud]: https://www.kancloud.cn/hanxt/springcloud