【XPack】MeterSphere 扩展协议支持:MQTT

一、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 XEMQ 开源的一款跨平台 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、断开连接


从 Support 门户上下载插件 Jar 包 --这个指的是?

指的是企业版用户的门户网站,该插件是企业版提供的内容之一。