SpringCloud之Spring Cloud Bus消息总线

先了解一下

前提：首先必须安装好RabbitMq。

    之前我们在Spring Cloud Config中提到，当更新了配置信息之后，客户端无法获取到最新的配置信息，那么Spring Cloud Bus就可以用来解决这个问题。这里我们借助RabbitMq来实现Server与Client端的消息通知。

    刷新配置信息大概流程：更新配置提交代码之后，在Config-Server端发post请求/ actuator/bus-refresh，Server端收到请求会通知给Spring Cloud Bus，Bus接收到消息并通知给客户端，客户端收到消息后请求Server端获取最新的配置，这样客户端最终就可以获取到更新之后的配置信息了。接下来我们修改完代码之后，更新并提交代码，请求Server端刷新接口，重新访问客户端，这时就可以获取到最新的配置信息了。

项目搭建

在springcloud-config-application的基础上进行修改：

1、修改Config-Server端

在config-server端添加依赖：

<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.yml添加配置：

spring:
  rabbitmq:
    host: *******
    port: 5672
    username: guest
    password: *******
management:
  endpoints:
    web:
      exposure:
        include: bus-refresh
           

config-server端刷新接口：

http://localhost:8081/actuator/bus-refresh
           

2、修改Config-Client端

在config-client端添加依赖：

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

bootstrap.properties添加RibbitMq配置信息

spring.rabbitmq.host=******
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=*****
spring.cloud.bus.enabled=true
spring.cloud.bus.trace.enabled=true
management.endpoints.web.exposure.include=bus-refresh
           

修改controller代码：

添加注解：@RefreshScope

Config-Client端刷新接口：

http://localhost:8083/actuator/bus-refresh
           

注：一般我们去刷新Server端，重新访问所有的Client端，就会得到最新的配置信息。

完整代码如下：

https://gitee.com/superbutton/spring-cloud-study/tree/develop/springcloud-bus-application