您现在的位置是:首页 > 文章详情

MQTT协议的初浅认识之推送订阅

日期:2018-09-21点击:698

背景

了解MQTT怎么建立连接之后,现在重点来了解MQTT怎么推送,订阅两个方面。

概念

先见一张图:

pub-sub-mqttt

这张图是依旧借鉴HiveMQ的图,来讲述MQTT协议的推送和订阅的过程。推送和订阅,我们很容易理解。这里里面的推送客户端和订阅客户端,在上篇文章MQTT协议的初浅认识之连接建立中也都提到过,都是属于MQTT的客户端。这里面有一个比较陌生的概念是Topic,即话题这个概念。

话题

这个东西在MQTT里面很灵活,客户端订阅的对象其实也就是话题。话题主要有话题主题+正斜杠组成。如下:

topic_basics

话题其实就是由话题主题+正斜杆,组成的一个字符串,客户端订阅了这个话题字符串之后,就可以接收这个MQTT推送过来关于这个话题的消息。中间件也是根据话题,来分发从推送客户端推送到中间件的消息。

话题通配符

单级:+

表示不接收间隔多个话题级别,如下图:

topic_wildcard_plus

匹配的消息结果,如下:

topic_wildcard_plus_example

多级:#

表示接收多级间隔话题,如下:

topic_wildcard_hash

匹配消息,如下:

topic_wildcard_hash_example

开头:$

表示以什么开头的消息,这个不常用。

推送消息

publish_packet

MQTT客户端可以在连接到中间件后立即发布消息。MQTT中间件利用基于话题的消息进行过滤。每条消息必须包含一个话题,中间件可以使用该话题将消息转发给感兴趣的客户端。通常,每条消息都有包含一个的MQTT载荷与数据有关。客户端决定了有效负载的结构。发送客户端(发布者)决定是否要发送二进制数据,文本数据,甚至是完整的数据。XML或JSON。

参考说明:

  • packetId:消息id
  • topicName:话题标识
  • qos:通讯质量级别,分为三个级别,对应着三种不同的通讯方式,这个很重要的。
  • retainFlag:此标志定义中间件是否将消息保存为指定话题的最后一个默认消息值。当新客户端订阅某个话题时,他们会收到该主题上保留的最后一条消息。
  • payload:载荷,业务内容就在这里。
  • dupFlag:是否已经重复发送消息标识。

当客户端向MQTT中间件发送消息以进行发布时,中间件会读取该消息,确认消息(根据QoS级别)并处理该消息。中间件处理消息包括确定哪些客户已订阅该话题并将消息发送给他们。

publish_flow

最初发布消息的客户端只关心向中间件发送PUBLISH消息。一旦中间件收到PUBLISH消息,中间件就有责任将消息传递给所有订阅客户端。发布客户端不会获得有关是否有人对发布的消息感兴趣或有多少订阅客户端从中间件接收消息的任何反馈。

订阅消息

subscribe_packet

客户端订阅消息,相对于推送消息结构要简单的多,主要包括两个部分:

  • packetId:消息id;
  • qos+topic:通讯质量级别和话题数组

中间件收到客户端端的订阅SUBSCRIBE消息后,中间件会回答SUBACK消息。

SUBACK消息

suback_packet

参数说明:

  • packetId:消息id
  • returnCode:返回代码

返回代码说明:

Return Code Return Code Response
0 Success – Maximum QoS 0
1 Success – Maximum QoS 1
2 Success – Maximum QoS 2
128 Failure

整个订阅过程,如图:

subscribe_flow

参考

MQTT Essentials Part 5: MQTT Topics & Best Practices

MQTT Essentials Part 4: MQTT Publish, Subscribe & Unsubscribe

原文链接:https://my.oschina.net/fxtxz2/blog/2120236
关注公众号

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。

持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。

文章评论

共有0条评论来说两句吧...

文章二维码

扫描即可查看该文章

点击排行

推荐阅读

最新文章