1 EMQ介绍

EMQ (Erlang/Enterprise/Elastic MQTT Broker) 是基于 Erlang/OTP 平台开发的开源物联网 MQTT 消息服务器。Erlang/OTP 是出色的软实时(Soft-Realtime)、低延时(Low-Latency)、分布式(Distributed) 的语言平台。MQTT 是轻量的(Lightweight)、发布订阅模式(PubSub) 的物联网消息协议

EMQ 项目设计目标是承载移动终端或物联网终端海量 MQTT 连接，并实现在海量物联网设备间快速低延时消息路由:

• 稳定承载大规模的 MQTT 客户端连接，单服务器节点支持50万到100万连接。
• 分布式节点集群，快速低延时的消息路由，单集群支持1000万规模的路由。
• 消息服务器内扩展，支持定制多种认证方式、高效存储消息到后端数据库。
• 完整物联网协议支持，MQTT、MQTT-SN、CoAP、WebSocket 或私有协议支持。

2 准备工作

搭建MQTT服务器之前，需要先下载EMQ软件包，个人使用选择EMQ X Broker，EMQ X Broker 是基于高并发的 Erlang/OTP 语言平台开发，支持百万级连接和分布式集群架构，发布订阅模式的开源 MQTT 消息服务器

进入官网下载，选择版本，软件包，笔者下载的是V2.3.11，软件包选择Window,Window10的压缩包

下载完成解压，打开emqttd文件夹，软件包里即包含如下文件（注意：EMQ的下载存放路径别有中文）：

3 安装EMQ

使用管理员身份运行cmd命令窗口，跳转到emqttd的存放路径下/bin文件夹路径

输入命令 emqttd install ,安装emq

输入命令 emqttd start ,启动emq，第一次安装启动emq时可能会卡住，没关系，关闭命令窗口，再次启动emq,当出现以下界面时候即表示已成功启动emq

EMQ 消息服务器启动后，会默认加载 Dashboard 插件，启动 Web 管理控制台。可通过 Web 控制台，查看服务器运行状态、统计数据、客户端(Client)、会话(Session)、主题(Topic)、订阅(Subscription)、插件(Plugin)。

控制台地址: http://127.0.0.1:18083，默认用户: admin，密码：public

尝试登录控制台，验证 EMQ 是否成功启动

能进入控制台，即表示EMQ安装成功

4 添加用户

EMQ 2.0 支持丰富的扩展插件，包括控制台、扩展模块、多种认证方式、多种接入协议等:

可以在 Web 控制台查看各个插件的运行情况：

用户名、密码认证插件（emq_auth_username）默认是停止运行的，我们需要将其更改为启动

在命令行窗口使用 emqttd_ctl users add 命令添加用户，添加一个用户名和密码均为test的用户做MQTT测试，可使用命令 emqttd_ctl users list 查看用户列表验证是否成功添加用户

4 数据交互测试

4.1 MQTTBox连接

使用MQTTBox工具测试 EMQ MQTT服务器是否能正常通信，自定义发布主题和订阅主题，得到MQTTBox连接信息如下：

MQTTBox连接上EMQ MQTT服务器，且订阅subscribe_test主题

4.2 Websocket 连接

EMQ 2.0 消息服务器默认占用的 TCP 端口包括:

故我们用WebSocket做MQTT连接时端口应该为8083，而不是1883，故得到WebSocket连接信息如下：

WebSocket连接上EMQ MQTT服务器，且订阅publish_test主题

4.3 信息交互测试

• MQTTBox发布一条主题为publish_test的消息，可以在EMQ WebSocket上看到发布的消息

• WebSocket发布一条主题为subscribe_test的消息，可以在MQTTBox上看到发布的消息

EMQ MQTT服务器能正常接收、发送数据，正常通信,使用EMQ搭建MQTT服务器成功

注意：此处搭建的MQTT服务器只能使用局域网通信进行数据传输