RabbitMQ消息流
AMQP
AMQP 一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。AMQP 是一个二进制协议，拥有一些现代化特点：多信道、协商式，异步，安全，扩平台，中立，高效。
RabbitMQ 是 AMQP 协议的 Erlang 的实现。
| 概念 | 说明 |
|---|---|
| 连接 Connection | 一个网络连接，比如 TCP/IP 套接字连接。 |
| 会话 Session | 端点之间的命名对话。在一个会话上下文中，保证 “恰好传递一次”。 |
| 信道 Channel | 多路复用连接中的一条独立的双向数据流通道。为会话提供物理传输介质。 |
| 客户端 Client | AMQP 连接或者会话的发起者。AMQP 是非对称的，客户端生产和消费消息，服务器存储和路由这些消息。 |
| 服务节点 Broker | 消息中间件的服务节点；一般情况下可以将一个 RabbitMQ Broker 看作一台 RabbitMQ 服务器。 |
| 端点 | AMQP 对话的任意一方。一个AMQP连接包括两个端点（一个是客户端，一个是服务器）。 |
| 消费者 Consumer | 一个从消息队列里请求消息的客户端程序。 |
| 生产者 Producer | 一个向交换机发布消息的客户端应用程序。 |
RabbitMQ运转流程
生产者发送消息：
- 生产者创建连接（Connection），开启一个信道（Channel），连接到 RabbitMQ Broker；
- 声明队列并设置属性；如是否排它，是否持久化，是否自动删除；
- 将路由键（空字符串）与队列绑定起来；
- 发送消息至 RabbitMQ Broker；
- 关闭信道；
- 关闭连接；
消费者接收消息：
- 消费者创建连接（Connection），开启一个信道（Channel），连接到 RabbitMQ Broker；
- 向 Broker 请求消费相应队列中的消息，设置相应的回调函数；
- 等待 Broker 回应闭关投递响应队列中的消息，消费者接收消息；
- 确认（ack，自动确认）接收到的消息；
- RabbitMQ 从队列中删除相应已经被确认的消息；
- 关闭信道；
- 关闭连接；
整个流程如下：
生产者流转过程说明
- 客户端与代理服务器 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 个命令的交互。
- 客户端调用 connection.createChannel 方法。此方法开启信道，其包装的 channel.open 命令发送给 Broker，等待 channel.basicPublish 方法，对应的 AMQP 命令为 Basic.Publish，这个命令包含了 content Header 和 content Body()。content Header 包含了消息体的属性，例如:投递模式，优先级等，content Body 包含了消息体本身。
- 客户端发送完消息需要关闭资源时，涉及到 Channel.Close 和 Channl.Close-Ok 与 Connetion.Close 和 Connection.Close-Ok 的命令交互。
消费者流转过程说明
- 消费者客户端与代理服务器 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 个命令的交互。
- 消费者客户端调用 connection.createChannel 方法。和生产者客户端一样，协议涉及 Channel.Open/Open-Ok 命令。
- 在真正消费之前，消费者客户端需要向 Broker 发送 Basic.Consume 命令(即调用 channel.basicConsume 方法〉将 Channel 置为接收模式，之后 Broker 回执 Basic.Consume-Ok 以告诉消费者客户端准备好消费消息。
- Broker 向消费者客户端推送(Push) 消息，即 Basic.Deliver 命令，这个命令和 Basic.Publish 命令一样会携带 Content Header 和 Content Body。
- 消费者接收到消息并正确消费之后，向 Broker 发送确认， 即Basic.Ack 命令。
- 客户端发送完消息需要关闭资源时，涉及到 Channel.Close 和 Channl.Close-Ok 与 Connetion.Close 和 Connection.Close-Ok 的命令交互。
