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

在这里插入图片描述

前言

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

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

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

Github仓库地址:github

github.com/qqxx6661/sp…web

菜鸟SpringCloud实战入门系列

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

前文回顾:后端

实战版本

  • 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实战入门专栏全导航:经过如下两种途径查看

关注我

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

来微信和我聊聊:yangzd1102

我的公众号:Rude3Knife

我的公众号:Rude3Knife

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

相关文章
相关标签/搜索