stm32f103c8t6连接OneNet云平台进行数据的上传与下发

2024-01-08 14:20
文章标签 进行 数据 平台 连接 上传 下发 stm32f103c8t6 onenet

本文主要是介绍stm32f103c8t6连接OneNet云平台进行数据的上传与下发，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

stm32f103c8t6连接OneNet云平台进行数据的上传与下发

注意此教程只适用于老版本onenet云平台

实现了数据发送云平台和云平台的数据发送到stm32单片机

首先是onenet.c中的云服务器设置部分

image-20240108122827604

esp8266.c中设置wifi名字和密码以及云平台IP和端口号

image-20240108123031583

数据上传部分在onenet.c中找到这个函数

image-20240108123341774

image-20240108123501402

接收onenet收到的数据

同样是onenet.c中的OneNet_RevPro函数

image-20240108123809807

image-20240108123847778

相关代码

onenet.c

//单片机头文件
#include "stm32f10x.h"//网络设备
#include "esp8266.h"//协议文件
#include "onenet.h"
#include "Mqttkit.h"//硬件驱动
#include "usart.h"
#include "delay.h"//C库
#include <string.h>
#include <stdio.h>#define PROID		"625345"#define AUTH_INFO	"asdafasfsdfsdffdsddfsdsdfds"#define DEVID		"1179835099"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, 0, MQTT_QOS_LEVEL0, NULL, NULL, 0, &mqttPacket) == 0){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);								//删包}elseUsartPrintf(USART_DEBUG, "WARN:	MQTT_PacketConnect Failed\r\n");return status;}unsigned char OneNet_FillBuf(char *buf)
{char text[32];memset(text, 0, sizeof(text));strcpy(buf, ",;");memset(text, 0, sizeof(text));sprintf(text, "Tempreture,%f;", 66.62);strcat(buf, text);memset(text, 0, sizeof(text));sprintf(text, "Humidity,%f;",20.0);strcat(buf, text);return strlen(buf);}//==========================================================
//	函数名称：	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));body_len = OneNet_FillBuf(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);															//删包}elseUsartPrintf(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消息，平台回复的Ackif(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++;}numBuf[num] = 0;num = atoi((const char *)numBuf);			//转为数值形式if(strstr((char *)req_payload, "key"))		//搜索"key"{UsartPrintf(USART_DEBUG,"key = %d\r\n", num);            //num就是key:{V}中V的值}else if(strstr((char *)req_payload, "knob"))	//搜索"knob"{UsartPrintf(USART_DEBUG,"knob = %d\r\n", num);}}
}

esp8266.c

//单片机头文件
#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=\"Xiaomi_02BB\",\"123456789\"\r\n"#define ESP8266_ONENET_INFO		"AT+CIPSTART=\"TCP\",\"183.230.40.39\",6002\r\n"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;}}DelayXms(10);}return 1;}//==========================================================
//	函数名称：	ESP8266_SendData
//
//	函数功能：	发送数据
//
//	入口参数：	data：数据
//				len：长度
//
//	返回参数：	无
//
//	说明：		
//==========================================================
void ESP8266_SendData(unsigned char *data, unsigned short len)
{char cmdBuf[32];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)								//如果接收完成{UsartPrintf(USART_DEBUG, "head:%s", esp8266_buf);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);}elsereturn NULL;}}DelayXms(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_14;					//GPIOC14-复位GPIO_Initure.GPIO_Speed = GPIO_Speed_50MHz;GPIO_Init(GPIOC, &GPIO_Initure);GPIO_WriteBit(GPIOC, GPIO_Pin_14, Bit_RESET);DelayXms(250);GPIO_WriteBit(GPIOC, GPIO_Pin_14, Bit_SET);DelayXms(500);ESP8266_Clear();UsartPrintf(USART_DEBUG, "1. AT\r\n");while(ESP8266_SendCmd("AT\r\n", "OK"))DelayXms(500);UsartPrintf(USART_DEBUG, "2. CWMODE\r\n");while(ESP8266_SendCmd("AT+CWMODE=1\r\n", "OK"))DelayXms(500);UsartPrintf(USART_DEBUG, "3. AT+CWDHCP\r\n");while(ESP8266_SendCmd("AT+CWDHCP=1,1\r\n", "OK"))DelayXms(500);UsartPrintf(USART_DEBUG, "4. CWJAP\r\n");while(ESP8266_SendCmd(ESP8266_WIFI_INFO, "GOT IP"))DelayXms(500);UsartPrintf(USART_DEBUG, "5. CIPSTART\r\n");while(ESP8266_SendCmd(ESP8266_ONENET_INFO, "CONNECT"))DelayXms(500);UsartPrintf(USART_DEBUG, "6. ESP8266 Init OK\r\n");}//==========================================================
//	函数名称：	USART2_IRQHandler
//
//	函数功能：	串口2收发中断
//
//	入口参数：	无
//
//	返回参数：	无
//
//	说明：		
//==========================================================
void USART2_IRQHandler(void)
{if(USART_GetITStatus(USART2, USART_IT_RXNE) != RESET) //接收中断{if(esp8266_cnt >= sizeof(esp8266_buf))	esp8266_cnt = 0; //防止串口被刷爆esp8266_buf[esp8266_cnt++] = USART2->DR;USART_ClearFlag(USART2, USART_FLAG_RXNE);}}

main.c

#include "stm32f10x.h" 
#include<stdio.h>
// Device header
#include "OLED.h"
//网络协议层
#include "onenet.h"//网络设备
#include "esp8266.h"//硬件驱动
#include "delay.h"
#include "usart.h"
void Hardware_Init(void)
{NVIC_PriorityGroupConfig(NVIC_PriorityGroup_2);	//中断控制器分组设置Delay_Init();									//systick初始化Usart1_Init(115200);							//串口1，打印信息用Usart2_Init(115200);							//串口2，驱动ESP8266用UsartPrintf(USART_DEBUG, " Hardware init OK\r\n");}int main(void)
{unsigned short timeCount = 300;	//发送间隔变量unsigned char *dataPtr;Hardware_Init();				//初始化外围硬件ESP8266_Init();					//初始化ESP8266OLED_Init();while(OneNet_DevLink())			//接入OneNETDelayXms(500);OLED_ShowString(1,1,"yes");while(1){DelayXms(500);OneNet_SendData();timeCount = 0;//ESP8266_Clear();dataPtr = ESP8266_GetIPD(0);//OneNet_RevPro(dataPtr); if(dataPtr != NULL){OneNet_RevPro(dataPtr);     //接收命令}	}}

代码gitee连接

这篇关于stm32f103c8t6连接OneNet云平台进行数据的上传与下发的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/583743。

相关文章

SQL Server修改数据库名及物理数据文件名操作步骤

SQL Server修改数据库名及物理数据文件名操作步骤

《SQLServer修改数据库名及物理数据文件名操作步骤》在SQLServer中重命名数据库是一个常见的操作,但需要确保用户具有足够的权限来执行此操作,：本文主要介绍SQLServer修改数据... 目录一、背景介绍二、操作步骤2.1 设置为单用户模式（断开连接）2.2 修改数据库名称2.3 查找逻辑文件名
阅读更多...
canal实现mysql数据同步的详细过程

canal实现mysql数据同步的详细过程

《canal实现mysql数据同步的详细过程》：本文主要介绍canal实现mysql数据同步的详细过程,本文通过实例图文相结合给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的... 目录1、canal下载2、mysql同步用户创建和授权3、canal admin安装和启动4、canal
阅读更多...
使用SpringBoot整合Sharding Sphere实现数据脱敏的示例

使用SpringBoot整合Sharding Sphere实现数据脱敏的示例

《使用SpringBoot整合ShardingSphere实现数据脱敏的示例》ApacheShardingSphere数据脱敏模块,通过SQL拦截与改写实现敏感信息加密存储,解决手动处理繁琐及系统改... 目录痛点一：痛点二：脱敏配置Quick Start——Spring 显示配置：1.引入依赖2.创建脱敏
阅读更多...
Linux使用scp进行远程目录文件复制的详细步骤和示例

Linux使用scp进行远程目录文件复制的详细步骤和示例

《Linux使用scp进行远程目录文件复制的详细步骤和示例》在Linux系统中,scp（安全复制协议）是一个使用SSH（安全外壳协议）进行文件和目录安全传输的命令,它允许在远程主机之间复制文件和目录,... 目录1. 什么是scp？2. 语法3. 示例示例 1: 复制本地目录到远程主机示例 2: 复制远程主
阅读更多...
详解如何使用Python构建从数据到文档的自动化工作流

详解如何使用Python构建从数据到文档的自动化工作流

《详解如何使用Python构建从数据到文档的自动化工作流》这篇文章将通过真实工作场景拆解,为大家展示如何用Python构建自动化工作流,让工具代替人力完成这些数字苦力活,感兴趣的小伙伴可以跟随小编一起... 目录一、Excel处理：从数据搬运工到智能分析师二、PDF处理：文档工厂的智能生产线三、邮件自动化：
阅读更多...
java连接opcua的常见问题及解决方法

java连接opcua的常见问题及解决方法

《java连接opcua的常见问题及解决方法》本文将使用EclipseMilo作为示例库,演示如何在Java中使用匿名、用户名密码以及证书加密三种方式连接到OPCUA服务器,若需要使用其他SDK,原理... 目录一、前言二、准备工作三、匿名方式连接3.1 匿名方式简介3.2 示例代码四、用户名密码方式连接4
阅读更多...
Python数据分析与可视化的全面指南(从数据清洗到图表呈现)

Python数据分析与可视化的全面指南(从数据清洗到图表呈现)

《Python数据分析与可视化的全面指南(从数据清洗到图表呈现)》Python是数据分析与可视化领域中最受欢迎的编程语言之一,凭借其丰富的库和工具,Python能够帮助我们快速处理、分析数据并生成高质... 目录一、数据采集与初步探索二、数据清洗的七种武器1. 缺失值处理策略2. 异常值检测与修正3. 数据
阅读更多...
pandas实现数据concat拼接的示例代码

pandas实现数据concat拼接的示例代码

《pandas实现数据concat拼接的示例代码》pandas.concat用于合并DataFrame或Series,本文主要介绍了pandas实现数据concat拼接的示例代码,具有一定的参考价值,... 目录语法示例：使用pandas.concat合并数据默认的concat：参数axis=0，join=
阅读更多...
MySQL 表的内外连接案例详解

MySQL 表的内外连接案例详解

《MySQL表的内外连接案例详解》本文给大家介绍MySQL表的内外连接,结合实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录表的内外连接（重点）内连接外连接表的内外连接（重点）内连接内连接实际上就是利用where子句对两种表形成的笛卡儿积进行筛选，我
阅读更多...
C#代码实现解析WTGPS和BD数据

C#代码实现解析WTGPS和BD数据

《C#代码实现解析WTGPS和BD数据》在现代的导航与定位应用中,准确解析GPS和北斗（BD）等卫星定位数据至关重要,本文将使用C#语言实现解析WTGPS和BD数据,需要的可以了解下... 目录一、代码结构概览1. 核心解析方法2. 位置信息解析3. 经纬度转换方法4. 日期和时间戳解析5. 辅助方法二、L
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2