协议间属性转换 | RabbitMQ 中文
版本:4.0
RabbitMQ 是一个支持多种协议的代理,支持
消息可以很容易地由一种协议发布,并由其他协议消费。这需要在不同协议格式之间进行数据格式转换。在 RabbitMQ 3.13 之前,所有消息在发布到 RabbitMQ 时都转换为基于 AMQP 0.9.1 协议的内部格式。这种方法通常会导致不必要的转换和/或数据保真度问题。
在当前的 RabbitMQ 版本中,AMQP、AMQP 0.9.1 和 MQTT 协议的方法发生了变化,消息将始终以其原始格式存储,并且仅在由与原始协议不同的协议消费时才进行转换。这样一来,当原始协议和消费协议相同时,就不会丢失任何协议特定的信息。
此规则的唯一例外是 流:无论使用哪种协议发布,流都会将其消息内部存储为 AMQP 编码的数据。因此,例如,当使用 AMQP 0.9.1 发布时,会发生转换为 AMQP 的操作。
所有转换都已重新编写并形式化。本文档旨在捕获已实现的转换规则,以便应用程序开发人员可以参考本文档,了解其消息在多协议消息传递应用程序中将如何转换。
shortstr
:(条件)小于 256 字节的字符串,并且仅包含有效的 UTF-8 编码数据,不包含 NUL
(二进制零八位字节组)字符。
*
:读作“任何”(字段/类型等)。
条件可以理解为按其写入的顺序进行评估。例如,类型为 utf8
且超过 255 字节的 AMQP message_id
将首先不满足 shortstr
条件,然后继续执行下一行。如果没有匹配的行,则数据将不会转换(因此消费应用程序也无法使用)。
AMQP 1.0 -> AMQP 0.9.1
如果消息使用 AMQP 0.9.1 消费,并且消息
则会进行从 AMQP 到 AMQP 0.9.1 的转换。 | AMQP 部分 | AMQP 字段 | AMQP 类型 | 条件 | AMQP 0.9.1 部分 | AMQP 0.9.1 字段 | AMQP 0.9.1 类型 |
---|
注释 | 头部 | 持久化 | | 布尔值 | 属性 | 投递模式 | 无符号字节 |
注释 | 2 = 持久化,1 = 短暂 | 投递模式 | | 布尔值 | 2 = 持久化,1 = 短暂 | 投递模式 | |
注释 | 优先级 | 生存时间 | | 布尔值 | 毫秒(无符号整数) | 过期时间 | 短字符串 |
布尔值 | 毫秒转换为字符串值 | 消息 ID | 过期时间 | 布尔值 | 毫秒转换为字符串值 | 过期时间 | |
布尔值 | 毫秒转换为字符串值 | 消息 ID | UTF-8 | 布尔值 | > 256 字节 | 头部,键:x-message-id | |
布尔值 | 毫秒转换为字符串值 | 长字符串 | | 布尔值 | 毫秒转换为字符串值 | 过期时间 | UUID(16 字节二进制) |
布尔值 | 毫秒转换为字符串值 | 转换为文本,例如“urn:uuid:550e8400-e29b-41d4-a716-446655440000” | | 布尔值 | 毫秒转换为字符串值 | 过期时间 | 无符号长整数 |
布尔值 | 毫秒转换为字符串值 | 转换为文本 | | 布尔值 | > 256 字节 | 转换为文本 | |
布尔值 | 二进制 | 转换为文本 | 过期时间 | 布尔值 | 二进制 | 过期时间 | |
布尔值 | 用户 ID | 至 | | | | | |
布尔值 | 地址 | 消息 ID | | | | | |
布尔值 | 主题 | 至 | 过期时间 | 布尔值 | 主题 | 过期时间 | |
布尔值 | 回复地址 | 消息 ID | 过期时间 | 布尔值 | 回复地址 | 过期时间 | |
布尔值 | 回复地址 | 消息 ID | UTF-8 | 布尔值 | 相关 ID | 头部,键:x-message-id | |
布尔值 | 回复地址 | 长字符串 | | 布尔值 | 回复地址 | 过期时间 | 头部,键:x-correlation-id |
布尔值 | 回复地址 | 转换为文本,例如“urn:uuid:550e8400-e29b-41d4-a716-446655440000” | | 布尔值 | 回复地址 | 过期时间 | 转换为数字的文本表示形式 |
布尔值 | 回复地址 | 转换为文本 | | 布尔值 | 相关 ID | 转换为文本 | |
布尔值 | 内容类型 | 符号 | | 布尔值 | 内容类型 | 过期时间 | |
布尔值 | 内容编码 | 符号 | | 布尔值 | 内容编码 | 过期时间 | |
布尔值 | 绝对过期时间 | 时间戳 | | | | | |
布尔值 | 创建时间 | 时间戳 | | 布尔值 | 时间戳 | 时间戳 | 转换为秒 |
布尔值 | 组 ID | 消息 ID | 过期时间 | 布尔值 | 应用 ID | 过期时间 | |
布尔值 | 组序列号 | 序列号 | | | | | |
布尔值 | 回复组 ID | 消息 ID | | | | | |
应用程序属性 | * | *(参见类型转换) | 键:shortstr | 布尔值 | 头部 | * | |
消息注释 | *(符号 - x-cc*) | | 键:x-cc | 布尔值 | 头部,键:“CC” | 头部,键:x-message-id | |
消息注释 | *(符号 - x-*) | *(参见类型转换) | 键:shortstr & x-* | 布尔值 | 头部 | * | 通常这意味着 x- 头部 |
数据 | | 数据 | 单个数据部分 | 有效负载 | | 转换为文本 | 从数据部分提取的纯二进制数据 |
数据(多个) | * | * | 多个数据部分 | 有效负载 | | AMQP 1.0 编码的二进制数据 | properties.type 将设置为“amqp-1.0” |
amqp.value | * | * | | 有效负载 | | AMQP 1.0 编码的二进制数据 | properties.type 将设置为“amqp-1.0” |
amqp.sequence | * | * | | 有效负载 | | AMQP 1.0 编码的二进制数据 | properties.type 将设置为“amqp-1.0” |
类型转换
AMQP 1.0 类型 | AMQP 类型 | AMQP 0.9.1 类型 | AMQP 0.9.1 类型 |
---|
UTF-8(字符串) | | 头部,键:x-message-id | RabbitMQ 不支持 shortstr 头部值,因此所有 utf8 输入都转换为 longstr,除非它是基本属性中的字段 |
转换为文本 | | 转换为文本 | |
长整数 | | 长整数 | |
转换为文本,例如“urn:uuid:550e8400-e29b-41d4-a716-446655440000” | | 长整数 | 溢出风险 |
投递模式 | | 无符号字节 | |
短整数 | | 短整数 | |
无符号短整数 | | 无符号短整数 | |
无符号整数 | | 无符号整数 | |
整数 | | 有符号整数 | |
双精度浮点数 | | 双精度浮点数 | |
单精度浮点数 | | 单精度浮点数 | |
持久化 | | 布尔值 | |
时间戳 | | 时间戳(秒) | 值除以 1000 |
字节 | | 字节 | |
空 | | 无效 | |
列表 | | 数组 | |
映射 | | 表 | |
符号 | | 头部,键:x-message-id | |
AMQP 0.9.1 -> AMQP 1.0
条件 | AMQP 0.9.1 字段 | AMQP 0.9.1 类型 | AMQP 类型 | AMQP 1.0 部分 | AMQP 1.0 字段 | AMQP 1.0 类型 | AMQP 0.9.1 类型 |
---|
基本属性 | 毫秒转换为字符串值 | 过期时间 | 有效的 urn uuid | 布尔值 | 毫秒转换为字符串值 | uuid | |
基本属性 | 毫秒转换为字符串值 | 过期时间 | | 布尔值 | 毫秒转换为字符串值 | 消息 ID | |
基本属性 | 回复地址 | 过期时间 | 有效的 urn uuid | 布尔值 | 回复地址 | uuid | |
基本属性 | 回复地址 | 过期时间 | | 布尔值 | 回复地址 | 消息 ID | |
基本属性 | 二进制 | 过期时间 | | 布尔值 | 二进制 | 转换为文本 | |
基本属性 | 毫秒(无符号整数) | 过期时间 | 如果可转换为数值类型 | 注释 | 优先级 | 无符号整数 | |
基本属性 | 类型 | 过期时间 | | 消息注释 | x-basic-type | 消息 ID | |
基本属性 | 主题 | 过期时间 | | 布尔值 | 主题 | 消息 ID | |
基本属性 | 应用 ID | 过期时间 | | 布尔值 | 组 ID | 消息 ID | |
基本属性 | 时间戳 | 时间戳(秒) | | 布尔值 | 创建时间 | 时间戳 | 转换为毫秒 |
基本属性 | 内容类型 | 过期时间 | | 布尔值 | 内容类型 | 符号 | |
基本属性 | 内容编码 | 过期时间 | | 布尔值 | 内容编码 | 符号 | |
基本属性 | 投递模式 | 八位字节组 | | 注释 | 头部 | 持久化 | 以前在 x-basic-delivery-mode 中 |
基本属性 | 2 = 持久化,1 = 短暂 | 八位字节组 | | 注释 | 2 = 持久化,1 = 短暂 | 投递模式 | 以前在 x-basic-priority 中 |
basic.properties | 头部 | | 键=x-amqp-1.0-properties | 布尔值 | - | - | 旧版 1.0 插件头部 |
basic.properties | 头部 | | 键=x-amqp-1.0-application-properties | 应用程序属性 | - | - | 旧版 1.0 插件头部 |
basic.properties | 头部 | | 键=x-amqp-1.0-message-annotations | 消息注释 | - | - | 旧版 1.0 插件头部 |
basic.properties | 头部 | | 键=x-reply-to-topic | 布尔值 | 主题 | 消息 ID | "/topic/" RK |
基本属性 | 头部 | * | 键以“x-”开头 | 消息注释 | 键 | * | 参见类型转换规则 |
基本属性 | 头部 | 表 | 值不是数组或表 | 应用程序属性 | 键 | * | 参见类型转换规则 |
基本属性 | 头部 | 表 | 值是数组或表 | - | - | - | 不转换 |
有效负载 | - | 转换为文本 | | 数据 | - | 数据 | |
类型转换
AMQP 0.9.1 类型 | AMQP 类型 | AMQP 1.0 类型 | AMQP 0.9.1 类型 |
---|
头部,键:x-message-id | 过期时间 | 消息 ID | 性能/精度权衡 |
头部,键:x-message-id | | 转换为文本 | |
长整数 | | 长整数 | |
投递模式 | | 投递模式 | |
短整数 | | 短整数 | |
无符号短整数 | | 无符号短整数 | |
无符号整数 | | 无符号整数 | |
整数 | | 整数 | |
双精度浮点数 | | 双精度浮点数 | |
单精度浮点数 | | 单精度浮点数 | |
布尔值 | | 持久化 | |
转换为文本 | | 转换为文本 | |
时间戳 | | 时间戳 | 从秒转换为毫秒 |
字节 | | 字节 | |
无效 | | 空 | |
数组 | | 列表 | |
表 | | 映射 | |
table.key | x-* 头部 | 符号 | |
table.key | | 消息 ID | |
table.value | | * | 根据此表进行转换 |
MQTT 5.0 -> AMQP 1.0
MQTT 5.0 部分 | MQTT 字段 | MQTT 5.0 类型 | AMQP 类型 | AMQP 1.0 部分 | AMQP 1.0 字段 | AMQP 1.0 类型 | AMQP 0.9.1 类型 |
---|
固定头部 | 重复 | 位 | | | | | 将设置设置为 header first-acquirer 没有意义,因为 DUP 标志仅适用于客户端到服务器(从服务器到客户端的消费由队列发送的 Redelivered 标志确定) |
固定头部 | QoS | 位 | | 注释 | 头部 | 持久化 | 如果 QoS > 0,则持久化为真 |
固定头部 | 保留 | 位 | | | | | |
可变头部 | 有效负载格式指示器 | 位 | | | | | 参见“有效负载”行,条件为“设置有效负载格式指示器” |
可变头部 | 消息过期间隔 | 无符号整数 | | 注释 | 优先级 | 毫秒 | 秒转换为毫秒 |
可变头部 | 主题别名 | 无符号短整数 | | | | | |
可变头部 | 回复主题 | 消息 ID | | 布尔值 | 主题 | 消息 ID | 将 MQTT 主题转换为 AMQP 路由键 (RK)。将回复地址设置为“/exchange/” X “/” RK。 |
可变头部 | 相关数据 | 转换为文本 | urn:uuid | 布尔值 | 回复地址 | uuid | |
可变头部 | 相关数据 | 转换为文本 | | 布尔值 | 回复地址 | 转换为文本 | |
可变头部 | 用户属性 | 消息 ID | 键以“x-”开头,键为 ASCII | 消息注释 | | 值:UTF-8 | 键的类型为符号 |
| | | 键不以“x-”开头 | 应用程序属性 | | 值:UTF-8 | 键的类型为 UTF-8 |
可变头部 | 订阅标识符 | 无符号整数 | | | | | |
可变头部 | 内容类型 | 消息 ID | 有效的 ASCII | 布尔值 | 内容类型 | 符号 | MQTT 内容类型为 UTF-8,而 AMQP 1.0 内容类型仅为 ASCII |
有效负载 | | | 未设置有效负载格式指示器 | 数据 | | 数据 | |
有效负载 | | | 设置有效负载格式指示器 | amqp.value | | 消息 ID | 如果设置了有效负载格式指示器,则将 MQTT 有效负载转换为字符串(即单个 AMQP 值部分),因为 AMQP 字符串为 UTF-8 编码 |
类型转换
MQTT 5.0 类型 | AMQP 类型 | AMQP 1.0 类型 | AMQP 0.9.1 类型 |
---|
位 | | 持久化 | 仅转换选定的标志 |
无符号短整数 | | 无符号短整数 | |
无符号整数 | | 无符号整数 | |
消息 ID | | 消息 ID | |
二进制数据 | 消息 ID | 消息 ID | |
二进制数据 | | 转换为文本 | |
UTF-8 字符串对 | | 映射 | 删除重复的键,但保持顺序 |
MQTT 5.0 -> AMQP 0.9.1
MQTT 5.0 部分 | MQTT 5.0 字段 | MQTT 5.0 类型 | AMQP 类型 | AMQP 0.9.1 部分 | AMQP 0.9.1 部分 | AMQP 0.9.1 字段 | AMQP 0.9.1 类型 |
---|
固定头部 | 重复 | 位 | | | | | 将设置设置为 basic.deliver 字段 redelivered 没有意义,因为 DUP 标志仅适用于客户端到服务器(从服务器到客户端的消费由队列发送的 Redelivered 标志确定) |
固定头部 | QoS | 位 | | 布尔值 | 属性 | | QoS 0 映射到 delivery_mode 1 QoS 1 映射到 delivery_mode 2 |
固定头部 | 保留 | 位 | | | | | |
可变头部 | 有效负载格式指示器 | 位 | | | | | AMQP 0.9.1 content_encoding 指的是 MIME 内容编码,其有效值列在 https://www.iana.org/assignments/http-parameters/http-parameters.xml 中。因此 AMQP 0.9.1 content_encoding 是不同的东西。它最好映射到 content_type 的 text/<subtype>; charset="utf-8 ,但 <subtype> 未定义。此外,MQTT 5.0 属性 Content Type 已经定义。 |
可变头部 | 消息过期间隔 | 无符号整数 | | 布尔值 | 毫秒(无符号整数) | 过期时间 | 秒转换为毫秒 |
可变头部 | 主题别名 | 无符号短整数 | | | | | |
可变头部 | 回复主题 | 消息 ID | | 布尔值 | 头部,键:x-reply-to-topic | 头部,键:x-message-id | AMQP 0.9.1 属性 reply_to 指的是队列名称,而不是主题名称 |
可变头部 | 相关数据 | 转换为文本 | 过期时间 | 布尔值 | 回复地址 | 过期时间 | |
| | | | 布尔值 | 相关 ID | 头部,键:x-message-id | |
可变头部 | 用户属性 | UTF-8 字符串对 | 名称为 shortstr | 布尔值 | 头部 | 头部,键:x-message-id | RabbitMQ 不能将 shortstr 作为例如头部值。 |
可变头部 | 订阅标识符 | 可变字节整数 | | | | | |
可变头部 | 内容类型 | 消息 ID | 过期时间 | 布尔值 | 内容类型 | 过期时间 | |
有效负载 | | | | 有效负载 | | | |
类型转换
MQTT 5.0 类型 | AMQP 类型 | AMQP 0.9.1 字段 | AMQP 0.9.1 类型 |
---|
位 | | 位 | |
无符号短整数 | | 无符号短整数 | |
无符号整数 | | 无符号整数 | |
消息 ID | < 256 字节且目标不是头部 | 过期时间 | RabbitMQ 不能将 shortstr 作为例如头部值。 |
消息 ID | >= 256 字节 | 头部,键:x-message-id | |
转换为文本 | < 256 字节的 UTF-8 编码数据 | 过期时间 | |
转换为文本 | 无效的 UTF-8 或 >= 256 字节 | 头部,键:x-message-id | |
UTF-8 对 | | 表 | “在 AMQP 0.9.1 字段表中,重复字段是非法的”。RabbitMQ 按键对字段进行排序。
|
AMQP 1.0 -> MQTT 5.0
AMQP 1.0 部分 | AMQP 1.0 字段 | AMQP 1.0 类型 | AMQP 类型 | MQTT 5.0 部分 | MQTT 5.0 字段 | MQTT 5.0 类型 | AMQP 0.9.1 类型 |
---|
注释 | 头部 | 持久化 | | 固定头部 | QoS | 位 | durable=true 映射到 QoS 1 durable=false 映射到 QoS 0 |
布尔值 | 毫秒转换为字符串值 | * | | | | | |
布尔值 | 二进制 | 转换为文本 | | | | | |
布尔值 | 用户 ID | 至 | | | | | |
布尔值 | 地址 | 消息 ID | | | | | |
布尔值 | 主题 | 至 | "/exchange/" X "/" RK 其中 X 匹配 mqtt.exchange | 可变头部 | 回复主题 | 消息 ID | 将 AMQP 主题转换为 MQTT 主题 |
布尔值 | 回复地址 | * | | 可变头部 | 相关数据 | 转换为文本 | 转换为二进制 |
布尔值 | 内容类型 | 符号 | | 可变头部 | 内容类型 | 消息 ID | |
布尔值 | 内容编码 | 符号 | | | | | |
布尔值 | 绝对过期时间 | 时间戳 | | | | | |
布尔值 | 创建时间 | 时间戳 | | | | | |
布尔值 | 组 ID | 消息 ID | | | | | |
布尔值 | 组序列号 | 序列号 | | | | | |
布尔值 | 回复组 ID | 消息 ID | | | | | |
应用程序属性 | * | * | 不是数组、列表、映射或二进制 | 用户属性 | | 消息 ID | 值转换为字符串表示形式 |
消息注释 | * | * | 仅 x- headers,不包括具有数组、列表、映射或二进制值的那些 | 用户属性 | | 消息 ID | |
数据 | | 数据 | 一个或多个数据部分 | 有效负载 | | 转换为文本 | |
数据 | * | * | 单个 AMQP 二进制值部分 | 有效负载 | | 转换为文本 | |
数据 | | amqp.value(utf8) | 可转换为 UTF-8 的单个 AMQP 值部分 | 有效负载 | | 转换为文本 | Payload-Format-Indicator 设置为 1,以便 MQTT 5.0 客户端可以解析消息的文本表示形式,从而理解消息。 |
数据 | | * | 其他单个 AMQP 值部分或 amqp-sequence 部分 | 有效负载 | | 转换为文本 | 使用 AMQP 类型系统进行编码,并包含 Content Type message/vnd.rabbitmq.amqp 。此 Content Type 未注册。 |
AMQP 0.9.1 -> MQTT 5.0
条件 | AMQP 0.9.1 字段 | AMQP 0.9.1 类型 | AMQP 类型 | MQTT 5.0 部分 | MQTT 5.0 字段 | MQTT 5.0 类型 | AMQP 0.9.1 类型 |
---|
基本属性 | 毫秒转换为字符串值 | 过期时间 | | | | | |
基本属性 | 回复地址 | 过期时间 | | 可变头部 | 相关数据 | 转换为文本 | |
基本属性 | 二进制 | 过期时间 | | | | | |
基本属性 | 毫秒(无符号整数) | 过期时间 | | 可变头部 | 消息过期间隔 | 无符号整数 | 从毫秒转换为秒 |
基本属性 | 类型 | 过期时间 | | | | | |
基本属性 | 主题 | 过期时间 | | | | | |
基本属性 | 应用 ID | 过期时间 | | | | | |
基本属性 | 时间戳 | 时间戳(秒) | | | | | |
基本属性 | 内容类型 | 过期时间 | | 可变头部 | 内容类型 | 消息 ID | |
基本属性 | 内容编码 | 过期时间 | | | | | |
基本属性 | 属性 | 八位字节组 | | 固定头部 | QoS | 位 | delivery-mode 2 映射到 QoS 1 delivery-mode 1 映射到 QoS 0 |
基本属性 | 2 = 持久化,1 = 短暂 | 八位字节组 | | | | | |
basic.properties | 头部 | 头部,键:x-message-id | 键=x-reply-to-topic | 可变头部 | 回复主题 | 消息 ID | 将 AMQP 主题转换为 MQTT 主题 |
basic.properties | 头部 | 头部,键:x-message-id | Key=x-correlation-id | 可变头部 | 相关数据 | 转换为文本 | |
basic.properties | 头部 | * | 不是数组、表 | 用户属性 | | 消息 ID | 简单值转换为其字符串表示形式 |
基本属性 | 头部 | 表 | | | | | |
有效负载 | | 转换为文本 | | 有效负载 | | | |
© 2024 RabbitMQ. All rights reserved.