转载

[菜鸟SpringCloud实战入门]第八章：通过消息总线Spring Cloud Bus实现配置文件刷新（使用Kafka）

欢迎来到菜鸟SpringCloud实战入门系列(SpringCloudForNoob)，该系列通过层层递进的实战视角，来一步步学习和理解SpringCloud。

本系列适合有一定Java以及SpringBoot基础的同学阅读。

每篇文章末尾都附有本文对应的Github源代码，方便同学调试。

Github仓库地址：

github.com/qqxx6661/sp…

菜鸟SpringCloud实战入门系列

你可以通过以下两种途径查看菜鸟SpringCloud实战入门系列：

关注我的公众号：Rude3Knife 点击公众号下方：技术推文——SpringCloud
菜鸟SpringCloud实战入门专栏导航页(CSDN)

前文回顾：

[菜鸟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。

以下是本文即将实现的架构：

[菜鸟SpringCloud实战入门]第八章：通过消息总线Spring Cloud Bus实现配置文件刷新（使用Kafka）

更新客户端配置文件整个流程是：

提交代码触发post请求给bus/refresh
server端接收到请求并发送给Spring Cloud Bus
Spring Cloud bus接到消息并通知给其它客户端
其它客户端接收到通知，请求Server端获取最新配置
全部客户端均获取到最新的配置

安装kafka

请参考我的文章：

blog.csdn.net/qqxx6661/ar…

与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，查看服务端现在的配置文件：

http://localhost:8769/spring-cloud-config-dev.properties

查看config-client的hello接口，得到配置文件内容：

http://localhost:8771/hello

接下来，将配置文件修改一下，加点字符。

随后push到远程服务器。

然后访问 http://localhost:8769/spring-cloud-config-dev.properties ：

发现已经服务端更新了。

这时候，我们需要做更新， 发送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
复制代码

本章代码

github.com/qqxx6661/sp…

参考

www.ityouknow.com/springcloud…

blog.csdn.net/superdangbo…

mp.weixin.qq.com/s/aZvrYpsWi…

-----正文结束-----

菜鸟SpringCloud实战入门专栏全导航：通过以下两种途径查看

关注我的公众号：Rude3Knife 点击公众号下方：技术推文——SpringCloud
菜鸟SpringCloud实战专栏(CSDN)

原文 https://juejin.im/post/5c92461bf265da610762f1a3

正文到此结束

所属分类： Spring

本文标签： UI src 希望本质注册中心服务器 https client MQ rabbitmq amqp web git 配置 Eureka IO springboot bus java 安装 App Service 高可用配置中心并发 spring maven map 代码文章分布式 Spring Cloud Config stream node 集群 GitHub ACE Spring Boot Spring cloud Hystrix Dashboard remote cat SDN Word id springcloud turbine 端口进程调试 http 服务端 Hystrix Dashboard 测试 tar
版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
本文海报： 生成海报一生成海报二

其他链接

关于本站

本站定位：个人技术类博客

本站作用：写博客、记日志、闲聊扯淡鼓捣技术。

问题交流

[菜鸟SpringCloud实战入门]第八章：通过消息总线Spring Cloud Bus实现配置文件刷新（使用Kafka）

菜鸟SpringCloud实战入门系列

你可以通过以下两种途径查看菜鸟SpringCloud实战入门系列：

前文回顾：

实战版本

-----正文开始-----

通过消息总线Spring Cloud Bus更新客户端配置文件（使用Kafka）

安装kafka

与config-server模块进行整合

与config-client模块进行整合

测试运行

本章代码

参考

-----正文结束-----

菜鸟SpringCloud实战入门专栏全导航：通过以下两种途径查看

热门推荐

相关文章

说给你听

本文目录

随机标签

书籍教程

近期评论

网站信息

其他链接

关于本站

问题交流