MQTT 5.0 报文解析 03:SUBSCRIBE 与 UNSUBSCRIBE

欢迎阅读 MQTT 5.0 报文系列 的第三篇文章。在上一篇中,我们介绍了 MQTT 5.0 的 PUBLISH 及其响应报文。现在,我们将介绍用于订阅和取消订阅的控制报文。

在 MQTT 中,SUBSCRIBE 报文用于发起订阅请求,SUBACK 报文用于返回订阅结果。而 UNSUBSCRIBE 和 UNSUBACK 报文则在取消订阅时使用。相比于取消订阅,订阅操作更加常用。不过在本文中,我们仍然会一并介绍订阅与取消订阅报文的结构与组成。

报文示例

首先我们借助 Wireshark 来捕获一次真实的 MQTT 订阅请求与响应,这里我们使用 MQTTX CLI 向 公共 MQTT 服务器 发起订阅请求。以下命令将创建一个主题为 demo,且最大 QoS 设置为 2 的订阅:

mqttx sub --hostname broker.emqx.io --mqtt-version 5 --topic demo --qos 2

以下是 Wireshark 捕获到的 SUBSCRIBE 和 SUBACK 报文数据:

# SUBSCRIBE
82 0a 05 be 00 00 04 64 65 6d 6f 02# SUBACK
90 04 05 be 00 02

Linux 环境可以先使用 tcpdump 命令抓取报文,然后导入至 Wireshark 分析。

这些由十六进制字节组成的原始且晦涩的报文数据,它们分别对应着以下报文内容:

01subscribepacket.png

02subackpacket.png

也许你开始好奇它们是如何完成从简单的 MQTTX CLI 命令到复杂的报文数据的转换,或者好奇当你捕获到一个 MQTT 报文,你应该如何从中提取你想要的信息。

那么在接下来的 SUBSCRIBE、SUBACK、UNSUBSCRIBE 以及 UNSUBACK 的报文结构的介绍中,你的疑问将得到解答。

SUBSCRIBE 报文结构

固定报头

在 SUBSCRIBE 报文中,固定报头中首字节的高 4 位值必须为 8(0b1000),而低 4 位保留位必须被设置为 2(0b0010)。第一个字节之后,仍然是剩余长度(Remaining Length)字段,它是一个可变字节整数。

SUBSCRIBE 固定报头

可变报头

SUBSCRIBE 报文的可变报头按顺序包含以下字段:

SUBSCRIBE 可变报头

  • 报文标识符(Packet Identifier):一个两个字节长度的无符号整数,用来唯一地标识订阅请求。PUBLISH、SUBSCRIBE、UNSUBSCRIBE 报文使用一组报文标识符,这表示它们不能同时使用同一个报文标识符。
  • 属性(Properties):下表列出了 SUBSCRIBE 报文的所有可用属性。
IdentifierProperty NameType
0x0BSubscription Identifier变长字节整数
0x26User PropertyUTF-8 字符串对

有效载荷

SUBSCRIBE 报文的有效载荷包含一个或多个主题过滤器/订阅选项对。主题过滤器是一个 UTF-8 编码的字符串,用于向服务端指明客户端希望订阅的主题,订阅选项则仅占用一个字节,目前由以下四个选项组成:

  • Reserved (Bit 7, 6):保留位,目前必须设置为 0。
  • Retain Handling (Bit 5, 4):用于指示当订阅建立时,服务端是否需要向此订阅发送保留消息。
  • Retain As Published (Bit 3):用于指示服务端在向此订阅转发应用消息时是否需要保持消息中的 Retain 标志。
  • No Local (Bit 2):用于指示服务端是否可以将应用消息转发给该消息的发布者。No Local 和 Retain As Published 通常用于桥接场景。
  • Maximum QoS (Bit 1, 0):这个选项决定了服务端向此订阅转发消息时可以使用的最大 QoS 等级。如果消息的原始 QoS 超过了这个限制,那么服务端就会对 QoS 进行降级以保证消息的传递。

SUBSCRIBE 报文的有效载荷

SUBACK 报文结构

固定报头

SUBACK 报文的首字节高 4 位的值为 9(0b1001),低 4 位都必须全部被设置为 0。

SUBACK 固定报头

可变报头

SUBACK 的可变报头按顺序包含以下字段:

SUBACK 可变报头

  • 报文标识符(Packet Identifier):SUBACK 报文中的报文标识符必须与对应的 SUBSCRIBE 报文一致,以便另一方正确地将响应与请求匹配。
  • 属性(Properties):下表列出了 SUBACK 报文的所有可用属性。
IdentifierProperty NameType
0x1FReason StringUTF-8 编码的字符串
0x26User PropertyUTF-8 字符串对

有效载荷

SUBACK 报文的有效载荷包含了一个 Reason Code 列表,Reason Code 指示了订阅是否成功或者失败的原因。一个 Reason Code 对应 SUBSCRIBE 报文的一个主题过滤器,所以 SUBACK 报文中 Reason Code 的顺序必须与 SUBSCRIBE 报文中主题过滤器的顺序一致。

SUBACK 有效载荷

下表列出了 SUBACK 报文可用的所有 Reason Code:

ValueReason Code NameDescription
0x00Granted QoS 0订阅被接受且最大 QoS 等级为 0。服务端授予的 QoS 等级可能低于客户端请求的 QoS 等级,这主要取决于服务端是否支持所有 QoS 或者是相应的权限设置。
0x01Granted QoS 1订阅被接受且最大 QoS 等级为 1。
0x02Granted QoS 2订阅被接受且最大 QoS 等级为 2。
0x80Unspecified error表示未指明的错误。当一方不希望向另一方透露错误的具体原因,或者协议规范中没有能够匹配当前情况的 Reason Code 时,那么它会在报文中使用这个 Reason Code。
0x83Implementation specific errorSUBSCRIBE 报文有效,但是不被当前服务端的实现所接受。
0x87Not authorized客户端无权进行此订阅。
0x8FTopic Filter invalid主题过滤器的格式正确,但是不被服务端接受。比如主题过滤器的层级超过了服务端允许的最大数量限制。
0x91Packet Identifier in use收到报文中的 Packet ID 正在被使用。
0x97Quota exceeded表示超出了配额限制。服务端可能会对订阅端的订阅配额进行限制,比如一个客户端最多建立 10 个订阅。
0x9EShared Subscriptions not supported服务端不支持共享订阅。
0xA1Subscription Identifiers not supported服务端不支持订阅标识符。
0xA2Wildcard Subscriptions not supported服务端不支持通配符订阅。

UNSUBSCRIBE 报文结构

固定报头

与 SUBSCRIBE 报文相同,唯一的区别是报文类型字段的值从 8(0b1000) 变成了 10(0b1010)。

UNSUBSCRIBE 固定报头

可变报头

与 SUBSCRIBE 报文相同。

有效载荷

UNSUBSCRIBE 报文的有效载荷包含一个或多个客户端希望取消订阅的主题过滤器,这些主题过滤器同样是 UTF-8 编码的字符串,并且多个主题过滤器紧密相连。

UNSUBSCRIBE 有效载荷

UNSUBACK 报文结构

固定报头

UNSUBACK 报文的首字节高 4 位的值为 11(0b1011),低 4 位都必须全部被设置为 0。

UNSUBACK 固定报头

可变报头

UNSUBACK 的可变报头按顺序包含报文标识符和属性字段,可用的属性与 SUBACK 报文相同。

有效载荷

UNSUBACK 报文的有效载荷同样包含了一个 Reason Code 列表,Reason Code 指示了取消订阅是否成功或者失败的原因。这些 Reason Code 按顺序对应 UNSUBSCRIBE 报文的主题过滤器。

UNSUBACK 有效载荷

下表列出了 UNSUBACK 报文可用的所有 Reason Code:

ValueReason Code NameDescription
0x00Success订阅已被删除
0x11No subscription existed服务端中不存在该订阅。
0x80Unspecified error取消订阅无法完成,服务器要么不希望透露原因,要么没有其他原因代码适用。
0x83Implementation specific errorUNSUBSCRIBE 报文有效,但是不被当前服务端的实现所接受。
0x87Not authorized客户端无权取消此订阅。
0x8FTopic Filter invalid主题过滤器的格式正确,但是不被服务端接受。比如主题过滤器的层级超过了服务端允许的最大数量限制。
0x91Packet Identifier in use收到报文中的 Packet ID 正在被使用。

总结

SUBSCRIBE 和 SUBACK 报文用于订阅,UNSUBSCRIBE 和 UNSUBACK 用于取消订阅,想要订阅或者取消订阅的主题过滤器列表,都在对应报文的有效载荷中,SUBSCRIBE 报文中的每个主题主题过滤器,都与一组订阅选项相关联。

指示请求结果的 Reason Code 位于 SUBACK 和 UNSUBACK 报文的有效载荷部分,并且它是一个列表,一一对应请求报文中的主题过滤器。

在下一篇文章中,我们将继续研究 MQTT 的心跳报文。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://xiahunao.cn/news/3016365.html

如若内容造成侵权/违法违规/事实不符,请联系瞎胡闹网进行投诉反馈,一经查实,立即删除!

相关文章

浅谈Session和Cookie

各位大佬光临寒舍,希望各位能赏脸给个三连,谢谢各位大佬了!!! 目录 1.Cookie 2.Sesssion(会话) 3.Session和Cookie的联系 4.总结 1.Cookie Cookie是客户端存储数据的机制,一般是…

OpenHarmony 实战开发—— refreshlayout 组件开发学习指南~

1. RefreshLayout_harmonyos 功能介绍 1.1. 组件介绍: RefreshLayout_harmonyos 是一款下拉刷新组件 1.2. 手机模拟器上运行效果: 2. RefreshLayout_harmonyos 使用方法 2.1 在目录 build.gradle 下 implementation project(":refreshlayout_ha…

信号产生的五种方式

文章目录 正文前的知识准备kill 命令查看信号man手册查看信号信号的处理方法 认识信号产生的5种方式1. 工具2. 键盘3. 系统调用kill 向任意进程发送任意信号raise 给调用方发送任意信号abort 给调用方发送SIGABRT信号 4. 软件条件5. 异常 正文前的知识准备 kill 命令查看信号 …

PM说|还有不会DISC的项目经理?

DISC行为模型是一种常用于职场中的人际交往工具,它通过对个体的行为特点进行分类和分析,帮助人们更好地理解自己和他人的行为方式,从而更加高效地进行沟通和合作。在项目管理过程中,多方沟通是必备工作技能,如何利用DI…

Day 63:单调栈 LeedCode 84.柱状图中最大的矩形

84. 柱状图中最大的矩形 给定 n 个非负整数,用来表示柱状图中各个柱子的高度。每个柱子彼此相邻,且宽度为 1 。 求在该柱状图中,能够勾勒出来的矩形的最大面积。 示例 1: 输入:heights [2,1,5,6,2,3] 输出:10 解释&a…

HarmonyOS开发案例:【电子相册】

介绍 如何实现一个简单的电子相册应用的开发,主要功能包括: 实现首页顶部的轮播效果。 实现页面跳转时共享元素的转场动画效果。 实现通过手势控制图片的放大、缩小、左右滑动查看细节等效果。 相关概念 [Swiper]:滑块视图容器&#x…

20230507,LIST容器

学了又忘学了又忘,明知道会忘又不想复习又还得学 LIST容器 1.1 基本概念 链表是一种物理存储单元上非连续的存储结构,数据元素的逻辑顺序是通过链表中的指针链接实现的;链表由一系列结点组成 结点:一个是存储数据元素的数据域&a…

Ubuntu18.04设置SSH密钥登录

我们一般使用 VSCode 、MobaXterm、PuTTY等 SSH 客户端来远程管理 Linux 服务器。但是,一般的密码方式登录,容易有密码被暴力破解的问题。所以,一般我们会将 SSH 的端口设置为默认的 22 以外的端口,或者禁用 root 账户登录。但是即…

值得收藏!修复Windows 10/11中找不到输出或输入设备的五种方法

序言 这篇文章主要关注处理声音输出/输入设备未发现的问题。它提供了许多可行的方法,帮助了许多Windows用户。阅读以下内容以找到你的解决方案。 最近,我将Windows 10更新到21H2,发现我的音频无法工作。当我把鼠标放在任务栏上的声音图标(上面有一个十字图标)上时,它会…

六、文件查找

一、文件查找 1.查找文件内容 ​ 命令:grep keywords /dir_path/filename 2.查找系统命令 ​ 命令:which command 3.查找命令及配置文件位置 ​ 命令:whereis command 4.find查找 ​ find $find_path -name|-type|-perm|-size|-atime…

休斯《公共管理导论》第5版/考研真题解析/章节题库

第一部分 考研真题精选 一、概念题二、简答题三、论述题四、案例分析题第二部分 章节题库 第1章 一个变革的时代第2章 政府的角色第3章 传统的公共行政模式第4章 公共管理第5章 公共政策第6章 治 理第7章 问 责第8章 利害关系人和外部环境第9章 管制、外包和公共企…

Redis(持久化)

文章目录 1.RDB1.介绍2.RDB执行流程3.持久化配置1.Redis持久化的文件是dbfilename指定的文件2.配置基本介绍1.进入redis配置文件2.搜索dbfilename,此时的dump.rdb就是redis持久化的文件3.搜索dir,每次持久化文件,都会在启动redis的当前目录下…

【数据库表的约束】

文章目录 一、NULL vs (空字符串)二、not null 和default三、列描述字段comment四、zerofill五、primary key 主键总结 一、NULL vs ‘’(空字符串) NULL和空字符串’’ NULL代表什么都没有。 空字符串’代表有,但串…

致远M3 Session 敏感信息泄露漏洞复现

0x01 产品简介 M3移动办公是致远互联打造的一站式智能工作平台,提供全方位的企业移动业务管理,致力于构建以人为中心的智能化移动应用场景,促进人员工作积极性和创造力,提升企业效率和效能,是为企业量身定制的移动智慧协同平台。 0x02 漏洞概述 致远M3 server多个日志文…

如何做好一个活动策划?

活动策划的关键要素是什么? 首先,要明确一个概念:做活动就是走钢丝,没有保险的高空走钢丝!因为,活动没有“彩排”,只有现场"直播”! 无论什么类型的活动,人数是50人还是2000人,也不论预算…

大数据与会计专业主要学什么课程

大数据与会计专业是一个结合了传统会计知识与现代大数据技术的交叉学科,旨在培养既懂会计又熟悉大数据分析的复合型人才。该专业的学生将会学习以下主要课程内容: 会计基础课程:包括基础会计、财务会计、成本会计、管理会计等,这些…

1天搞定SpringBoot+Vue全栈开发 (8)前端路由VueRouter(进行组件切换)

1.VueRouter安装与使用 2.参数传递 创建路由组件 在项目中定义Discover.vue、Friends.vue、My.vue三个组件&#xff0c;将来要使用vue-router来控制它们的展示与切换&#xff1a; Discover.vue <template><div><h1>发现音乐</h1></div> <…

动态规划——路径问题:LCR 166.珠宝的最高价值

文章目录 题目描述算法原理1.状态表示&#xff08;题目经验&#xff09;2.状态转移方程3.初始化4.填表顺序5.返回值 代码实现CJava 题目描述 题目链接&#xff1a;LCR 166.珠宝的最高价值 算法原理 1.状态表示&#xff08;题目经验&#xff09; 对于这种路径类的问题&…

GORM 与 MySQL(一)

GORM 操作 Mysql 数据库&#xff08;一&#xff09; 温馨提示&#xff1a;以下关于 GORM 的使用&#xff0c;是基于 Gin 框架的基础上&#xff0c;如果之前没有了解过 Gin 可能略微困难。 GORM 介绍 GORM 是 Golang 的一个 orm 框架。简单说&#xff0c;ORM 就是通过实例对象…

ASP.NET网上鲜花销售系统的设计

摘 要 本系统实现了一般电子商务所具备的功能&#xff0c;如商品浏览、用户登录注册、网上与购物、结算、后台数据库管理等&#xff0c;利用这些功能可以对鲜花销售信息进行较好的管理。 网上鲜花销售系统的使用者主要是客户和销售管理者&#xff0c;对于客户来说&#xff0…