MQTT协议解析 : 物联网领域的最佳选择

1. MQTT协议概述

1.1 MQTT协议是什么

MQTT : Message Queuing Telemetry Transport

  • 模式 : 发布 / 订阅主题
  • 优点 : 代码量小、低带宽、实时可靠
  • 应用 : 物联网、小型设备、移动应用
  • MQTT 常用端口 : 1883

MQTT是一个网络协议,和HTTP类似,因为轻量简单,很多时候传输效率是后者的数十倍。
它仅用极少的代码和有限的带宽,就能为连接远程设备提供实时可靠的消息服务,所以逐渐在物联网(IOT)领域成为了最佳选择。
其实,日常生活中我们也许使用过MQTT,比如你用手机解锁一辆共享单车的时候。

在这里插入图片描述

1.2 MQTT里的角色

MQTT里有3个角色,基于发布 / 订阅模式

  • 代理 Broker (服务器) (消息中转站)
    • 负责接收各个设备发送来的消息,然后把消息转发给需要的设备
  • 发布者 Publisher (客户端)
  • 订阅者 Subscriber (客户端)

可以用视频软件(如抖音/B站)举例子,你(订阅者)关注了某个创作者(发布者),当这个创作者发布新视频的时候,你就会收到B站的推送通知。MQTT协议和上面的简直一模一样。

在这里插入图片描述

2. MQTT协议的工作原理

MQTT协议的消息传输基于客户端-服务器模型,客户端可以是发布者(Publisher)或订阅者(Subscriber),而服务器则负责消息的路由和分发。

2.1 工作流程

  1. 客户端首先与MQTT服务器建立TCP连接,连接成功后,客户端发送一个CONNECT消息,包含客户端标识、用户名、密码等信息。
  2. 服务器验证这些信息后,返回一个CONNACK消息,确认连接。发布者客户端发送PUBLISH消息,将消息发送到特定的主题(Topic),消息包含主题名称、消息有效荷载(Payload)和质量服务等级(QoS)。
  3. MQTT服务器接收到PUBLISH消息后,根据消息的主题,将消息分发给所有订阅了该主题的客户端。这个过程是异步的,确保了消息的高效分发。

在这里插入图片描述

2.2 MQTT底层是TCP/IP

MQTT底层是TCP/IP

  • 连接 : 主动连接服务器,连接的时候带了很多的信息,比如用户名和密码
    • 信息匹配成功后,才会给你响应
  • 发送心跳 & 回应心跳 : 发布者或订阅者发起,服务端响应。
    • 如果长时间没有发送心跳,服务端会认为这个客户端已经离线了,会主动断开连接。
  • 服务质量等级QoS
    • 等级 QoS0 : “最多一次” : 只管发送,不管接收
    • 等级 QoS1 : “最少一次” : 发布以后,服务器必须要回复。如果没收到回复,那么还会继续发,直到你给我回复。
    • 等级 QoS2 : “仅一次” : 发布以后,服务器回复,客户端收到回复以后,发布释放,客户端回复发布完成
      • 应用 : 计费的场景,对次数有严格要求,只要求有一次就够了

除了基于 TCP 的 MQTT,也存在基于 UDP 的 MQTT-SN 等变种协议,不过它们的应用场景和特性与基于 TCP 的 MQTT 有所不同。

3. MQTT数据结构

在MQTT协议中,一个MQTT数据包由:固定头(Fixed header)、可变头(Variable header)、消息体 (payload)三部分构成。MQTT数据包结构如下:

在这里插入图片描述

  • 固定头部(Fixed Header) : 这是每个 MQTT 消息都有的部分,长度最小为 2 字节。它包含了消息类型和标志位等信息。
  • 可变头部(Variable Header) : 可选(根据消息类型来判定是否存在)
    • 存在于部分MQTT数据包中,数据包类型决定了可变头是否存在及其具体内容。
  • 有效载荷(Payload) : 可选(根据消息类型来判定是否存在)
    • 存在于部分MQTT数据包中,表示客户端收到的具体内容。

在这里插入图片描述

3.1 固定头部

这是每个 MQTT 消息都有的部分,长度最小为 2 个字节,最多为 5 个字节。

3.1.1 第一个字节

MQTT 协议明确规定高 4 位用于表示消息类型,低 4 位用于表示标志位(如 QoS 级别、保留位、重复位等)。这种定义是基于一种默认的、统一的位顺序来理解的,所有遵循 MQTT 协议的实现都应该按照这个规定的顺序来解析和处理消息。
在这里插入图片描述

3.1.2 第二个字节 - 至多五个字节

第二个字节,高位第一个字节如果为1,表明存在第三个字节,如果为0,表示不存在第三个字节。
在这里插入图片描述

3.2 可变报头

如果是连接请求,可见报头就是下图所示这样。
Byte1-Byte2 是 协议长度。
Byte3-Byte6 是 协议名。
Byte7 是 协议级别。
Byte8 是 连接标志,用来确定是否包含 用户名、密码等。
Byte9-Byte10 用作心跳间隔时间。

在这里插入图片描述

3.3 有效载荷

如果是连接请求,有效载荷就是下图所示这样。
客户端标识符 : 表示你设备的名字,
还有用户名和密码就是放在这里的 (如果有的话)

在这里插入图片描述

4. 抓包

4.1 连接的请求报文

可以看到固定报头、可变报头和有效载荷, Message TypeConnect Command

在这里插入图片描述

4.2 连接的响应报文

没有有效载荷,只有固定报头和可变报头

在这里插入图片描述

4.3 发布的请求报文

Message Type : Publish Message
Topic Length : 主题的长度
Topic : 主题
Message Identifier : 消息ID
Message : 有效载荷,其实解析后就是一个JSON字符串
在这里插入图片描述

4.4 发布的应答报文

在这里插入图片描述

5. 智能家居场景示例

5.1 设备角色介绍

想象一下,你有一个智能家居系统。在这个系统中,有各种各样的设备,就像一个个“小通讯员”。其中包括温度传感器、湿度传感器、智能灯泡和智能窗帘等设备,这些设备就是MQTT中的“客户端(Client)”。

5.2 代理服务器(Broker)的作用

在这个智能家居网络中,还有一个“消息中转站”,也就是MQTT代理(Broker)。它就像是一个社区的收发室,负责接收各个设备发送来的消息,然后把消息转发给需要的设备。

5.3 发布/订阅模式的体现

  • 发布过程:温度传感器就像一个小广播员,它会定期检测室内的温度,然后把温度信息发送(发布)出去。例如,它会把温度数据发布到一个主题(Topic)下,这个主题可以是“home/temperature”。这就好比广播员在广播频道“家庭温度频道”上广播室内温度信息。
  • 订阅过程:智能空调是一个对温度很感兴趣的设备,它会订阅“home/temperature”这个主题。当温度传感器发布了新的温度消息后,代理服务器就会把这个消息转发给智能空调。这就像智能空调一直收听“家庭温度频道”,一旦有新的温度消息广播,它就能收到并根据温度信息来决定是否调整制冷或制热模式。

5.4 不同QoS级别的应用场景

  • QoS 0 - 最多一次传递:智能灯泡的颜色变化信息可以采用QoS 0级别。假设你有一个可以改变颜色的智能灯泡,你通过手机应用设置了一个灯光颜色变化的动态效果。这个颜色变化的消息对于偶尔丢失几条数据不太敏感。如果因为网络问题,有一两条关于颜色变化的指令没有传达到灯泡,可能不会被用户明显察觉,因为灯光效果的连续性不会因为偶尔的丢失而受到严重影响。
  • QoS 1 - 至少一次传递:对于智能窗帘的控制指令可以采用QoS 1级别。比如你发送一个指令让窗帘打开,这个指令比较重要,不能丢失。如果因为网络波动,代理服务器没有收到智能窗帘的确认消息,它会重新发送这个指令,这样就确保了窗帘至少能收到一次打开的指令。即使偶尔收到两次相同的指令,窗帘也只是执行相同的动作(打开),不会产生严重的后果。
  • QoS 2 - 恰好一次传递:在智能家居系统与外部支付系统进行联动的场景下,例如当你购买了一个智能家居服务套餐,支付成功的消息需要以QoS 2级别传递。这个消息必须准确无误地在智能家居系统和支付系统之间传递,既不能丢失也不能重复,以确保你的服务能够正确开通,同时避免因为重复支付而造成损失。

6. 其他

参考

物联网系列 - MQTT协议原理与数据包结构
用B站解释MQTT协议
MQTT协议的工作原理——消息传输
MQTT协议原理与应用精讲
MQTT 协议入门:基础知识和快速教程 | EMQ

MQTT协议测试——MQTT X工具使用_梦的博客-CSDN博客_mqtt测试
推荐八款常用 MQTT 客户端工具 - 知乎 (zhihu.com)
两款常用的 MQTT 调试工具_zuozewei的博客-CSDN博客_mqtt测试工具
MQTT基础 三: 发布、订阅和取消订阅 - 简书 (jianshu.com)

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

快速入门Zookeeper

Zookeeper ZooKeeper作为一个强大的开源分布式协调服务,扮演着分布式系统中至关重要的角色。它提供了一个中心化的服务,用于维护配置信息、命名、提供分布式同步以及提供组服务等。通过其高性能和可靠的特性,ZooKeeper能够确保在复杂的分布式…

「Mac玩转仓颉内测版1」入门篇1 - Cangjie环境的搭建

本篇详细介绍在Mac系统上快速搭建Cangjie开发环境的步骤,涵盖VSCode的下载与安装、Cangjie插件的离线安装、工具链的配置及验证。通过这些步骤,确保开发环境配置完成,为Cangjie项目开发提供稳定的基础支持。 关键词 Cangjie开发环境搭建VSC…

从0开始学习机器学习--Day20--优化算法的思路

确定执行的优先级(Prioritizing what to work on : Spam classification example) 在建立学习系统前,我们不仅要梳理框架,更重要的是我们要弄清楚有哪些事情是要优先做的,这可以帮我们节约大量的时间。 以垃圾邮件为例,按照之前…

H5播放器EasyPlayer.js 流媒体播放器是否支持npm(yarn) install 安装?

EasyPlayer.js H5播放器是一款功能强大的H5视频播放器,它支持多种流媒体协议播放,包括WebSocket-FLV、HTTP-FLV、HLS(m3u8)、WebRTC等格式的视频流。它不仅支持H.264和H.265编码格式,还具备实时录像、低延时直播等功能…

SpringCloud篇(微服务)

目录 一、认识微服务 1. 单体架构 2. 分布式架构 3. 微服务 3.1. 特点 3.2. 优点 3.3 缺点 二、微服务设计、拆分原则 1. AKF 拆分原则 2. Y轴(功能)关注应用中功能划分,基于不同的业务拆分 3. X轴(水平扩展&#xff09…

【鸿蒙】HarmonyOS NEXT应用开发快速入门教程之布局篇(下)

系列文章目录 【鸿蒙】HarmonyOS NEXT开发快速入门教程之ArkTS语法装饰器(上) 【鸿蒙】HarmonyOS NEXT开发快速入门教程之ArkTS语法装饰器(下) 【鸿蒙】HarmonyOS NEXT应用开发快速入门教程之布局篇(上) 【…

ts 如何配置引入 json 文件

ts 如何配置引入 json 文件 参考文档: https://maxgadget.dev/article/how-to-import-a-json-file-in-typescript-a-comprehensive-guide 项目中有一个 .json 的文件是配置文件,如何引入到 ts 项目中 配置 tsconfig.json 文件,添加这两个 {…

Jenkins找不到maven构建项目

有的可能没有出现maven这个选项 解决办法:需要安装Maven项目插件 输入​Maven Integration plugin​

解决 “Error: listen EACCES: permission denied 0.0.0.0:80“ 错误

前言 在开发过程中,我们经常会遇到各种各样的错误。其中一个常见的错误是 Error: listen EACCES: permission denied 0.0.0.0:80。这个错误通常发生在尝试启动一个开发服务器时,服务器试图绑定到80端口,但由于权限不足而失败。本文将详细介绍…

华为2288HV2服务器安装BCLinux8U6无法显示完整安装界面的问题处理

本文记录了华为2288HV2服务器安装BCLinux8U6无法显示完整安装界面,在安装过程中配置选择时,右侧安装按钮不可见,导致安装无法继续的问题处理过程。 一、问题现象 华为2288HV2服务器安装BCLinux8U6时无法显示完整的安装界面,问题…

使用docker形式部署jumpserver

文章目录 前言一、背景二、使用步骤1.基础环境准备2.拉取镜像3.进行部署4.备份记录启动命令 前言 记录一下使用docker形式部署jumpserver服务的 一、背景 搭建一个jumpserver的堡垒机,但是发现之前是二进制文件部署的,会在物理机上部署污染环境&#x…

【SQL50】day 1

目录 1.可回收且低脂的产品 2.寻找用户推荐人 3.使用唯一标识码替换员工ID 4.产品销售分析 I 5.有趣的电影 6.平均售价 7.每位教师所教授的科目种类的数量 8.平均售价 1.可回收且低脂的产品 # Write your MySQL query statement below select product_id from Products w…

Mac如何将多个pdf文件归并到一个

电脑:MacBook Pro M1 操作方式: very easy 选中想要归并的所有pdf文件,然后 右键 -> quick actions -> Create PDF 然后就可以看到将所选pdf文件归并为一个pdf的文件了

elementUI 点击弹出时间 date-picker

elementUI的日期组件,有完整的UI样式及弹窗,但是我的页面不要它的UI样式,点击的时候却要弹出类似的日期选择器,那怎么办呢? 以下是elementUI自带的UI风格,一定要一个输入框来触发。 这是我的项目中要用到的…

PCA(主成分分析)算法的应用场景

PCA(主成分分析)算法的应用场景非常广泛,以下是一些主要的应用领域: 数据压缩: PCA可以将高维数据映射到低维空间,从而实现数据的压缩,减少存储空间和计算复杂度。这对于存储和传输大量数据的情…

优选算法第五讲:位运算模块

优选算法第五讲:位运算模块 1.常见的位运算总结2.判断字符是否唯一3.丢失的数字4.两整数之和5.只出现一次的数字II6.消失的两个数字 1.常见的位运算总结 2.判断字符是否唯一 链接: link class Solution { public:bool isUnique(string astr) {if(astr.size() >…

求平面连接线段组成的所有最小闭合区间

这个功能确实非常实用,我在过去开发地面分区编辑器时就曾应用过这一算法。最近,在新产品的开发中再次遇到了类似的需求。尽管之前已经实现过,但由于长时间未接触,对算法的具体细节有所遗忘,导致重新编写时耗费了不少时…

Spring Boot开发入门教程

简介 Spring Boot是一个开源的Java基础框架,用于创建独立、生产级的基于Spring框架的应用程序。通过Spring Boot,你可以轻松地创建独立的、生产级的Spring应用程序。 环境准备 Java开发环境:确保你的机器上安装了Java 8或更高版本。Maven…

虚拟化数据恢复—XenServer虚拟机中SQL Server数据库数据恢复案例

服务器虚拟化数据恢复环境: 某品牌720服务器中有一组通过同品牌、型号为H710P的RAID卡4块STAT硬盘组建的RAID10磁盘阵列。上层部署XenServer虚拟化平台。1台Windows Server操作系统虚拟机,该虚拟机有2块虚拟磁盘(系统盘数据盘)&am…

2024年【流动式起重机司机】模拟考试及流动式起重机司机证考试

题库来源:安全生产模拟考试一点通公众号小程序 流动式起重机司机模拟考试考前必练!安全生产模拟考试一点通每个月更新流动式起重机司机证考试题目及答案!多做几遍,其实通过流动式起重机司机模拟考试题很简单。 1、【多选题】( )和…