栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

测试开发进阶——Spring cloud——理解——微服务中消息总线理解(转载)

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

测试开发进阶——Spring cloud——理解——微服务中消息总线理解(转载)

消息总线。简单理解就是一个消息中心,众多微服务实例可以连接到总线上,实例可以往消息中心发送或接收信息(通过监听)。

比如:实例A发送一条消息到总线上,总线上的实例B可以接收到信息(实例B订阅了实例A),这样的话,消息总线就充当一个中间者的角色,使得实例A和实例B解偶了,很方便。

消息总线(Spring Cloud Bus) 原理

Spring Cloud Bus通过建立多个应用之间的通信频道,管理和传播应用间的消息,从技术角度来说,应用了AMQP消息代理作为通道,通过MQ的广播机制实现消息的发送和接收。

以其典型应用——配置中心客户端刷新为例,说明下工作流程:

(1)修改配置文件,触发webhook向clientA发送bus/refresh;

(2)clientA重新从配置中心获取新的配置信息,同时发送消息到Spring Cloud Bus;

(3)Spring Cloud Bus收到消息,同时通知clientB、clientC(订阅配置更新事件);

(4)clientB、clientC收到通知,重新请求配置中心,获取新的配置信息。

这样,三个客户端均得到最新的配置。

          消息代理

这个过程中,作为通道的AMQP消息代理很重要。

AMQP(高级消息队列协议,是一个标准)是一个网络协议,从扮演角色来说,消息代理从生产者(producers)那儿接收消息,并根据既定的路由规则把接收到的消息发送给处理消息的消费者(consumers),这个过程中的发布者,消费者,消息代理可以存在于不同的设备上,下面简单介绍下工作流程(其实跟上面的类似):

消息(message)被发布者(publisher)发送给交换机(exchange),交换机常常被比喻成邮局或者邮箱。然后交换机将收到的消息根据路由规则分发给绑定的队列(queue)。

最后AMQP代理会将消息投递给订阅了此队列的消费者,或者消费者按照需求自行获取。

AMQP作为一个标准协议,主要实现方案有RabbitMQ、ActiveMQ、Qpid等。

这里我主要以RabbitMQ为例进行说明,它是一个优秀的微服务架构消息中间件,与Spring Cloud Bus能够很好的结合使用。

下图显示了RabbitMQ的Web管理首页:

(1)Broker:消息队列服务器,即负责接收生产者消息,发送至消费者的;

(2)Connections:连接,即发送者、消息接收者、消费者之间的物理连接;

(3)Channel:通道,连接生产者、消费者的逻辑结构。一个Connection可以对应多个Channel;

(4)Exchange:消息交换机,消息第一个到达的地方,可以指定路由规则,决定消息分发到不同的消息队列中去;

(5)Queue:消息队列,消息经Exchange路由转发至此,进入逻辑等待状态(等待消费,即客户端获取);

(6)Binding:绑定,把Exchange和Queue按照路由规则进行绑定,即决定Exchange接收消息后,需要发送到哪些Queue中:

消息发送-接收原理图
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/285048.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号