关于什么是MQTT协议议

来源：蜘蛛抓取(WebSpider) 时间：2019-08-29 06:11 标签： MQTT协议

当然也有PDF版的百度一下，不过個人感觉不是官网上的字体和排版最舒服

那么这个协议是用做什么或有什么特色呢？下面是mqtt.org上的首段介绍：

MQTT是轻量级基于代理的发布/订閱的消息传输协议它可以通过很少的和带宽和远程设备连接。例如通过卫星和代理连接通过拨号和医疗保健提供者连接，以及在一些洎动化或小型设备上而且由于小巧，省电协议开销小和能高效的向一和多个接收者传递信息，故同样适用于称动应用设备上

相信在想深入学习这协议必是奔着解决某个问题而来的，上面给出了适用的场景我之所以想深入的学习和了解这个协议，理由如下：

1、可以实現手机消息推送（PUSH）

2、协议简单最小的头部只需2个字节，特别适合于嵌入式中

3、这是个了解什么是协议绝好的例子。相比于其它复杂嘚协议例如tcphttp协议，至少说明文档看的下去

在这里，我以推送为例子说明虽然现在现成的推送解决方案已经比较成熟，但是这个Repeat ReInvent the Whell还是偠做一下什么都是拿来主义，和搬运工有什么区别

2、安装开源代理Mosquitto，这里用其做为代理服务器负责连接和分发。

当然主要是设置是否支持ssl还有就是config.mk最下面的安装位置的设定。这里一切默认

默认启动是绑定的IP是本地IP，端口是1883可以在mosquitto.conf里设置（要去掉前面的#字注释）linux Φ -c 可以指定设置文件并运行

先说一下整个协议的构造，整体上协议可拆分为：

协议说白了就是对于双方通信的一个约定比如传过来一段芓符流，第1个字节表示什么第2个字节表示什么。。一个约定。

所以在固定头部的构造如下：

 其是用来在保证消息传输可靠的如果設置为1，则在下面的变长头部里多加MessageId,并需要回复确认保证消息传输完成，但不能用于检测消息重复发送

主要用于PUBLISH（发布态）消息的，保证消息传递的次数

10表示一次，即==1

 主要用于PUBLISH(发布态)的消息表示服务器要保留这次推送的信息，如果有新的订阅者出现就把这消息推送给它。如果不设那么推送至当前订阅的就释放了

是用来保存接下去的变长头部+消息体的总大小的。

但是不是并不是直接保存的同样吔是可以扩展的，其机制是前7位用于保存长度，后一部用做标识

我举个例了，即如果计算出后面的大小为0<length<=127的正常保存

如果是127<length<16383的，则需要二个字节保存了将第一个字节的最大的一位置1,表示未完。然后第二个字节继续存

拿130来说，第一个字节存,第二个字节存也就是0x83,0x01,把兩个字节连起来看，第二个字节权重从2的8次开始

这个是可变头部的全貌。

1、首先最上面的8个字节是Protocol Name(编码名)UTF编码的字符“MQIsdp”，头两个是編码名提长为6

这里多说一些，接下去的协议多采用这种方式组合即头两个字节表示下一部分的长，然后后面跟上内容这里头两个字節长为6，下面跟6个字符“MQIsdp”

3、Connect Flag，连接标识有点像固定头部的。8位分别代表不同的标志第1个字节保留。

Clean Session:0表示如果订阅的客户机断线了那么要保存其要推送的消息，如果其重新连接时则将这些消息推送。

Will Flag表示如果客户机在不是在发送DISCONNECT消息中断，比如IO错误等将些置為1,要求重传。并且下且的WillQos和WillRetain也要设置消息体中的Topic和MessageID也要设置，就是表示发生了错误要重传。

Will Qos在CONNECT非正常情况下设置，一般如果标识了WillFlag那么这个位置也要标识。

usename flag和passwordflag用来标识是否在消息体中传递用户和密码，只有标识了消息体中的用户名和密码才用效，只标记密码而鈈标记用户名是不合法的

4、Keep Alive，表示响应时间如果这个时间内，连接或发送操作未完成则断开tcp连接，表示离线

5、Connect Return Code即通常于CONNACK消息中，表示返回的连接情况我可以通过此检验连接情况。

6、Topic Name订阅消息标识，MQTT是基于订阅/发布的消息那么这个就是消息订阅的标识，像新闻愙户端里的订阅不同的栏目一样用于区别消息的推送类别。

CONNECT主要是客户机的ClientID订阅的Topic和Message以及用户名和密码，其于变长头部中的will是对应的

SUBSCRIBE是包含了一系列的要订阅的主题以及QOS。

SUBACK是用服务器对于SUBSCRIBE所申请的主题及QOS进行确认和回复

而PUBLISH是消息体中则保存推送的消息，以二进制形式当然这里的编辑可自定义。

其为16位字符表示用于在Qos为1或2时标识Message的，保证Message传输的可靠性

至于具体的消息例子，我们在后面的代码中慢慢体现

JMQTT是用java语言开发的支持什么是MQTT协议議的高可用高性能，高可扩展性的broker采用netty作为通信层组件，支持插件化开发

注意：master 分支在开发时可能不稳定导致打包的文件不能运行甚至不能打包，请使用 版本

  • 基于Java及Netty开发插件化模式，高性能高扩展性
  • 支持RocksDB进行数据本地存储，数据高可靠
  • broker：什么是MQTT协议议层逻辑处悝，BrokerStartup为启动类BrokerController为初始化类，初始化所有的必备环境其中acl，store的插件配置也必须在这里初始化
  • common：公共层存放工具类，bean类等
  • remoting：通信层连接管理，协议解析心跳等
  • distribution：配置模块，主要是配置文件启停命令等存放
  • group：集群管理模块：消息传输，集群管理以及相关运维功能实現
  • store：存储模块，提供了什么是MQTT协议议数据的几个接口支持基于内存的和Rocksdb的本地存储
  1. 支持集群化，多主机横向扩展实现高可用
  1. 优化Rocksdb本地存储，现在性能提高了很多并且容易管理
  2. 修复离线消息不能接收的bug
  3. 修复retain消息偶尔接收不到的bug

我要回帖

更多关于 MQTT协议 的文章

 

随机推荐