Eclipse Mosquitto是一个开源消息代理,实现了MQTT协议版本3.1和3.1.1,这里使用该服务器进行测试。针对该服务器更详细的介绍也可以参考 https://www.jianshu.com/p/b6a75bfbe82f 。
MQTT有个重要的参数QOS,因下面使用较多,这里列出便于后续查看:
AT+ECMTOPEN=<tcpconnectID>,“<host_name>”,<port>
<tcpconnectID>整型。 MQTT Socket 标识符。范围: 0~4
<host_name> IP 地址或域名
<port>整型。服务器端口
示例:AT+ECMTOPEN=0, "test.mosquitto.org",1883 //建立 tcp
返回值:+ECMTOPEN:<tcpconnectID>,<result>
<tcpconnectID>Integer type,MQTT socket identifier. The value is 0
<result>1 Failed to open network,0 Opened network successfully
AT+ECMTCONN=<tcpconnectID>,“<clientID>”[,“<username>”[,“<password>”]]
<tcpconnectID> MQTT socket identifier. The value is 0
“<clientID>” 用户不指定标准服务器会自行创建
“<username>”,“<password>” 标准MQTT服务器不使用
示例:AT+ECMTCONN=0 //在 mosquitto 平台上注册设备
返回值:+ECMTCONN:<tcpconnectID>,<result>[,<ret_code>]
AT+ECMTSUB=<tcpconnectID>,<msgID>,“<topic>”,<qos>
<tcpconnectID> MQTT socket identifier. The value is 0
<msgID>任意填写,Message identifier of packet. The range is 1-65535
<topic>String type,Topic that the client wants to subscribe to or unsubscribe from.
<qos> Message QoS, can be 0,1 or 2
示例:AT+ECMTSUB=0,1,”test”,2 //订阅 topic
返回值:+ECMTSUB:<tcpconnectID>,<msgID>,<result>[,<value>]
额外指令:AT+ECMTUNS=0,4, “test” //取消订阅 topic
AT+ECMTPUB=<tcpconnectID>,<msgID>,<qos>,<retain>,“<topic>”,“<payload>"
<tcpconnectID> MQTT socket identifier. The value is 0
<msgID> Message identifier of packet.
<qos> Message QoS, can be 0,1 or 2
<retain> 0 Server should not retain the message 1 Server should retain the message
<topic>String type
<payload>String type
示例:AT+ECMTPUB=0,0,0,0,"test","hello" //发送数据给 mosquitto 平台
+ECMTPUB:<tcpconnectID>,<msgID>,<result>[,<value>]
额外指令:AT+ECMTDISC=0 //删除 mqtt client 和 mqtt 连接
MQTT ( 消息队列遥测传输 )是ISO 标准(ISO/IEC PRF 20922)下基于发布/订阅范式的消息协议。它工作在 TCP/IP协议族 上,是为硬件性能低下的远程设备以及网络状况糟糕的情况下而设计的发布/订阅型消息协议,为此,它需要一个 消息中间件 。
MQTT是一个基于客户端-服务器的消息发布/订阅传输协议。MQTT协议是轻量、简单、开放和易于实现的,这些特点使它适用范围非常广泛。在很多情况下,包括受限的环境中,如:机器与机器(M2M)通信和物联网(IoT)。其在,通过卫星链路通信传感器、偶尔拨号的医疗设备、智能家居、及一些小型化设备中已广泛使用。
MQTT协议是为大量计算能力有限,且工作在低带宽、不可靠的网络的远程传感器和控制设备通讯而设计的协议,它具有以下主要的几项特性:
实现MQTT协议需要客户端和服务器端通讯完成,在通讯过程中,MQTT协议中有三种身份: 发布者(Publish) 、 代理(Broker) (服务器) 、订阅者(Subscribe) 。其中,消息的发布者和订阅者都是客户端,消息代理是服务器,消息发布者可以同时是订阅者。
MQTT传输的消息分为: 主题(Topic)和负载(payload) 两部分:
MQTT服务器以称为"消息代理"(Broker),可以是一个应用程序或一台设备。它是位于消息发布者和订阅者之间,它可以:
在MQTT协议中,一个MQTT数据包由: 固定头(Fixed header)、可变头(Variable header)、消息体(payload) 三部分构成。MQTT数据包结构如下:
(1) 固定头(Fixed header) 。存在于所有MQTT数据包中,表示数据包类型及数据包的分组类标识。
(2) 可变头(Variable header) 。存在于部分MQTT数据包中,数据包类型决定了可变头是否存在及其具体内容。
(3) 消息体(Payload) 。存在于部分MQTT数据包中,表示客户端收到的具体内容。
固定头存在于所有MQTT数据包中,其结构如下:
相于一个4位的无符号值,类型、取值及描述如下
在不使用标识位的消息类型中,标识位被作为保留位。如果收到无效的标志时,接收端必须关闭网络连接:
Payload消息体位MQTT数据包的第三部分,包含CONNECT、SUBSCRIBE、SUBACK、UNSUBSCRIBE四种类型的消息:
欢迎分享,转载请注明来源:夏雨云
评论列表(0条)