STM32+ESP8266上传温湿度数据至新版OneNET

欢迎大家来到IT世界,在知识的湖畔探索吧!

本文详细介绍了，STM32连接新版OneNET平台上报温湿度数据的操作与步骤。

使用资源：

STM32F103C8T6、ESPF、DHT11温湿度传感器

通讯协议：

MQTT

数据格式：

CJson

一、OneNET平台创建

1. 登录https://open.iot.10086.cn/，注册账号、登录。

2. 点击右上角的“开发者中心”进入产品开发界面

3. 创建产品，点击左侧“产品中心”然后在主界面右侧“创建产品”

创建产品信息：

添加产品物模型信息：点击创建产品的“产品开发”

编辑物模型：点击“设置物模型”，只保留当前温度和当前湿度，删除多余物模型即可

4. 添加设备

点击左侧“设备管理”，然后点击“添加设备”

添加设备信息：

5. 设备信息查看

二、设备端代码编写

主要代码包含：esp8266.c、mqtt.c、onenet.c、main.c

1. esp8266.c

首先对GPIOA进行初始化，将GPIOA0配置为复位引脚。然后进行ESP8266模块的复位操作。接着调用ESP8266_Clear函数清空ESP8266模块的接收缓存区。之后分别发送AT指令，设置模块为STA模式、连接WiFi、连接到OneNet平台。最后输出ESP8266初始化成功的信息。

//单片机头文件 #include "stm32f10x.h" //网络设备驱动 #include "esp8266.h" //硬件驱动 #include "delay.h" #include "usart.h" //C库 #include <string.h> #include <stdio.h> #define ESP8266_WIFI_INFO "AT+CWJAP=\"xxxxx",\"xxxxx\"\r\n" #define ESP8266_ONENET_INFO "AT+CIPSTART=\"TCP\",\"mqtts.heclouds.com\",1883\r\n" //新版OneNET地址 unsigned char esp8266_buf[128]; unsigned short esp8266_cnt = 0, esp8266_cntPre = 0; //========================================================== // 函数名称： ESP8266_Clear // // 函数功能： 清空缓存 // // 入口参数： 无 // // 返回参数： 无 // // 说明： //========================================================== void ESP8266_Clear(void) { memset(esp8266_buf, 0, sizeof(esp8266_buf)); esp8266_cnt = 0; } //========================================================== // 函数名称： ESP8266_WaitRecive // // 函数功能： 等待接收完成 // // 入口参数： 无 // // 返回参数： REV_OK-接收完成 REV_WAIT-接收超时未完成 // // 说明： 循环调用检测是否接收完成 //========================================================== _Bool ESP8266_WaitRecive(void) { if(esp8266_cnt == 0) //如果接收计数为0 则说明没有处于接收数据中，所以直接跳出，结束函数 return REV_WAIT; if(esp8266_cnt == esp8266_cntPre) //如果上一次的值和这次相同，则说明接收完毕 { esp8266_cnt = 0; //清0接收计数 return REV_OK; //返回接收完成标志 } esp8266_cntPre = esp8266_cnt; //置为相同 return REV_WAIT; //返回接收未完成标志 } //========================================================== // 函数名称： ESP8266_SendCmd // // 函数功能： 发送命令 // // 入口参数： cmd：命令 // res：需要检查的返回指令 // // 返回参数： 0-成功 1-失败 // // 说明： //========================================================== _Bool ESP8266_SendCmd(char *cmd, char *res) { unsigned char timeOut = 200; Usart_SendString(USART2, (unsigned char *)cmd, strlen((const char *)cmd)); while(timeOut--) { if(ESP8266_WaitRecive() == REV_OK) //如果收到数据 { if(strstr((const char *)esp8266_buf, res) != NULL) //如果检索到关键词 { ESP8266_Clear(); //清空缓存 return 0; } } delay_ms(10); } return 1; } //========================================================== // 函数名称： ESP8266_SendData // // 函数功能： 发送数据 // // 入口参数： data：数据 // len：长度 // // 返回参数： 无 // // 说明： //========================================================== void ESP8266_SendData(unsigned char *data, unsigned short len) { char cmdBuf[200]; ESP8266_Clear(); //清空接收缓存 sprintf(cmdBuf, "AT+CIPSEND=%d\r\n", len); //发送命令 if(!ESP8266_SendCmd(cmdBuf, ">")) //收到‘>’时可以发送数据 { Usart_SendString(USART2, data, len); //发送设备连接请求数据 } } //========================================================== // 函数名称： ESP8266_GetIPD // // 函数功能： 获取平台返回的数据 // // 入口参数： 等待的时间(乘以10ms) // // 返回参数： 平台返回的原始数据 // // 说明： 不同网络设备返回的格式不同，需要去调试 // 如ESP8266的返回格式为 "+IPD,x:yyy" x代表数据长度，yyy是数据内容 //========================================================== unsigned char *ESP8266_GetIPD(unsigned short timeOut) { char *ptrIPD = NULL; do { if(ESP8266_WaitRecive() == REV_OK) //如果接收完成 { ptrIPD = strstr((char *)esp8266_buf, "IPD,"); //搜索“IPD”头 if(ptrIPD == NULL) //如果没找到，可能是IPD头的延迟，还是需要等待一会，但不会超过设定的时间 { //UsartPrintf(USART_DEBUG, "\"IPD\" not found\r\n"); } else { ptrIPD = strchr(ptrIPD, ':'); //找到':' if(ptrIPD != NULL) { ptrIPD++; return (unsigned char *)(ptrIPD); } else return NULL; } } // UsartPrintf(USART_DEBUG,"ESP8266_WaitRecive: %s\n", esp8266_buf); //提示打印信息 delay_ms(5); //延时等待 } while(timeOut--); return NULL; //超时还未找到，返回空指针 } //========================================================== // 函数名称： ESP8266_Init // // 函数功能： 初始化ESP8266 // // 入口参数： 无 // // 返回参数： 无 // // 说明： //========================================================== void ESP8266_Init(void) { GPIO_InitTypeDef GPIO_Initure; RCC_APB2PeriphClockCmd(RCC_APB2Periph_GPIOA, ENABLE); //ESP8266复位引脚 GPIO_Initure.GPIO_Mode = GPIO_Mode_Out_PP; GPIO_Initure.GPIO_Pin = GPIO_Pin_0; //GPIOA0-复位 GPIO_Initure.GPIO_Speed = GPIO_Speed_50MHz; GPIO_Init(GPIOA, &GPIO_Initure); GPIO_WriteBit(GPIOA, GPIO_Pin_0, Bit_RESET); delay_ms(250); GPIO_WriteBit(GPIOA, GPIO_Pin_0, Bit_SET); delay_ms(500); ESP8266_Clear(); UsartPrintf(USART_DEBUG, "1. AT\r\n"); while(ESP8266_SendCmd("AT\r\n", "OK")) delay_ms(500); UsartPrintf(USART_DEBUG, "2. CWMODE\r\n"); while(ESP8266_SendCmd("AT+CWMODE=1\r\n", "OK")) delay_ms(500); UsartPrintf(USART_DEBUG, "3. CWJAP\r\n"); while(ESP8266_SendCmd(ESP8266_WIFI_INFO, "GOT IP")) delay_ms(500); UsartPrintf(USART_DEBUG, "4. CIPSTART\r\n"); while(ESP8266_SendCmd(ESP8266_ONENET_INFO, "CONNECT")) delay_ms(500); UsartPrintf(USART_DEBUG, "5. ESP8266 Init OK\r\n"); } 

欢迎大家来到IT世界,在知识的湖畔探索吧!

2. mqtt.c

MQTT程序编写流程如下：

引入MQTT库和所需的头文件。

连接WiFi网络。

连接MQTT服务器。

订阅需要接收的主题。

在程序中实现消息的发布和接收。

关闭MQTT连接。

主要代码如下：

欢迎大家来到IT世界,在知识的湖畔探索吧! //========================================================== // 函数名称： EDP_NewBuffer // // 函数功能： 申请内存 // // 入口参数： edpPacket：包结构体 // size：大小 // // 返回参数： 无 // // 说明： 1.可使用动态分配来分配内存 // 2.可使用局部或全局数组来指定内存 //========================================================== void MQTT_NewBuffer(MQTT_PACKET_STRUCTURE *mqttPacket, uint32 size) { uint32 i = 0; if(mqttPacket->_data == NULL) { mqttPacket->_memFlag = MEM_FLAG_ALLOC; mqttPacket->_data = (uint8 *)MQTT_MallocBuffer(size); if(mqttPacket->_data != NULL) { mqttPacket->_len = 0; mqttPacket->_size = size; for(; i < mqttPacket->_size; i++) mqttPacket->_data[i] = 0; } } else { mqttPacket->_memFlag = MEM_FLAG_STATIC; for(; i < mqttPacket->_size; i++) mqttPacket->_data[i] = 0; mqttPacket->_len = 0; if(mqttPacket->_size < size) mqttPacket->_data = NULL; } } //========================================================== // 函数名称： MQTT_DeleteBuffer // // 函数功能： 释放数据内存 // // 入口参数： edpPacket：包结构体 // // 返回参数： 无 // // 说明： //========================================================== void MQTT_DeleteBuffer(MQTT_PACKET_STRUCTURE *mqttPacket) { if(mqttPacket->_memFlag == MEM_FLAG_ALLOC) MQTT_FreeBuffer(mqttPacket->_data); mqttPacket->_data = NULL; mqttPacket->_len = 0; mqttPacket->_size = 0; mqttPacket->_memFlag = MEM_FLAG_NULL; } int32 MQTT_DumpLength(size_t len, uint8 *buf) { int32 i = 0; for(i = 1; i <= 4; ++i) { *buf = len % 128; len >>= 7; if(len > 0) { *buf |= 128; ++buf; } else { return i; } } return -1; } int32 MQTT_ReadLength(const uint8 *stream, int32 size, uint32 *len) { int32 i; const uint8 *in = stream; uint32 multiplier = 1; *len = 0; for(i = 0; i < size; ++i) { *len += (in[i] & 0x7f) * multiplier; if(!(in[i] & 0x80)) { return i + 1; } multiplier <<= 7; if(multiplier >= ) //128 * *128 * *128 { return -2; // error, out of range } } return -1; // not complete } //========================================================== // 函数名称： MQTT_UnPacketRecv // // 函数功能： MQTT数据接收类型判断 // // 入口参数： dataPtr：接收的数据指针 // // 返回参数： 0-成功 其他-失败原因 // // 说明： //========================================================== uint8 MQTT_UnPacketRecv(uint8 *dataPtr) { uint8 status = 255; uint8 type = dataPtr[0] >> 4; //类型检查 if(type < 1 || type > 14) return status; if(type == MQTT_PKT_PUBLISH) { uint8 *msgPtr; uint32 remain_len = 0; msgPtr = dataPtr + MQTT_ReadLength(dataPtr + 1, 4, &remain_len) + 1; if(remain_len < 2 || dataPtr[0] & 0x01) //retain return 255; if(remain_len < ((uint16)msgPtr[0] << 8 | msgPtr[1]) + 2) return 255; if(strstr((int8 *)msgPtr + 2, CMD_TOPIC_PREFIX) != NULL) //如果是命令下发 status = MQTT_PKT_CMD; else status = MQTT_PKT_PUBLISH; } else status = type; return status; } //========================================================== // 函数名称： MQTT_PacketConnect // // 函数功能： 连接消息组包 // // 入口参数： user：用户名：产品ID // password：密码：鉴权信息或apikey // devid：设备ID // cTime：连接保持时间 // clean_session：离线消息清除标志 // qos：重发标志 // will_topic：异常离线topic // will_msg：异常离线消息 // will_retain：消息推送标志 // mqttPacket：包指针 // // 返回参数： 0-成功 其他-失败 // // 说明： //========================================================== uint8 MQTT_PacketConnect(const int8 *user, const int8 *password, const int8 *devid, uint16 cTime, uint1 clean_session, uint1 qos, const int8 *will_topic, const int8 *will_msg, int32 will_retain, MQTT_PACKET_STRUCTURE *mqttPacket) { uint8 flags = 0; uint8 will_topic_len = 0; uint16 total_len = 15; int16 len = 0, devid_len = strlen(devid); int16 user_len = strlen(user),password_len = strlen(password); if(!devid) return 1; total_len += devid_len + 2; //断线后，是否清理离线消息：1-清理 0-不清理-------------------------------------------- if(clean_session) { flags |= MQTT_CONNECT_CLEAN_SESSION; } //异常掉线情况下，服务器发布的topic------------------------------------------------------ if(will_topic) { flags |= MQTT_CONNECT_WILL_FLAG; will_topic_len = strlen(will_topic); total_len += 4 + will_topic_len + strlen(will_msg); } //qos级别--主要用于PUBLISH（发布态）消息的，保证消息传递的次数----------------------------- switch((unsigned char)qos) { case MQTT_QOS_LEVEL0: flags |= MQTT_CONNECT_WILL_QOS0; //最多一次 break; case MQTT_QOS_LEVEL1: flags |= (MQTT_CONNECT_WILL_FLAG | MQTT_CONNECT_WILL_QOS1); //最少一次 break; case MQTT_QOS_LEVEL2: flags |= (MQTT_CONNECT_WILL_FLAG | MQTT_CONNECT_WILL_QOS2); //只有一次 break; default: return 2; } //主要用于PUBLISH(发布态)的消息，表示服务器要保留这次推送的信息，如果有新的订阅者出现，就把这消息推送给它。如果不设那么推送至当前订阅的就释放了 if(will_retain) { flags |= (MQTT_CONNECT_WILL_FLAG | MQTT_CONNECT_WILL_RETAIN); } //账号为空 密码为空--------------------------------------------------------------------- if(!user || !password) { return 3; } flags |= MQTT_CONNECT_USER_NAME | MQTT_CONNECT_PASSORD; total_len += strlen(user) + strlen(password) + 4; //分配内存----------------------------------------------------------------------------- MQTT_NewBuffer(mqttPacket, total_len); if(mqttPacket->_data == NULL) return 4; memset(mqttPacket->_data, 0, total_len); /*固定头部*/ //固定头部----------------------连接请求类型--------------------------------------------- mqttPacket->_data[mqttPacket->_len++] = MQTT_PKT_CONNECT << 4; //固定头部----------------------剩余长度值----------------------------------------------- len = MQTT_DumpLength(total_len - 5, mqttPacket->_data + mqttPacket->_len); if(len < 0) { MQTT_DeleteBuffer(mqttPacket); return 5; } else mqttPacket->_len += len; /*可变头部*/ //可变头部----------------------协议名长度 和 协议名-------------------------------------- mqttPacket->_data[mqttPacket->_len++] = 0; mqttPacket->_data[mqttPacket->_len++] = 4; mqttPacket->_data[mqttPacket->_len++] = 'M'; mqttPacket->_data[mqttPacket->_len++] = 'Q'; mqttPacket->_data[mqttPacket->_len++] = 'T'; mqttPacket->_data[mqttPacket->_len++] = 'T'; //可变头部----------------------protocol level 4----------------------------------------- mqttPacket->_data[mqttPacket->_len++] = 4; //可变头部----------------------连接标志(该函数开头处理的数据)----------------------------- mqttPacket->_data[mqttPacket->_len++] = flags; //可变头部----------------------保持连接的时间(秒)---------------------------------------- mqttPacket->_data[mqttPacket->_len++] = MOSQ_MSB(cTime); mqttPacket->_data[mqttPacket->_len++] = MOSQ_LSB(cTime); /*消息体/ //消息体----------------------------devid长度、devid------------------------------------- mqttPacket->_data[mqttPacket->_len++] = MOSQ_MSB(devid_len); mqttPacket->_data[mqttPacket->_len++] = MOSQ_LSB(devid_len); strncat((int8 *)mqttPacket->_data + mqttPacket->_len, devid, devid_len); mqttPacket->_len += devid_len; // UsartPrintf(USART_DEBUG,"111: %s\r\n", PROID); // UsartPrintf(USART_DEBUG,"mqttPacket._data content: %s\n", mqttPacket->_data); //消息体----------------------------will_flag 和 will_msg--------------------------------- if(flags & MQTT_CONNECT_WILL_FLAG) { unsigned short mLen = 0; if(!will_msg) will_msg = ""; mLen = strlen(will_topic); mqttPacket->_data[mqttPacket->_len++] = MOSQ_MSB(mLen); mqttPacket->_data[mqttPacket->_len++] = MOSQ_LSB(mLen); strncat((int8 *)mqttPacket->_data + mqttPacket->_len, will_topic, mLen); mqttPacket->_len += mLen; mLen = strlen(will_msg); mqttPacket->_data[mqttPacket->_len++] = MOSQ_MSB(mLen); mqttPacket->_data[mqttPacket->_len++] = MOSQ_LSB(mLen); strncat((int8 *)mqttPacket->_data + mqttPacket->_len, will_msg, mLen); mqttPacket->_len += mLen; } //消息体----------------------------use--------------------------------------------------- if(flags & MQTT_CONNECT_USER_NAME) { unsigned short user_len = strlen(user); mqttPacket->_data[mqttPacket->_len++] = MOSQ_MSB(user_len); mqttPacket->_data[mqttPacket->_len++] = MOSQ_LSB(user_len); strncat((int8 *)mqttPacket->_data + mqttPacket->_len, user, user_len); mqttPacket->_len += user_len; } //消息体----------------------------password---------------------------------------------- if(flags & MQTT_CONNECT_PASSORD) { unsigned short psw_len = strlen(password); mqttPacket->_data[mqttPacket->_len++] = MOSQ_MSB(psw_len); mqttPacket->_data[mqttPacket->_len++] = MOSQ_LSB(psw_len); strncat((int8 *)mqttPacket->_data + mqttPacket->_len, password, psw_len); mqttPacket->_len += psw_len; } return 0; } 

3. onenet.c

函数OneNet_DevLink用于与OneNet平台建立连接；函数MqttOnenet_Savedata将温湿度数据转换为JSON数据形式；函数OneNet_SendData用于上传数据到平台。该代码使用了MQTT协议进行通信。

#define PROID "xxxxx" //产品ID #define AUTH_INFO "xxxxxxx" //鉴权信息 #define DEVID "xxxx" //设备名称 extern unsigned char esp8266_buf[128]; //========================================================== // 函数名称： OneNet_DevLink // // 函数功能： 与onenet创建连接 // // 入口参数： 无 // // 返回参数： 1-成功 0-失败 // // 说明： 与onenet平台建立连接 //========================================================== _Bool OneNet_DevLink(void) { MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0}; //协议包 unsigned char *dataPtr; _Bool status = 1; UsartPrintf(USART_DEBUG, "OneNet_DevLink\r\n" "PROID: %s, AUIF: %s, DEVID:%s\r\n" , PROID, AUTH_INFO, DEVID); if(MQTT_PacketConnect(PROID, AUTH_INFO, DEVID, 256, 1, MQTT_QOS_LEVEL0, NULL, NULL, 0, &mqttPacket) == 0) //修改clean_session=1 { ESP8266_SendData(mqttPacket._data, mqttPacket._len); //上传平台 dataPtr = ESP8266_GetIPD(250); //等待平台响应 if(dataPtr != NULL) { if(MQTT_UnPacketRecv(dataPtr) == MQTT_PKT_CONNACK) { switch(MQTT_UnPacketConnectAck(dataPtr)) { case 0:UsartPrintf(USART_DEBUG, "Tips: 连接成功\r\n");status = 0;break; case 1:UsartPrintf(USART_DEBUG, "WARN: 连接失败：协议错误\r\n");break; case 2:UsartPrintf(USART_DEBUG, "WARN: 连接失败：非法的clientid\r\n");break; case 3:UsartPrintf(USART_DEBUG, "WARN: 连接失败：服务器失败\r\n");break; case 4:UsartPrintf(USART_DEBUG, "WARN: 连接失败：用户名或密码错误\r\n");break; case 5:UsartPrintf(USART_DEBUG, "WARN: 连接失败：非法链接(比如token非法)\r\n");break; default:UsartPrintf(USART_DEBUG, "ERR: 连接失败：未知错误\r\n");break; } } } MQTT_DeleteBuffer(&mqttPacket); //删包 } else UsartPrintf(USART_DEBUG, "WARN: MQTT_PacketConnect Failed\r\n"); return status; } //访问ONENET需要提交JSON数据，就获取到的温湿度转换为JSON数据形式 unsigned char MqttOnenet_Savedata(char *t_payload) { extern u8 temperature; extern u8 humidity; // u8 temperature = 12; //调试使用 // u8 humidity = 12; char json[]="{\"id\":\"0\",\"version\":\"1.0\",\"params\":{\"humidity_value\":{\"value\":%d},\"temp_value\":{\"value\":%d}}}"; //更换了JSON数据形式，符合OneNET需求 char t_json[200]; unsigned short json_len; sprintf(t_json, json, temperature, humidity); json_len = strlen(t_json)/sizeof(char); memcpy(t_payload, t_json, json_len); return json_len; } //========================================================== // 函数名称： OneNet_SendData // // 函数功能： 上传数据到平台 // // 入口参数： type：发送数据的格式 // // 返回参数： 无 // // 说明： //========================================================== void OneNet_SendData(void) { MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0}; //协议包 char buf[128]; short body_len = 0, i = 0; UsartPrintf(USART_DEBUG, "Tips: OneNet_SendData-MQTT\r\n"); memset(buf, 0, sizeof(buf)); //清空buff body_len=MqttOnenet_Savedata(buf); if(body_len) { if(MQTT_PacketSaveData(DEVID, body_len, NULL, 5, &mqttPacket) == 0) //封包 { for(; i < body_len; i++) mqttPacket._data[mqttPacket._len++] = buf[i]; ESP8266_SendData(mqttPacket._data, mqttPacket._len); //上传数据到平台 UsartPrintf(USART_DEBUG, "Send %d Bytes\r\n", mqttPacket._len); MQTT_DeleteBuffer(&mqttPacket); //删包 } else { UsartPrintf(USART_DEBUG, "WARN: EDP_NewBuffer Failed\r\n"); } } } //========================================================== // 函数名称： OneNet_RevPro // // 函数功能： 平台返回数据检测 // // 入口参数： dataPtr：平台返回的数据 // // 返回参数： 无 // // 说明： //========================================================== void OneNet_RevPro(unsigned char *cmd) { MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0}; //协议包 char *req_payload = NULL; char *cmdid_topic = NULL; unsigned short req_len = 0; unsigned char type = 0; short result = 0; char *dataPtr = NULL; char numBuf[10]; int num = 0; type = MQTT_UnPacketRecv(cmd); switch(type) { case MQTT_PKT_CMD: //命令下发 result = MQTT_UnPacketCmd(cmd, &cmdid_topic, &req_payload, &req_len); //解出topic和消息体 if(result == 0) { UsartPrintf(USART_DEBUG, "cmdid: %s, req: %s, req_len: %d\r\n", cmdid_topic, req_payload, req_len); if(MQTT_PacketCmdResp(cmdid_topic, req_payload, &mqttPacket) == 0) //命令回复组包 { UsartPrintf(USART_DEBUG, "Tips: Send CmdResp\r\n"); ESP8266_SendData(mqttPacket._data, mqttPacket._len); //回复命令 MQTT_DeleteBuffer(&mqttPacket); //删包 } } break; case MQTT_PKT_PUBACK: //发送Publish消息，平台回复的Ack if(MQTT_UnPacketPublishAck(cmd) == 0) UsartPrintf(USART_DEBUG, "Tips: MQTT Publish Send OK\r\n"); break; default: result = -1; break; } ESP8266_Clear(); //清空缓存 if(result == -1) return; dataPtr = strchr(req_payload, '}'); //搜索'}' if(dataPtr != NULL && result != -1) //如果找到了 { dataPtr++; while(*dataPtr >= '0' && *dataPtr <= '9') //判断是否是下发的命令控制数据 { numBuf[num++] = *dataPtr++; } num = atoi((const char *)numBuf); //转为数值形式 } if(type == MQTT_PKT_CMD || type == MQTT_PKT_PUBLISH) { MQTT_FreeBuffer(cmdid_topic); MQTT_FreeBuffer(req_payload); } }

鉴权信息和获取方式参考：OneNET – 中国移动物联网开放平台

4. main.c

主要包括硬件初始化、接入OneNET平台、读取温湿度、发送数据等功能。其中，timeCount变量用于控制发送数据的时间间隔，dataPtr变量用于存储ESP8266模块接收到的数据。如果timeCount计数达到50，则执行发送数据的操作，将温湿度数据上传至OneNET平台并清空ESP8266模块缓存。同时，使用ESP8266_GetIPD函数获取ESP8266模块接收到的数据，并使用OneNet_RevPro函数处理该数据。

欢迎大家来到IT世界,在知识的湖畔探索吧!int main(void) { unsigned short timeCount = 0; //发送间隔变量 unsigned char *dataPtr = NULL; delay_init(); //延时函数初始化 Usart1_Init(); //串口1初始化为 Usart2_Init(); //串口2初始化为 LED_Init(); //初始化与LED连接的硬件接口 UsartPrintf(USART_DEBUG, " Hardware init OK\r\n"); ESP8266_Init(); while(OneNet_DevLink()) //接入OneNET delay_ms(500); while(1) { DHT11_Read_Data(&temperature,&humidity); //读取温湿度值 delay_ms(100); if(++timeCount >= 50) //发送间隔5s { UsartPrintf(USART_DEBUG, "温度：%d\r\n",temperature); UsartPrintf(USART_DEBUG, "湿度：%d\r\n",humidity); UsartPrintf(USART_DEBUG, "OneNet_SendData\r\n"); OneNet_SendData(); //发送数据 timeCount = 0; ESP8266_Clear(); } dataPtr = ESP8266_GetIPD(0); if(dataPtr != NULL) OneNet_RevPro(dataPtr); } }

三、上报效果

不知为何，源码始终上传不成功，需要源码请在评论区留言。