IoT(Gateway)-阿里云IoT平台网关连接组件

硬件平台

gateway(Object option)

创建IoT Gateway实例，同时开始尝试连接阿里云IoT平台。

入参

返回

IoT Gateway实例。

addTopo(array option)

添加子设备网络拓扑。

入参

Object Array类型，其属性有：

返回

Number类型。

• 0：成功。

• 其他：失败。

getTopo(Function callback)

获取子设备网络拓扑。

入参

Function类型，回调函数返回值是Object Array对象，其属性值有：

返回

Number类型。

• 0：成功。

• 其他：失败。

removeTopo(Object option)

删除子设备网络拓扑。

入参

Object Array类型，其属性有：

返回

Number类型。

• 0：成功。

• 其他：失败。

login(Object option)

登录子设备至阿里云物联网平台。

入参

Object Array类型，其属性有：

返回

Number类型。

• 0：成功。

• 其他：失败。

logout(Object option)

子设备退出阿里云物联网平台。

入参

Object Array类型，其属性有：

返回

Number类型。

• 0：成功。

• 其他：失败。

registerSubDevice(Object option)

网关动态注册子设备至阿里云物联网平台。

入参

Object Array类型，其属性有：

返回

Number类型。

• 0：成功。

• 其他：失败。

subscribe(Object option)

订阅主题。

入参

Object类型，其属性有：

返回

Number类型。

• 0：成功。

• 其他：失败。

unsubscribe(String topic)

取消订阅主题。

入参

String类型：topic。

返回

Number类型。

• 0：成功。

• 其他：失败。

publish(Object option)

向某个主题发布消息。

入参

Object类型，其属性有：

返回

Number类型。

• 0：成功。

• 其他：失败。

getNtpTime(Function callback)

获取网络实时时间。

入参

Function类型，回调函数返回值是Object对象，其属性值有：

返回

Number类型。

• 0：成功。

• 其他：失败。

end()

断开网关和阿里云物联网平台的连接并注销实例。

入参

无。

返回

Number类型。

• 0：成功。

• 其他：失败。

事件

示例代码

import * as iot from 'iot';
import * as network from 'network';

var net = network.openNetWorkClient();

var productKey = '';   /* your gateway productKey*/
var deviceName = '';   /* your gateway deviceName */
var deviceSecret = ''; /* your gateway deviceSecret */

var lightSwitch = 0;
var gateway;

var subdev = [
    {
        productKey: '',   /* your subdev1 productKey */   
        deviceName: '',   /* your subdev1 deviceName */
        deviceSecret: ''  /* your subdev1 deviceSecret */
    },
    {
        productKey: '',   /* your subdev2 productKey */ 
        deviceName: '',   /* your subdev2 deviceName */ 
        deviceSecret: ''  /* your subdev2 deviceSecret */ 
    }
];

/* post property */
function postProperty(id, devInfo, content) {
    var topic = '/sys/' + devInfo.productKey + '/' + devInfo.deviceName + '/thing/event/property/post';
    var payload = JSON.stringify({
        id: id,
        version: '1.0',
        params: content,
        method: 'thing.event.property.post'
    });

    gateway.publish({
        topic: topic,
        payload: payload
    });
}

/* post event */
function postEvent(id, devInfo, eventId, content) {
    var topic = '/sys/' + devInfo.productKey + '/' + devInfo.deviceName + '/thing/event/' + eventId + '/post';
    var payload = JSON.stringify({
        id: id,
        version: '1.0',
        params: content,
        method: 'thing.event.' + eventId + '.post'
    });

    gateway.publish({
        topic: topic,
        payload: payload
    });
}

function createGateway() {
    gateway = iot.gateway({
        productKey: productKey,
        deviceName: deviceName,
        deviceSecret: deviceSecret
    });

    gateway.on('connect', function () {
        console.log('(re)connected');

        gateway.addTopo(subdev);

        gateway.login(subdev);

        setInterval(function () {
            postProperty(1, subdev[0], { 'PowerSwitch_1': lightSwitch });
            postEvent(1, subdev[0], 'Error', { 'ErrorCode': 0 });
        }, 2000);
    });

    /* 网络断开事件 */
    gateway.on('disconnect', function () {
        console.log('disconnect ');
    });

    /* mqtt消息 */
    gateway.on('message', function (res) {
        /* 通过 topic中的pk和dn信息，判断是对哪个子设备的调用 */
        var pk = res.topic.split('/')[2];
        var dn = res.topic.split('/')[3];
        console.log('mqtt message')
        console.log('mqtt topic is ' + res.topic);
        console.log('PK: ' + pk)
        console.log('DN: ' + dn)
        console.log('mqtt payload is ' + res.payload);
    })

    /* 关闭连接事件 */
    gateway.on('end', function () {
        console.log('iot client just closed');
    });

    /* 发生错误事件 */
    gateway.on('error', function (err) {
        console.log('error ' + err);
    });
}


var status = net.getStatus();
console.log('net status is: ' + status);

if (status == 'connect') {
    createGateway();
} else {
    net.on('connect', function () {
        createGateway();
    });
}