物联网开发之esp8266连接onenet控制板载小灯

Posted 2021-10-23 创客协会的阿蛋°

怎么样用索引去找数据“{}”
以及怎么样用App Inventor 去做一个app去发送信号控制

#include <ESP8266WiFi.h>
#include <ESP8266WiFiMulti.h>
#include <Ticker.h>  //导入定时器库
#include <ArduinoJson.h>
Ticker flipper;  //实例化定时器对象
int count = 0;
String led1, led2;
String led_shuju;
String shuju;
const char *ssid     = "adan";//这里写入网络的ssid
const char *password = "88888888";//wifi密码
const char *host = "183.230.40.33";//修改为Server服务端的IP，即你电脑的IP，确保在同一网络之下。
byte mark, a, b;
WiFiClient client;
const int tcpPort = 80;//修改为你建立的Server服务端的端口号，此端口号是创建服务器时指定的。
uint8_t LED = 2;           //esp8266--01s的板载小灯是2号引脚
int dakuohaodeweizhi; //做个变量为大括号的位置
int shujuchangdu; //数据长度
void setup() {
  Serial.begin(115200);
  pinMode(LED, OUTPUT);
  delay(10);
  Serial.println();
  Serial.print("Connecting to ");//会通过usb转tll模块发送到电脑，通过ide集成的串口监视器可以获取数据。
  Serial.println(ssid);
  WiFi.begin(ssid, password);//启动
  //在这里检测是否成功连接到目标网络，未连接则阻塞。
  while (WiFi.status() != WL_CONNECTED)
  {
    delay(500);
    Serial.println(".");
  }
  //几句提示
  Serial.println("");
  Serial.println("WiFi connected");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());
  // 设置睡眠模式（可选参数：WIFI_NONE_SLEEP、WIFI_LIGHT_SLEEP、WIFI_MODEM_SLEEP ）
  WiFi.setSleepMode(WIFI_LIGHT_SLEEP);
  delay(2000);
  flipper.attach(0.5, flip);//每隔0.5秒执行一次回调函数
}

void loop() {
  jian_Cha();
  get_Shu_Ju();
  post_Shu_Ju();
  print_Shu_Ju();
}



void post_Shu_Ju()//上传数据
{ a++;
  if (client.connected()) {              //若连接成功，就发送POST 请求上报数据
    b++;
    String url = "http://api.heclouds.com/devices/736615010/datapoints?type=3";  //参数type=3表示用 简洁数据格式,735131939是你在移动OneNET上创建的设备ID 不是产品的ID!!!! 一定要记住
    client.print(String("POST ") + url + " HTTP/1.1\\r\\n");                                             //使用HTTP/1.1协议
    client.print(String("api-key: ") + "Y3B9HobS89bRKlC9R4LAm6PnYaM=\\r\\n");           //一定要改为设备的API key，不是产品的API key!!!! 一定要记住
    client.print(String("Host: ") + "api.heclouds.com\\r\\n");
    String data = "{'led':" + String(b) + ",'led0':" + String(a) + "}";
    //   Serial.write("data:");
    //   Serial.print(data);
    //   Serial.print(String(data.length()));
    //   Serial.print("Content-Length:" + String(data.length()) + "\\r\\n\\r\\n");
    client.print("Content-Length:" + String(data.length()) + "\\r\\n\\r\\n");
    client.print(data);
  }
  // client.stop();                     //关闭HTTP客户端
  delay(400);
}



void get_Shu_Ju() //获取数据
{
  if (client.connected()) {
    String url = "http://api.heclouds.com/devices/736615010/datastreams/led1?type=3";  //735131939是你在移动OneNET上创建的设备ID 不是产品的ID!!!! 一定要记住
    client.print(String("GET ") + url + " HTTP/1.1\\r\\n");                                             //使用HTTP/1.1协议
    client.print(String("api-key: ") + "Y3B9HobS89bRKlC9R4LAm6PnYaM=\\r\\n");           //一定要改为设备的API key，不是产品的API key!!!! 一定要记住
    client.print(String("Host: ") + "api.heclouds.com\\r\\n");
    delay(400);
  }
}

void print_Shu_Ju()    //打印数据
{

  while (client.available())//available()表示是否可以获取到数据
  {
    shuju += char(client.read());
    delay(2);
    mark = 1;
  }

  if (mark == 1)   //获取到数据后 就可以对数据进心处理了  比如点灯
  {
    dakuohaodeweizhi = shuju.indexOf('{'); //'{'所在的位置
    shuju.length();
    led1  = String(shuju).substring(dakuohaodeweizhi, shuju.length());        //赋值led灯是shuju的第295个数据到第296个数据
    delay(500);
    jieXiJson();//解析数据
    shuju = "";
    mark = 0;     //清除获取的数据的标志位
  }
}


void jian_Cha()   //检查  检查是否连接的上服务器,如果没连接 就一直在连接，并且卡死在这里  出不去
{
  while (!client.connected())//若未连接到服务端，则客户端进行连接。
  {
    if (!client.connect(host, tcpPort))//实际上这一步就在连接服务端，如果连接上，该函数返回true，就可以跳出这个函数了
    {
      Serial.print("connection....");
      delay(500);
    }
  }
}

void jieXiJson()//解析json函数
{ //建立对象 对象名为doc
  const size_t capacity = JSON_OBJECT_SIZE(3) + JSON_OBJECT_SIZE(4) + 250;//250我瞎写的，好看
  DynamicJsonDocument doc(capacity);
  // 即将解析的json文件
  // 反序列化数据
  deserializeJson(doc, led1);
  JsonObject data = doc["data"];  //返回1证明有数据
  // 获取解析后的数据信息
 led_shuju = data["current_value"].as<String>();
  Serial.println(led_shuju); //串口打印我们的数据
  /*
    数据案例是：
    {
    "errno":0,
    "data":{
        "update_at":"2021-07-03 12:53:12",
        "id":"led1",
        "create_time":"2021-06-22 15:17:33",
        "current_value":"1"
    },
    "error":"succ"
    }
    用json库解析
    是这样子的
    首先是先建立对象 设置好对象的名字和长度
    长度=对象+数组+额位的数据长度。
    所以我们的数据有"errno""data""error"三个对象，其中"errno""error"只有一个名值对（对象，变量），
    所以=2*JSON_OBJECT_SIZE(1)
    而"data"有四个名值对，所以data的数据是JSON_OBJECT_SIZE(4)
    所以长度=2*JSON_OBJECT_SIZE(1)+JSON_OBJECT_SIZE(4)+预留的数据;(我算错了。。。)
    用位置https://arduinojson.org/v5/assistant/去算：
    const size_t capacity = JSON_OBJECT_SIZE(3) + JSON_OBJECT_SIZE(4) + 130;
    解析出来的数据是
    JsonObject& root = jsonBuffer.parseObject(doc);

    int errno = root["errno"]; // 0

    JsonObject& data = root["data"];
    const char* data_update_at = data["update_at"]; // "2021-07-03 12:53:12"   doc["data"]["update_at"]
    const char* data_id = data["id"]; // "led1"
    const char* data_create_time = data["create_time"]; // "2021-06-22 15:17:33"
    const char* data_current_value = data["current_value"]; // "1"

    const char* error = root["error"]; // "succ"


根目录可以直接找对象
 JsonObject data = doc["data"];  //有数据返回1 无数据返回0
 然后再从对象里面找值
 String led1 = data["current_value"].as<String>();
  */




}

中断：

void flip() {     //回调函数


    if (led_shuju == "1") {
         digitalWrite(LED, LOW);
    }
    if (led_shuju == "0") {
     digitalWrite(LED, HIGH);
    }
  
}