本文导读

展开导读

文档首页/ 设备接入 IoTDA/ 开发指南/ 设备侧开发/ 使用MQTT Demo接入/ MQTT over WebSocket 使用说明

MQTT over WebSocket 使用说明

更新时间：2024-08-21 GMT+08:00

查看PDF

概述

本文以JavaScript为例，介绍基于WebSocket的MQTTS/MQTT协议接入平台，使应用程序或者小程序可以快速接入到平台，通过平台接口实现“属性上报”、“订阅接收命令”等功能。

说明：

本文中使用的代码为样例代码，仅用于体验平台通信功能，如需进行商用，可以参考资源获取获取对应语言的IoT Device SDK进行集成。

使用限制

MQTT over WebSocket只支持wss方式，需要使用和TLS直连一样的根证书。
MQTT over WebSocket默认使用的端口为443，企业版实例可以根据业务场景定制。
MQTT over WebSocket的接口同MQTT接口一致。

前提条件

已在管理控制台获取设备接入地址。获取地址的操作步骤，请参考平台对接信息。
已在管理控制台创建产品和注册设备。创建产品和注册设备具体操作，请参考创建产品、注册单个设备或批量注册设备。

导入代码样例

下载quickStart(websocket).zip样例，并解压。
修改Demo里的关键工程配置参数。其中MqttOverWebsocketDemo.html需要配置host地址、设备ID和设备密钥，用于启动Demo时连接平台。
- host地址：即域名，请参考平台对接信息获取；
- 设备ID和设备密钥：在物联网平台注册设备或调用创建设备接口后获取。
```
    var host = '****'; //IoT平台mqtt对接地址
    var deviceId = '****'; //请填写在平台注册的设备ID
    var secret = '****'; //请填写在平台注册的设备密钥
```

程序启动

设备或网关在接入物联网平台时首先需要和平台建立连接，从而将设备或网关与平台进行关联。开发者通过传入设备信息，将设备连接到物联网平台。

找到MqttOverWebsocketDemo.html源码目录，修改关键工程配置参数后用浏览器打开Demo，启动程序前，在平台界面上显示设备状态是离线。

图1 设备列表-设备离线
点击放大

启动程序后，按F12进入调试界面console栏中日志显示如下：

图2 日志显示连接成功
点击放大

平台上显示设备状态变为在线

图3 设备列表-设备在线
点击放大

注意：

如果连接失败，需要在重连回调函数中实现退避重连，代码样例如下：

 function reConnect() {
        log("reconnect is starting");
        //退避重连
        let lowBound = Number(defaultBackoff) * Number(0.8);
        let highBound = Number(defaultBackoff) * Number(1.2);
        let randomBackOff = parseInt(Math.random() * (highBound - lowBound + 1), 10);
        let backOffWithJitter = (Math.pow(2.0, retryTimes)) * (randomBackOff + lowBound);
        let waitTImeUtilNextRetry = (minBackoff + backOffWithJitter) > maxBackoff ? maxBackoff : (minBackoff + backOffWithJitter);
        log("wait time: " + waitTImeUtilNextRetry);
        setTimeout(()=> { client.connect(options); }, waitTImeUtilNextRetry);
        retryTimes++;
    }

订阅某Topic的设备才能接收平台发布的关于该Topic的消息，关于平台预置Topic可参考Topic定义。此Demo调用subScribeTopic方法进行订阅Topic，订阅成功后等待平台命令下发：

      
             //订阅接收命令topic
    function subScribeTopic() {
        log('subscribe topic ' + getCmdRequestTopic());
        client.subscribe(getCmdRequestTopic());
    }

发布Topic是指设备主动向平台上报自己的属性或消息，详细见设备属性上报接口文档。连接成功后，调用publishMessage方法进行属性上报：

      
         //上报json数据，注意serviceId要与Profile中的定义对应
function publishMessage() {
    var jsonMsg = propertiesReport;
    log("publish message topic is " + getReportTopic());
    log("publish message is " + jsonMsg);
    client.publish(getReportTopic(), jsonMsg);
    log("publish message successful");
}

上报属性的json：

       
          var propertiesReportJson = {'services':[{'properties':{'alarm':1,'temperature':12.670784,'humidity':18.37673,'smokeConcentration':19.97906},'service_id':'smokeDetector','event_time':null}]};

浏览器调试界面的console栏中显示如下：

图4 日志显示上报数据成功
点击放大

属性上报成功，平台界面如下：

图5 查看上报数据-WSDemo_smokeDetector
点击放大

说明：

如果在“设备详情”页面没有最新上报数据，请修改产品模型中服务和属性的内容，确保设备上报的服务/属性和产品模型中的服务/属性一致，或者进入“产品 > 基本信息”页面，删除所有服务。

接收下发命令

在Demo中提供了接收平台下发命令的功能，在MQTT建链完成并成功订阅Topic后，可以在管理控制台设备详情中命令下发或使用应用侧Demo对该设备ID进行命令下发。下发成功后，在Demo中接收到平台下发给设备的命令。

例如下发参数名为smokeDetector: SILENCE，参数值为1的命令。

图6 命令下发-SILENCE_1
点击放大

命令下发成功后，Demo收到平台下发的命令，浏览器调试界面的console栏显示如下：

图7 显示

说明：

由于是同步命令需要端侧回复响应可参考接口。

父主题： 使用MQTT Demo接入

上一篇：Node.js Demo使用说明

下一篇：通过华为认证模组接入

意见反馈

文档内容是否对您有帮助？

有帮助没帮助

提供反馈

提交成功！非常感谢您的反馈，我们会继续努力做到更好！您可在我的云声建议查看反馈及问题处理状态。

系统繁忙，请稍后重试

在使用文档中是否遇到以下问题

内容与产品页面不一致

内容不易理解

缺失示例代码

步骤不可操作

搜不到想要的内容

缺少最佳实践

意见反馈（选填）

0/500

请至少选择一项反馈信息并填写问题反馈

字符长度不能超过500

直接提交取消

如您有其它疑问，您也可以通过华为云社区问答频道来与我们联系探讨

智能客服提问云社区提问

MQTT over WebSocket 使用说明

概述

使用限制

前提条件

导入代码样例

程序启动

接收下发命令

相关文档

意见反馈

文档内容是否对您有帮助？

7*24

备案

专业服务

退订

建议反馈

售前咨询热线

文档反馈