内容:
重点介绍MQTT 中的发布、订阅和取消订阅的细节
正文
发布(Publish)
- MQTT 客户端可以在连接到代理后立即发布消息。MQTT 在代理上使用基于主题的消息过滤。每条消息都必须包含一个主题,代理可以使用该主题将消息转发给感兴趣的客户端。通常,每条消息都有一个负载,其中包含要以字节格式传输的数据。MQTT 与数据无关。客户端的用例决定了有效负载的结构。发送客户端(发布者)决定是否要发送二进制数据、文本数据,甚至完整的 XML 或 JSON。
topicName
主题名称是一个简单的字符串,它以正斜杠作为分隔符进行分层结构。例如,“我的家/客厅/温度”Qos
此数字表示消息的服务质量 (QoS)。有三个级别:0、1 和 2。服务级别决定了消息到达预期接收者(客户端或代理)的保证类型。RatainFlag(保留标志)
此标志定义消息是否由代理保存为指定主题的最后一个已知良好值。当新客户端订阅主题时,他们会收到保留在该主题上的最后一条消息。PayLoad
这是消息的实际内容。MQTT 与数据无关。可以发送图像、任何编码的文本、加密数据以及几乎所有二进制数据。packetId(数据包标识符)
数据包标识符标识唯一消息,因为它在客户端和代理之间流动。数据包标识符仅与大于零的 QoS 级别相关。客户端库和/或代理负责设置此内部 MQTT 标识符。-
DupFlag
该标志表明该消息是重复的并且由于预期的接收者(客户端或代理)没有确认原始消息而被重新发送。这仅与 QoS 大于 0 相关。通常,重新发送/复制机制由 MQTT 客户端库或代理作为实现细节处理。当客户端向MQTT 代理发送消息进行发布时,代理读取消息、确认消息(根据 QoS 级别)并处理消息。代理的处理包括确定哪些客户端订阅了主题并将消息发送给他们。
最初发布消息的客户端只关心将 PUBLISH 消息传递给代理。一旦代理收到 PUBLISH 消息,代理就有责任将消息传递给所有订阅者。发布客户端不会得到关于是否有人对发布的消息感兴趣或有多少客户端从代理收到消息的任何反馈。
订阅(Subscribe)
- 如果没有人收到消息,发布消息就没有意义。换句话说,如果没有客户端订阅消息的主题。这个订阅消息非常简单,它包含一个唯一的数据包标识符和一个订阅列表。
数据包标识符
数据包标识符唯一标识消息,因为它在客户端和代理之间流动。客户端库和/或代理负责设置此内部 MQTT 标识符。订阅列表
一个 SUBSCRIBE 消息可以包含一个客户端的多个订阅。每个订阅由一个主题和一个 QoS 级别组成。订阅消息中的主题可以包含通配符,使订阅主题模式而不是特定主题成为可能。如果一个客户端存在重叠订阅,则代理会传送该主题具有最高 QoS 级别的消息。
Suback(确认消息)
-
为了确认每个订阅,代理向客户端发送一个SUBACK确认消息。该消息包含原始 Subscribe 消息的数据包标识符(以明确标识该消息)和返回码列表。
包标识符
包标识符是用于标识消息的唯一标识符。它与 SUBSCRIBE 消息中的相同。-
返回代码
代理为它在 SUBSCRIBE 消息中收到的每个主题/QoS 对发送一个返回代码。
例如,如果 SUBSCRIBE 消息有五个订阅,则 SUBACK 消息包含五个返回码。返回码确认每个主题并显示代理授予的 QoS 级别。如果代理拒绝订阅,则 SUBACK 消息包含该特定主题的失败返回代码。例如,如果客户端没有足够的权限订阅主题或主题格式错误。
客户端成功发送 SUBSCRIBE 消息并收到 SUBACK 消息后,它会获取与 SUBSCRIBE 消息包含的订阅中的主题匹配的每条已发布消息。
UNSUBACK
- 为了确认取消订阅,代理向客户端发送一个UNSUBACK确认消息。此消息仅包含原始 UNSUBSCRIBE 消息的数据包标识符(以明确标识该消息)。
-
包标识符
包标识符唯一地标识消息。如前所述,这与 UNSUBSCRIBE 消息中的数据包标识符相同。
客户端收到来自broker的UNSUBACK后,可以认为UNSUBSCRIBE消息中的订阅被删除了。