阿里云 - 微消息队列 MQTT

2020-03-08 本文已影响0人 1bdd9a4a74a2

玩了一下阿里的 mqtt, 感觉要放弃了

demo

// 开源sdk地址：https://github.com/mqttjs/MQTT.js
var mqtt = require('mqtt')
var CryptoJS = require('crypto-js')

var accessKey='xxxx'
var secretKey='xxxx'

var clientId = 'GID_dev@@@hardware2'
var instanceId='mqtt-cn-xxxx'

// https://help.aliyun.com/document_detail/48271.html
var username = 'Signature|' + accessKey + '|' + instanceId;
var password = CryptoJS.HmacSHA1(clientId, secretKey).toString(CryptoJS.enc.Base64);

var options={
    'username':username,
    'password':password,
    'clientId':clientId,
        'keepalive':90,
        'connectTimeout': 3000
}

// //tls安全连接："tls://host:8883"
var client  = mqtt.connect('tcp://host:1883',options)

var topic='dev'

// client.on('connect', function () {
//   client.subscribe(topic, {'qos':1})
// })

// client.on('message', function (topic, message) {
//   console.log('topic:'+topic+' msg:'+message.toString())
// })

var i=0
setInterval(function(){
  client.publish(topic + '/test/1', 'Hello mqtt ' + (i++))
  // client.publish(topic + '/p2p/' + clientId, 'Hello mqtt ' + (i++))
},1000)