1. 概述

老话说的好：会休息的人才更会工作，身体是革命的本钱，身体垮了，就无法再工作了。

言归正传，之前我们聊了 SpringCloud 的分布式配置中心 Config，文章里我们聊了config配置的动态刷新，但这个动态刷新，一次只能刷新一个 Config Client 节点，如果服务节点少还好，如果业务多了，有成百上千个服务节点，再一台一台刷新，就不合适了。

因此，今天我们来聊聊 SpringCloud的消息总线组件 Bus，Bus 组件可以借助MQ中间件，向所有的 Config Client 发送刷新广播，只需要调用一个接口，就可以刷新整个集群的Config 配置。

我们使用 RabbitMQ 作为中间件，关于 RabbitMQ 集群的搭建，可参见我的另一篇文章《RabbitMQ 3.9.7 镜像模式集群的搭建》（https://www.jianshu.com/p/187325419e95）。

闲话不多说，直接上代码。

2. Git 准备

1）创建一个 repository，用于放置配置文件，例如：my-config-repo

2）创建 my-bus-client 文件夹

3）在 my-bus-client 文件夹下，新建 my-bus-client-dev.yml 配置文件，内容如下：

info:
  profile: dev
    
name: zhuifengren
desc: hello dev

3. Config Server 引入 Bus 组件

3.1 主要依赖

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-config-server</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bootstrap</artifactId>
            <version>3.0.2</version>
        </dependency>
        <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>

3.2 application.yml 配置

server:
  port: 42000

spring:
  application:
    name: my-bus-server
  rabbitmq:
    addresses: 192.168.1.22:5672,192.168.1.12:5672,192.168.1.11:5672  # rabbitmq 集群的地址
    username: guest
    password: guest
    virtual-host: /
    connection-timeout: 16000
  cloud:
    config:
      server:
        git:
          uri: https://github.com/w84422/my-config-repo.git   # git地址
          force-pull: true  # 强制拉取资源文件
          default-label: main   # 默认拉取的分支
          search-paths: '{application}'      # 将配置文件放到接入方服务名称对应的文件夹下，这种写法，只在config组件设置生效

management:
  endpoints:
    web:
      exposure:
        include: '*'
  endpoint:
    health:
      show-details: always

eureka:
  client:
    service-url:
      defaultZone: http://zhuifengren1:35000/eureka/,http://zhuifengren2:35001/eureka/    # Eureka Server的地址

3.3 启动类增加注解

@SpringBootApplication
@EnableConfigServer
@EnableDiscoveryClient
public class MyBusServerApplication {

    public static void main(String[] args) {
        SpringApplication.run(MyBusServerApplication.class, args);
    }
}

3.4 启动 Config Server

启动 Config Server

4. Config Client 引入 Bus 组件

4.1 主要依赖

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-config</artifactId>
            <version>3.0.4</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bootstrap</artifactId>
            <version>3.0.2</version>
        </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>

4.2 bootstrap.yml 配置

server:
  port: 43000

spring:
  application:
    name: my-bus-client
  rabbitmq:
    addresses: 192.168.1.22:5672,192.168.1.12:5672,192.168.1.11:5672
    username: guest
    password: guest
    virtual-host: /
    connection-timeout: 16000
  cloud:
    config:
      profile: dev  # 拉取的配置文件
      label: main   # 拉取的分支
      name: my-bus-client  # 指定远程获取配置文件的 application，默认会取 spring.application.name
      discovery:
        enabled: true
        service-id: my-bus-server    # config服务的服务名称

myDesc: ${desc}

eureka:
  client:
    service-url:
      defaultZone: http://zhuifengren1:35000/eureka/,http://zhuifengren2:35001/eureka/    # Eureka Server的地址

management:
  endpoints:
    web:
      exposure:
        include: '*'
  endpoint:
    health:
      show-details: always

4.3 启动类增加注解

@SpringBootApplication
@EnableDiscoveryClient
public class MyBusClientApplication {

    public static void main(String[] args) {
        SpringApplication.run(MyBusClientApplication.class, args);
    }
}

4.4 增加用于实验的 Controller 类

@RefreshScope
@RestController
public class MyBusClientRefreshController {

    @Value("${info.profile}")
    private String profile;
    @Value("${name}")
    private String name;
    @Value("${myDesc}")
    private String desc;

    @RequestMapping("/refresh-info")
    public String getInfo() {

        String info = "profile：" + profile + "<br>";
        info += "name：" + name + "<br>";
        info += "desc：" + desc + "<br>";

        return info;
    }
}