https://open.iot.10086.cn/doc/v5/develop/detail/582
https://console.apipost.cn/apis/project
| index.js | 页面逻辑代码用js实现 |
| index.json | json数据 |
| index.wxml | 页面标记语言与HTML相似 |
| index.wxss | 页面样式 |
Page({data: {temperature:"0",humidity: "0",},//周期函数onLoad: function () {setInterval(function () {this.init()}.bind(this), 1000)},init: function () {var that = thiswx.request({url: "https://api.heclouds.com/devices/********/datapoints", //将请求行中的数字换成自己的设备IDheader: {"api-key": "***************" //换成自己的api-key},data: {limit: 1},method: "GET",success: function (e) {console.log(e.data.data)that.setData({humidity: e.data.data.datastreams[0].datapoints[0].value,temperature : e.data.data.datastreams[1].datapoints[0].value,})}});}})
humidity: e.data.data.datastreams[0].datapoints[0].value,temperature : e.data.data.datastreams[1].datapoints[0].value
ESP32 MQTT旧版本程序与新版本有区别但不大，旧版本鉴权信息可以自己设定。
#include#include "WiFi.h"#include "PubSubClient.h"#include "Ticker.h"#includeconst char *ssid = "Redmi K40"; //wifi名const char *password = "********"; //wifi密码const char *mqtt_server = "183.230.40.39"; //onenet 的 IP地址const int led =2; //灯的接口#define mqtt_devid "*****" //设备ID#define mqtt_pubid "*****" //产品ID//鉴权信息#define mqtt_password "*****" //鉴权信息（自己设定的不需要token）#define Addr_SHT30 0x44 // SHT30 IIC 7位地址为0x44#define SDA_PIN 21 //引脚接法在这里#define SCL_PIN 22WiFiClient espClient; //创建一个WIFI连接客户端PubSubClient client(espClient); // 创建一个PubSub客户端, 传入创建的WIFI客户端char msg_buf[200]; //发送信息缓冲区char dataTemplate[] = "{\"temp\":%.2f,\"hum\":%.2f}"; //信息模板char msgJson[75]; //要发送的json格式的数据unsigned short json_len = 0; //json长度Ticker tim1; //定时器,用来循环上传数据//连接WIFI相关函数void setupWifi(){delay(10);Serial.println("连接WIFI");WiFi.begin(ssid, password);while (!WiFi.isConnected()){Serial.print(".");delay(500);}Serial.println("OK");Serial.println("Wifi连接成功");}//收到主题下发的回调, 注意这个回调要实现三个形参 1:topic 主题, 2: payload: 传递过来的信息 3: length: 长度void callback(char *topic, byte *payload, unsigned int length){Serial.println("message rev:");Serial.println(topic);for (size_t i = 0; i < length; i++){Serial.print((char)payload[i]);}Serial.println();if ((char)payload[0] == '0') {digitalWrite(led, LOW); //} if ((char)payload[0] == '1') {digitalWrite(led, HIGH); //}else{}}//向主题发送模拟的温湿度数据void sendTempAndHumi(){if (client.connected()){unsigned int data[6]; //存储获取到的六个数据Wire.beginTransmission(Addr_SHT30);//开始IIC //写地址Wire.write(0x2C); //发送测量命令 0x2C06,但是因为IIC一次只能发一个8位数据，所以得发两次Wire.write(0x06); //停止IICWire.endTransmission(); //等待500ms是等待SHT30器件测量数据，实际上这个时间可以很短delay(500);Wire.requestFrom(Addr_SHT30, 6); //请求获取6字节的数据，然后会存到8266的内存里if (Wire.available() == 6) //读取6字节的数据，这六个字节分别为：温度8位高数据，温度8位低数据，温度8位CRC校验数据，湿度8位高数据，湿度8位低数据，湿度8位CRC校验数据{data[0] = Wire.read();data[1] = Wire.read();data[2] = Wire.read();data[3] = Wire.read();data[4] = Wire.read();data[5] = Wire.read();}float temp = ((((data[0] * 256.0) + data[1]) * 175) / 65535.0) - 45; //然后计算得到的数据，要转化为摄氏度、相对湿度float hum = ((((data[3] * 256.0) + data[4]) * 100) / 65535.0);snprintf(msgJson, 40, dataTemplate, temp, hum); //将模拟温湿度数据套入dataTemplate模板中, 生成的字符串传给msgJsonjson_len = strlen(msgJson); //msgJson的长度msg_buf[0] = char(0x03); //要发送的数据必须按照ONENET的要求发送, 根据要求,数据第一位是3msg_buf[1] = char(json_len >> 8); //数据第二位是要发送的数据长度的高八位msg_buf[2] = char(json_len & 0xff); //数据第三位是要发送数据的长度的低八位memcpy(msg_buf + 3, msgJson, strlen(msgJson)); //从msg_buf的第四位开始,放入要传的数据msgJsonmsg_buf[3 + strlen(msgJson)] = 0; //添加一个0作为最后一位, 这样要发送的msg_buf准备好了Serial.print("public message:");Serial.println(msgJson);client.publish("$dp", (uint8_t *)msg_buf, 3 + strlen(msgJson)); //发送数据到主题$dp}}//重连函数, 如果客户端断线,可以通过此函数重连void clientReconnect(){while (!client.connected()) //再重连客户端{Serial.println("reconnect MQTT...");if (client.connect(mqtt_devid, mqtt_pubid, mqtt_password)){Serial.println("connected");}else{Serial.println("failed");Serial.println(client.state());Serial.println("try again in 5 sec");delay(5000);}}}void setup(){pinMode(led,OUTPUT);//输出Wire.begin(SDA_PIN, SCL_PIN); //初始化IIC(作为主设备)Serial.begin(115200); //初始化串口delay(3000); //这个延时是为了让我打开串口助手setupWifi(); //调用函数连接WIFIclient.setServer(mqtt_server, 6002); //设置客户端连接的服务器,连接Onenet服务器, 使用6002端口client.connect(mqtt_devid, mqtt_pubid, mqtt_password); //客户端连接到指定的产品的指定设备.同时输入鉴权信息client.setCallback(callback); //设置好客户端收到信息是的回调tim1.attach(1, sendTempAndHumi); //定时每1秒调用一次发送数据函数sendTempAndHumi}void loop(){if (!WiFi.isConnected()) //先看WIFI是否还在连接{setupWifi();}if (!client.connected()) //如果客户端没连接ONENET, 重新连接{clientReconnect();}client.loop(); //客户端循环检测}
