springcloud(七):bus消息总线整合kafka

1.环境配置

在linux中准备：
jdk1.8
zookeeper3.4.13
kafka 2.0.0

2. 整体项目构建

本项目目的：实现当git仓库中的数据更新以后，只需要一个config client请求刷新数据，其他的config client都会同步更新数据。
在这里插入图片描述

3.改造config-client

pom引入新的jar
在这里插入图片描述
bootstrap.properties新增kafka配置
在这里插入图片描述

因为再配置文件中已经配置好了，bus-refresh就是刷新命令，所以访问http://localhost:8881/actuator/bus-refresh 就可以刷新config
在这里插入图片描述

4. config-client2

config-client2中的内容保持和config-client一模一样就可以了，修改的端口
在这里插入图片描述

5. 测试

按照顺序启动：eureka-server -> config-server -> config-client2 -> config-client

  1. 因为eureka-server必须要先启动，其他的erueka才可以被发现，第一启动
  2. config-server的数据拉到本地了，其他的config-client才可以到config-server中拉取数据，第二启动
  3. config-client和config-client2没有区别，顺序没有特殊需求。
    在这里插入图片描述

最开始仓库中的数据：hii,ql
在这里插入图片描述
访问config-client和config-client2：
在这里插入图片描述

在这里插入图片描述

访问config-server
在这里插入图片描述
更改git仓库的数据：hello,ql
在这里插入图片描述
postman给client发送请求，请求刷新config仓库配置。
在这里插入图片描述

其他的config-client也马上同步最新数据
在这里插入图片描述

在这里插入图片描述

config client在更新数据以后都会出现：从conifg server中拉取数据的现象（Fetching config from server at : http://localhost:8888/）
在这里插入图片描述

源码： https://github.com/LUK-qianliu/springcloud

版权声明：本文为qq_35688140原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接和本声明。