嗨客网搜索
RabbitMQ消息流

AMQP

AMQP 一个提供统一消息服务的应用层标准高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。AMQP 是一个二进制协议,拥有一些现代化特点:多信道、协商式,异步,安全,扩平台,中立,高效。

RabbitMQ 是 AMQP 协议的 Erlang 的实现。

概念 说明
连接 Connection 一个网络连接,比如 TCP/IP 套接字连接。
会话 Session 端点之间的命名对话。在一个会话上下文中,保证 “恰好传递一次”。
信道 Channel 多路复用连接中的一条独立的双向数据流通道。为会话提供物理传输介质。
客户端 Client AMQP 连接或者会话的发起者。AMQP 是非对称的,客户端生产和消费消息,服务器存储和路由这些消息。
服务节点 Broker 消息中间件的服务节点;一般情况下可以将一个 RabbitMQ Broker 看作一台 RabbitMQ 服务器。
端点 AMQP 对话的任意一方。一个AMQP连接包括两个端点(一个是客户端,一个是服务器)。
消费者 Consumer 一个从消息队列里请求消息的客户端程序。
生产者 Producer 一个向交换机发布消息的客户端应用程序。

RabbitMQ运转流程

生产者发送消息:

  1. 生产者创建连接(Connection),开启一个信道(Channel),连接到 RabbitMQ Broker;
  2. 声明队列并设置属性;如是否排它,是否持久化,是否自动删除;
  3. 将路由键(空字符串)与队列绑定起来;
  4. 发送消息至 RabbitMQ Broker;
  5. 关闭信道;
  6. 关闭连接;

消费者接收消息:

  1. 消费者创建连接(Connection),开启一个信道(Channel),连接到 RabbitMQ Broker;
  2. 向 Broker 请求消费相应队列中的消息,设置相应的回调函数;
  3. 等待 Broker 回应闭关投递响应队列中的消息,消费者接收消息;
  4. 确认(ack,自动确认)接收到的消息;
  5. RabbitMQ 从队列中删除相应已经被确认的消息;
  6. 关闭信道;
  7. 关闭连接;

整个流程如下:

07_rabbitmq消息流.png

生产者流转过程说明

  1. 客户端与代理服务器 Broker 建立连接。会调用 newConnection() 方法,这个方法会进一步封装 Protocol Header 0-9-1 的报文头发送给 Broker ,以此通知 Broker 本次交互采用的是 AMQPO-9-1 协议,紧接着 Broker 返回 Connection.Start 来建立连接,在连接的过程中涉及 Connection.Start/.Start-OK 、Connection.Tune/.Tune-Ok ,Connection.Open/.Open-Ok 这 6 个命令的交互。
  2. 客户端调用 connection.createChannel 方法。此方法开启信道,其包装的 channel.open 命令发送给 Broker,等待 channel.basicPublish 方法,对应的 AMQP 命令为 Basic.Publish,这个命令包含了 content Header 和 content Body()。content Header 包含了消息体的属性,例如:投递模式,优先级等,content Body 包含了消息体本身。
  3. 客户端发送完消息需要关闭资源时,涉及到 Channel.Close 和 Channl.Close-Ok 与 Connetion.Close 和 Connection.Close-Ok 的命令交互。

消费者流转过程说明

  1. 消费者客户端与代理服务器 Broker 建立连接。会调用 newConnection() 方法,这个方法会进一步封装 Protocol Header 0-9-1 的报文头发送给 Broker,以此通知 Broker 本次交互采用的是 AMQPO-9-1 协议,紧接着 Broker 返回 Connection.Start 来建立连接,在连接的过程中涉及 Connection.Start/.Start-OK 、Connection.Tune/.Tune-Ok ,Connection.Open/.Open-Ok 这 6 个命令的交互。
  2. 消费者客户端调用 connection.createChannel 方法。和生产者客户端一样,协议涉及 Channel.Open/Open-Ok 命令。
  3. 在真正消费之前,消费者客户端需要向 Broker 发送 Basic.Consume 命令(即调用 channel.basicConsume 方法〉将 Channel 置为接收模式,之后 Broker 回执 Basic.Consume-Ok 以告诉消费者客户端准备好消费消息。
  4. Broker 向消费者客户端推送(Push) 消息,即 Basic.Deliver 命令,这个命令和 Basic.Publish 命令一样会携带 Content Header 和 Content Body。
  5. 消费者接收到消息并正确消费之后,向 Broker 发送确认, 即Basic.Ack 命令。
  6. 客户端发送完消息需要关闭资源时,涉及到 Channel.Close 和 Channl.Close-Ok 与 Connetion.Close 和 Connection.Close-Ok 的命令交互。
嗨客网顶部