Spring Cloud Bus消息总线
目录
- 一、概述简介
- 1.1. Bus是什么
- 1.2. Bus能干嘛
- 1.3. 为何被称为总线
- 二、RabbitMQ环境配置
- 2.1. windows下载与安装
- 2.2. 使用RabbitMQ
- 三、Bus动态刷新全局广播
- 3.1. Bus设计思想
- 3.2. 代码实现
- 3.2.1. 调整3344config服务端
- 3.2.2. 调整3355config客户端
- 3.2.3. 搭建3366config客户端
- 3.2.4. 测试
- 3.2.5. Bus动态刷新定点通知
- 四、其他
- 4.1. 疑点
- 4.2. 自定义主题
一、概述简介
官网:https://docs.spring.io/spring-cloud-bus/docs/current/reference/html/
1.1. Bus是什么
Spring Cloud Bus是用来将分布式系统的节点 与 轻量级消息系统 链接起来的框架
。
注意:它不属于消息中间件,他是通过和消息中间件整合,来完成服务之间消息通讯,类似于消息代理。
Spring Clud Bus目前支持RabbitMQ和Kafka。
1.2. Bus能干嘛
Spring Cloud Bus能管理和传播分布式系统间的消息,就像一个分布式执行器,可用于广播状态更改、事件推送等,也可以当作微服务间的通信通道。
提到bus我们第一印象是config+bus结合 完成
动态获取配置
的功能,config配置中心有 个弊端,就是假如配置文件有修改,config客户端需要通过调用一个接口来告诉客户端,配置文件变了你需要重新拉去配置文件。假如微服务特别多的情况下,无疑是一件烦心事,bus可以完成微服务之间的通信,如下图所示:
config教程:https://blog.csdn.net/weixin_43888891/article/details/126454087
上图当中应该很明显了,其中/bus/refresh就是动态刷新的接口。也就是通过这个接口为触发条件,告诉config服务端,他收到之后,通过消息总线通知所有连接他的客户端。
1.3. 为何被称为总线
在微服务架构的系统中,通常会使用轻量级的消息代理来构建一个共用的消息主题
,并让系统中所有微服务实例都连接上来
。由于该主题中产生的消息会被所有实例监听和消费,所以称它为消息总线
。在总线上的各个实例,都可以方便地广播一些需要让其他连接在该主题上的实例都知道的消息。
基本原理
ConfigClient实例都监听MQ中同一个topic(默认是springCloudBus)。当一个服务刷新数据的时候,它会把这个信息放入到Topic中,这样其它监听同一Topic的服务就能得到通知,然后去更新自身的配置。
二、RabbitMQ环境配置
2.1. windows下载与安装
RabbitMQ官网:https://www.rabbitmq.com/
截止到现在RabbitMQ最新版本是3.10.7
RabbitMQ下载地址:https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.10.7/rabbitmq-server-3.10.7.exe
官网明确表示要想安装windows版的RabbitMQ就必须要安装Erlang,如果电脑没有安装Erlang,在安装RabbitMQ时候直接会报错!
Erlang官网:https://erlang.org/download/otp_versions_tree.html
Erlang下载地址:https://github.com/erlang/otp/releases/download/OTP-25.0.4/otp_win64_25.0.4.exe
关于Erlang和RabbitMQ安装,直接傻瓜式下一步即可,安装地址可以自己定。
2.2. 使用RabbitMQ
rabbitmq-plugins enable rabbitmq_management
这样就添加了rabbitmq界面,只要启动rabbitmq,然后在浏览器输入http://127.0.0.1:15672/就可以访问了
访问地址查看是否安装成功:
注意:有时候可能上面显示启动好了,但是还没启动完,所以访问的时候会访问不到,需要稍微等一会。
输入账号密码并登录: guest guest
三、Bus动态刷新全局广播
3.1. Bus设计思想
(1)利用消息总线触发一个客户端/bus/refresh,而刷新所有客户端的配置
(2)利用消息总线触发一个服务端ConfigServer的/bus/refresh端点,而刷新所有客户端的配置
图二的架构显然更加适合,图一不适合的原因如下:
- 打破了微服务的职责单一性,因为微服务本身是业务模块,它本不应该承担配置刷新的职责。
- 破坏了微服务各节点的对等性。
- 有一定的局限性。例如,微服务在迁移时,它的网络地址常常会发生变化,此时如果想要做到自动刷新,那就会增加更多的修改
3.2. 代码实现
基于config实现:https://blog.csdn.net/weixin_43888891/article/details/126454087
3.2.1. 调整3344config服务端
1.添加pom
<!--添加消息总线RabbitMQ支持-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
2.添加yml配置
##rabbitmq相关配置,暴露bus刷新配置的端点
management:endpoints: #暴露bus刷新配置的端点web:exposure:include: 'bus-refresh'
3.2.2. 调整3355config客户端
1.添加pom
<!--添加消息总线RabbitMQ支持-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
2.添加yml配置
spring:
#rabbitmq相关配置 15672是Web管理界面的端口;5672是MQ访问的端口rabbitmq:host: localhostport: 5672username: guestpassword: guest
3.2.3. 搭建3366config客户端
搭建3366主要是为了演示多客户端的情况
1.新建项目
2.添加pom
<properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><springboot.version>2.6.8</springboot.version><springcloud.version>2021.0.3</springcloud.version>
</properties><dependencyManagement><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-dependencies</artifactId><version>${springboot.version}</version><type>pom</type><scope>import</scope></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${springcloud.version}</version><type>pom</type><scope>import</scope></dependency></dependencies>
</dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-config</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency><!--添加消息总线RabbitMQ支持--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bus-amqp</artifactId></dependency><!--cloud新版本默认将bootstrap移除了,所以需要添加如下依赖--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bootstrap</artifactId></dependency>
</dependencies>
3.添加bootstrap.yml
server:port: 3366spring:application:name: config-clientcloud:#Config客户端配置config:label: master #分支名称name: application #配置文件名称profile: dev #读取后缀名称 上述3个综合:master分支上config-dev.yml的配置文件被读取http://config-3344.com:3344/master/config-dev.ymluri: http://localhost:3344 #配置中心地址krequest-connect-timeout: 10000 #使用属性配置连接超时request-read-timeout: 185000 #使用属性配置读取超时#rabbitmq相关配置 15672是Web管理界面的端口;5672是MQ访问的端口rabbitmq:host: localhostport: 5672username: guestpassword: guest
4.添加业务类
@RestController
@RefreshScope
public class ConfigClientController {@Value("${name}")private String name;@GetMapping("/configInfo")public String getName() {return name;}
}
3.2.4. 测试
启动3344服务端和3355、3366客户端
当修改git云端配置的时候,通过以下接口来通知其他客户端,就是通过bus来完成通知的,这样config客户端就拿到了最新的配置。
假如cloud用的H老版本使用:
curl -X POST "http://localhost:3344/actuator/bus-refresh"
假如cloud用的新版本使用:curl -X POST "http://localhost:3344/actuator/busrefresh"
这块需要注意一下,要不然访问会报以下错误!
这块记住访问接口他会刷新所有客户端,config上一篇文章我们最后完成的是访问接口只刷新自己的配置,而并不会刷新其他客户端的配置,这一点一定要弄清楚。
3.2.5. Bus动态刷新定点通知
走到这我们就算是完成了一次发送接口,所有客户端都会生效的功能,说白了就是广播。
现在还存在一个问题,假如有多个客户端,我并不想全部通知,想着只通知个别客户端,需要怎么做呢?
公式: http://localhost:配置中心的端口号/actuator/bus-refresh/{destination}
destination参数是spring.application.name + server.port
案例:只通知3355,不通知3306:curl -X POST "http://localhost:3344/actuator/busrefresh/config-client:3355"
其实就是如下图所示的流程:
四、其他
4.1. 疑点
(1)问题一: 既然config的服务端是通过消息总线来通知客户端的,但是我们会发现一个问题,我们在config服务端其实并没有添加rabbitmq相关的连接信息,而只是引入了他的依赖,就完成了客户端通知,这是怎么回事呢?如下请看官网解释:
4.2. 自定义主题
bus的配置属性:https://docs.spring.io/spring-cloud-bus/docs/current/reference/html/appendix.html
Spring Cloud Bus消息总线相关推荐
- Spring Cloud(十一)高可用的分布式配置中心 Spring Cloud Bus 消息总线集成(RabbitMQ)
上一篇文章,留了一个悬念,Config Client 实现配置的实时更新,我们可以使用 /refresh 接口触发,如果所有客户端的配置的更改,都需要手动触发客户端 /refresh ,当服务越来越多 ...
- Spring Cloud Bus 消息总线介绍
作者 | 洛夜 来源 | 阿里巴巴云原生公众号 在 Spring 生态中玩转 RocketMQ 系列文章: <如何在 Spring 生态中玩转 RocketMQ?> <罗美琪和春波特 ...
- 干货|Spring Cloud Bus 消息总线介绍
2019独角兽企业重金招聘Python工程师标准>>> 继上一篇 干货|Spring Cloud Stream 体系及原理介绍 之后,本期我们来了解下 Spring Cloud 体系 ...
- Spring Cloud Bus 消息总线实现配置自动刷新
why 当微服务太多的时候,服务之间需要建立通信或一个服务的改变需要广播到所有其它服务,这时就需要有一个总线来承担对应的职责. what spring cloud bus 是通过轻量消息代理连接各个分 ...
- Spring Cloud Bus 消息总线
在微服务架构的系统中,我们通常会使用轻量级的消息代理来构建一个共用的消息主题让系统中所有微服务实例都连接上来,由于该主题中产生的消息会被所有实例监听和消费, 所以称它为消息总线. 在总线上的各个实例都 ...
- Spring Cloud Bus + RabbitMq 自动刷新
2019独角兽企业重金招聘Python工程师标准>>> 最近两天在鼓捣Spring Cloud Bus消息总线的刷新机制问题,探索的路程总是坎坷的,一些坑是逃不掉的,总算将其大概了解 ...
- 原 史上最简单的SpringCloud教程 | 第八篇: 消息总线(Spring Cloud Bus)(Finchley版本)
转载请标明出处: 原文首发于:https://www.fangzhipeng.com/springcloud/2018/08/30/sc-f8-bus/ 本文出自方志朋的博客 转载请标明出处: Spr ...
- 史上最简单的SpringCloud教程 | 第八篇: 消息总线(Spring Cloud Bus)(Finchley版本)
首先:欢迎各位学习java和大数据的程序员朋友们加入Java交流学习群: 721506929,群内提供免费的架构学习资料,有需要的朋友可以进群来学习. https://www.fangzhipeng. ...
- 消息总线(Spring Cloud Bus)
spring CloudBus 将分布式的节点和轻量的消息代理连接起来.这可以用于广播配置文件的更改或者其他的管理工作.一个关键的思想就是,消息总线可以为微服务做监控,也可以作为应用程序之间相互通讯. ...
最新文章
- Python 2.7.18 发布,Python 2 时代结束
- OPNET中的zigbee
- 【Python】快速设置 pip 源
- zTree树形菜单使用实例
- 目标检测系列(五)——Faster R-CNN译文
- 多线程编程 RW_LOCK 读写锁
- gatsby_如何使用Gatsby和MDX从头开始构建编码博客
- 蚂蚁集团回应两地暂缓上市;​iPhone 有望采用侧面指纹识别;Pyston v2 发布|极客头条
- unity 后台计时器实现
- Open3d之计算源点云与目标云的距离
- MLT-type渲染算法review(笔记)
- java使用websocket,并且获取HttpSession,源码分析
- Java 实战篇-JDK9新特性
- 数据库系统教程第三版施伯乐
- telnet 命令参数及其应用方式
- 判断多边形是凹多边形还是凸多边形,以及求凹点
- 百度初级认证有用吗_赤峰BIM工程师认证
- 《PWM整流器及其控制》读书笔记-第二章-PWM整流器拓扑结构及原理
- 12,jesd204b实战操作笔记
- 华为网络设备-生成树协议配置
热门文章
- 如何下载FLASH里面的歌曲(保证管用)
- 位运算符之无符号右移(十进制整数)
- STM32之视频播放器(AVIJPEG)
- windows截取右键菜单截图
- Mbus主机常用发送命令解析
- mysql5.6收费吗_免费mysql和收费mysql
- Golang安装及golang.org包的安装
- 【MDPI】全球最大 OA 出版商旗下所有期刊被拉入黑名单,包括 98 本 SCI 期刊
- 把SubText1.9.4(类似.Text单用户)免安装源码发给大家
- C/C++程序员必读的十本书