MQTT中的保留消息(Retained Message)

一条保留消息是MQTT中保留标志设置为true的一条普通消息。代理(broker)为对应的主题保留最后的保留消息及对应的QoS。每一个订阅了该主题的客户端在订阅之后会马上收到这个保留消息。代理(broker)为每个主题只存储一条保留消息。本文主要讨论为什么是保留消息,为什么我们要使用它,如何使用它,何时使用它。
无标题.png

保留消息和普通MQTT消息的区别

保留消息是MQTT中的一项重要功能,可减轻消息发布的不确定性。通过启用有关主题的最新消息的保留,订阅者可以随时了解当前状态,即使在不活动期间也是如此。

在MQTT中,理解一点非常重要,即一条消息的发布者不能保证订阅的客户端可以收到这条消息。发送者有责任确保安全的将消息发送到代理。同样的,订阅的客户端不能确定何时发布方会发布消息到它们订阅的相关的主题。发送消息的时间间隔能够有很大区别,从几秒钟到几分钟,甚至几小时。因此,订阅客户端并不关心当前主题的状态,直到有一条新的发布消息。这里保留消息将扮演重要的角色。
保留消息对于上面提到的情况,提供了解决方案。当客户端发布一条保留标志为true的消息时,代理(broker)会保留这条消息。因此任何订阅对应主题的客户端将会收到最新的保留消息,即使最近没有消息发布。
从本质上讲,保留的消息为订阅者提供了主题最后已知状态的快照,无论发布频率如何,都能确保访问最新的相关信息。

保留消息的结构

一条保留消息是一条标准的、保留标志设置为true的消息,标记它的重要性。当一个客户端发布一条保留消息,代理(broker)连同该主题的QoS都存储起来。订阅的客户端会马上收到保留消息,当它们订阅保留消息的主题时。
值得注意的是,代理(broker)为每个主题只保留一条消息。
即使订阅客户端在主题中使用了通配符,他们仍然可以收到可能与主题不完全匹配的保留消息。
比如,如果客户端A发布了一条保留消息到myhome/livingroom/temperature,然后客户端B订阅了主题myhome/#,客户端B会马上收到主题myhome/livingroom/temperature的保留消息,通过读取保留标志为true,订阅客户端可以根据自己的需求处理保留消息。
保留消息对于为新订阅的客户端提供订阅主题后的即时状态更新至关重要,无需等待发布客户端的后续更新。实质上,一条保留消息代表一个特定主题最后一个已知有效值。它不一定是最新值,但必须是保留标志设置为true的最新消息。
其他一些重要的东西要强调,保留消息的操作独立于持久会话(http://t.csdnimg.cn/8H38Z),代理(broker)一旦存储保留消息,只有一种办法删除,后面会讨论。

如何发送保留消息

作为一个开发人员,发送保留消息是一个简单要过程。为了标记一条消息保留,所要做的就是在发送消息时将保留标志设置了true。这个标志告知代理(broker)保留这条消息,使之对订阅者可用。好消息是,大部分MQTT客户端库提供了方便、用户友好的方式来启用这个标志,简化了流程。通过使用这个功能,开发人员可以保证持久化重要信息,对订阅者可用,即使客户端之后才加入进来或经历短暂的连接问题。保留消息提供了一种强力的机制来分享重要数据,确保在以MQTT为基础的系统中无缝通信。

如何删除保留消息

只有一个方法删除一个主题的保留消息。为此,只需将具有零字节有效负载的保留消息发布到存储保留消息的主题即可。当代理(broker)收到这个特殊的保留消息,它识别为消息的请求,然后删除对应主题的保留消息。因此,新的订阅者将不会收到这个主题之前的保留消息。
在很多案例中没有必要,明确的删除保留消息也许没有必要。这是因为对于同一主题,新的保留消息会自动覆盖前一个保留消息。因此,如果你发送一条新的保留消息到一个主题,它将替换并取代任何现有的保留消息,有效的达到和删除之前消息同样的效果。这个举动保证订阅者收到最新的相关信息,在很多场景中消除了手动删除的必要。

何时使用保留消息

保留消息在各种方案中都提供了保留的好处,特别是当你需要新连接的订阅者及时接收消息而无需等待下一次消息发布时。
这对于提供特定主题的组件或设备的实时状态更新特别有利。例如,让我们考虑一个名为device1的设备示例,其状态发布在主题myhome/devies/device1/status上。通过利用保留消息,此主题的新订阅者在订阅后立即收到设备的状态。
同样,这适用于定期传输数据的客户端,例如温度读取、GSP坐标和其他相关信息。如果没有保留消息,新订阅的客户端将不知道消息间隔之间的最新更新。通过利用保留消息,可以无缝地为连接的客户端提供最新和准确的值,确保它们能够立即访问关键信息。

结论

如上所述,保留消息(Retained Message)在MQTT通信中发挥着至关重要的作用,它解决了不确定消息传递的挑战,并提供了对主题最后已知状态的即时访问。通过启用保留有关主题的最新消息,订阅者可以随时了解当前状态,即使在不活动期间也是如此。
保留消息(Retained Message)有利于提供状态更新,确保新订阅客户端收到相关信息,而无需等待后续消息发布。通过利用保留消息,MQTT使客户端和代理(broker)之间能够高效可靠地进行通信,从而提高IoT和消息传递应用程序的整体效率。
后续的文章中,将讨论遗嘱(Last Will and Testament)

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

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

相关文章

Docker本地镜像发布到阿里云或私有库

本地镜像发布到阿里云流程 : 1.自己生成个要传的镜像 2.将本地镜像推送到阿里云: 阿里云开发者平台:开放云原生应用-云原生(Cloud Native)-云原生介绍 - 阿里云 2.1.创建仓库镜像: 2.1.1 选择控制台,进入容器镜像服…

MQTT的奇妙之旅:探索RabbitMQ Web MQTT插件的威力【RabbitMQ 十一】

欢迎来到我的博客,代码的世界里,每一行都是一个故事 MQTT的奇妙之旅:探索RabbitMQ Web MQTT插件的威力 前言第一:揭秘RabbitMQ Web MQTT插件背景和目的:MQTT 协议简介:WebSockets 和 MQTT 的融合&#xff1…

谣言检测常用数据集汇总

Pheme-R 获取地址:https://figshare.com/articles/dataset/PHEME_rumour_scheme_dataset_journalism_use_case/2068650 PHEME社交媒体谣言数据集:这些谣言与9条不同的突发新闻有关。它是为分析社交媒体谣言而创建的,并包含由谣言推文发起的推特对话;这些…

竞赛保研 python区块链实现 - proof of work工作量证明共识算法

文章目录 0 前言1 区块链基础1.1 比特币内部结构1.2 实现的区块链数据结构1.3 注意点1.4 区块链的核心-工作量证明算法1.4.1 拜占庭将军问题1.4.2 解决办法1.4.3 代码实现 2 快速实现一个区块链2.1 什么是区块链2.2 一个完整的快包含什么2.3 什么是挖矿2.4 工作量证明算法&…

flink安装

什么是flink flink是一个分布式,高性能,随时可用的以及准确的流处理计算框架, flink可以对无界数据(流处理)和有界数据(批处理)进行有状态计算(flink天生支持状态计算)…

开源 CAD 计算机辅助设计软件,基于 Node.js 开发,使用浏览器进行访问-供大家学习研究参考

下载:开源CAD计算机辅助设计软件,基于Node.js开发,使用浏览器进行访问-供大家学习研究参考资源-CSDN文库 https://download.csdn.net/download/weixin_43097956/88623022

Web开发:ibatis的使用笔记

一、简介 ibatis是一个基于SQL映射支持Java和.NET的持久层框架&#xff1a; 1.如下所示id是对应程序的statement&#xff0c;resultClass需要填写SQL查询到的字段对应的类的命名空间类名&#xff08;DAO.QueryForList<实体类>&#xff09;&#xff0c;以此完成持久层和…

Redis新数据类型-Bitmaps

目录 Bitmaps 简介 命令 1. setbit (1) 格式 (2) 实例 2. getbit (1) 格式 (2) 实例 3. bitcount (1) 格式 (2) 实例 4. bitop (1) 格式 (2) 实例 我的其他博客 Bitmaps 简介 Bitmaps 是 Redis 的一种新数据类型&#xff0c;它是一种用于存储位信息的数据结构&…

【FPGA】Verilog:解码器 | 实现 2-4 解码器

实践内容&#xff1a;解释 2 至 4 解码器的结果和仿真过程 (包括真值表创建和 k 映射、AND 门&#xff09;。 0x00 解码器&#xff08;Decoder&#xff09; 解码器是一种根据输入信号从多个输出 bit 中只选择一个的设备。 例如&#xff0c;如果有一个解码器接收一个 2 位二进…

基于spacy的句法依存、实体识别、分析

文章目录 简介spaCy特性&#xff1a; 系统环境与版本安装应用示例参考文献 简介 spaCy spaCy 是一个 Python 和 CPython 的 NLP 自然语言文本处理库。因此它是一个非常快的库。它建立在最新的研究基础上&#xff0c;从设计的第一天起就被用于实际产品中。 spaCy 自带预训练的…

好用的硬盘分区工具,傲梅分区助手 V10.2

傲梅分区助手软件可以帮助用户在硬盘上创建、调整、合并、删除分区&#xff0c;以及管理磁盘空间等操作。它可以帮助你进行硬盘无损分区操作。 支持系统 目前这款软件支持 Windows 7、Windows 8、Windows 10、Windows 11 等个人系统&#xff0c;还支持 Windows 2012/2016/2019…

五金品牌网站建设的效果如何

五金产品多而广&#xff0c;无论零售还是批发&#xff0c;都有很高需求&#xff0c;市场中也林立着众多大小品牌&#xff0c;在实际经营中&#xff0c;五金也分为多个类目&#xff0c;同时高需求下相关企业也面临着一些痛点&#xff1a; 1、品牌传播难 对普通消费者来说&…

android下的app性能测试应主要针对那些方面,如何开展?

如何开展安卓手机下的App性能测试&#xff0c;对于优秀的测试人员而言&#xff0c;除了要懂得性能测试的步骤流程外&#xff0c;还应该懂的性能测试的一些其他知识&#xff0c;比如性能测试指标、各指标的意义&#xff0c;常用的性能测试工具、如何查看结果分析等等知识。所以本…

linux空洞文件以及多线程写入

介绍空洞文件 Linux空洞文件&#xff08;hole file&#xff09;是一种特殊类型的文件&#xff0c;其大小可能超过实际存储的数据量。在空洞文件中&#xff0c;文件系统会为文件分配磁盘空间&#xff0c;但实际上只在文件中存储了部分数据&#xff0c;其余部分被称为"空洞…

linux应用程序直接return与exit的区别

在Linux应用程序中&#xff0c;可以使用return语句直接从main函数返回。这将导致程序终止并返回给操作系统。然而&#xff0c;有时候使用exit函数比直接使用return语句更有优势&#xff0c;以下是一些原因&#xff1a; 清理资源&#xff1a;exit函数可以确保在程序终止之前执行…

C/C++常见面试知识总结(三)

C语言是一种通用计算机&#xff08;高级&#xff09;编程语言&#xff1b;面向过程&#xff1b;广泛应用于计算机系统设计以及应用程序编写&#xff1b;设计目标&#xff0c;是提供一种能以简易的方式编译、处理低级存储器、产生少量的机器码以及不需要任何运行环境支持便能运行…

01_Web开发基础之HTML+CSS

Web开发基础之HTMLCSS 学习目标和内容 1、能够描述Web开发需要的技术点 2、能够描述HTML的作用 3、能够实现一个列表 4、能够实现创建一个表格 5、能够实现一个表单 6、能够描述CSS的作用 7、能够使用选择器获取到标签 8、能够使用CSS设置字体的颜色和大小 一、Web开发相关介绍…

Python+Selenium UI自动化测试环境搭建及使用

一、什么是Selenium &#xff1f; Selenium 是一个浏览器自动化测试框架&#xff0c;它主要用于web应用程序的自动化测试&#xff0c;其主要特点如下&#xff1a;开源、免费&#xff1b;多平台、浏览器、多语言支持&#xff1b;对web页面有良好的支持&#xff1b;API简单灵活易…

window同时安装java8和java11

背景 在日常工作中&#xff0c;使用的工具&#xff0c;有一些java写的比较老的工具&#xff0c;环境要求是1.8,有一些java写的工具&#xff0c;环境要求是java11以上。 痛点 使用java写的工具要求是1.8的java&#xff0c;但是window电脑上只安装了java11。就会报下面的错误 …

pytorch中数据预处理模块:transforms详解

1 tranforms概述 1.1 torchvision介绍 torchvision是pytorch的计算机视觉工具包&#xff0c;主要有以下三个模块&#xff1a; torchvision.transforms&#xff1a;提供了常用的一系列图像预处理方法&#xff0c;例如数据的标准化&#xff0c;中心化&#xff0c;旋转&#xff…