nodejs连接阿里云物联网套件(mqtt)

文档地址：https://help.aliyun.com/document_detail/73742.html
连接方法：先HTTPS认证再连接
/*
 *阿里云物联网套件nodejs连接示例
 *Created by 薛将军 on 2018/1/8. 
 */

var mqtt = require(\'mqtt\'); //mqtt
var request = require(\'request\'); //request用于https认证
var crypto = require(\'crypto\'); //加密模块

var productKey = \'物联网套件key\'; //产品key
var deviceName = \'物联网套件设备名称\'; //设备名称
var clientId = Math.random().toString(16).substr(2, 8); //自id
var deviceSecret = \'物联网套件设备密码\'; //设备密码
var host = `mqtt://${productKey}.iot-as-mqtt.cn-shanghai.aliyuncs.com:1883`; //阿里mqtt host

var content = {
    productKey: productKey,
    deviceName: deviceName,
    clientId: clientId
}

//字典排序
function sign_hmac(ct) {
    var secretString = \'\';
    for (let key of Object.keys(ct).sort()) {
        secretString += key + content[key];
    }
    return secretString;
}
//加密 crypto.createHmac(\'sha1\', deviceSecret).update(\'待加密字串\').digest(\'hex\');
var sign = crypto.createHmac(\'sha1\', deviceSecret).update(sign_hmac(content)).digest(\'hex\');

var url = \'https://iot-auth.cn-shanghai.aliyuncs.com/auth/devicename\'

var requestForm = {
    productKey: productKey,
    deviceName: deviceName,
    sign: sign,
    clientId: clientId,
    signmethod: \'hmacsha1\'
}

var params = {
    url: url,
    form: requestForm
}

//HTTPS认证
request.post(params, function(error, response, body) {
    if (error) {
        console.log(error)
    }
    if (!error && response.statusCode == 200) {
        var res = JSON.parse(body)

        var options = {
            clientId: clientId,
            username: res.data.iotId,
            password: res.data.iotToken,

        }

        var client = mqtt.connect(host, options);
        client.on(\'connect\', function() {
            console.log(\'MQTT服务器链接成功!\')
            client.subscribe(`/${productKey}/${deviceName}/send_push`)
        })

        client.on(\'error\', function(err) {
            console.log(err)
        })

        //topic
        client.on(\'message\', function(topic, message) {
            // message is Buffer
            console.log(\'收到:\' + topic + \'消息:\' + message.toString())
            client.end() //结束连接
        })
    }
})