参考文章为:http://www.tuicool.com/articles/bmQn6bv http://www.jianshu.com/p/b28946d58043 http://www.jianshu.com/p/bcf0251dc181
MQTT协议中文版连接地址: https://www.gitbook.com/book/mcxiaoke/mqtt-cn/details
MQTT服务器搭建参考:http://emqtt.com/docs/v2/install.html
MQTT简介:
MQTT协议是基于订阅者模型架构的,客户端若相互通信必须在同一订阅主题下,都订阅了同一个topic,客户端之间无法直接通讯,一对多消息发布。该协议拆分为:固定头部+可变头部+消息体。
MQTT特点:1》发布/订阅消息模式;2》对负载内容屏蔽的消息传输;3》使用TCP/IP提供网络连接-主流MQTT基于TCP连接进行数据推送,也有基于UDP的版本 MQTT-SN;4》3中消息传输方式QoS-0:至多一次 1:至少一次 2:只有一次
MQTT控制报文格式:
1:固定报头:共2个字节。其格式如下:
其标志位0-3: 0:表示retain 若retain为true则表示将会话信息存在服务器。1,2:表示服务质量 00:0 “至多一次”,其消息发布完全依赖底层TCP/IP网络,容易发生消息丢失,(接收者不会发送响应,发送者也不会重试);01:1 “至少一次”,确保消息到达,但消息会发生重复 10:2 “只有一次”,确保消息会到达一次。3:发布报文中的保留标识
MQTT控制报文类型4-7(共16位,第0位和15位为保留位),这14种类型协议中文版中有详细解析。如下
具体说说CONNECT报文
CONNECT报文是客户端到服务端的网络连接建立后,客户端发送给服务端的第一个报文。其固定头部跟MQTT固定头部类似。说一说可变头部。
CONNECT报文的可变报头按下列次序包含四个字段:协议名(Protocol Name),协议级别(Protocol Level),连接标志(Connect Flags)和保持连接(Keep Alive)。其中连接标志位如下:
主要说一下cleanSession:清理会话。当cleanSession为true时客户端和服务端必须丢弃之前的任何会话并开始一个新的会话。当为false时服务端必须基于当前会话(使用客户端标识符识别)的状态恢复与客户端的通信。如果没有与这个客户端标识符关联的会话,服务端必须创建一个新的会话。
通配符:订阅的主题过滤器可以包含特殊的通配符,允许你一次订阅多个主题。主题层级分隔符(‘/’)如存在则将层级分为了多个主题。多层通配符(‘#’)[应该是包含这个层级及该层级下的所有层级的主题];单层通配符(‘+’)[该层级下的所有主题];以$开头的主题,服务端不能将 $ 字符开头的主题名匹配通配符 (#或+) 开头的主题过滤器
主题名和主题过滤器必须符合下列规则:1》所有的主题名和主题过滤器必须至少包含一个字符。2》主题名和主题过滤器是区分大小写的。3》主题名和主题过滤器可以包含空格。4》主题名或主题过滤器以前置或后置斜杠 “/” 区分。5》只包含斜杠 “/” 的主题名或主题过滤器是合法的。6》主题名和主题过滤器不能包含空字符 (Unicode U+0000) [Unicode] 。7》主题名和主题过滤器是UTF-8编码字符串,它们不能超过65535字节 [MQTT-4.7.3-3]。
除了不能超过UTF-编码字符串的长度限制之外,主题名或主题过滤器的层级数量没有其它限制。
基于MQTTClient的实战:
其Demo地址为:https://github.com/liuqianios/MQTTDemo-MQTTClient
Tips:1》MQTTSession初始化:
其中keepAlive:心跳时间,单位秒,每隔固定时间发送心跳包
cleanSeesion:最好设置为false,如果设置为true不能收到离线之后的数据,而且还需要重新订阅。
2》断开重连:MQTTSession的代理方法