SpringCloud.H-Bus消息总线
# SpringCloud.H-Bus消息总线
笔记日期:2020.5.20
# 1.概述
# 1 .解决问题
- ==实现分布式自动刷新配置功能==
- SpringCloud Bus 配合 SpringCloud Config 使用,可以实现==配置的动态解析==
# 2. 是什么? 能干嘛?
Bus: 支持两种消息代理: RabbitMQ和Kafka
# 1. 利用消息总线触发一个客户端/bus/refresh,而刷新所有客户端的配置
- 通知一个==客户端==
# 2. 利用消息总线触发一个服务端ConfigServer的/bus/refresh端点,而刷新所有客户端的配置
- 全部拉取,==全部通知==
SpringCloud Bus 能管理和传播分布式系统间的消息,就像一个分布式执行器
,可用于广播状态更改.时间推送等,也可以当做微服务间的通信通道
# 3. 什么是总线?
在微服务架构的系统中,通常会使用轻量级的消息代理来构建一个共用的消息主题,并让系统中所有微服务实例都连接上来。由于该主题中产生的消息会被所有实例监听和消费,所以称它为消息总线。在总线上的各个实例,都可以方便的广播一些需要让其他连接在该主题上的实例都知道的消息。
# 4. 基本原理
ConfigClient 实例都监听MQ中同一个topic(默认是springcloubus),当一个服务刷新数据的时候,它会把这个信息放入到Topic中,这样其他监听统一topic的服务就能得到通知,然后去更新自身的配置。
# 2. RabbitMQ配置
基于erlang语言
# 3. SpringCloud Bus==动态刷新全局广播==
- 先具备良好的 RabbitMQ 环境
# 1. 配置
- 依赖(服务端.客户端)
<!--添加消息总线RbbitMQ支持-->
<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
3
4
5
6
7
8
9
- 服务端3344配置
#rabbit相关配置
spring:
rabbitmq:
host: 116.196.118.167
port: 5672
username: guest
password: guest
#rabbitmq相关配置,暴露bus刷新配置的端点
management:
endpoints: #暴露bus刷新配置的端点
web:
exposure:
include: 'bus-refresh' #凡是暴露监控、刷新的都要有actuator依赖,bus-refresh就是actuator的刷新操作
2
3
4
5
6
7
8
9
10
11
12
13
14
- 客户端 3355,3366
#rabbit相关配置
spring:
rabbitmq:
host: 116.196.118.167
port: 5672
username: guest
password: guest
2
3
4
5
6
7
==需要运维人员发送POST请求,刷新3344服务端==
必修为 =="POST"== 请求
cmd 进入控制台 curl -X POST "http://localhost:3344/actuator/bus-refresh" ==激活3344,刷新数据,一次刷新,处处生效==
效果
- 服务端: http://config-3344.com:3344/master/config-dev.yml
- 客户端1: http://localhost:3355/configInfo
- 客户端2: http://localhost:3366/configInfo
==避免了服务重启==
- eureka
- rabbitMQ
==一处修改,处处生效===
# 2. 设计思想
# 1. 利用消息总线触发一个客户端/bus/refresh,而刷新所有客户端的配置
# 2. 利用消息总线触发一个服务端ConfigServer的/bus/refresh端点,而刷新所有客户端的配置
图二的架构显然更加合适,图一不合适的原因如下:
- 打破了微服务的职责单一性,因为微服务本身是业务模块,它本不应该承担配置刷新的职责
- 破坏了微服务各节点的对等性
- 有一定的局限性。例如,微服务在迁移时,它的网络地址常常会发生变化,此时如果想要做到自动刷新,那就好增加更多的修改
# 4. SpringCloud Bus动态刷新==定点通知==
# 1. ==定点通知==
- 如果现在不想全部通知,只定向通知,只通知一个,其余不通知
# 2. 解决:
- 指定具体某一个实例生效而不是全部
- 公式:http://localhost:配置中心端口号/actuator/bus-refresh/{destination}
- /bus/refresh请求不再发送到具体的服务实例上,而是发给 config server并通过destination参数类指定需要更新配置的服务或实例
# 3. 案例
刷新运行在3355端口上的config-client为例,只通知3355,不通知3366?
处理
现在再来修改github配置文件的version,改为3
3344可以获取数据,3355/3366不能获取处理?
执行: curl -X POST "http://localhost:3344/actuator/bus-refresh/config-client:3355" 3355接收数据
结果
3355
3366