EMQ帮助开发者快速认识 MQTT 协议及其相关特性

发布时间：2022-07-20 13:02:29 所属栏目：交互来源：互联网

导读：MQTT 协议是什么？随着 5G 时代的来临，万物互联的伟大构想正在成为现实。联网的物联网设备在 2018 年已经达到了 70 亿，在未来两年，仅智能水电气表就将超过10亿。海量的设备接入和设备管理对网络带宽、通信协议以及平台服务架构都带来了很大挑战。对于

　　MQTT 协议是什么？

　　随着 5G 时代的来临，万物互联的伟大构想正在成为现实。联网的物联网设备在 2018 年已经达到了 70 亿，在未来两年，仅智能水电气表就将超过10亿。

　　海量的设备接入和设备管理对网络带宽、通信协议以及平台服务架构都带来了很大挑战。对于物联网协议来说，必须针对性地解决物联网设备通信的几个关键问题：其网络环境复杂而不可靠、其内存和闪存容量小、其处理器能力有限。

　　MQTT 协议是基于发布／订阅模式的物联网通信协议，凭借简单易实现、支持 QoS、报文小等特点，占据了物联网协议的半壁江山：

　　灵活的发布订阅和主题设计

　　发布订阅模式是传统 Client／Server 模式的一种解耦方案。发布者通过 Broker 与消费者之间通信，Broker 的作用是将收到的消息通过某种过滤规则，正确地发送给消费者。发布／订阅模式相对于客户端／服务器模式的好处在于：

　　发布者和消费者之间不必预先知道对方的存在，比如不需要预先沟通对方的 IP Address 和 Port

　　发布者和消费者之间不必同时运行。因为 Broker 是一直运行的。

　　在 MQTT 协议里，上面提到的过滤规则是 Topic。比如：所有发布到 news 这个 Topic 的消息，都会被 Broker 转发给已经订阅了 news 的订阅者：

　　上图中订阅者预先订阅了 news，然后发布者向 Broker 发布了一条消息＂some msg＂并指定发布到 news 主题，Broker 通过 Topic 匹配，决定将这条消息转发给订阅者。

　　MQTT 的 Topic 有层级结构，并且支持通配符＋和＃：

　　带宽消耗最小化

　　MQTT 协议将协议本身占用的额外消耗最小化，消息头部最小只需要占用 2 个字节。

　　MQTT 的消息格式分三部分：

　　固定长度头部，2 个字节，所有消息类型里都有

　　可变长度头部，只有某些消息类型里有

　　Payload，只有某些消息类型里有

　　MQTT 的主要消息类型有：

　　CONNECT ／ CONNACK

　　PUBLISH ／ PUBACK

　　SUBSCRIBE ／ SUBACK

　　UNSUBSCRIBE ／ UNSUBACK

　　PINGREQ ／ PINGRESP

　　DISCONNECT

　　其中 PINGREQ ／ PINGRESP 和 DISCONNECT 报文是不需要可变头部的，也没有 Payload，也就是说它们的报文大小仅仅消耗 2 个字节。

　　在 CONNECT 报文的可变长度头部里，有个 Protocol Version 的字段。为了节省空间，只有一个字节。所以版本号不是按照字符串＂3．1．1＂存放的，而是使用数字 4 来表示 3．1．1 版本。

　　三个可选的 QoS 等级

　　为适应设备不同的网络环境，MQTT 设计了 3 个 QoS 等级，0， 1， 2：

　　At most once（0）

　　At least once（1）

　　Exactly once（2）

　　QoS 0 是一种＂fire and forget＂的消息发送模式：Sender （可能是 Publisher 或者 Broker）发送一条消息之后，就不再关心它有没有发送到对方，也不设置任何重发机制。

　　QoS 1 包含了简单的重发机制，Sender 发送消息之后等待接收者的 ACK，如果没收到 ACK 则重新发送消息。这种模式能保证消息至少能到达一次，但无法保证消息重复。

　　QoS 2 设计了略微复杂的重发和重复消息发现机制，保证消息到达对方并且严格只到达一次。

　　总的来说，Keepalive 有两个作用：

　　发现对端死亡或者网络中断

　　在长时间无消息交互的情况下，保持连接不被网络设备断开

　　对于那些想要在重新上线后，重新收到离线期间错过的消息的设备，MQTT 设计了持久化连接：在 CONNECT 报文里可设置 CleanSession 字段为 False，则 Broker 会为终端存储：

　　设备所有的订阅

　　还未被设备确认的 QoS1 和 QoS 消息

　　设备离线时错过的消息

　　在线状态感知

　　MQTT 设计了遗愿（Last Will）消息，让 Broker 在发现设备异常下线的情况下，帮助设备发布一条遗愿消息到指定的主题。

　　实际上在某些 MQTT 服务器的实现里（比如 EMQX），设备上线或下线的时候 Broker 会通过某些系统主题发布设备状态更新，更符合实际应用场景。

　　开源 MQTT 服务器如何选择

　　到目前为止，比较流行的开源 MQTT 服务器有几个：

　　Eclipse Mosquitto使用 C 语言实现的 MQTT 服务器。Eclipse 组织还还包含了大量的 MQTT 客户端项目：https：／／www．eclipse．org／paho／＃

　　EMQX使用 Erlang 语言开发的 MQTT 服务器，内置强大的规则引擎，支持许多其他 IoT 协议比如 MQTT－SN、 CoAP、LwM2M 等。

　　Mosca使用 Node．JS 开发的 MQTT 服务器，简单易用。

　　VerneMQ同样使用 Erlang 开发的 MQTT 服务器．

　　从支持 MQTT 5．0、稳定性、扩展性、集群能力等方面考虑，EMQX 的表现应该是最好的：

　　使用 Erlang OTP 开发，容错能力好（电信领域久经考验的语言，曾经做出过 99．9999999％可用性的交换机设备）

　　官方有大量的扩展插件可供扩展。有很多认证插件，数据存储（backend）插件可供选择。可支持各种关系型数据库，NoSQL 数据库，以及常见消息队列如 Kafka，RabbitMQ，Pulsar 等

（编辑：开发网_开封站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!