写点什么

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:371674

评论

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

PreparedStatement实践和批处理实践

FunTester

Programming Abstractions in C阅读笔记:p242-p245

codists

docker rabbitmq-清空queue队列数据

百度搜索:蓝易云

云计算 Linux 运维 RabbitMQ 云服务器

传统 VC 机构,是否还能在 Fair launch 的散户牛市中胜出?

BlockChain先知

C 语言文件读取全指南:打开、读取、逐行输出

小万哥

程序人生 编程语言 软件工程 C/C++ 后端开发

使用JMeter安装RabbitMQ测试插件的步骤

百度搜索:蓝易云

云计算 Linux 运维 RabbitMQ Jmeter

IPQ8074: the leader in high-performance router motherboard chips

wallysSK

京东方精电亮相CES2024,携手合作伙伴共绘智慧出行未来图景

科技热闻

数据库内核那些事|PolarDB查询优化:好好的谓词,为什么要做下推?

阿里云瑶池数据库

数据库 阿里云 云原生

异步编程利器:CompletableFuture深度解析

Java随想录

Java 多线程 并发

网易首款鸿蒙原生游戏《倩女幽魂》手游完成开发,商业化版本已就绪

新消费日报

可编程线性霍尔传感器 IC

梦笔生花

【深入浅出JVM原理及调优】「搭建理论知识框架」全方位带你探索和分析JMM并发模型之(重排序机制)

洛神灬殇

Java 重排序 并发编程 JVM as-if-serial

舞台婚庆租赁屏选哪个型号更好?

Dylan

节日 LED显示屏 户外LED显示屏 led显示屏厂家 户内led显示屏

传统 VC 机构,是否还能在 Fair launch 的散户牛市中胜出?

石头财经

2024-01-10:用go语言,给你一个下标从 0 开始的二维整数数组 pairs 其中 pairs[i] = [starti, endi] 如果 pairs 的一个重新排列 满足对每一个下标 i

福大大架构师每日一题

福大大架构师每日一题

文心大模型融入荣耀MagicOS!打造大模型“端云协同”创新样板

爱编程的喵喵

苹果应用上架是否需要软件著作权?

雪奈椰子

传统 VC 机构,是否还能在 Fair launch 的散户牛市中胜出?

加密眼界

Go与C语言的互操作,import “C“的实例

百度搜索:蓝易云

Go 云计算 Linux C语言 云服务器

从 AutoMQ Kafka 导出数据到 Databend

Databend

Kafk

传统 VC 机构,是否还能在 Fair launch 的散户牛市中胜出?

股市老人

线索系统性能优化实践

京东科技开发者

极狐 GitLab 冷知识:使用 Email 也可以创建 Issue?

极狐GitLab

vivo 海量微服务架构最新实践

vivo互联网技术

开源 微服务 中间件

XSKY 与 英特尔联手,释放星飞分布式全闪存储潜能

XSKY星辰天合

sds intel 软件定义存储 QAT XSKY

传统 VC 机构,是否还能在 Fair launch 的散户牛市中胜出?

大瞿科技

在线文档软件哪个好?5个好用的协同文档app推荐!

彭宏豪95

团队协作 在线文档 在线白板 在线协同文档 效率软件

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