MQTT协议理解并实践

MQTT是一个轻量的发布订阅模式消息传输协议,专门针对低带宽和不稳定网络环境的物联网应用设计

MQTT协议根据主题来分发消息进行通信,支持通配符匹配,可以低开销的使用数百万Topic进行一对一,一对多双向通信。

协议特点
1. 开放消息协议,简单易实现2. 发布订阅模式,一对多消息分发和应用程序分离3. 基于TCP/IP网络连接,有序,无损,双向连接的网络协议4. 字节固定包头,字节心跳报文,报文结构紧凑,协议交换最小化,以减少网络流量5. 消息QoS支持,可靠传输保证
服务质量等级
QoS 0:消息可能丢失
QoS 1:消息不会丢失但可能重复
QoS 2:消息不会丢失也不会重复
MQTT报文类型
  • 连接
CONNECT,CONNACk,DISCONNECT
  • 发布
PUBLISH,PUBACk,PUBREC(publish receive),PUBREL(publish release),PUBCOMP(publish complete)
  • 订阅
SUBSCRIBE,SUBACk,UNSUBSCRIBE,UNSUBACk
  • 心跳
PINGREQ,PINGRESP
主要报文类型
  • CONNECT
客户端标识符
用户名
密码
遗嘱消息
  • PUBLISH
主题
QoS
Payload(负载)
  • SUBSCRIBE
主题
QoS
发布订阅模式
发布者&订阅者 <----> Broker代理服务 <----> 订阅者&发布者
  1. 发布,订阅和取消订阅的相关报文

如何发布消息

client ------> publish(Topic Name,QoS,Payload) -------> brokerTopic Name(String):
示例:temperature  livingroom/temperature  kitchen/temperatureQos(Integer):
Qos 0 消息可能丢失
Qos 1 消息不会丢失但可能重复
Qos 2 消息不会丢失也不会重复Payload(Binary):
可为Json类型:
{“from":"client","temperature":26
}可为Binary类型进制数据
4d 69 72 61 63 6c 65 73...可为Ciphertext类型加密数据
UFsdGVkX1/PucJg+taTQ...

如何订阅消息

client ------> subscribe(Packet ID,Subscription List) ------> brokerPacket ID:
Subscribe: Packet ID    45678
Suback: Packet ID    45678Subscription List:
Topic Filter 1(QoS 1)
Topic Filter 2(Qos 2)
Topic Filter 3(Qos 3)Topic Filter subscribe可以使用主题通配符
subscribed topic a/+ 
代表:     publish to topic a/1
也可代表: publish to topic a/2 等

如何订阅响应

client -----> suback(Packet ID,Reason Codes) ------>BrokerReason Codes(原因码):
成功:
0x00:订阅成功且最大QoS等级为0
0x01: 订阅成功且最大QoS等级为1
0x02:订阅成功且最大QoS等级为2
失败:
0x80:订阅失败

如何取消订阅

client -----> unsubscribe(Packet ID,Topic Filters) -----> broker想要取消订阅的Topic Filter ------ 完全的文本匹配 ----- 实际订阅的Topic Filter

取消订阅响应

client ----- unsuback(Packet ID,Person Codes) ------ broker

Topic主题定义:

UTF-8字符串类型,最大长度65535长度,区分大小写home/livingroom/temperature + 主题通配符 = 一次订阅多个主题主题通配符类型:
1. 单层通配符(+): /home/+/temperature2. 多层通配符(#): 也可匹配0个层级 /home/#3. 以$开头的主题:$SYS/ (客户端上下线事件通知,报文收发统计,Broker状态信息)注意:通配符+和#可以同时使用,不建议主题以“/”开头或者结尾
准备条件

需要用到的工具

1.EMQX - MQTT Broker2.MQTTX- MQTT Client3.Wireshark-网络抓包工具

拉取EMQX镜像

docker pull emqx:5.0.19

运行EMQX

docker run -d --name emqx -p 18083:18083 -p 1883:1883 emqx:5.0.19

修改EMQX日志等级为 Debug

docker exec -i emqx /opt/emqx/bin/emqx ctl log set-level debug

查看EMQX日志

docker logs -f emgx
mqtt题目练习
1. 发布两条QoS1消息,这两条消息将使用不同的 Packet ID,并且Packet ID 不需要我们自己设置。2. 订阅未授权的主题 ($SYS/#),EMQX将返回 Reason Code 为 0x80的SUBACK。3. 订阅 a/+,可以收到 a/1、a/2 等主题的消息。4. 订阅 a/+ 和 a/1,当有客户端发布消息到主题 a/1时,订阅者将收到两条消息。5. 使用相同的主题过滤器进行多次订阅,新的订阅会覆盖旧的订阅,不会失败,也不会收到重复的消息。6. 订阅时设置最大 QoS为 1,发布 QoS为2的消息,订阅者收到的消息的 QoS为17. 订阅a/1 和a/+,取消订阅 a/+ 主题,只会取消订阅 a/+ 这个主题。8. example和Example、example/ 属于不同的主题。9. /example 主题必须用/+ 来匹配,仅使用+是匹配不到的。10. 单层通配符可以多次出现,订阅 a/+/+/d,可以接收来自 a/1/2/d 和 a/3/4/d 主题的消息。11. 订阅 a/#,可以接受来自 a/1 和 a/1/2 主题的消息12. 单层通配符和多层通配符可以同时使用,订阅 a/+/# 主题,发布消息到 a/1/2/3 主题13. 系统消息,订阅 $SYS/brokers/+/clients/#,可以接收到客户端上下线事件消息。

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

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

相关文章

Vulhub-信息泄露

1.Jetty WEB-INF 敏感信息泄露漏洞&#xff08;CVE-2021-28164&#xff09; docker-compose up -d 启动环境&#xff0c;显示8080端口被占用 修改 docker-compose.yml 中的映射端口 curl 访问 http://192.168.48.129:8090/WEB-INF/web.xml 显示404&#xff1a; 通过 %2e 绕过…

STlink下载程序不能复位的说明

STLINK在MDK5.28或其他版本中下载程序后不能复位&#xff0c;需要手动按复位键&#xff0c;MCU 才正常运行。 首先判断是不是该MDK版本的问题&#xff0c;按照以下进行 点击魔法棒 点击Debug&#xff0c;Settings 勾选Reset and Run 如果还是不行&#xff0c;取消Enable…

1423. 可获得的最大点数 --力扣 --JAVA

题目 几张卡牌 排成一行&#xff0c;每张卡牌都有一个对应的点数。点数由整数数组 cardPoints 给出。 每次行动&#xff0c;你可以从行的开头或者末尾拿一张卡牌&#xff0c;最终你必须正好拿 k 张卡牌。 你的点数就是你拿到手中的所有卡牌的点数之和。 给你一个整数数组 cardP…

九章量子计算机:引领量子计算的新篇章

九章量子计算机:引领量子计算的新篇章 一、引言 随着科技的飞速发展,量子计算已成为全球科研领域的前沿议题。九章量子计算机作为中国自主研发的量子计算机,具有划时代的意义。本文将深入探讨九章量子计算机的原理、技术特点、应用前景等方面,带领读者领略量子计算的魅力…

初识主力投资者

在股票市场中&#xff0c;真正赚钱的散户并不多。“七亏二平一赚”似乎已经成为了大家公认的一个股市定律。 为什么散户炒股赚的人少呢&#xff1f;原因很简单&#xff0c;就是因为市场上除了散户之外&#xff0c;还存在着一个重要的投资主体——主力。股市交易的过程&#xff…

树_对称二叉树

//给你一个二叉树的根节点 root &#xff0c; 检查它是否轴对称。 // // // // 示例 1&#xff1a; // // //输入&#xff1a;root [1,2,2,3,4,4,3] //输出&#xff1a;true // // // 示例 2&#xff1a; // // //输入&#xff1a;root [1,2,2,null,3,null,3] //输出…

【源码篇】基于SpringBoot+Vue实现的在线考试系统

文章目录 系统说明技术选型成果展示账号地址及其他说明 系统说明 基于SpringBootVue实现的在线考试系统是为高校打造的一款在线考试平台。 系统功能说明 1、系统共有管理员、老师、学生三个角色&#xff0c;管理员拥有系统最高权限。 2、老师拥有考试管理、题库管理、成绩管…

【物联网无线通信技术】ZigBee从理论到实践(CC2530)

文章延续之前【物联网无线通信技术】系列文章的风格&#xff0c;首先对ZigBee这种在物联网发展初期出现的无线通信技术进行了相关背景概念的介绍&#xff0c;并横向介绍了几款时间跨度比较大的ZigBee芯片。然后以CC2530为例&#xff0c;从硬件到软件介绍了ZigBee这中无线通信技…

java+springboot校园一卡通学生卡管理系统+jsp

利用校园卡实现了学生在学校的身份认证&#xff0c;对学生在学校的各种消费提供了方便的途径。对于学校图书馆&#xff0c;将自动存储学生图书借阅情况&#xff0c;记录处罚情况.对于任课教师可以及时、准确、方便的了解学生出勤、作业等情况。是凭借发达的网络技术&#xff0c…

【Redis】Redis缓存使用问题

目录 Redis缓存使用问题 数据一致性 新增数据类 更新缓存类 1、先更新缓存,再更新DB 2、先更新DB,再更新缓存 删除缓存类 3、先删除缓存,后更新DB 4、先更新DB,后删除缓存 如何选择问题 缓存穿透、击穿、雪崩 缓存穿透 缓存击穿 使用互斥锁(mutex key) 永远…

Group normalization是什么

在您提供的代码中&#xff0c;使用了 nn.GroupNorm 来创建一个规范化层。GroupNorm 是一种规范化技术&#xff0c;与批量规范化&#xff08;Batch Normalization&#xff09;和层规范化&#xff08;Layer Normalization&#xff09;相似&#xff0c;但有一些关键的区别。 Grou…

C语言之实现贪吃蛇小游戏篇(2)

目录 &#x1f387;测试游戏test.c &#x1f387;游戏头文件包含&函数声明snake.h &#x1f387;游戏实现snake.c &#x1f387;测试游戏test.c #define _CRT_SECURE_NO_WARNINGS 1 #include "snake.h" void test() {int ch 0;do{Snake snake { 0 };//创建…

智能优化算法应用:基于黏菌算法无线传感器网络(WSN)覆盖优化 - 附代码

智能优化算法应用&#xff1a;基于黏菌算法无线传感器网络(WSN)覆盖优化 - 附代码 文章目录 智能优化算法应用&#xff1a;基于黏菌算法无线传感器网络(WSN)覆盖优化 - 附代码1.无线传感网络节点模型2.覆盖数学模型及分析3.黏菌算法4.实验参数设定5.算法结果6.参考文献7.MATLAB…

Could NOT find resource [logback-test.xml]

修改 之后就可以正常启动了

训练自己的YOLOv8姿态估计模型

在不断发展的计算机视觉领域&#xff0c;姿态估计作为一项关键创新脱颖而出&#xff0c;改变了我们理解视觉数据以及与视觉数据交互的方式。 Ultralytics YOLOv8 处于这一转变的最前沿&#xff0c;提供了一个强大的工具来捕捉图像中物体方向和运动的微妙之处。 NSDT工具推荐&am…

高德地图海量点标记图片(智慧交通道路事件情况)

1.先建个js文件 import AMapLoader from "amap/amap-jsapi-loader"; 2.文件中代码 const initMap async (config) > {return new Promise((resolve, reject) > {AMapLoader.load({key: "0650fbe85c708dc3388fe803d0e5d861",// key: config.key,v…

考虑极端天气线路脆弱性的配电网分布式电源配置优化模型_IEEE33节点(附带Matlab代码)

随着新能源技术及智能电网的发展&#xff0c;越来越多的分布式电源加入配电网中&#xff0c;不仅改变了配电网结构及供电方式&#xff0c;而且提升了配电网的供电质量。但是在全球气候变暖的背景下&#xff0c;极端天气发生的频率也越来越高&#xff0c;一旦发生必将对配电网系…

系统清理软件CCleaner pro mac功能亮点

CCleaner pro for mac是一款mac系统清理软件。CCleaner pro 主要用来清除mac系统不再使用的垃圾文件&#xff0c;以腾出更多硬盘空间。CCleaner pro下载的另一大功能是清除使用者的上网记录。CCleaner的体积小&#xff0c;运行速度极快&#xff0c;可以对临时文件夹、历史记录、…

Spring Cloud Gateway与spring-cloud-circuitbreaker集成与理解

官方文档地址 本文以 spring-cloud2021版本为例子 spring-cloud-gateway文档地址&#xff1a; https://spring.io/projects/spring-cloud-gateway#overview spring-cloud-circuitbreaker文档地址&#xff1a; https://spring.io/projects/spring-cloud-circuitbreaker 两者…

Gradio库的安装和使用教程

目录 一、Gradio库的安装 二、Gradio的使用 1、导入Gradio库 2、创建Gradio接口 3、添加接口到Gradio应用 4、处理用户输入和模型输出 5、关闭Gradio应用界面 三、Gradio的高级用法 1、多语言支持 2、自定义输入和输出格式 3、模型版本控制 4、集成第三方库和API …