写点什么

MQTT 协议之连接

  • 2019-11-20
  • 本文字数:3292 字

    阅读完需:约 11 分钟

MQTT协议之连接

在之前的文章中已简单介绍了 MQTT 协议报文的格式,本篇文章将对集中的连接协议进行详细的介绍,以及自己对该协议的一些思考和理解。

1 CONNECT

客户端和服务端建立连接之后,发送的第一个报文必须是 CONNECT。客户端只能发送一次 CONNECT 报文,如果服务端收到了第二个 CONNECT 报文,必须将其视为错误,并且断开连接。

协议格式

固定报头

可变报头

可变报头分为四个部分,分别是协议名称(Protocol Name),协议级别(Protocol Level),连接标志(Connect Flags),保持连接(Keep Alive)。

协议名称


  1. 协议名是 MQTT 的 UTF-8 编码的字符串。MQTT 规范的后续版本不会改变这个字符串的偏移和长度。

  2. 如果协议不正确服务端断开连接。(MQTT 3.1.1)其他规范中可以有其他规范。

  3. 数据包检测工具,可以使用协议名来识别 MQTT 流量。

协议级别


  1. 使用 8 位来表示协议的修订版本级别。MQTT3.1.1 的协议级别为 4。这个也是 MQTT5 的由来,MQTT5 的协议级别为 5,故称为 MQTT5。

  2. 服务端收到一个自己不支持的协议级别的时候,必须返回一个 returnCode 为 0x01 的 CONNACK 的报文给客户端,随后服务端断开相应的连接。

  3. 连接标志



  1. 服务端必须校验连接标志中的预留字段是否为 0,如果不为 0,必须断开该连接。

  2. 清理会话标志


A. 清理会话标志的表现


a.清理会话标志为0(false)
i.如果已存在相同ClientId的会话,则必须恢复相应的会话。
ii.不存在相同ClientId的会话,则重新创建一个新的会话。
iii.客户端和服务端断开连接后,服务端必须保存相应的会话信息。
iv.连接断开后,服务端必须保留该Session所有的订阅Topic的Qos1和Qos2的消息。服务端也可以保留Qos0的消息,此为可选项。
b.清理会话标志1(true) 客户端和服务端都必须丢弃之前的会话并且重新创建一个会话。会话信息是和连接绑定的,该会话相关的数据,不能被后续的会话使用
复制代码


B. 状态信息


a. 客户端
i.Qos和Qos2已经发送到服务端,但是还没有完全结束的消息。
ii.Qos2已经收到的消息,但是还没有最终完成的消息。
b. 服务端
i.会话存在的信息,即时会话的其他内容都是空的。
ii.客户端的订阅信息。
iii.Qos1和Qos2已经发送到客户端但是没有完全结束的消息。
iv.Qos2已经收到的,但是还没有最终结束的消息。
v.等待发送给客户端的Qos1和Qos2消息。
vi.可选的等待发送给客户端的Qos0的消息。
复制代码


C. 注意事项


a. 保留消息不是服务端会话状态的一部分,会话中止时不能删除。
b. 清理会话设置为1时,客户端和服务端的状态删除不需要是原子操作。
c. 如果希望保证在异常时的状态一致性,可以通过清理会话标志始终设置为1直到成功连接上服务。
复制代码


  1. 遗嘱标志 遗嘱标志设置了(1 或者 true)之后,连接建立成功之后,遗嘱消息会被存储在服务端并且和这个网络连接绑定,当该网络连接异常关闭时,服务端必须发布这个遗嘱消息,除非客户端发送了 DISCONNECT 消息后,服务端删除了该消息。


A. 遗嘱消息发布的条件,包括但不限于


a. 服务端检测到IO错误或者网络故障。
b. 客户端在保持连接的时间内未能通讯。
c. 客户端没有先发送DISCONNECT报文而直接关闭了连接。
d. 由于协议错误服务端关闭了网络连接。
复制代码


B. 注意事项


a. 遗嘱标志设置后,Will Qos和Will Retain会被用到,有效载荷必需包含Will Topic和Will Message。
b. 被发布或收到客户端的DISCONNECT报文之后,遗嘱消息必须从存储中删除。
c. 遗嘱标志设置为0时,Will Qos和Will Retain字段必须设置为0,并且有效载荷中不能包含Will Topic和Will Message.
d. 服务端应该迅速发布遗嘱消息。在关机或者故障的情况下,服务端可以推迟发布消息到服务恢复。
复制代码


  1. 遗嘱消息 Qos 遗嘱消息的 QOS。

  2. 遗嘱预留消息 遗嘱消息的保留标志。

  3. 用户名标志 表示是否又用户名在有效载荷中。

  4. 密码标志 表示是否又密码在有效载荷中,如果用户名标志为 0,该字段也必须为 0。

  5. 保持连接



  1. 保持连接单位为秒(s),两个 Byte 16 位表示,所以最长的 keepAlive 的时间为 18 小时 12 分 15 秒。

  2. 表示的是客户端从发送完一个报文到发送下一个报文,两者之间允许的最大时间间隔。客户端负责保证控制报文发送的时间间隔不超过保持连接的值,如果没有其他的报文可以发送,客户端必须发送 PINGREQ 报文。

  3. 客户端可以随时发送 PINGREQ 报文,并且根绝 PINGRESP 的报文判断和服务端的活动状态。

  4. 如果服务端在 1.5 倍的保持连接(非 0)时间内没有收到任何的报文,服务端必须断开相应的连接。

  5. 客户端发送 PINGREQ 之后,在规定的时间没有收到服务端的 PINGRESP 报文的回应,客户端应该断开该连接。

  6. 保持连接设置为 0 表示关闭保持连接的功能。服务端不需要因为客户端的不活跃而断开连接。

  7. 服务端主要认为客户端是不活跃或者无响应的,都可以断开客户端连接。

有效载荷

有效载荷中的字段包含一个或者多个是根据可变报头中的标志来决定有无的。如果存在的话,必须按照如下的顺序,ClientId, Will Topic, Will Message, User Name, Password。


  1. ClientId

  2. A. 每个客户端连接服务端必须有一个唯一的 ClientId 标志。该标志是客户端和服务端用来区分会话的唯一标志。

  3. B. 必须提供并且必须是 CONNECT 报文有效负载的第一个字段。

  4. C. 必须[1-23]的 UTF-8 编码,包含的内容必须是[0-9][a-z][A-Z]。服务端也可以支持更长的以及其他的 UTF-8 字符。

  5. D. 如果 ClientId 是 0 字节的,服务端必须为其赋予一个唯一的标志,然后进行后续的处理。ClientId 为 0 字节时有如下的限制,

  6. a. 清理会话标志必须设置为 1,否则服务端返回 returnCode=0x02 的 CONNACK,并且关闭该网络连接。

  7. E. 服务端如果拒绝该 ClientId,服务端必须返回 returnCode=0x02 的 CONNACK,并且关闭该网络连接。

  8. Will Topic 遗嘱消息的 topic,必须是 UTF-8 编码的字符串。

  9. Will Message 遗嘱消息的内容。

  10. User Name 用户名,必须是 UTF-8 的字符串。

  11. Passowrd



由两个 Byte 表示的二进制数据标识。最长可以为 65535Bytes 的二进制。

响应

检验
复制代码


  1. 网络建立后,服务端在指定时间内没有收到客户端的 CONNECT 消息,服务端应该关闭连接。

  2. 服务端必须按照以上规范来验证 CONNECT 报文,如果不符合规范,服务端必须关闭连接,而且不需要发送 CONNACK。

  3. 服务端可以检查 CONNECT 的内容,如果任何一个检查没有通过,应该返回一个指定的 CONNACK 的报文,并且必须关闭该连接。

  4. 服务端检验通过后的处理

  5. 如果又相同 ClientId 的连接,服务端必须关闭已有的连接。

  6. 服务端需要处理和清理会话相关的内容。

  7. 返回客户端 CONNACK。

  8. 开始消息投递和保活监控。 备注:客户端可以不等待 CONNACK 的返回,直接发送其他的控制报文,如果服务端拒绝了相应的连接,服务端必须不处理 CONNECT 报文之后的任何协议。

  9. CONNACK

  10. 服务端返回给客户端的第一个协议必须是 CONNACK 报文。

  11. 协议格式

  12. 固定报头



固定报头中只有报文类型为2。
可变报头
复制代码



可变报头包含连接确认标志和连接返回码。
连接确认标志
复制代码


  1. 保留位必须为 0

  2. 当前会话 SP

  3. A. 服务端如果没有之前的会话时,该值为 0。

  4. B. 如果 returnCode=0(连接被接收),服务端存在之前的会话,该值为 1。

  5. C. 该标志能够是客户端和服务端是否又已存在会话保持一致,如果两者不一致,客户端可以选择断开连接或者继续连接。客户端可以通过断开连接,清理会话设置为 1,再次连接,然后再次断开连接的方式来丢弃客户端和服务端的会话状态。

  6. D. 如果返回码非 0,会话状态必须为 0。

  7. 连接返回码



 有效载荷
CONNACK报文没有有效载荷字段。
复制代码

2 总结

  1. 连接报文是 MQTT 连接建立之后的第一个报文,如果不是将会断开连接,并且连接报文也只能发送一次。

  2. 清理会话的设置也是通过连接报文进行设置,可以通过重新连接,设置清理会话的标志来保持客户端和服务端的会话信息。

  3. 遗言是跟连接绑定的,在用户非正常 DISCONNECT 的情况下将触发遗言的发布。

  4. 保持连接是检测客户端发送到服务端的消息的间隔时间,协议固定在 1.5 倍的保持连接的时间,会断开连接。现在使用的 EMQ 的保持连接的机制,KeepAlive * backoff = CheckTime,从客户端建立连接开始进行循环检测,连续两次没有检测到 Socket 报文的话,则认为超时,故真实的超时时间为 CheckTime * 2 < RealTimeout < CheckTime * 3。


本文转载自公众号 360 云计算(ID:hulktalk)。


原文链接:


https://mp.weixin.qq.com/s/lq7uN8CUf3m9CmnqLxK01A


2019-11-20 11:371915

评论

发布
暂无评论
发现更多内容

鲲鹏DevKit助力南京信息工程大学高效开发

说山水

支持M1的苹果电脑视频下载器-Downie 4 Mac中文版

Rose

Mac 视频下载工具 Downie 4许可证 Downie 4中文版 Downie mac破解版

mac电脑如何远程控制win?微软远程桌面连接工具来帮你!

Rose

Mac远程控制软件 mac电脑如何远程控制win microsoft remote desktop 微软远程桌面连接工具

鲲鹏DevKit助力深圳财富趋势高效开发行情分析系统,行情揭示快人一步

说山水

提升您的 MQTT 云服务:深入探索 BYOC

EMQ映云科技

物联网 云服务 mqtt

开源创新 协同融合|2023开放原子全球开源峰会开源协作平台分论坛即将启幕

开放原子开源基金会

开源 开源协作

秒验 iOS端集成指南

MobTech袤博科技

Waves 14 Complete Mac激活最新版(Waves混音效果全套插件) v31.05.2023

真大的脸盆

Mac 软件 Waves 14破解教程 混音软件 混音套件 waves

FC红白机游戏600合集 for mac(小霸王游戏) 单机离线版

Rose

Mac游戏下载 FC 红白机游戏 任天堂游戏下载 小霸王游戏

abaqus有限元仿真常见问题(一):数值仿真在产品研发中的作用

思茂信息

CAE abaqus abaqus软件 abaqus有限元仿真

挖掘算力产业的创新力量和新型机遇|2023开放原子全球开源峰会先进计算分论坛即将启幕

开放原子开源基金会

开源 算力 先进计算

乘云而上,山西软件行业CXO思享会在晋起航

说山水

Java 高效处理千万级数据:技巧与最佳实践

xfgg

Java 大数据

如何在大学校园内合作运营共享电单车

共享电单车厂家

校内共享电单车 共享电动车投放 共享电单车合作 共享电单车厂家

Scrum敏捷项目管理真实案例

顿顿顿

Scrum 敏捷开发 敏捷开发管理 敏捷项目管理 scrum工具

软件测试/测试开发丨接口测试学习笔记

测试人

程序员 软件测试 自动化测试 测试开发

解锁软件工程新角色——平台工程师

SEAL安全

DevOps 平台工程 平台工程师

在软件定义汽车的时代,低代码究竟给车企数字化转型带来了什么?

优秀

低代码 车企 车企数字化

CodeWhisperer 初体验

天黑黑

AI 亚马逊云 CodeWhisperer

植物大战僵尸mac版下载

Rose

植物大战僵尸 mac 植物大战僵尸中文版 植物大战僵尸下载 mac塔防游戏

一文回顾 Boundless Hackathon at Stanford 首期 Workshop

鳄鱼视界

华为教育中心:奇趣“童”行庆六一 多彩儿童应用助成长

科技热闻

led显示屏保养技巧

Dylan

故障 LED显示屏 设备日常保养

对应用数据开发还有疑惑?看这篇就够了!数据存储、管理,通通掌握!

HarmonyOS开发者

HarmonyOS

一文回顾 Boundless Hackathon at Stanford 首期 Workshop

西柚子

智能出行 驱动未来|2023开放原子全球开源峰会CARSMOS开源智能出行生态年会即将启幕

开放原子开源基金会

开源 智能出行 CARSMOS

百度倾力出品|《神经网络机器翻译技术及产业应用》正式上线

飞桨PaddlePaddle

人工智能 深度学习 百度飞桨

技术的交流 思想的碰撞|2023开放原子全球开源峰会TOC面对面分论坛即将启幕

开放原子开源基金会

开源 社区 TOC

MQTT协议之连接_文化 & 方法_张超_InfoQ精选文章