使用官方 MQTT 驱动

本文介绍了边缘智能官方 MQTT 驱动的使用方法。

背景信息

MQTT（Message Queuing Telemetry Transport）是一种轻量级的通信协议，用于在物联网和传感器网络中进行消息传递。MQTT 协议的设计目标是在带宽有限、网络不稳定的环境下实现可靠的通信。它使用简单的发布-订阅模型，其中有一个消息代理（Broker）负责接收和转发消息；设备可以作为发布者（Publisher）将消息发布到代理，也可以作为订阅者（Subscriber）订阅感兴趣的消息主题。

边缘智能提供了官方 MQTT 驱动。通过在一体机上部署官方 MQTT 驱动并接入设备，您可以使一体机成为一个 MQTT 消息订阅者。MQTT 驱动能够从 MQTT 服务器（即消息代理 Broker）订阅来自特定发布者的消息。这些发布者是接入到一体机的 MQTT 设备。

驱动说明

您可以在边缘智能控制台的 设备管理 > 驱动模板 页面，查看边缘智能的官方 MQTT驱动。

准备工作

准备一体机

使用 MQTT 驱动前，您需要准备一台边缘一体机，并完成以下工作：

• 为一体机配置网络
• 为一体机绑定项目

准备 MQTT 服务器和客户端

使用 MQTT 驱动前，您需要准备可访问的 MQTT 服务器。为了测试消息接收和转发，您还需要准备一个 MQTT 客户端来与 MQTT 服务器建立连接。为便于演示操作，本教程将在一体机上部署 MQTT 服务，使一体机成为一个 MQTT 服务器；本教程还使用了 MQTT 客户端工具来模拟消息的发送。

部署 MQTT 服务器

在本章节，您将使用边缘智能的官方 Helm 模板（emqx），在一体机上部署 MQTT 消息服务，使一体机成为 MQTT 消息服务器。

1. 登录边缘智能控制台。

2. 在左侧导航栏顶部的 我的项目 区域，选择您的项目。

3. 在左侧导航栏，选择 应用管理 > Helm 应用。

4. 单击 官方模板 页签。

5. 定位到 emqx 模板，单击 操作 列的 部署。

6. 在 部署应用 页面，修改以下参数的设置，然后单击 确认。

   • 名称：设置为 emqx，表示 MQTT 服务器的名称。
   • 一体机：选择要使用的一体机。
   • 镜像仓库版本：选择最新的版本。
   • 参数配置（可选）：使用默认 参数配置 部署的 MQTT 服务不开放外部访问。如需允许外部访问，您可以对 service 部分的参数配置做以下修改：
     • 将 service.type 的值设置为 NodePort。
     • 将 service.nodePorts.mqtt 的值设置为 31883。
     • 将 service.nodePorts.dashboard 的值设置为 30000。

等待应用部署成功后，您可以访问 MQTT 服务器的仪表盘来验证服务器是否正常。验证方法如下：

1. 打开本地计算机的浏览器，访问 http://<一体机IP>:30000。

   注意

   本地计算机必须与一体机处于相同的私有网络。

2. 使用初始登录凭证（用户名/密码：admin/public）登录 MQTT 服务器的仪表盘。
   

如果登录成功，表示 MQTT 服务器已经正常工作。

安装 MQTT 客户端

MQTTX 是一款 MQTT 客户端工具，它支持 MQTT 5.0、3.1.1 和 3.1 协议。在本章节，您将在自己的终端设备上安装 MQTTX，并与 MQTT 服务器建立连接。

1. 根据 MQTTX 的官方说明，在您的设备上安装 MQTTX，使您的设备成为 MQTT 客户端。
2. 验证客户端与服务器是否连通。
   1. 在您的设备上打开 MQTTX。
   2. 新建一个连接。
   3. 在 新建 面板，填写连接信息，然后单击右上角的 连接。
      • 服务器地址：填写一体机的 IP 地址。
      • 端口：填写 31883。
        

连接成功后，您可以前往 MQTT 服务器的仪表盘，在 监控 > 客户端 列表查看已连接的客户端。

步骤1：准备设备模板

1. 登录边缘智能控制台。

2. 在左侧导航栏顶部的 我的项目 区域，选择您的项目。

3. 在左侧导航栏，选择 设备管理 > 设备模板。
4. 创建一个设备模板。
   1. 单击 创建设备模板。
   2. 在 创建设备模板 对话框，为模板设置一个 名称 并添加 描述，然后单击 确定。

      在本教程中，我们使用 MQTT 作为设备模板的名称。

5. 单击新建的设备模板的名称。

您将进入模板详情。接下来，您需要在设备模板详情中完成物模型定义。

定义物模型

1. 在设备模板详情页，单击 物模型定义 页签。

2. 单击 编辑。

3. 在 默认模块 下，根据需要 添加自定义功能。
   您可以添加 属性 类型的自定义功能。每个自定义功能表示 MQTT 服务器从客户端接收的某种数据。

   在本教程中，我们添加了下表罗列的自定义功能用于测试。

   功能类型	功能名称	标识符	数据类型	数据定义
   属性	bool	bool	bool	0-off、1-on
   属性	enum	enum	enum	枚举对：1-一、2-二
   属性	text	text	text	数据长度：1024
   属性	int	int	int	无

4. 添加完自定义功能，在 编辑物模型 页面左下角，单击 确定。

5. 在 发布新版本 对话框，设置 版本号 和 描述，然后单击 确定。

   在本教程中，我们使用 1.0.0.0 作为物模型的版本号。

发布版本后，您将会得到如下图所示的物模型。

步骤2：接入设备

1. 在左侧导航栏，单击 一体机。
2. 在 一体机 页面，找到要部署 MQTT 驱动的一体机，单击一体机名称。
3. 单击 设备接入 页签。

接下来，您需要在 设备接入 页签依次完成以下操作：部署驱动实例、添加驱动通道、添加设备。

部署驱动实例

1. 如果您是首次在当前一体机上部署驱动实例，单击 立即部署。如果您不是首次在当前一体机上部署驱动实例，在 驱动实例 列表上方，单击 新建驱动实例。
2. 在 新建驱动实例 对话框，选择 MQTT驱动 的最新版本，然后单击 确定。

您提交部署请求后，系统将在一体机上部署驱动实例。部署过程涉及到数据传输。根据现场网络环境不同，部署所需时间不同。请确保您的一体机在线，并耐心等待部署完成。当驱动部署成功后，驱动实例状态 将变为 运行中。

添加驱动通道

驱动通道表示多个设备与驱动通信时所使用的相同配置。在 MQTT 驱动使用场景下，MQTT 驱动可以从一个 MQTT 服务器（消息代理）订阅来自多个设备（发布者）的消息。一个驱动通道就表示一种订阅途径，它定义了从一个 MQTT 服务器订阅消息的通用配置。

1. 在驱动实例列表，将光标放置在 MQTT驱动 上，然后单击添加图标。
2. 在 添加通道 对话框，完成以下设置，然后单击 确定。

成功添加驱动通道后，您可以单击驱动以展示或隐藏驱动通道。

添加设备

1. 选择 MQTT驱动 和新建的通道，然后单击 添加设备。
2. 在 添加设备 面板，完成以下设置，然后单击 确定。

完成以上操作后，MQTT 驱动将自动与 MQTT 服务器建立连接。您可以前往 MQTT 服务器的仪表盘，在 监控 > 客户端 页面查看新建的客户端。新建的客户端的 ID 就是您在驱动通道中设置的 Client ID。

步骤3：创建北向通道

默认情况下，一体机未开启向边缘智能控制台上报数据的功能。您必须在一体机上部署 数据上报 类型的北向通道，才能允许一体机将设备的属性数据上报到边缘智能控制台。

1. 在左侧导航栏，选择 设备管理 > 北向通道。

2. 单击 创建北向通道。

3. 在 创建北向通道 页面，选择 数据上云 类型，并选择将北向通道部署到您的边缘一体机。

   注意

   每种类型的北向通道仅允许有一个。如果您已经创建过 数据上云 类型的北向通道，则无需创建新的北向通道。您只需编辑已有北向通道的配置，将您的边缘一体机添加到部署列表。更多信息，请参见编辑北向通道。

4. 等待北向通道在一体机部署成功。
   部署成功后，北向通道在一体机上的状态将变为 运行中。

步骤4：验证数据上报

您可以通过 MQTTX 客户端向 MQTT 服务器发送测试数据。MQTT 接收的测试数据将通过北向通道上报到边缘智能控制台。

模拟发送测试数据

以发送 int 类型测试数据为例。在 MQTTX 客户端的连接页面，发送测试数据到以下 Topic：test/mqtt-dv1/int。您也可以模拟发送其他类型的数据进行测试。

查看上报的测试数据

1. 在左侧导航栏，选择 设备管理 > 设备实例。

2. 找到 MQTT 设备，单击设备的名称。

3. 单击 运行状态 页签。

4. 设置一个时间段（包含您发送测试数据的时间），查看 MQTT 设备的数据。

   下图展示了通过 MQTTX 客户端发送到 MQTT 服务器的测试数据。