MQTT 与 EMQ快速入门

MQTT 与 EMQ 摘要

1. 物联网消息协议 MQTT

1.1 MQTT简介

MQTT（Message Queuing Telemetry Transport）是一种轻量级的消息协议，采用发布/订阅模式，设计简洁，适用于低带宽、高延迟、不稳定的网络环境。其特点包括动态主题创建、支持会话保持、灵活的消息格式等。应用领域涵盖物联网通信、智能硬件、车联网、智慧城市等。

1.2 MQTT协议相关概念

MQTT协议包含多个方法用于管理连接、发布、订阅等操作，如CONNECT（连接）、PUBLISH（发布消息）、SUBSCRIBE（订阅请求）等。

1.3 消息服务质量QoS

MQTT定义了三个QoS等级：QoS 0（至多一次）、QoS 1（至少一次）、QoS 2（仅一次）。这保证了消息在不同网络条件下的可靠传输。

1.4 topic通配符匹配规则

MQTT支持通过通配符进行主题匹配，以提高消息订阅的灵活性。

2. 物联网级消息中间件 EMQ

2.1 EMQX简介

EMQX是基于Erlang/OTP开发的开源MQTT消息服务器，支持百万级连接和分布式架构。其特点包括支持MQTT5.0协议、扩展性强、提供插件机制以及中国本地技术支持等。

2.2 环境搭建与配置

通过Docker拉取EMQX镜像并创建容器即可完成安装。EMQX具备清晰的目录结构，方便用户操作。

2.3 EMQDashboard

EMQX提供Dashboard用于管理设备和监控指标，支持查看连接状态、动态加载插件等功能。

2.4 客户端调试工具 MQTTX

MQTTX是跨平台的MQTT 5.0桌面客户端，支持多客户端管理、快速测试MQTT连接及消息发布与订阅。

2.5 延迟消息

EMQX支持延迟发布功能，用户可通过特定主题格式配置延迟时间，最大间隔为4294967秒。

2.6 共享订阅

EMQX支持共享订阅功能，分为带群组和不带群组两种模式，分别采用不同的主题格式。

3. Eclipse Paho

3.1 Eclipse Paho是什么

Eclipse Paho是实现MQTT协议的Java客户端库，常用于项目连接EMQX进行消息收发。

3.2 Eclipse Paho技术调研

通过Spring Boot集成Eclipse Paho实现消息发布与订阅功能。使用内存持久化、自动重连等选项优化连接体验。