物联网mqtt协议

2017-11-09  本文已影响103人  lennasu

mqtt协议学习与使用

一.先简单介绍一下mqtt协议

mqtt协议是基于Tcp/ip 的一种通信协议,是建立在可靠的传输协议之上的,比起基于UDP协议就会想到mqtt协议的强大之处了吧。mqtt协议使用很广泛,如:经过对移动端应用的了解,像极光推送十有八九都是使用这个协议作为底层进行封装的。所以mqtt协议可以使用在各聊天中,但是我们没必要去重新造轮子,况且搭建一个推送协议不是一个小工程。mqtt不仅仅使用在推送协议中,现在的物联网这么发达,好多工程的实现都是使用mqtt协议作为通信协议,知道mqtt的强大之处了吧。

二.MQTT协议具有以下几个特点:

1.发布和订阅消息提供一对多的模式,具体就是:发布可以是一个终端,可以又多个终端订阅。也可以一个终端订阅多个发布终端。可以达到降低应用程序之间的耦合度。

2.当消息内容又载体时,协议会进行屏蔽。

3.使用TCP/IP提供网络连接。

4.有三种消息发布质量,分别是:

(1)最多一次发布,以就是当消息发布完全是依赖于底层TCP/IP网络协议的,因为TCP/IP是可靠性传输的,当数据丢失了之后就会重传,所以这样的传输是可能会发生消息的重复。

(2)最少一次传输:这样的传输模式目的是能够确保消息能够到达,所以会出现多次传输,消息会出现重复。

(3)只有一次的发布:确保消息到达一次,这不能让消息重复,这种情况出现再计费系统中,不会出现重复的消息。这种模式不准消息丢失或者重复。

5.小型传输,开销小,能够降低网络流量。

6还有一特点就是使用Last will和Testament特性通知各客户端异常中断的机制。

三、MQTT协议的消息格式

首先MQTT的消息格式中的头部占2个字节,第一个字节中的7、6、5、位是表示消息类型的,故可以表示16种消息类型,下面是对16种消息类型的解释;

Reserved 0(转化成二进制是0000) 表示是保留位

CONNECT 1(转化成二进制是0001 ) 表示请求连接服务器

CONNACK 2 (转化成二进制是0010 ) 表示连接确认

PUBLISH 3 (转化成二进制是0011 ) 表示发布消息

PUBACK 4 (转化成二进制是0100 ) 表示发布确认

PUBREC 5 (转化成二进制是0101 ) 表示发布了(保证交付第1部分)

PUBREL 6(转化成二进制是0110 )发布版本(保证交付第2部分)

PUBCOMP 7 (转化成二进制是0111 )发布完成(保证交付第3部分)

SUBSCRIBE 8 (转化成二进制是1000 )客户端订阅请求

SUBACK 9 (转化成二进制是1001) 订阅确认

UNSUBSCRIBE 10(转化成二进制是1010)客户端取消订阅请求

UNSUBACK 11 (转化成二进制是1011)取消订阅确认

PINGREQ 12 (转化成二进制是1100) ping请求

PINGRESP 13 (转化成二进制是1101)ping响应

DISCONNECT 14(转化成二进制是1110)客户端断开

Reserved 15 (转化成二进制是1111)保留位

flag标记位是第3位:第三位用0或者1来表示,1表示收到的消息已收到过,0表示没有收到过。

QoS level 占2位,那么表示四种类型:

0(00)表示最多一次模式

1(01)表示最少一次模式

2(10)表示确保一次模式

3(11)保留,不代表任何意思

最后一位表示保留位

最后一个字节是表示剩余消息的长度是多少。

且记录长度不能超过4个字节,那么能够存储256MB的长度。

在使用MQTT协议时,最需要考虑的是安全性问题,因为MQTT协议是运行再Tcp上的,那么可以使用TLS来进行加密。

mqtt协议使用模式

MQTT采用代理的发布/订阅模式实现了发布者和订阅者的解耦(decouple),因此,在MQTT协议中有三种角色:代理服务器、发布者客户端以及订阅者客户端,其中发布者和订阅者互不干扰,也就是说发布者和订阅者互不知道对方的存在,它们只知道代理服务器,代理服务器负责将来自发布者的消息进行存储处理并将这些消息发送到正确的订阅者中去。这种解耦体现在以下3个方面上:

·空间解耦:发布者和订阅者不必知道对方的存在,例如对方的IP地址或者端口;

·时间解耦:发布者和订阅者不必同时建立连接;

·同步解耦:发布者和订阅者在发布消息或接收消息的时候不需要同步。

结语

要想使用mqtt协议进行编程,我们得使用大公司封装好的协议进行编码,还得搭建代理服务器,使其各个客户端进行连接,能达到通信效果。

上一篇下一篇

猜你喜欢

热点阅读