个人网站的设计与制作论文,手表网站建站,湖北省建设工程质量安全监督网站,三河建设局网站解决的痛点: 当git仓库的配置更新后#xff0c; cloud config 客户端不能获取到配置信息的问题, 需要手动发送请求#xff0c;刷新配置。 可以参照 spring cloud config cloud busbus消息总线使用rabbitMQ推送消息原理架构实现使用curl命令刷新客户端的配置bus bus配合conf…解决的痛点: 当git仓库的配置更新后 cloud config 客户端不能获取到配置信息的问题, 需要手动发送请求刷新配置。 可以参照 spring cloud config
cloud busbus消息总线使用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
dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-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/
