JS 遇上 IOT

'use strict';

$.ready(function (error) {
    if (error) {
        console.log(error);
        return;
    }

    $('#led-r').turnOn();  //点亮小灯
});

$.end(function () {
    $('#led-r').turnOff();
});

'use strict';

var fs = require('fs');
var os = require('os')
var mqtt = require('mqtt')

var productKey = '填写在阿里云物联网套件中申请的productKey'
var deviceName = '填写在阿里云物联网套件中申请的deviceName'
var deviceSecret = '填写在阿里云物联网套件中申请的deviceSecret'
var targetServer = "tcp://" + productKey + ".iot-as-mqtt.cn-shanghai.aliyuncs.com:1883"
var port = 1883
var host = productKey + '.iot-as-mqtt.cn-shanghai.aliyuncs.com'

var clientId = os.hostname();
var timestamp = (new Date()).valueOf()
var mqttClientId = clientId + "|securemode=3,signmethod=hmacsha1,timestamp=" + timestamp + "|";
var mqttUsername = deviceName + "&" + productKey
var content = 'clientId' + clientId + 'deviceName' + deviceName + 'productKey' + productKey + 'timestamp' + timestamp

// var forge = require('forge')
// var hmac = forge.hmac.create();
// hmac.start('sha1', deviceSecret);
// hmac.update(content);
// var mqttPassword = hmac.digest().toHex();
// console.log(mqttPassword)
// 目前ruff上无法使用crypto等包，可以自行实现一个hmac sha1加密
var mqttPassword = '生成的秘文';

var puburl = "/" + productKey + "/" + deviceName + "/update"
var suburl = "/" + productKey + "/" + deviceName + "/get"

var tsl_options = {
  port: port,
  host: host,
  rejectUnauthorized: false,
  keepalive: 100,
  clientId: mqttClientId,
  username: mqttUsername,
  password: mqttPassword
}


$.ready(function (error) {
  if (error) {
    console.log(error);
    return;
  }

  var mqttClient = mqtt.connect(targetServer, tsl_options)

   mqttClient.on('connect', function () {
    console.log('********** Connected **********')
    //当按键被按下时，通过mqtt协议，向阿里云mns服务发送消息
    
    $('#button').on('push', function () {
      var data = { ts: (new Date()).valueOf(), deviceName: deviceName }
      mqttClient.publish(puburl, JSON.stringify(data))
      console.log(JSON.stringify(data))
    });
    //level 0：最多一次的传输
    //level 1：至少一次的传输
    //level 2：只有一次的传输
    mqttClient.subscribe(suburl, {qos:1})
   
    //当接受到消息时控制小红灯亮灭
    mqttClient.on('message', function (topic, message) {
      var msg = message.toString()
      console.log('您接收到的消息为: ' + msg)
      if(msg=='turn_on_led'){
        $('#led-r').turnOn();
        setTimeout(function(){
          $('#led-r').turnOff();
        }, 500)
      }
    })
  })
  mqttClient.on('error', function (error) {
    console.log(error)
  })

});

const RPCClient = require('@alicloud/pop-core').RPCClient;
const MNSClient = require('@alicloud/mns');
const Base64 = require('js-base64').Base64;

var iotClient = new RPCClient({
  accessKeyId: '阿里云accessKeyId',
  secretAccessKey: '阿里云accessKeySecret',
  endpoint: 'https://iot.cn-shanghai.aliyuncs.com',
  apiVersion: '2017-04-20'
});

var mnsClient = new MNSClient('阿里云账户id', {
  region: 'cn-shanghai',
  accessKeyId: '阿里云accessKeyId',
  accessKeySecret: '阿里云accessKeySecret',
});

const queueName = 'aliyun-iot-xGEDKBE*****' //开通阿里云物联网套件生成MNS消息队列
//从队列中消费消息
setInterval(async ()=>{
  try{
    var receiveRes = await mnsClient.receiveMessage(queueName)
    var deleteRes = await mnsClient.deleteMessage(queueName, receiveRes.body.ReceiptHandle);
    var payload = JSON.parse(Base64.decode(receiveRes.body.MessageBody))
    var data = Base64.decode(payload.payload)
    console.log('从IoT设备接受到的数据为：' + data)
  } catch(err) {
    console.log(err)
  }
}, 500)


const productKey = '**********'    //阿里云物联网套件productKey
const deviceName = '**********'    //阿里云物联网套件deviceName

const iotClientParams = {
  ProductKey: productKey,
  TopicFullName: `/${productKey}/${deviceName}/get`,
  MessageContent: Base64.encode('turn_on_led'),
}

//向ruff发送消息
setInterval(async ()=>{
  try{
    var sedRes = await iotClient.request('Pub', iotClientParams)
  }catch(err){
    console.log(err)
  }
}, 2000)