wordpress案例站点,360建筑网如何修改名字,网站老提示有风险,对外贸网站建设的建议Bus
前言
戳我了解Config
学习Config中我们遇到了一个问题#xff1a; 当我们修改了GitHub上配置文件内容#xff0c;微服务需要配置动态刷新并且需要手动向客户端发送post请求刷新微服务之后才能获取到GitHub修改过后的内容
假如有多个微服务客户端3355/3366/3377…等等…Bus
前言
戳我了解Config
学习Config中我们遇到了一个问题 当我们修改了GitHub上配置文件内容微服务需要配置动态刷新并且需要手动向客户端发送post请求刷新微服务之后才能获取到GitHub修改过后的内容
假如有多个微服务客户端3355/3366/3377…等等百十个微服务呢 难道每个微服务都要执行一次post请求手动刷新 我们可否广播一次通知处处生效 我们想大范围的自动刷新并且还能够定点通知、精确通知比如100台中我要剔除2台通知其他98台微服务
于是我们请出来Config的连体兄弟–Bus它能做到
ConfigBus完成分布式自动刷新配置功能
概述
能干嘛
spring cloud Bus配置spring cloud Config使用可以实现配置的动态刷新
其实就是之前Config中我们配置完自动刷新还需要向客户端发送post请求刷新微服务相当于告诉微服务GitHub内容已更新现在消息中间件帮我们把这件事给做了它刷新一台微服务客户端然后这台微服务告诉BusBus会通知其他微服务 刷新一台微服务服务端然后这台微服务告诉BusBus会通知其他微服务客户端
这两张图是两种实现方式一种是触发客户端一种是触发服务端下边会讲到
为什么被称为消息总线
什么是总线 在微服务架构的系统中通常会使用轻量级的消息代理来构建一个共用的消息主题并让系统中所有微服务实例都连接上来。由于该主题中产生的消息会被所有实例监听和消费所以称它为消息总线。在总线上的各个实例都可以方便地广播一些需要让其他连接在该主题上的实例都知道的消息。
基本原理 ConfigClient实例都监听MQ中同一个topic(默认是springCloudBus)。当一个服务刷新数据的时候它会把这个信息放入到Topic中这样其它监听同一Topic的服务就能得到通知然后去更新自身的配置。
阳哥RabbitMQ视频
安装RabbitMQ的依赖环境
安装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
SpringCloud Bus动态刷新全局广播
必须先具备良好的RabbitMQ环境RabbitMQ安装成功并能正常登录
演示广播效果增加复杂度再以3355为模板再制作一个3366
设计思想
利用消息总线触发一个客户端/bus/refresh,而刷新所有客户端的配置 利用消息总线触发一个服务端ConfigServer的/bus/refresh端点而刷新所有客户端的配置 图二的架构显然更加适合图一不适合的原因如下
打破了微服务的职责单一性因为微服务本身是业务模块它本不应该承担配置刷新的职责破坏了微服务各节点的对等性。有一定的局限性“例如微服务在迁移时它的网络地址常常会发生变化此时如果想要做到自动刷新那就会增加更多的修改
给cloud-config-center-3344配置中心服务端添加消息总线支持
pom文件 !--添加消息总线RabbitMQ支持--dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-bus-amqp/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-actuator/artifactId/dependencyyml文件
spring:application:name: cloud-config-center #注册进Eureka服务器的微服务名cloud:config:server:git:uri: gitgithub.com:mazhuorui/springcloud_config.git #GitHub上面的git仓库名字####搜索目录search-paths:- springcloud_config####读取分支label: master#rabbitmq相关配置rabbitmq:host: localhostport: 5672username: guestpassword: guest#rabbitmq相关配置,暴露bus刷新配置的端点
management:endpoints: #暴露bus刷新配置的端点web:exposure:include: bus-refresh给cloud-config-client-3355及3366客户端添加消息总线支持
pom文件 !--添加消息总线RabbitMQ支持--dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-bus-amqp/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-actuator/artifactId/dependencyyml文件
spring:application:name: cloud-config-center #注册进Eureka服务器的微服务名cloud:config:server:git:uri: gitgithub.com:mazhuorui/springcloud_config.git #GitHub上面的git仓库名字####搜索目录search-paths:- springcloud_config####读取分支label: master#rabbitmq相关配置rabbitmq:host: localhostport: 5672username: guestpassword: 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 SpringCloud Bus动态刷新定点通知
功能指定具体某一个实例生效而不是全部
公式: 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请求即可完成动态刷新定点通知
