一、关于mqtt协议

mqtt协议常用于物联网，是一种轻量级的消息推送协议。

其中有三个角色，Publisher设备（客户端）发布主题到服务器，其他的设备通过订阅主题，获取该主题下的消息，Publisher可以发布消息到主题下，从而推送消息给其他设备。

选择MQTT协议的原因是其轻量化并且可以离线缓存消息在主题中，适合我们的移动低功耗低处理的设备。

二、使用微信小程序连接onenet

1.GET获取平台信息

authInfo: "version=2018-10-31&res=products%2F69lP2GPJQV%2Fdevices%2Fwenshi&et=2014049634&method=md5&sign=KiQMG9fabKZC5sQtd354Bg%3D%3D",

在小程序里，借助authInfo这个变量存放授权信息，它包含了版本、资源路径、过期时间以及签名等内容。在后续发起的 HTTP 请求的请求头中，会携带此授权信息，从而实现对平台资源的访问授权。

wx.request({
  url: "https://iot-api.heclouds.com/thingmodel/query-device-property?product_id=60KP2GPJQV&device_name=wenshi",
  header: {
    "authorization": that.data.authInfo
  },
  method: "GET",
  // 后续处理逻辑
});

小程序运用wx.request这个 API 来发送 HTTP 请求。这里是向平台的设备属性查询接口发送 GET 请求，在请求头中携带了之前提到的授权信息。平台返回的数据里包含了设备的温湿度和水位信息，成功获取后会更新到小程序的界面上。

onLoad() {
  var that = this;
  setInterval(
    function () {
      that.getinfo();
    }, 3000
  );
}

再在循环中循环去调用getinfo去循环获取平台数据。

2.POST下发数据置平台

openclick: function () {
  var that = this;
  wx.showToast({ title: 'xx', duration: 1000 }); // 显示提示
  
  wx.request({
    url: 'https://iot-api.heclouds.com/thingmodel/set-device-property?product_id=xxxxxx&device_name=xxxx',
    method: "POST",
    header: { "Authorization": that.data.authInfo }, // 身份认证信息
    data: {
      product_id: 'xxxxxxxx',
      device_name: 'xxxxx',
      params: { "key": true } // 控制参数：打开设备
    },
    success: function (res) {
      console.log('控制请求成功', res);
    },
    fail: function (err) {
      console.log('控制请求失败', err.errMsg);
    }
  });
},

将该函数绑定在按钮上，当按下按钮时执行一次该函数

3.echarts图形化显示

import * as echarts from '../../ec-canvas/echarts.min';

let chart = null;

function initChart(canvas, width, height, dpr) {
    chart = echarts.init(canvas, null, {
        width: width,
        height: height,
        devicePixelRatio: dpr
    });
    canvas.setChart(chart);
    return chart;
}