15.SpringCloud Bus Basic

Spring Cloud Bus

学习消息总线之前，我们先回顾一下第三篇笔记，在说到SpringCloud Config如何实现自动拉取服务器上配置时，我们使用的方式是定时器配合ContextRefresh进行刷新，虽然实现简单，但是循环执行肯定会造成性能消耗，这里我们讲另一种方式，就需要使用到Spring Cloud Bus，通过发布订阅的消息中间件，进行Config的动态刷新。

这里我们用一张图来介绍Spring Cloud Bus的配置机制：

根据此图我们可以看出利用Spring Cloud Bus做配置更新的步骤:

提交代码触发webhook，发送post请求给clientA
clientA接收请求后从Server更新配置，并发送Message给Bus，告知配置更新了
Bus接收到消息会被ClientB和ClientC监听到进行消费
clientB和C就会请求config-server获取最新配置
从而全部客户端获取到最新配置，实现动态更新
RabbitMQ实现

准备工作

首先是RabbitMQ的安装启动，以及基本概念，这里没学过RabbitMQ的可以看下我的博客

接着是准备两个工程

config-server：配置服务器
config-client：配置客户端

这里在第三节创建过，直接接着使用即可，就不再代码演示了

代码回顾

Config-Server：

1577688662963

一开始我们使用本地配置，后面将配置文件加载到github上使用

1577688738808

主要使用prod环境的配置，配置了user的信息，以便client使用

Config-Client：

## 配置客户端应用关联的应用
## spring.cloud.config.name 是可选的
## 如果没有配置，采用 ${spring.application.name}
spring.cloud.config.name = enbuys
## 关联 profile
spring.cloud.config.profile = prod
## 关联 label
spring.cloud.config.label = master
## 配置配置服务器URI
spring.cloud.config.uri = http://127.0.0.1:9090/

@RestController
@EnableConfigurationProperties(User.class)
public class UserController {

    //通过构造器注入
    private final User user;

    @Autowired
    public UserController(User user) {
        this.user = user;
    }

    @GetMapping("/user")
    public User user() {
        return user;
    }
}

在Client中，配置文件拉取Config信息，并通过访问/user获取user信息

RabbitMQ整合

接着我们进行整合，其实非常简单

1.扩展config-client的依赖

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

2.配置文件添加RabbitMQ的配置

spring.rabbitmq.virtual-host=/
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
spring.rabbitmq.addresses=192.168.56.120:5672

这时，我们对于Bus的配置就完成了，就是这么简单

3.启动测试

首先将config-server启动起来，然后启动config-client，在控制台可以看到如下信息

1
2
3

# /bus/refresh
EndpointHandlerMapping     : Mapped "{[/bus/refresh],methods=[POST]}" onto public void org.springframework.cloud.bus.endpoint.RefreshBusEndpoint.refresh(java.lang.String)
Created new connection: rabbitConnectionFactory#6fb0261e:0/SimpleConnection@19d53ab4 [delegate=amqp://guest@192.168.56.120:5672/, localPort= 14499]

并且在RabbitMQ控制台可以看到一条Connection

1577689305447