Spring Cloud 对Bus的解释：

Spring Cloud Bus links nodes of a distributed system with a lightweight message broker. This can then be used to broadcast state changes (e.g. configuration changes) or other management instructions. The only implementation currently is with an AMQP broker as the transport, but the same basic feature set (and some more depending on the transport) is on the roadmap for other transports.

个人发挥：

理解： 让所有为服务来订阅这个事件，当这个事件发生改变了，就可以通知所有微服务去更新它们的内存中的配置信息。这时Bus消息总线就能解决，你只需要在springcloud Config Server端发出refresh，就可以触发所有微服务更新了。

Spring Cloud Bus

步骤：

  • 在config微服务中引入依赖（需要使用到mq，不懂的话移步Docker）
1
2
3
4
5
6
7
8
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-bus</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
</dependency>
  • 保证mq启动

  • 在yml中配置mq
1
2
3
4
5
6
7
rabbitmq:
    host: 127.0.0.1（rabbitmq服务地址）
management:
  endpoints:
    web:
      exposure:
        include: bus-refresh
  • 在userinfo微服务中引入依赖
1
2
3
4
5
6
7
8
9
10
11
12
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-bus</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

  • 代码块需要注意


@RefreshScope注解的作用: 如果刷新了bean，那么下一次访问bean(即执行一个方法)时就会创建一个新实例。

测试：

  • 启动Eureka、Config、userinfo三个微服务


http://127.0.0.1:9001/user/config

  • 去Git的配置中心修改其中的一些参数

  • 更新

当前post请求是刷新了所有微服务的配置文件Spring Cloud Bus对这种场景也有很好的支持：/bus/refresh接口还提供了destination参数，用来定位具体要刷新的应用程序。比如，我们可以请求/bus/refresh?destination=服务名字:9000，此时总线上的各应用实例会根据destination属性的值来判断是否为自己的实例名

  • 在不重启服务的情况下刷新一下页面


ok
可以看到打印信息已经改变