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中:

    消息发送-接收原理图




  • 相关阅读:
    C#将List<T>转化为DataTable
    SqlServer常用内置函数
    C#索引器
    验证Textbox的字符长度
    WM消息对应的Message消息中的Lparam和WParam
    对窗体操作的WM消息
    DllImport使用
    C#获取当前路径的七种方法
    注册ActiveX控件
    [转]VS2010中水晶报表安装应用及实例
  • 原文地址:https://www.cnblogs.com/xiaobaibailongma/p/15357181.html
Copyright © 2011-2022 走看看