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)

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

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

相关文章

OpenStack-train版安装之安装Swift(对象存储服务)、安装Cinder(块存储服务)

安装Swift(对象存储服务)、安装Cinder(块存储服务) 安装Swift(对象存储服务)控制节点安装和配置对象存储节点安装和配置Create and distribute initial rings配置与启动验证 安装Cinder(块存储服…

云仓酒庄的品牌雷盛红酒分享红酒里加二氧化硫有害吗?

雷盛葡萄酒是广州万豪酒业有限公司旗下主力葡萄酒品牌,该品牌由云仓酒庄负责全国运营。雷盛(LEESON)品牌系列葡萄酒有幸邀请著名导演张纪中先生担任品牌代言人。采用多国家采购、多葡萄酒品种、多价位区间的全系列整体品牌形式,让…

Nginx配合Vue的history模式

加上一行代码就行: try_files $uri $uri/ /index.html;

Java医院3D人体智能导诊系统源码 Uniapp+springboot 微信小程序

“智能导诊”以人工智能手段为依托,为人们提供智能分诊、问病信息等服务,在一定程度上满足了人们自我健康管理、精准挂号等需求。智能导诊可根据描述的部位和病症,给出适合病症的科室参考。 智能导诊页面会显示男性或女性的身体结构图&#x…

深度学习 Day14——P3天气识别

🍨 本文为🔗365天深度学习训练营 中的学习记录博客🍖 原作者:K同学啊 | 接辅导、项目定制 文章目录 前言1 我的环境2 代码实现与执行结果2.1 前期准备2.1.1 引入库2.1.2 设置GPU(如果设备上支持GPU就使用GPU,否则使用C…

Gerrit 提交报错missing Change-Id in message footer

直接执行提示的命令: gitdir$(git rev-parse --git-dir); scp -p -P 29418 liyjgerrit.ingageapp.com:hooks/commit-msg ${gitdir}/hooks/ 如果报错: subsystem request failed on channel 0 在.git/hooks目录下看有没有生成commit-msg文件&#xff…

(四)STM32 操作 GPIO 点亮 LED灯 / GPIO工作模式

目录 1. STM32 工程模板中的工程目录介绍 2. GPIO 简介 3. GPIO 框图剖析 1)保护二极管及上、下拉电阻 2) P-MOS 管和 N-MOS 管 3)输出数据寄存器 3.1)ODR 端口输出数据寄存器 3.2)BSRR 端口位设置/清除寄存器 4&a…

一点技术细节

匈牙利算法: 14-4: 匈牙利算法 Hungarian Algorithm_哔哩哔哩_bilibili 课件:https://github.com/wangshusen/AdvancedAlgorithms.git SWin transformer: Swin Transformer论文精读【论文精读】_哔哩哔哩_bilibili patch:灰色 窗口&…

八、Seata的XA模式

目录 八、Seata的XA模式8.3 XA模式多数据源场景1 环境搭建2、使⽤XA模式解决事务 八、Seata的XA模式 8.3 XA模式多数据源场景 1 环境搭建 建库建表 代码的db.sql中 创建工程 添加依赖 <dependency><groupId>org.springframework.boot</groupId><ar…

ssl证书问题导致本地启动前端服务报500

报错如下&#xff1a;注意查看报错信息 问题&#xff1a;系统原是http&#xff0c;后台调整为https后&#xff0c;ssl证书有点问题&#xff0c; vue项目本地服务&#xff0c;使用代理&#xff0c;webpack默认&#xff0c;证书强校验&#xff0c;导致请求无法发出&#xff0c;后…

COSCon 的台前幕后:KCC@上海 12.2 活动总结

沐浴着冬日暖阳&#xff0c;KCC上海的第三次活动如期而至。第八届中国开源年会&#xff08;COSCon23&#xff09;的顺利举办离不开许多优秀志愿者们的辛勤付出&#xff0c;本次活动作为 COSCon23 的 After Party&#xff0c;我们有幸邀请到了其中的部分台前幕后人员&#xff0c…

c语言单向链表

看如下代码&#xff0c;这是一个完整的可运行的c源文件&#xff0c;要注意的点&#xff1a; c语言程序运行不一定需要头文件NULL其实是 (void*)0&#xff0c;把指针赋值成(void*)0,就是防止程序员不想该指针被引用的时候被引用&#xff0c;引用地址为0的值程序会引起系统中断&…

【Vitamin ; amino acid 】

【NAD NADPH&#xff1b; FMN FAD &#xff1b; NMN -化学】

数字化转型对企业有什么好处?

引言 数字化转型已经成为当今商业领域中的一股强大力量&#xff0c;它不仅仅是简单的技术更新&#xff0c;更是企业发展的重要战略转变。随着科技的迅猛发展和全球化竞争的加剧&#xff0c;企业们正在积极探索如何将数字化的力量融入到他们的运营和战略中。 数字化转型不仅是传…

基于ssm游戏美术外包管理信息系统源码和论文

摘 要 随着信息技术和网络技术的飞速发展&#xff0c;人类已进入全新信息化时代&#xff0c;线下管理技术已无法高效&#xff0c;便捷地管理信息。为了迎合时代需求&#xff0c;优化管理效率&#xff0c;各种各样的管理系统应运而生&#xff0c;各行各业相继进入信息管理时代&…

spring面试:二、bean的生命周期和循环引入问题(三级缓存、@Lazy)

bean的生命周期 Spring容器在进行实例化时&#xff0c;会将xml配置的的信息封装成一个BeanDefinition对象&#xff0c;Spring根据BeanDefinition来创建Bean对象&#xff0c;里面有很多的属性用来描述Bean。 其中比较重要的是&#xff1a; beanClassName&#xff1a;bean 的类…

救命~这件国风旗袍女儿穿也太好看了吧

这款中式提花改良版旗袍 一眼就戳中了我的心巴 整件精美刺绣好看不大众 两侧网纱的加持增添仙气缥缈感 穿上厚实不显臃肿 袖口处拼接毛毛徒增可爱俏皮的感觉 穿上过年过节满满的焦点呀~

Logstash访问安全访问Elasticsearch集群

生成logstash证书: opensal pkcs12 -in elastic-stack-ca.p12 -clcerts -nokeys > logafash.cer openssl x509 -in logstash.cer -out logstash.pem 编排配置文件

Elasticsearch:使用 OpenAI 生成嵌入并进行向量搜索 - nodejs

在我之前的文章&#xff1a; Elasticsearch&#xff1a;使用 Open AI 和 Langchain 的 RAG - Retrieval Augmented Generation &#xff08;一&#xff09;&#xff08;二&#xff09;&#xff08;三&#xff09;&#xff08;四&#xff09;​​​​​ 我详细地描述了如何使用…

【C++11特性篇】盘点C++11中三种简化声明的方式【auto】【decltype】【nullptr】(3)

前言 大家好吖&#xff0c;欢迎来到 YY 滴C系列 &#xff0c;热烈欢迎&#xff01; 本章主要内容面向接触过C的老铁 主要内容含&#xff1a; 欢迎订阅 YY滴C专栏&#xff01;更多干货持续更新&#xff01;以下是传送门&#xff01; 目录 一.auto&#xff06;范围for二.decltyp…