Esp8266(NodeMcu)接入新大陆物联网平台并且上传温湿度

    技术2022-07-10  147

    Esp8266[NodeMcu]接入新大陆物联网

    1、平台注册和产品创建2、代码协议部分2.1 连接请求协议:2.2 数据上报部分协议 3、完整代码部分3.1 效果图:   使用Esp8266接入新大陆物联网平台,这几天找了一下物联网平台,发现这个物联网平台 新大陆物联网就自己试着接入了以下。以下是接入过程的一些记录,使用DTH11上传温度和湿度数据。

    开始先来一张,APP显示的界面图:

    1、平台注册和产品创建

      这个平台操作起来相对其它平台比较简单,注册我就不说了,这个是官方文档链接自己看看,官方文档。账号注册完成之后,进入开发者中心,开始创建产品。

    添加设备: 添加传感器:

      我自己在上传温度和湿度数据,所以我创建了2个传感器,分别对于温度和湿度数据,添加了一个生成应用,这个类似于界面化可以用来显示数据。

    2、代码协议部分

      首先在官网查看自己需要的协议文档。协议文档下载链接。我是使用的TCP连接的,所以下载了TCP协议文档。如果想要其它连接方式,自行下载文档查看。 在官方文档可以看到连接的相关协议:

    2.1 连接请求协议:

    连接请求协议代码部分:

    2.2 数据上报部分协议

    数据上传协议代码: 更多的相关协议自己在官方文档里面查看,我就不在多说了,我想说的一点是,关于上传数据的处理,程序里面使用的一个库函数,ArduinoJson库,这个库可以处理json字符,进行数据序列化和反序列化,可以看我以前的博客介绍。博客链接:https://blog.csdn.net/weixin_45488643/article/details/106818579

    3、完整代码部分

    最后贴上完整的程序代码。

    #include <ESP8266WiFi.h> #include <WiFiClient.h> #include <ArduinoJson.h> #include <SimpleDHT.h> //平台接入服务器地址ndp.nlecloud.com或IP 117.78.1.201 #define TCP_SERVER_ADDR "ndp.nlecloud.com" //服务器端口,tcp新大陆物联TCP端口8600,8700,8800 #define TCP_SERVER_PORT "8600" //WIFI名称,区分大小写,不要写错 #define DEFAULT_STASSID "tsy_B5AC58" //修改为自己WIFI //WIFI密码 #define DEFAULT_STAPSW "19980208" //设置上传速率5s(1s<=upDataTime<=60s) #define upDataTime 5*1000 //DHT11引脚值 int pinDHT11 = D4; //温湿度 // for DHT11, // VCC: 5V or 3V // GND: GND // DATA: 2 //**************************************************// SimpleDHT11 dht11(pinDHT11); //**************************************************// //最大字节数 #define MAX_PACKETSIZE 512 //设置心跳值10s #define KEEPALIVEATIME 10*1000 //tcp客户端相关初始化,默认即可 WiFiClient TCPclient; String TcpClient_Buff = ""; unsigned int TcpClient_BuffIndex = 0; unsigned long TcpClient_preTick = 0; unsigned long preHeartTick = 0;//心跳 unsigned long preTCPStartTick = 0;//连接 bool preTCPConnected = false; //相关函数初始化 //连接WIFI void doWiFiTick(); void startSTA(); //TCP初始化连接 void doTCPClientTick(); void startTCPClient(); void sendtoTCPServer(String p); //led 控制函数 void turnOnLed(); void turnOffLed(); //继电器 void turnOnLed1(); void turnOffLed1(); /* *发送数据到TCP服务器 */ void sendtoTCPServer(String p){ if (!TCPclient.connected()) { Serial.println("Client is not readly"); return; } TCPclient.print(p); Serial.println("[Send to TCPServer]:String"); Serial.println(p); } /* *初始化和服务器建立连接 */ void startTCPClient(){ if(TCPclient.connect(TCP_SERVER_ADDR, atoi(TCP_SERVER_PORT))){ Serial.print("\nConnected to server:"); Serial.printf("%s:%d\r\n",TCP_SERVER_ADDR,atoi(TCP_SERVER_PORT)); DynamicJsonDocument doc(256); // 替换成自己的 String Start_put = "{\"t\":\"1\",\"device\":\"QingYeXXXXXXXuRong\",\"Key\":\"6e34a3de19b1475fbc09dd75XXXXXXXXXXXca74916a\",\"ver\":\"v1.1\"}"; //替换成自己的 deserializeJson(doc, Start_put); //创建数据 sendtoTCPServer(Start_put); preTCPConnected = true; preHeartTick = millis(); TCPclient.setNoDelay(true); } else{ Serial.print("Failed connected to server:"); Serial.println(TCP_SERVER_ADDR); TCPclient.stop(); preTCPConnected = false; } preTCPStartTick = millis(); } /* *检查数据,发送心跳 */ void doTCPClientTick(){ //检查是否断开,断开后重连 if(WiFi.status() != WL_CONNECTED) return; if (!TCPclient.connected()) {//断开重连 if(preTCPConnected == true){ preTCPConnected = false; preTCPStartTick = millis(); Serial.println(); Serial.println("TCP Client disconnected."); TCPclient.stop(); } else if(millis() - preTCPStartTick > 1*1000)//重新连接 startTCPClient(); } else { if (TCPclient.available()) {//收数据 char c =TCPclient.read(); TcpClient_Buff +=c; TcpClient_BuffIndex++; TcpClient_preTick = millis(); if(TcpClient_BuffIndex>=MAX_PACKETSIZE - 1){ TcpClient_BuffIndex = MAX_PACKETSIZE-2; TcpClient_preTick = TcpClient_preTick - 200; } preHeartTick = millis(); } if(millis() - preHeartTick >= KEEPALIVEATIME){//保持心跳 preHeartTick = millis(); Serial.println("--Keep alive:"); sendtoTCPServer("$#AT#\r\n"); } } if((TcpClient_Buff.length() >= 1) && (millis() - TcpClient_preTick>=200)) {//data ready TCPclient.flush(); Serial.println("Buff"); Serial.println(TcpClient_Buff); TcpClient_Buff=""; TcpClient_BuffIndex = 0; } //上传数据 //DTH11上传数据 if (millis() - preHeartTick >= upDataTime) { //上传数据 preHeartTick = millis(); /*****************获取DHT11 温湿度*****************/ // read without samples. byte temperature = 0; byte humidity = 0; int err = SimpleDHTErrSuccess; if ((err = dht11.read(&temperature, &humidity, NULL)) != SimpleDHTErrSuccess) { Serial.print("Read DHT11 failed, err="); Serial.println(err); delay(1000); return; } /*********************数据上传*******************/ DynamicJsonDocument doc(1024); //替换成自己需要的 String input = "{\"t\":\"3\",\"datatype\":1,\"datas\":{\"Temp\":temperature,\"Hum\":humidity}}"; //替换成自己需要的 deserializeJson(doc, input); //创建数据 //Serial.println(input); JsonObject obj = doc.as<JsonObject>(); obj["datas"]["Temp"] = temperature; obj["datas"]["Hum"] = humidity; String output; serializeJson(doc, output); sendtoTCPServer(output); //Serial.println(output); } } void startSTA(){ WiFi.disconnect(); WiFi.mode(WIFI_STA); WiFi.begin(DEFAULT_STASSID, DEFAULT_STAPSW); } /************************************************************************** WIFI ***************************************************************************/ /* WiFiTick 检查是否需要初始化WiFi 检查WiFi是否连接上,若连接成功启动TCP Client 控制指示灯 */ void doWiFiTick(){ static bool startSTAFlag = false; static bool taskStarted = false; static uint32_t lastWiFiCheckTick = 0; if (!startSTAFlag) { startSTAFlag = true; startSTA(); Serial.printf("Heap size:%d\r\n", ESP.getFreeHeap()); } //未连接1s重连 if ( WiFi.status() != WL_CONNECTED ) { if (millis() - lastWiFiCheckTick > 1000) { lastWiFiCheckTick = millis(); } } //连接成功建立 else { if (taskStarted == false) { taskStarted = true; Serial.print("\r\nGet IP Address: "); Serial.println(WiFi.localIP()); startTCPClient(); } } } // void turnOnLed1(){ Serial.println("Turn ON"); digitalWrite(LED_Pin,LOW); } //继电器 void turnOffLed1(){ Serial.println("Turn OFF"); digitalWrite(LED_Pin,HIGH); } //打开灯泡 void turnOnLed(){ Serial.println("Turn ON"); digitalWrite(LED_Pin_led,LOW); } //关闭灯泡 void turnOffLed(){ Serial.println("Turn OFF"); digitalWrite(LED_Pin_led,HIGH); } // 初始化,相当于main 函数 void setup() { Serial.begin(115200); pinMode(LED_Pin_led,OUTPUT); pinMode(LED_Pin,OUTPUT); digitalWrite(LED_Pin_led,HIGH); digitalWrite(LED_Pin,HIGH); } //循环 void loop() { doWiFiTick(); doTCPClientTick(); }

      代码最后部分,我有一些函数,虽然我没有使用但是可以直接拓展外设。 关于界面部分,大家自行在官网查看也比较简单操作,我就不在说了。

    3.1 效果图:

    最后,希望小伙伴,随手给个赞呗。

    Processed: 0.016, SQL: 9