zoukankan      html  css  js  c++  java
  • 测试开发进阶——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中:

    消息发送-接收原理图




  • 相关阅读:
    如何让我domain里的机器都跟domain controller的时间保持一致?
    [PowerShell Utils] Create a list of virtual machines based on configuration read from a CSV file in Hyper-V
    Reboot server stuck at “Press ESC in 1 seconds to skip startup.nsh”
    [PowerShell Utils] Remotely install Hyper-V and Failover Cluster feature on a list of windows 2012 servers
    [PowerShell Utils] Automatically Change DNS and then Join Domain
    SharePoint 2016 IT Preview的新feature列表
    LeetCode Permutations问题详解
    Rotate Image 旋转图像
    单链表的快速排序(转)
    anagrams 查找序列里具有相同字符但顺序不同的单词
  • 原文地址:https://www.cnblogs.com/xiaobaibailongma/p/15357181.html
Copyright © 2011-2022 走看看