解决的痛点: 当git仓库的配置更新后,
cloud config 客户端不能获取到配置信息的问题,
需要手动发送请求,刷新配置。
可以参照 spring cloud config
cloud bus
- bus
- 消息总线使用rabbitMQ推送消息
- 原理架构
- 实现
- 使用curl命令刷新客户端的配置
bus
bus配合config可以实现配置的动态刷新。
Spring Cloud Bus是用来将分布式系统的节点与轻量级消息系统链接起来的框架,它整合了Java的事件处理机制和消息中间件的功能。
Bus支持两种消息代理:RabbitMQ和Kafka。
Spring Cloud Bus能管理和传播分布式系统间的消息,就像一个分布式执行器,
可用于广播状态更改、事件推送等,也可以当作微服务间的通信通道。
什么是总线:
在微服务架构的系统中,通常会使用轻量级的消息代理来构建一个共用的消息主题,并让系统中所有微服务实例都连接上来。于该注题中产生的消
息会被所有实例监听和消费,所以称它为消息总线。在总线上的各个实例,都可以方便地广播-些需要让其他连接在该主题上的实例都知道的消息。
基本原理:
ConfigClient实例都监听MQ中同一个topic(默认是springCloudBus)。
当-个服务刷新数据的时候,它会把这个信息放入到Topic中,这样其它监听 同一Topic的服务就能得到通知,然后去更新自身的配置。
消息总线使用rabbitMQ推送消息
docker 安装
# 1. 拉取镜像
docker pull rabbitmq:management# 2. 运行 5672是rabbit启动端口, 15672是web界面
docker run -d -p 5672:5672 -p 15672:15672 --name rabbitmq rabbitmq:management# 3. 访问 http://[宿主机IP]:15672
# 账号密码 guest, guest
原理架构
刷新总配置config center, 然后其它微服务便能获取到消息了。
实现
需要给配置中心添加消息总线的支持
配置中心,和客户端需要添加rabbitMQ和bus的支持
- pom
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>
- 配置中心yaml
server:port: 3344spring:application:name: cloud-config-centercloud:config:server:git:uri: https://github.com/xxx/springcloud-config.git # github url..search-paths: springcloud-config # 仓库名称# rabbitmq 相关配置 15627是web管理界面的端口, 5672 是mq访问的端口rabbitmq:host: 66.66.66.66.66port: 5672username: guestpassword: guesteureka:client:service-url:defaultZone: http://localhost:7001/eureka# 暴露监控端点
management:endpoints:web:exposure:include: 'bus-refresh'
- 客户端 bootstrap.yaml 优先application.yaml加载
server:port: 3355spring:application:name: config-clientcloud:config:label: master # 分支名称 mastername: config # 配置文件名称前缀 config-dev.ymlprofile: dev # 读取后缀名称 master分支config-dev.yml 会被读取uri: http://localhost:3344 # 从配置中心拿# rabbitmq 相关配置 15627是web管理界面的端口, 5672 是mq访问的端口rabbitmq:host: 66.66.66.66.66port: 5672username: guestpassword: guesteureka:client:service-url:defaultZone: http://eureka7001.com:7001/eureka# 暴露服务端口, 修改git上的配置后, 当前服务的配置不能得到同步management:endpoints:web:exposure:include: "*" # all
使用curl命令刷新客户端的配置
# 端口为配置中心服务端的端口
curl -X POST "http://localhost:3344/actuator/bus-refresh"
全部刷新和定点刷新配置。
## 全部广播
curl -X POST "http://localhost:cloud配置中心sever的端口/actuator/bus-refresh"## 广播一处
curl -X POST "http://localhost:3344/actuator/bus-refresh/config-client:3366" # {destination}
更好的解决方案:
阿里dadi的nacos,可作为配置中心,而且配置信息支持存入mysql,更安全。配置信息直接可在nacos web可视化界面修改。
https://nacos.io/zh-cn/