上一节的统一配置中心《》演示了属性热加载
其中提到,每次热加载属性时,都要逐次调用每个应用的 /refresh
接口(或者维护 Git 仓库的 Webhooks)来触发属性更新
随着系统的扩充,应用的增加,若所有的触发动作都要手工去做(或者维护 Git 仓库的 Webhooks),这是不人道的
所以我们希望配置中心的属性发生变化时,能有一种途径去通知所有的相关应用去自动刷新配置
而通过 Spring Cloud Bus 就能够实现以消息总线的方式,通知集群上的应用,去动态更新配置信息
本文是以 RabbitMQ 来作为消息代理的中间件(实现将消息路由到一个或多个目的地),所以要先安装 RabbitMQ
RabbitMQ的安装
RabbitMQ 是 AMQP(Advanced Message Queuing Protocol)协议的一个开源实现的产品
它是由以高性能、健壮、可伸缩性出名的 Erlang OTP 平台实现的工业级的消息队列服务器
所以在安装 RabbitMQ 之前,要先安装 Erlang,下面是它们的下载地址
Windows 下安装成功后,RabbitMQ Server 会自动注册为服务,并以默认配置启动
也可以在开始菜单,找到 RabbitMQ Server 目录,点击 RabbitMQ Service - start 来启动
RabbitMQ的管理
为了能在 Web 界面管理 RabbitMQ,我们还需要启用它的管理插件
D:\Develop\RabbitMQServer\rabbitmq_server-3.6.9\sbin>rabbitmq-plugins enable rabbitmq_managementThe following plugins have been enabled: amqp_client cowlib cowboy rabbitmq_web_dispatch rabbitmq_management_agent rabbitmq_managementApplying plugin configuration to rabbit@Jadyer-PC... started 6 plugins.D:\Develop\RabbitMQServer\rabbitmq_server-3.6.9\sbin>
启用后,浏览器访问 即可(登录的用户名密码均为 guest)
登录进去之后,可以在上方的 Admin 导航菜单中新建用户,并分配权限等等
示例代码
示例代码如下(也可以直接从 Github 下载:)
它是由四个模块组成的 Maven 工程,包含了一个注册中心、一个配置中心、两个读取了配置中心属性的服务提供方
它是在上一节的统一配置中心《》的代码基础上改的
由于改动不多,所以下面就只列出来各个改动点
注册中心
无修改
配置中心
- 引入依赖项spring-cloud-starter-bus-amqp
- application.yml 中添加 spring.rabbitmq.* 的配置,如下所示
spring: rabbitmq: host: 127.0.0.1 port: 5672 # 注意端口是5672,不是15672 username: xuanyu password: xuanyu
服务提供方
其改动部分与配置中心相同:都是引入依赖,添加 rabbitmq 配置,简单粗暴一步到位(Spring Cloud Bus 自动化配置的功劳)
验证
还是分别访问两个服务提供方暴露出来的接口
属性热加载时,需要调用消息总线的 /bus/refresh
接口,共有两种方式(都能使集群中其它节点动态刷新读取到的属性)
- 调用某个应用的接口:
curl -X POST http://127.0.0.1:2100/bus/refresh
- 调用消息总线的接口:
curl -X POST http://127.0.0.1:4100/bus/refresh
但在需要迁移某个使用了的节点时,就不得不修改 Git 仓库的 Webhooks
所以,为了使得各个微服务保持对等,故推荐第二种方式来刷新属性
另外,也可通过 destination 参数来指定刷新范围,举例如下
curl -X POST http://127.0.0.1:4100/bus/refresh?destination=demo.cloud.config:2200
curl -X POST http://127.0.0.1:4100/bus/refresh?destination=demo.cloud.config:**