@@ -1,58 +0,0 @@ RabbitMQ相关概念 - AQMP 协议介绍 | 凤凰涅槃进阶之路

RabbitMQ相关概念 - AQMP 协议介绍

Abel sun2022年12月24日
约 667 字大约 2 分钟

RabbitMQ相关概念 - AQMP 协议介绍

1. 简介

RabbitMQ 是 AMQP 协议的 Erlang 的实现(RabbitMQ 还支持 STOMP、MQTT 等协议)。

AMQP 的模型架构和 RabbitMQ 的模型架构是一样的:

  1. 生产者发送消息给交换器
  2. 交换器和队列绑定
  3. 当 RoutingKey 和 BindingKey 相匹配时,消息被存入相应的队列中
  4. 消费者可以订阅相应的队列来获取消息。

RabbitMQ 中的交换器、交换器类型、队列、绑定、路由键等都遵循 AMQP 协议中相应的概念。本书讲解的 RabbitMQ 版本对应的是 AMQP 0-9-1 版本协议。如无特指,则以该协议为基准介绍。

  • STOPM:Simple/Streaming Text Oriented Messaging Protocol

简单/流文本面向消息协议,提供了一个可互操作的连接格式,运行 STOMP 客户端与任意 STOMP 消息代理(Broker)进行交互。

STOMP 协议由于设计简单,易于开发客户端,因此在多种遇上和平台上得到广泛应用

  • MQTT:Message Queuing Telemetry Transport

消息队列遥测传输。是 IBM 开发的一个 及时通信协议,有可能成为物联网的重要组成部分。

该协议支持所有平台,几乎可以把所有物联网和外部连接起来,被用来当做传感器和制动器的通信协议。

2. AMQP 三层协议

AMQP 协议本身包括三层:

  • Module Layer:

    位于协议最高层,主要定义了一些供客户端调用的命令,客户端可以利用这些命令实现自己的业务逻辑。

    例如:客户端可以使用 Queue.Declare 命令声明一个队列或使用 Basic.Consume 订阅消费一个队列中的消息。

  • Session Layer:

    位于中间层,主要负责将客户端的命令发送给服务器,再将服务端的应答返回给客户端,主要为客户端与服务器之间的通信提供可靠性同步机制和错误处理。

  • Transport Layer:

    位于最底层,主要传输二进制数据流,提供帧的处理、信道复用、错误检测和数据表示等。

3. AMQP 报文交互

AMQP 是一个通信协议,会涉及到 报文交互

  • 从 low-level 举例来说,AMQP 本身是应用层的协议,填充于 TCP 协议层的数据部分
  • 从 high-level 来说,AMQP 是通过协议命令进行交互的。可以看成是一系列结构化命令的集合,这里的命令代表一种操作,类似于 HTTP 中的方法,GET、POST...

参考文章

AQMP 协议介绍open in new window

评论
  • 按正序
  • 按倒序
  • 按热度
Powered by Waline v2.9.1