前言
学习Config中我们遇到了一个问题:
当我们修改了GitHub上配置文件内容,微服务需要配置动态刷新并且需要手动向客户端发送post请求刷新微服务之后才能获取到GitHub修改过后的内容
假如有多个微服务客户端3355/3366/3377…等等百十个微服务呢?
难道每个微服务都要执行一次post请求,手动刷新?
我们可否广播,一次通知,处处生效?
我们想大范围的自动刷新,并且还能够定点通知、精确通知,比如100台中我要剔除2台通知其他98台微服务?
于是我们请出来Config的连体兄弟–Bus,它能做到!
Config+Bus完成分布式自动刷新配置功能
其实就是:之前Config中我们配置完自动刷新,还需要向客户端发送post请求刷新微服务,相当于告诉微服务GitHub内容已更新,现在消息中间件帮我们把这件事给做了,它刷新一台微服务客户端,然后这台微服务告诉Bus,Bus会通知其他微服务
刷新一台微服务服务端,然后这台微服务告诉Bus,Bus会通知其他微服务客户端
这两张图是两种实现方式,一种是触发客户端,一种是触发服务端,下边会讲到
什么是总线
在微服务架构的系统中,通常会使用轻量级的消息代理来构建一个共用的消息主题
,并让系统中所有微服务实例都连接
上来。由于该主题中产生的消息会被所有实例监听和消费
,所以称它为消息总线。在总线上的各个实例,都可以方便地广播一些需要让其他连接在该主题上的实例都知道的消息。
基本原理
ConfigClient实例都监听MQ中同一个topic(默认是springCloudBus)
。当一个服务刷新数据的时候,它会把这个信息放入到Topic中,这样其它监听同一Topic的服务就能得到通知,然后去更新自身的配置
。
安装Erlang 下载地址:http://erlang.org/download/otp_win64_21.3.exe
安装RabbitMQ 下载地址: http://dl.bintray.com/rabbitmq/all/rabbitmq-server/3.7.14/rabbitmq-server-3.7.14.exe
进入 rabbitMQ安装目录的sbin目录下,在此目录打开cmd命令行窗口,执行 rabbitmq-plugins enable rabbitmq_management 命令启动管理功能
访问http://localhost:15672/,输入密码账号:默认为guest
必须先具备良好的RabbitMQ环境(RabbitMQ安装成功并能正常登录)
图二的架构显然更加适合,图一不适合的原因如下
pom文件
<!--添加消息总线RabbitMQ支持-->
<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>
yml文件
spring:
application:
name: cloud-config-center #注册进Eureka服务器的微服务名
cloud:
config:
server:
git:
uri: git@github.com:mazhuorui/springcloud_config.git #GitHub上面的git仓库名字
####搜索目录
search-paths:
- springcloud_config
####读取分支
label: master
#rabbitmq相关配置
rabbitmq:
host: localhost
port: 5672
username: guest
password: guest
#rabbitmq相关配置,暴露bus刷新配置的端点
management:
endpoints: #暴露bus刷新配置的端点
web:
exposure:
include: 'bus-refresh'
pom文件
<!--添加消息总线RabbitMQ支持-->
<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>
yml文件
spring:
application:
name: cloud-config-center #注册进Eureka服务器的微服务名
cloud:
config:
server:
git:
uri: git@github.com:mazhuorui/springcloud_config.git #GitHub上面的git仓库名字
####搜索目录
search-paths:
- springcloud_config
####读取分支
label: master
#rabbitmq相关配置
rabbitmq:
host: localhost
port: 5672
username: guest
password: guest
# 暴露监控端点
management:
endpoints:
web:
exposure:
include: "*"
修改Github上配置文件
发送POST请求curl -X POST http://localhost:3344/actuator/bus-refresh
一次修改,广播通知,处处生效
Config中我们执行post请求刷新的是客户端,并且每个客户端都需要执行一次,这次我们执行post请求
刷新服务端
curl -X POST http://localhost:3344/actuator/bus-refresh
功能:指定具体某一个实例生效而不是全部
公式: http://localhost3344/actuator/bus-refresh/{destination}
,destination为微服务名称:端口号
请求不再发送到具体的服务实例上,而是发给config server通过destination参数类指定需要更新配置的服务或实例
我们这里以刷新运行在3355端口上的config-client为例,只通知3355不通知3366
curl -X POST “http://localhost:3344/actuator/bus-refresh/config-client:3355”
执行完post请求即可完成动态刷新定点通知