一、MQTT 服务端
1、EMQ X介绍
EMQ X 是一款完全开源,高度可伸缩,高可用的分布式 MQTT 消息服务器,适用于 IoT、M2M 和移动应用程序,可处理千万级别的并发客户端。关于 EMQ X 的更多信息,可访问 EMQ 官网 进行了解。
2、EMQ X安装
EMQ X安装方式有很多种,官网docs文档有介绍,这里使用docker方式安装。
docker pull emqx/emqx:v3.1.0 docker run -d --name emqx31 -p 1883:1883 -p 8083:8083 -p 8883:8883 -p 8084:8084 -p 18083:18083 emqx/emqx:v3.1.0
2、EMQ X控制台
启动成功后可以通过浏览器访问 http://IP:18083,看到一个 EMQ X 登录界面(默认的用户名/密码为admin/public)
二、MQTT客户端
1、MQTTX介绍
MQTT X 是 EMQ 开源的一款跨平台 MQTT 5.0 客户端工具,它支持 macOS, Linux, Windows,并且支持 MQTT 消息格式转换。
MQTT X 的用户界面借助聊天软件的形式简化了页面的操作逻辑,用户可以快速创建连接保存并同时建立多个连接客户端,方便用户快速测试 MQTT/TCP、MQTT/TLS、MQTT/WebSocket 的 连接/发布/订阅 功能及其他特性。
2、MQTTX安装
3、MQTTX界面
二、MQTT 插件安装
1、插件下载
从 Support 门户上下载插件 Jar 包
2、插件上传
在 MeterSphere 系统设置里上传 Jar 包
三、MQTT 协议接口测试
1、创建接口连接
该请求的作用是建立连接,本次使用 MQTT 服务端进行测试,IP 为 EMQ X 服务器地址。
端口和协议对应关系如下:
1883 MQTT TCP 协议端口
8883 MQTT/TCP SSL 端口
8083 MQTT/WebSocket 端口
8084 MQTT/WebSocket with SSL 端口
调试接口,可以看到EMQ X后台已经收到连接会话。
2、发布Topic
该请求作用是发布消息到服务器,只需要输入主题、发送消息内容即可。
3、订阅消息
调试接口,可以看到客户端同步收到在 MeterSphere 上发布的消息。
4、断开连接