一、系统架构

我们的MQTT测试环境需要一个MQTT代理服务器，作为MQTT消息的中转。MQTT客户端可以进行订阅消息、发布消息。

二、MQTT代理服务器

常用的MQTT Broker有Mosquitto、HiveMQ、EMQX等。现在我们使用EMQX作为自己的MQTT代理服务器。

下载地址:

https://www.emqx.com/zh/try?product=broker

根据我们的环境下载对应的版本。

下载好之后，我们解压完成并进入bin目录。使用CMD命令执行 emqx start，开启EMQX。

然后浏览器访问:http://localhost:18083/

账号名:admin 密码:123456  进入EMQX控制台

三、MQTT客户端

客户端MQTT Client我们也可以用现成的工具，本文使用MQTT X，如下所示；

下载网址:https://mqttx.app/downloads

选择适合自己系统的版本，进行安装即可；

下载并安装好之后，我们打开MQTTX,添加两个客户端。

• Client ID：客户端的ID，这里需要保证唯一性；
• 代理服务器地址：按照实际的地址进行填写，默认的监听端口号为1883；
• MQTT版本：默认一般为V3.1.1

我们手动添加两个客户端，一个用于接收消息，一个用于发送消息。

客户端 test-1 订阅主题 test/a，接收客户端test-2的MQTT消息，如下所示；

如何我们在test-2客户端发送指定主题 的消息。

test-2发送消息后，test-1接收到了消息。

以上结果证明可以正常进行消息传递。