使用MQTT服务网关接入设备

本文档以MQTT.fx为例,介绍使用第三方软件以MQTT协议接入物联网平台。MQTT.fx是一款基于Eclipse Paho,使用Java语言编写的MQTT客户端工具。支持通过Topic订阅和发布消息。

创建协议

自定义消息协议创建,请参考消息协议定义

i. 选择 设备管理-->协议管理--> 点击新建协议按钮

新建协议导航

ii. 输入型号名称

iii. 选择型号类型为 jar

iv. 输入类名org.jetlinks.demo.protocol.DemoProtocolSupportProvider

v. 上传jar包 demo-protocol-1.0.jar使用MQTT直接接入设备 - 图2

vi. 点击保存,完成协议新增。

创建完成信息展示

新建型号协议

创建设备型号

完整的设备型号创建,请参考添加设备型号

i.下载型号文件配置JSON

ii. 选择 设备管理-->设备型号--> 点击导入配置按钮

导入型号导航

iii. 选择配置JSON文件

iv.型号导入完成效果如下图

未发布型号

v.点击上图中未发布链接完成型号发布,导航栏中发布状态变为已发布代表发布成功。

已发布型号

创建成功的型号信息展示

i. 点击导航栏中编辑链接查看型号基本信息

ii. 点击弹出框中设备定义板块查看型号设备定义

iii. 点击属性定义、事件定义对应操作下的编辑按钮查看更详细的型号信息

属性定义参数:
型号信息1

功能定义参数:
型号信息2

事件定义参数:
型号信息3

创建设备实例

自定义创建设备实例,请参考添加设备实例

i. 下载设备实例Excel文件设备实例Excel

ii. 选择 设备管理-->设备实例--> 点击导入实例按钮

导入设备导航

iii. 选择设备实例Excel文件

iv. 设备实例导入完成效果如下图

未激活的设备

v. 点击上图中激活链接完成设备实例激活,状态栏中发布状态变为离线代表设备激活成功。

已激活的设备

创建成功的设备实例信息展示

i. 设备基本信息

设备基本信息

ii. 设备运行状态信息

设备运行状态信息

iii. 设备日志

设备日志

创建网关配置

参照启动设备网关服务

  • 创建MQTT服务网络组件
  • 创建MQTT服务设备网关

MQTT服务组件配置
MQTT服务组件配置

MQTT服务设备网关
MQTT服务设备网关

使用MQTT.fx接入

1.下载并安装MQTT.fx软件。请访问MQTT.fx官网使用MQTT直接接入设备 - 图18

2.打开MQTT.fx软件,单击设置图标。

mqttfx首页

3.设置连接参数。

注意

设置参数时,请确保参数值中或参数值的前后均没有空格。

i. 设置基本信息

mqtt基本信息设置

参数说明
Profile Name输入您的自定义名称。
Profile Type选择为MQTT Broker

MQTT Broker Profile Settings

参数说明
Broker Address连接域名。本地连接可直接填写 127.0.0.1,如为远程连接,请填写远程连接地址
Broker Port设置为1889
Client ID设备Id。本文档中为演示设备实例test001

General栏目下的设置项可保持系统默认,也可以根据您的具体需求设置。

ii. 单击User Credentials,设置User Name和Password。

在消息协议未定义前,username,password可以填写任意字符,但是不能留空。

mqtt用户名名密码设置

参数说明
User Name消息协议定义中决定User Name值(消息协议未定义时可填写任意值)
Password消息协议定义中决定Password值 (消息协议未定义时可填写任意值)

4.设置完成后,单击右下角的OK

设备操作

设备连接上平台,并进行一些基本的事件收发、属性读取操作。

设备上下线

单击 Mqtt fx 中Connect进行连接

mqtt连接

平台中设备状态变为上线即为连接成功

设备上线

在设备日志模块可以看到设备上线日志

设备上线日志

单击 Mqtt fx 中Disconnect断开连接

mqtt连接

平台中设备状态变为离线即为断开连接成功

设备离线

在设备日志模块可以看到设备离线日志

设备离线日志

读取设备属性

注意

第2步中回复平台属性值需要在第1步平台发送订阅以后的十秒钟内完成,否则平台会视为该次操作超时,导致读取属性值失败。

1.平台告知设备(MQTT.fx)需要设备返回设备属性

在MQTT.fx上订阅消息,订阅物联网平台下发设备返回属性的Topic

i. 在MQTT.fx上,单击Subscribe。

ii. 输入平台获取设备属性会发送给网关的topic/read-property

iii. 单击Subscribe,订阅这个topic

订阅topic

iv. 平台发送订阅操作

单击设备实例页面中test001设备对应的查看链接

选择弹出框中运行状态板块

单击属性刷新

平台属性订阅操作

v. 订阅topic: /read-property对应的消息

订阅topic

注意:

复制好订阅该topic收到的消息中的messageId。此messageId将作为回复与平台设备属性的凭据之一

2.设备(MQTT.fx)回复平台设备属性值

在MQTT.fx上发送消息,发送平台所需要的设备属性值。

i. 在MQTT.fx上,单击 Publish

ii. 输入一个回复平台属性值消息Topic和要发送的消息内容,单击Publish,向平台推送该消息。

回复设备属性

参数说明
messageId第一步订阅平台topic“/read-property”所收到的messageId值
deviceId设备Id
timestamp当前时间戳
success成功标识
properties设备属性值对象。例如: { “threshold”:”50”}

该文档所使用的回复内容

  1. {
  2. "messageId":"第一步订阅平台topic“/read-property”所收到的messageId值",
  3. "deviceId":"test001",
  4. "timestamp":1583809148000,
  5. "success":true,
  6. "properties":{
  7. "temperature":36.5
  8. }
  9. }

iii. 平台收到Mqtt.fx推送的属性值

平台收到属性值

iv. 读取设备属性回复的日志

设备属性读取日志

获取设备属性值完整演示

注意:在下图中,从在界面上刷新属性开始直到动图结束的所有操作,需要在十秒钟内完成。否则平台会视为该次操作超时,导致读取属性值失败。

获取设备属性值

设备事件上报

MQTT.fx 推送设备事件消息到平台

以火灾报警事件为例。

1.在MQTT.fx上,单击 Publish

2.输入事件上报Topic和要发送的事件内容,单击Publish按钮,向平台推送该事件消息。

设备事件上报

该文档使用的topic: /fire_alarm

该文档所使用的回复内容

  1. {
  2. "deviceId":"test001",
  3. "pname":"智能温控",
  4. "aid":105,
  5. "a_name":"未来科技城",
  6. "b_name":"C2 栋",
  7. "l_name":"12-05-201",
  8. "timestamp":"2019-11-06 16:28:50",
  9. "alarm_type":1,
  10. "alarm_describe":"火灾报警",
  11. "event_id":1,
  12. "event_count":1
  13. }
参数说明
deviceId设备Id
pname设备型号名称
aid区域Id
a_name区域名称
b_name建筑名称
l_name位置名称
timestamp上报时间
alarm_type报警类型
alarm_describe报警描述
event_id事件 ID
event_count该事件上报次数

3.事件上报设备日志

事件上报设备日志

4.事件上报内容

事件上报内容 事件上报内容1