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

时间 2019-12-07

标签菜鸟 springcloud 实战入门第八经过消息总线 spring cloud bus 实现配置文件刷新使用 kafka 栏目主板繁體版

原文原文链接

前言

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

本系列适合有必定Java以及SpringBoot基础的同窗阅读。node

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

Github仓库地址：github

github.com/qqxx6661/sp…web

菜鸟SpringCloud实战入门系列

你能够经过如下两种途径查看菜鸟SpringCloud实战入门系列：spring

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

前文回顾：后端

实战版本

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。springboot

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

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

提交代码触发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)

关注我

我是蛮三刀把刀，后端开发。主要关注后端开发，数据安全，爬虫等方向。

来微信和我聊聊：yangzd1102

我的公众号：Rude3Knife

若是文章对你有帮助，不妨收藏起来并转发给您的朋友们~