MQTT中的保留消息(Retained Message)

2023-12-17 00:12

本文主要是介绍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)

这篇关于MQTT中的保留消息(Retained Message)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/502410

相关文章

聊聊springboot中如何自定义消息转换器

《聊聊springboot中如何自定义消息转换器》SpringBoot通过HttpMessageConverter处理HTTP数据转换,支持多种媒体类型,接下来通过本文给大家介绍springboot中... 目录核心接口springboot默认提供的转换器如何自定义消息转换器Spring Boot 中的消息

springboot整合mqtt的步骤示例详解

《springboot整合mqtt的步骤示例详解》MQTT(MessageQueuingTelemetryTransport)是一种轻量级的消息传输协议,适用于物联网设备之间的通信,本文介绍Sprin... 目录1、引入依赖包2、yml配置3、创建配置4、自定义注解6、使用示例使用场景:mqtt可用于消息发

Java对接MQTT协议的完整实现示例代码

《Java对接MQTT协议的完整实现示例代码》MQTT是一个基于客户端-服务器的消息发布/订阅传输协议,MQTT协议是轻量、简单、开放和易于实现的,这些特点使它适用范围非常广泛,:本文主要介绍Ja... 目录前言前置依赖1. MQTT配置类代码解析1.1 MQTT客户端工厂1.2 MQTT消息订阅适配器1.

Python实现MQTT通信的示例代码

《Python实现MQTT通信的示例代码》本文主要介绍了Python实现MQTT通信的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一... 目录1. 安装paho-mqtt库‌2. 搭建MQTT代理服务器(Broker)‌‌3. pytho

RabbitMQ消息总线方式刷新配置服务全过程

《RabbitMQ消息总线方式刷新配置服务全过程》SpringCloudBus通过消息总线与MQ实现微服务配置统一刷新,结合GitWebhooks自动触发更新,避免手动重启,提升效率与可靠性,适用于配... 目录前言介绍环境准备代码示例测试验证总结前言介绍在微服务架构中,为了更方便的向微服务实例广播消息,

Java MQTT实战应用

《JavaMQTT实战应用》本文详解MQTT协议,涵盖其发布/订阅机制、低功耗高效特性、三种服务质量等级(QoS0/1/2),以及客户端、代理、主题的核心概念,最后提供Linux部署教程、Sprin... 目录一、MQTT协议二、MQTT优点三、三种服务质量等级四、客户端、代理、主题1. 客户端(Clien

java向微信服务号发送消息的完整步骤实例

《java向微信服务号发送消息的完整步骤实例》:本文主要介绍java向微信服务号发送消息的相关资料,包括申请测试号获取appID/appsecret、关注公众号获取openID、配置消息模板及代码... 目录步骤1. 申请测试系统2. 公众号账号信息3. 关注测试号二维码4. 消息模板接口5. Java测试

如何在Spring Boot项目中集成MQTT协议

《如何在SpringBoot项目中集成MQTT协议》本文介绍在SpringBoot中集成MQTT的步骤,包括安装Broker、添加EclipsePaho依赖、配置连接参数、实现消息发布订阅、测试接口... 目录1. 准备工作2. 引入依赖3. 配置MQTT连接4. 创建MQTT配置类5. 实现消息发布与订阅

C++ RabbitMq消息队列组件详解

《C++RabbitMq消息队列组件详解》:本文主要介绍C++RabbitMq消息队列组件的相关知识,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录1. RabbitMq介绍2. 安装RabbitMQ3. 安装 RabbitMQ 的 C++客户端库4. A

MQTT SpringBoot整合实战教程

《MQTTSpringBoot整合实战教程》:本文主要介绍MQTTSpringBoot整合实战教程,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考... 目录MQTT-SpringBoot创建简单 SpringBoot 项目导入必须依赖增加MQTT相关配置编写