设备接入 IoTDA设备接入 IoTDA

更新时间:2021/07/21 GMT+08:00
分享

MQTT over WebSocket 使用说明

概述

平台支持基于WebSocket的MQTT协议,使基于浏览器的应用程序或者小程序可以快速接入到平台。

本文以JavaScript为例,介绍设备通过基于WebSocket的 MQTT协议接入平台,通过平台接口实现“数据上报”“命令下发”的功能。

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

前提条件

导入代码样例

  1. 下载quickStart(websocket)样例,并解压。
  2. 修改Demo里的关键工程配置参数。其中MqttOverWebsocketDemo.html需要配置host地址、设备ID和设备密钥,用于启动Demo时连接平台。

        var host = 'iot-mqtts.cn-north-4.myhuaweicloud.com'; //IoT平台mqtt对接地址
        var deviceId = '****'; //请填写在平台注册的设备ID
        var secret = '****'; //请填写在平台注册的设备密钥

程序启动

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

  1. 找到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++;
        }

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

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

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

    1
    2
    3
    4
    5
    6
    7
    8
    //上报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:
    1
    var propertiesReportJson = {'services':[{'properties':{'alarm':1,'temperature':12.670784,'humidity':18.37673,'smokeConcentration':19.97906},'service_id':'smokeDetector','event_time':null}]};
    

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

    图4 日志显示上报数据成功

    属性上报成功,平台界面如下:

    图5 平台界面显示最新上报的数据

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

接收下发命令

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

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

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

分享:

    相关文档

    相关产品