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://www.mzph.cn/news/835048.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

蓝桥杯备战4.双子数

P9420 [蓝桥杯 2023 国 B] 子 2023 / 双子数 - 洛谷 | 计算机科学教育新生态 (luogu.com.cn) 筛素数 void get_prime(int n) {for(int i1;i<n;i){if(!st[i])prime[cnt]i;for(int j0;prime[j]<n/i;j){st[prime[j]*i]true;if(i%prime[j]0)break;}} } 解题 #include<…

Java通过百度地图API获取定位-普通IP定位

项目中有一个登录邮箱提醒的功能&#xff0c;需要根据IP地址获取定位信息&#xff0c;从而更好地提示用户账号登录的所在地。为此&#xff0c;花费了一些时间来实现这个功能。 在CSDN搜索了一下&#xff0c;发现关于获取定位的文章说明都不够详细&#xff0c;于是决定自己创作一…

Markdown和Latex中文字上下标的方法

技术背景 在Markdown和Latex中&#xff0c;如果只是写公式&#xff0c;不论是行内公式还是行间公式&#xff0c;都可以直接使用^和_这两个符号实现上下标。但有个问题是&#xff0c;如果只是使用公式来做上下标&#xff0c;出来的字体是斜着的。例如这样的语法&#xff1a; $$ …

为什么要学Python?学Python有什么用?

为什么要学Python&#xff1f;学Python有什么用&#xff1f; 在当今的数字化时代&#xff0c;编程已成为一项宝贵的技能。Python&#xff0c;作为一种流行的编程语言&#xff0c;因其易于学习和强大的功能而受到全球开发者的青睐。本文将探讨学习Python的原因和它的实际应用&am…

【操作系统期末速成】​操作系统概述(定义|功能|特征)|发展阶段和分类|结构设计|概念补充

&#x1f3a5; 个人主页&#xff1a;深鱼~&#x1f525;收录专栏&#xff1a;操作系统&#x1f304;欢迎 &#x1f44d;点赞✍评论⭐收藏 推荐 前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。点击跳转到…

Nginx部署前后端分离项目

部署前后端分离项目&#xff0c;要求前端项目、后端项目、数据库分别部署在3台服务器 服务器准备 服务器名IP软件包前端192.168.99.137nginx后端192.168.99.139jar数据库192.168.99.100mariadb 1、前端服务器 yum install -y epel-release && yum install -y nginx…

202012青少年软件编程(Python)等级考试试卷(二级)

第 1 题 【单选题】 执行以下代码中,输出的结果是?( ) sum=0for i in range(1,10,3):sum=sum+iprint(sum,i)A :22 10 B :12 7 C :45 9 D :55 10 正确答案:B 试题解析: 第 2 题 【单选题】 下列代码的执行结果是?( ) s1="abcde"s2="fgh"s3=…

golang编程规范

文章目录 1&#xff1a;使用适当的缩进2&#xff1a;规范地导入包3&#xff1a;使用描述性变量和函数名称4&#xff1a;限制行长5&#xff1a;使用常量来代替魔术值6&#xff1a;错误处理7&#xff1a;避免使用全局变量8&#xff1a;使用结构体处理复杂数据9&#xff1a;给代码…

官宣:vAsterNOS正式发布!开放网络操作系统免费试用!

近期&#xff0c;vAsterNOS&#xff08;设备模拟器&#xff09;正式发布&#xff0c;可以满足用户快速了解 AsterNOS、体验实际操作、搭建模拟网络的需求&#xff0c;可运行在GNS3、EVE-NG等网络虚拟软件中。 AsterNOS 网络操作系统是星融元为人工智能、机器学习、高性能计算、…

算法 第56天 动态规划16

583 两个字符串的删除操作 给定两个单词 word1 和 word2 &#xff0c;返回使得 word1 和 word2 相同所需的最小步数。 每步 可以删除任意一个字符串中的一个字符。 def minDistance(word1,word2):dp[[0]*(len(word2)1) for _ in range(len(word1)1)]for i in range(len(word…

前端面试:项目细节问题(已工作|给大家做个分享)

1、介绍介绍整个项目的开发流程&#xff1f; 答&#xff1a;我面试时的回答&#xff1a;首先&#xff0c;产品、项目经理和甲方一起开会确认需求&#xff0c;产品编写需求文档&#xff0c;并画出原型图贴在需求文档上&#xff1b;然后&#xff0c;产品、项目经理、甲方、技术、…

vCenter 7.3证书过期无法登录处理方法

登录报错&#xff1a;如下图 Exception in invking authentication handler [SSL: CERTIFICATE_VERIFY_FAILED] certificate vertify failed: certificate has expired(_ssl.c:1076) 处理方法1&#xff1a;推荐&#xff0c;可行 登录vCenter控制台&#xff0c;AltF3切换至命令…

antdVue 自定义table列配置

最近做项目的时候需要对页面的table进行列配置的需求 子组件 <div><a-modaltitle"列配置" :visible"visible" :closable"false" :footer"null"width"800px" height"448px"><div><a-row>…

.DevicData-P-XXXXXXX勒索病毒数据怎么处理|数据解密恢复

导言&#xff1a; 在网络空间&#xff0c;每一次病毒或勒索软件的涌现都如同一次科技界的“地震”。而.DevicData-P-XXXXXXX勒索病毒&#xff0c;正是这场“地震”中的一股不可忽视的力量。它以其独特的加密技术和狡猾的传播方式&#xff0c;给全球的个人和企业带来了前所未有…

office 官方下载地址

office 官方下载地址&#xff1a;https://answers.microsoft.com/en-us/msoffice/forum/all/useful-microsoft-download-links-for-office-direct/7bcaa971-9493-44b6-a1ba-0db4c6957c47 Office 2013 Home and Student Russian https://officeredir.microsoft.com/r/rlidO15C2…

在linux里登录远程服务器

在linux里登录远程服务器。在虚拟终端里输入命令&#xff1a; ssh 远程服务器ip -l username 然后输入登录密码&#xff0c;就可以登录到远程服务器的命令行界面。登录方便&#xff0c;字体也可以在本地机的虚拟终端里设置得大一点。 下面是一张截屏图片。

QTableWidget导入导出excel

导入导出excel的方式有很多种&#xff0c;我这里使用的表格类型为CSV&#xff0c;这样可以不依赖那些office软件 导入&#xff1a; QList<QStringList> data;QString file_name QFileDialog::getOpenFileName(this,tr("Read file"),"",tr("fil…

系统Cpu利用率降低改造之路

系统Cpu利用率降低改造之路 一.背景 1.1 系统背景 该系统是一个专门爬取第三方数据的高并发系统&#xff0c;该系统单台机器以每分钟400万的频次查询第三方数据&#xff0c;并回推给内部第三方系统。从应用类型上看属于IO密集型应用,为了提高系统的吞吐量和并发&#xff0c;…

音频数字信号I2S一些知识理解

(1)I2S单向基本传输需要几根线传输音频信号? 3根线 LRCK SCLK(也叫BLK) DATA(单向) (2)如何理解I2S MASTER或者SLAVE的模式&#xff1f; codec的i2s作为slave mode,LRCK和SCLK来自于soc主控端,codec端自动检测MCLK和LRCK codec的i2s作为master mode,codec通过MCLK LRCLKDIV…

【Delphi 爬虫库 5】HTTP响应状态码说明详解(Response Status Code)

HTTP&#xff08;Hypertext Transfer Protocol&#xff09;是互联网上应用最广泛的协议之一&#xff0c;用于在客户端和服务器之间传输数据。在HTTP通信中&#xff0c;服务器在接收到客户端请求后&#xff0c;会返回一个HTTP响应&#xff0c;其中包含一个状态码&#xff0c;这个…