SpringCloud H版系列10--Bus消息中心
2021/11/5 23:14:03
本文主要是介绍SpringCloud H版系列10--Bus消息中心,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
Bus消息中心
- 一、Spring Cloud Bus
- 1.1Bus 解决的问题
- 1.2刷新类型介绍
- 1.3 Bus消息中心原理和思想
- 二、搭建RabbitMQ
- 三、参照3355模块新建3366模块
- 四、测试
书接上文,继续跟着周阳老师学习SpringCloud的消息中心Bus。
一、Spring Cloud Bus
Spring Cloud Bus 集成了市面上常用的消息代理(rabbitmq、kafka等 2种),连接微服务系统中的所有节点,当有数据变更时,可以通过消息代理广播通知微服务及时变更数据;例如微服务的配置更新。
1.1Bus 解决的问题
Bus 解决了微服务数据变更,及时同步的问题。
Spring cloud bus目前只这次RabbitMQ/Kafka作为消息总线,并没有对ActiveMQ/RokcetMQ做支持。
1.2刷新类型介绍
Bus消息总线的刷新类型有两类,一类是对client整合,通过client接口刷新一个client后,经过bus通知其他的client刷新信息。如下图:
Bus消息总线刷新类型第二种是通知统一配置管理中心,将由统一配置管理中心通知bus,然后告诉其他的微服务获取配置信息。如下图:
1.3 Bus消息中心原理和思想
设计原理:
ConfigBus实例监听MQ中同一个topic(默认是springCloudBus).当一个服务刷新数据的时候,它会把这个消息放入到Topic中,这样其他监听同一个Topic的服务就能得到通知,然后去更新自身的配置;
设计思想:
1)利用消息总线触发一个客户端/bus/refresh,而刷新所有客户端的配置:破环微服务单一性,对等性;
2)利用消息总线触发一个服务端ConfigServer的/bus/fresh端点,而刷新所有客户端的配置;
二、搭建RabbitMQ
搭建过程请自行谷歌、百度
双击RabbitMQ service start
浏览器输入:localhost:15672 ,输入账号和密码:guest、guest 可以看到RabbitMQ的主界面
三、参照3355模块新建3366模块
bootstrap.yml
server: port: 3366 spring: application: name: config-client cloud: config: label: master name: config profile: dev uri: http://localhost:3344 #15672是管理界面端口,5672是MQ访问的端口 rabbitmq: host: localhost port: 5672 username: guest password: guest eureka: client: service-url: defaultZone: http://localhost:7001/eureka # 暴露监控端点 management: endpoints: web: exposure: include: "*"
ConfigClientMain3366
@SpringBootApplication @EnableEurekaClient public class ConfigClientMain3366 { /*消息总线: 微服务中使用轻量级消息代理来构建一个共用的消息主题,并让微服务系统中所有实例都连接上来。 *由于该主题中产生的消息会被所有实例监听和消费,所以称为消息总线。 *在总线上个各个实例,都可以广播一些需要其他连接到该主题上的实例都知道的消息 * * 基本原理: * ConfigClient实例都监听MQ中同一个topic(默认是SpringCloudBus),当一个服务刷新数据时,会把这个信息放到topic * ,这样其他监听到同一个topic服务就能得到通知,然后去更新自身的配置。 */ //利用消息总线,触发一个服务器端ConfigServer的bus/refresh端点,而刷新所有客户端的配置,总的来说就是:实现自动刷新配置功能 //用3344作为Server,通知3355、3366两个Client public static void main(String[] args) { SpringApplication.run(ConfigClientMain3366.class, args); } }
ConfigClientController
@RestController @RefreshScope public class ConfigClientController { @Value("${server.port}") private String serverPort; @Value("${config.info}") private String configInfo; @GetMapping("/configInfo") public String configInfo(){ return "serverPort: " +serverPort+ "\t\n\n configInfo: "+ configInfo; } }
3355、3366yml新增:
rabbitmq: #rabbitmq相关配置,15672是web管理端口,5672是mq访问端口 port: 5672 host: localhost username: guest password: guest #暴露监控端点 management: endpoints: web: exposure: include: "*"
四、测试
1、修改Gitee中config-dev.yml版本号
2、cmd 刷新3344
cmd窗口中执行
curl -X POST "http://localhost:3344/actuator/bus-refresh"
结果:3355、3366 都已经改变,一次修改、广播通知、到处运行。
上面是全局通知,但如果我们想定点通知该如何做呢?
定点通知:只通知3355,不通知3366
实现方法:cmd 刷新3344
curl -X POST "http://localhost:3344/actuator/bus-refresh/config-client:3355"
这篇关于SpringCloud H版系列10--Bus消息中心的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-11-01后台管理开发学习:新手入门指南
- 2024-11-01后台管理系统开发学习:新手入门教程
- 2024-11-01后台开发学习:从入门到实践的简单教程
- 2024-11-01后台综合解决方案学习:从入门到初级实战教程
- 2024-11-01接口模块封装学习入门教程
- 2024-11-01请求动作封装学习:新手入门教程
- 2024-11-01登录鉴权入门:新手必读指南
- 2024-11-01动态面包屑入门:轻松掌握导航设计技巧
- 2024-11-01动态权限入门:新手必读指南
- 2024-11-01动态主题处理入门:新手必读指南