前言
欢迎来到菜鸟 SpringCloud 实战入门系列(SpringCloudForNoob), 该系列通过层层递进的实战视角, 来一步步学习和理解 SpringCloud.
本系列适合有一定 Java 以及 SpringBoot 基础的同学阅读.
每篇文章末尾都附有本文对应的 GitHub 源代码, 方便同学调试.
GitHub 仓库地址:
https://github.com/qqxx6661/springcloud_for_noob
菜鸟 SpringCloud 实战入门系列
你可以通过以下两种途径查看菜鸟 SpringCloud 实战入门系列:
关注我的公众号: Rude3Knife 点击公众号下方: 技术推文 --SpringCloud
菜鸟 SpringCloud 实战入门专栏导航页(CSDN) https://blog.csdn.net/qqxx6661/column/info/35018
前文回顾:
[菜鸟 SpringCloud 实战入门]第一章: 构建多模块的 Maven 项目 + 创建注册中心 Eureka 子模块
[菜鸟 SpringCloud 实战入门]第二章: 创建服务提供者并在 Eureka 进行注册
[菜鸟 SpringCloud 实战入门]第三章: 将 Eureka 改造为高可用集群
[菜鸟 SpringCloud 实战入门]第四章: 远程调用服务实战
[菜鸟 SpringCloud 实战入门]第五章: 熔断器 Hystrix 的使用 + 可视化监控 Hystrix Dashboard 和 Turbine
[菜鸟 SpringCloud 实战入门]第六章: 配置中心 Spring Cloud Config 初体验
[菜鸟 SpringCloud 实战入门]第七章: 配置中心客户端主动刷新机制 + 配置中心服务化和高可用改造
... 更多文章请查看上方: 菜鸟 SpringCloud 入门实战专栏导航页
实战版本
- SpringBoot:2.0.3.RELEASE
- SpringCloud:Finchley.RELEASE
----- 正文开始 -----
通过消息总线 Spring Cloud Bus 更新客户端配置文件(使用 Kafka)
前文提到, 如果需要客户端获取到最新的配置信息需要执行 refresh, 我们可以利用 webhook 的机制每次提交代码发送请求来刷新客户端, 当客户端越来越多的时候, 需要每个客户端都执行一遍, 这种方案就不太适合了. 使用 Spring Cloud Bus 可以完美解决这一问题.
Spring bus 的一个核心思想是通过分布式的启动器对 spring boot 应用进行扩展, 也可以用来建立一个多个应用之间的通信频道. 目前唯一实现的方式是用 AMQP 消息代理作为通道, 同样特性的设置 (有些取决于通道的设置) 在更多通道的文档中. 其实本质是利用了 MQ 的广播机制在分布式的系统中传播消息, 目前常用的有 Kafka 和 RabbitMQ.
以下是本文即将实现的架构:
更新客户端配置文件整个流程是:
提交代码触发 post 请求给 bus/refresh
server 端接收到请求并发送给 Spring Cloud Bus
Spring Cloud bus 接到消息并通知给其它客户端
其它客户端接收到通知, 请求 Server 端获取最新配置
全部客户端均获取到最新的配置
安装 kafka
请参考我的文章:
与 config-server 模块进行整合
config-server 模块在上一章有介绍
添加依赖:
- <dependency>
- <groupId>org.springframework.cloud</groupId>
- <artifactId>spring-cloud-starter-bus-kafka</artifactId>
- </dependency>
修改配置文件, 添加 kafka 配置:
springboot2 中只需要这一句, 不足要 zk-node 等设置啦.
- # kafka
- stream:
- kafka:
- binder:
- brokers: localhost:9092
- bus:
- trace:
- enabled: true
完整配置文件如下:
- server:
- port: 8769
- spring:
- application:
- name: spring-cloud-config-server
- cloud:
- config:
- server:
- Git:
- uri: https://xxxxxxxxxxxx.git # 配置 Git 仓库的地址
- search-paths: config-repo # Git 仓库地址下的相对地址, 可以配置多个, 用, 分割.
- username: xxxxxxxx # Git 仓库的账号
- password: xxxxxxx # Git 仓库的密码
- # kafka
- stream:
- kafka:
- binder:
- brokers: localhost:9092
- bus:
- trace:
- enabled: true
- # 客户端调用需要
- management:
- endpoints:
- Web:
- exposure:
- include: "*"
- # 在服务中心注册
- eureka:
- client:
- serviceUrl:
- defaultZone: http://localhost:8761/eureka/
与 config-client 模块进行整合
服务端设置好了总线, 客户端当然也要和总线连接
依赖和配置文件的修改, 与 config-server 一模一样, 照着上面修改就可以了.
测试运行
分别运行 eureka,config-server 和 config-client 模块, 这里我们开启两个 config-client 模块, 分别对应端口 8771,8772.
启动后的进程结构如下:
可以看到 eureka 里注册了服务端和两个客户端:
我们直接访问 config-server, 查看服务端现在的配置文件:
查看 config-client 的 hello 接口, 得到配置文件内容:
http://localhost:8771/hello
接下来, 将配置文件修改一下, 加点字符.
随后 push 到远程服务器.
然后访问 :
发现已经服务端更新了.
这时候, 我们需要做更新, 发送 POST 请求:
curl -X POST http://localhost:8769/actuator/bus-refresh
这是 springboot2 的请求, 和老的请求格式不同, 可以从进程启动时候的 mapping 日志中看出.
这时候请求 :
- http://localhost:8771/hello
- http://localhost:8772/hello
更新成功!
你还可以通过 trace 来跟踪总线事件:
一些场景下, 我们可能希望知道 Spring Cloud Bus 事件传播的细节. 此时, 我们可以跟踪总线事件(RemoteApplicationEvent 的子类都是总线事件).
http://localhost:8769/actuator/httptrace
本章代码
参考
https://mp.weixin.qq.com/s/aZvrYpsWiTuV9R_TfjBGpg
----- 正文结束 -----
菜鸟 SpringCloud 实战入门专栏全导航: 通过以下两种途径查看
关注我的公众号: Rude3Knife 点击公众号下方: 技术推文 --SpringCloud
菜鸟 SpringCloud 实战专栏(CSDN) https://blog.csdn.net/qqxx6661/column/info/35018
关注我
我是蛮三刀把刀, 后端开发. 主要关注后端开发, 数据安全, 爬虫等方向.
来微信和我聊聊: yangzd1102
个人公众号: Rude3Knife
如果文章对你有帮助, 不妨收藏起来并转发给您的朋友们~
来源: https://juejin.im/post/5c92461bf265da610762f1a3