文章目录[隐藏]
一、环境介绍
单片机采用：STM32F103C8T6
上网方式：采用ESP8266，也可以使用其他设备代替，只要支持TCP协议即可。比如：GSM模块、有线网卡等。
云平台: 采用中国移动OneNet. 也可以采用腾讯、阿里云、华为云、百度天工物接入、机智云等等。 前面文章有讲解。
协议： 采用MQTT协议
开发软件：keil5
完整项目源码下载: https://download.csdn.net/download/xiaolong1126626497/19766925
二、包含的硬件与实物图介绍
1. 一个光敏电阻传感器
2. 一个DHT11温湿度传感器
3. 一个MQ-5 液化气/天然气/煤气监测传感器
4. 一个MQ-2 烟雾传感器
5. 3盏LED灯表示窗帘开关、空调开关、电视开关
6. 联网WIFI采用: ESP8266
7. 最小系统板: STM32F103C8T6
8. 物联网服务器: OneNet平台
9. 物联网手机APP: 设备云
设备云APP下载地址（Android）: https://download.csdn.net/download/xiaolong1126626497/18697132
三、功能介绍
这是基于STM32设计的智能家居控制系统，采用ESP8266连接OneNet云平台。
设备端可以实时采集烟雾浓度、温湿度、煤气天然气浓度到云平台，在云平台网页端或者手机APP上可以远程查看数据，还可以点击云平台界面上的按钮，完成对家里的电器设备控制：窗帘开关、空调开关、电视开关(采用LED灯模拟)等。
四、OneNet创建设备
从0开始创建OneNet设备，参考这里：https://xiaolong.blog.csdn.net/article/details/107385118
首地址：https://open.iot.10086.cn/
这是STM32设备端连接OneNet串口打印的提示信息：
登录成功的效果：
数据流收到物联网终端上传的信息。
查看设计的网页界面：
五、程序下载介绍
点击开始编程之后，按下开发板上的RST按钮，即可启动下载。
六、STM32设备端代码
6.1 esp8266.c
#include "esp8266.h"
struct ESP8266_WIFI esp8266_wifi;
/*
函数功能: 配置ESP8266WIFI为AP模式+TCP服务器模式
函数参数:
char *ssid :将要创建的WIFI热点名称(英文字母)
char *password :将要创建的WIFI热点密码(最短长度8位)
u16 port :TCP服务器的端口号(0~65535)
返 回 值:0表示成功,其他值表示失败
*/
u8 ESP8266_AP_TCP_ServerMode(const char *ssid,const char *password,u16 port)
{
u8 i;
char *find_str=NULL;
char cmd_buffer[100];
/*1. 发送测试指令,检测WIFI是否正常*/
printf("发送测试指令,检测WIFI是否正常...\n");
if(ESP8266_SendCmd("AT\r\n"))return 1;
/*2. 关闭回显*/
printf("关闭回显...\n");
if(ESP8266_SendCmd("ATE0\r\n"))return 2;
/*3. 设置当前WIFI的模式为AP模式*/
printf("设置当前WIFI的模式为AP模式...\n");
if(ESP8266_SendCmd("AT+CWMODE=2\r\n"))return 3;
/*4. 复位模块,设置的模式必须复位之后才会生效*/
printf("复位模块...\n");
if(ESP8266_SendCmd("AT+RST\r\n"))return 4;
DelayMs_72M(1000);
DelayMs_72M(1000);
DelayMs_72M(1000);
DelayMs_72M(1000);
/*5. 关闭回显*/
printf("关闭回显...\n");
if(ESP8266_SendCmd("ATE0\r\n"))return 5;
/*6. 设置创建的热点信息*/
printf("设置创建的热点信息...\n");
snprintf(cmd_buffer,100,"AT+CWSAP=\"%s\",\"%s\",1,4\r\n",ssid,password);
if(ESP8266_SendCmd(cmd_buffer))return 6;
/*7. 开启多连接,在服务器模式下才可开启*/
printf("开启多连接...\n");
if(ESP8266_SendCmd("AT+CIPMUX=1\r\n"))return 7;
/*8. 设置端口号(0~65535)*/
printf("设置端口号...\n");
snprintf(cmd_buffer,100,"AT+CIPSERVER=1,%d\r\n",port);
if(ESP8266_SendCmd(cmd_buffer))return 8;
/*9.查询本地IP地址*/
printf("查询本地IP地址...\n");
if(ESP8266_SendCmd("AT+CIFSR\r\n"))return 9;
/*10. 保存WIFI的信息*/
esp8266_wifi.port=port;
strcpy(esp8266_wifi.mode,"AP");
//提取IP地址
/*
IP地址=+CIFSR:APIP,"192.168.4.1"
+CIFSR:APMAC,"86:f3:eb:17:e6:86"
*/
find_str=strstr((char*)USART3_RX_BUFF,"APIP");
if(find_str) //判断是否查找成功
{
find_str+=6;
for(i=0;*find_str!='"';i++)
{
esp8266_wifi.ip[i]=*find_str;
find_str++;
}
esp8266_wifi.ip[i]='\0';
}
USART3_RX_FLAG=0;
USART3_RX_CNT=0;
printf("当前WIFI模式:%s\n",esp8266_wifi.mode);
printf("当前网络协议类型:%s\n","TCP");
printf("当前网络通信模式:%s\n","server");
printf("当前网络端口号:%d\n",esp8266_wifi.port);
printf("本地网络IP地址:%s\n",esp8266_wifi.ip);
return 0;
}
/*
函数功能:向ESP8266wifi发送指令
说明:该函数只是适用于成功后返回OK的指令
返回值: 0表示成功 1表示失败
*/
u8 ESP8266_SendCmd(char *cmd)
{
u8 i,j;
for(i=0;i<5;i++) //测试的总次数
{
USART3_RX_FLAG=0;
USART3_RX_CNT=0;
USART_X_SendString(USART3,cmd);
for(j=0;j<200;j++) //等待的时间(ms单位)
{
if(USART3_RX_FLAG)
{
USART3_RX_BUFF[USART3_RX_CNT]='\0';
printf("USART3_RX_BUFF=%s\r\n",USART3_RX_BUFF);
if(strstr((char*)USART3_RX_BUFF,"OK\r\n"))
{
return 0;
}
else break;
}
DelayMs_72M(2); //一次的时间
}
}
return 1;
}
/*
函数功能:ESP8266wifi处于TCP服务器模式下的数据发送函数
函数参数:
u8 id :已经连接服务器的客户端ID号
char *data :将要发送数据(字符串)
返回值: 0表示成功 1表示失败
说明:只有在TCP服务器模式下才可使用该函数
OK
>
Recv 12 bytes
SEND OK
*/
u8 ESP8266_ServerSendData(u8 id,char *data)
{
u32 i,j,n;
char cmd[100];
snprintf(cmd,1024,"AT+CIPSEND=%d,%d\r\n",id,strlen(data));
for(i=0;i<5;i++) //测试的总次数
{
USART3_RX_FLAG=0;
USART3_RX_CNT=0;
USART_X_SendString(USART3,cmd);
for(j=0;j<200;j++) //等待的时间(ms单位)
{
if(USART3_RX_FLAG)
{
USART3_RX_BUFF[USART3_RX_CNT]='\0';
if(strstr((char*)USART3_RX_BUFF,">")) //开始发送数据
{
USART3_RX_FLAG=0;
USART3_RX_CNT=0;
USART_X_SendString(USART3,data); //发送数据
for(n=0;n<10000;n++)
{
if(USART3_RX_FLAG)
{
USART3_RX_BUFF[USART3_RX_CNT]='\0';
if(strstr((char*)USART3_RX_BUFF,"SEND OK")) //开始发送数据
{
USART3_RX_FLAG=0;
USART3_RX_CNT=0;
return 0;
}
else return 1;
}
DelayMs_72M(1); //一次的时间
}
}
else break;
}
DelayMs_72M(5); //一次的时间
}
}
return 1;
}
/*
函数功能: 设置STA模式下连接的热点信息
返 回 值: 0表示成功,1表示失败
连接成功的提示符:
WIFI DISCONNECT
WIFI CONNECTED
WIFI GOT IP
OK
*/
u8 ESP8266_STA_ModeConnectWIFI(char *cmd)
{
u32 i,j;
for(i=0;i<3;i++) //测试的总次数
{
USART3_RX_FLAG=0;
USART3_RX_CNT=0;
USART_X_SendString(USART3,cmd);
for(j=0;j<30000;j++) //等待的时间(ms单位)
{
if(USART3_RX_FLAG)
{
USART3_RX_BUFF[USART3_RX_CNT]='\0';
if(strstr((char*)USART3_RX_BUFF,"OK"))
{
return 0;
}
else
{
memset(USART3_RX_BUFF,0,sizeof(USART3_RX_BUFF));
USART3_RX_FLAG=0;
USART3_RX_CNT=0;
}
}
DelayMs_72M(1); //一次的时间
}
}
return 1;
}
/*
函数功能: 用于在客户端模式下,连接服务器
返 回 值: 0表示成功,1表示失败
连接成功的提示符:CONNECT
*/
u8 ESP8266_ConnectServer(char *cmd)
{
u32 i,j;
for(i=0;i<5;i++) //测试的总次数
{
USART3_RX_FLAG=0;
USART3_RX_CNT=0;
USART_X_SendString(USART3,cmd);
for(j=0;j<10000;j++) //等待的时间(ms单位)
{
if(USART3_RX_FLAG)
{
USART3_RX_BUFF[USART3_RX_CNT]='\0';
if(strstr((char*)USART3_RX_BUFF,"CONNECT"))
{
return 0;
}
else
{
memset(USART3_RX_BUFF,0,sizeof(USART3_RX_BUFF));
USART3_RX_FLAG=0;
USART3_RX_CNT=0;
}
}
DelayMs_72M(1); //一次的时间
}
}
return 1;
}
/*
函数功能: 配置ESP8266WIFI为STA模式+TCP客户端模式
函数参数:
char *ssid :将要连接的WIFI热点名称(英文字母)
char *password :将要连接的WIFI热点密码(最短长度8位)
u16 port :TCP服务器的端口号(0~65535)
返 回 值:0表示成功,其他值表示失败
*/
u8 ESP8266_STA_TCP_ClientMode(const char *ssid,const char *password,char *server_ip,u16 port)
{
u8 i;
char *find_str=NULL;
char cmd_buffer[100];
/*1. 发送测试指令,检测WIFI是否正常*/
printf("发送测试指令,检测WIFI是否正常...\n");
for(i=0;i<10;i++)
{
if(ESP8266_SendCmd("AT\r\n")) //可能WIFI正处于透传模式，无法接收指令
{
USART_X_SendString(USART3,"+++"); //退出透传模式
DelayMs_72M(80); //等待退出透传模式
}
else break;
}
if(i==10)return 1; //检测失败
/*2. 关闭回显*/
printf("关闭回显...\n");
if(ESP8266_SendCmd("ATE0\r\n"))return 2;
/*3. 设置当前WIFI的模式为STA模式*/
printf("设置当前WIFI的模式为STA模式...\n");
if(ESP8266_SendCmd("AT+CWMODE=1\r\n"))return 3;
/*4. 复位模块,设置的模式必须复位之后才会生效*/
printf("复位模块...\n");
if(ESP8266_SendCmd("AT+RST\r\n"))return 4;
DelayMs_72M(1000);
DelayMs_72M(1000);
DelayMs_72M(1000);
DelayMs_72M(1000);
/*5. 关闭回显*/
printf("关闭回显...\n");
if(ESP8266_SendCmd("ATE0\r\n"))return 5;
/*6. 设置连接的热点信息*/
printf("设置连接的热点信息...\r\n");
snprintf(cmd_buffer,100,"AT+CWJAP=\"%s\",\"%s\"\r\n",ssid,password);
printf("cmd_buffer=%s",cmd_buffer);
if(ESP8266_STA_ModeConnectWIFI(cmd_buffer))return 6;
/*7. 开启单连接,在客户端模式下才可开启*/
printf("开启单连接...\n");
if(ESP8266_SendCmd("AT+CIPMUX=0\r\n"))return 8;
/*8.查询本地IP地址*/
printf("查询本地IP地址...\n");
if(ESP8266_SendCmd("AT+CIFSR\r\n"))return 7;
/*9. 保存WIFI的信息*/
esp8266_wifi.port=port;
strcpy(esp8266_wifi.mode,"STA");
//提取IP地址
/*
+CIFSR:STAIP,"192.168.1.115"
+CIFSR:STAMAC,"84:f3:eb:17:e6:86"
*/
find_str=strstr((char*)USART3_RX_BUFF,"STAIP");
if(find_str) //判断是否查找成功
{
find_str+=7;
for(i=0;*find_str!='"';i++)
{
esp8266_wifi.ip[i]=*find_str;
find_str++;
}
esp8266_wifi.ip[i]='\0';
}
/*10. 连接服务器*/
printf("开始连接服务器...\n");
snprintf(cmd_buffer,100,"AT+CIPSTART=\"TCP\",\"%s\",%d\r\n",server_ip,port);
if(ESP8266_ConnectServer(cmd_buffer))return 9;
/*11. 开启透传模式*/
printf("开启透传模式...\n");
if(ESP8266_SendCmd("AT+CIPMODE=1\r\n"))return 10;
/*12. 开始透传*/
printf("开始透传...\n");
if(ESP8266_SendCmd("AT+CIPSEND\r\n"))return 11;
printf("当前WIFI模式:%s\r\n",esp8266_wifi.mode);
printf("当前网络协议类型:%s\r\n","TCP");
printf("当前网络通信模式:%s\r\n","Client");
printf("连接的服务器端口号:%d\r\n",esp8266_wifi.port);
printf("连接的服务器IP地址:%s\r\n",server_ip);
printf("本地的IP地址:%s\r\n",esp8266_wifi.ip);
return 0;
}
6.2 esp8266.h
#ifndef ESP8266_H
#define ESP8266_H
#include "stm32f10x.h"
#include "usart.h"
#include "key.h"
#include "led.h"
#include <string.h>
#include <stdlib.h>
u8 ESP8266_SendCmd(char *cmd);
u8 ESP8266_AP_TCP_ServerMode(const char *ssid,const char *password,u16 port);
u8 ESP8266_ServerSendData(u8 id,char *data);
u8 ESP8266_STA_TCP_ClientMode(const char *ssid,const char *password,char *server_ip,u16 port);
struct ESP8266_WIFI
{
u16 port;
char mode[10]; //sta/ap
char ip[10]; //ip地址
};
extern struct ESP8266_WIFI esp8266_wifi;
#endif
3.3 main.c
#include "stm32f10x.h"
#include "led.h"
#include "key.h"
#include "usart.h"
#include <string.h>
#include "adc.h"
#include "esp8266.h"
#include "timer.h"
#include "rtc.h"
#include "dht11.h"
//网络协议层
#include "onenet.h"
//协议封装文件
#include "dStream.h"
/*WIFI信息配置---将要连接的WIFI信息*/
#define WIFI_NAME "Xiaomi_meizi6"
#define WIFI_PASSWORD "12170307yu"
/*Onenet服务器地址:固定的*/
#define SERVER_IP "183.230.40.39"
#define SERVER_PORT 6002
//产品ID
const char OneNetPROID[]="332761";
//鉴权信息 access_key
const char OneNetAUTH_INFO[]="1234567890";
//设备ID
char OneNetDEVID[]="590592359";
//ApiKey
char OneNetAPI_KEY[]="fTgT3L9k3gyalPDMeojEEPrwzlo=";
//onenet数据点定义
DATA_STREAM data_stream[]=
{
{"DHT11_T","66",TYPE_STRING,1}, //温度
{"DHT11","66",TYPE_STRING,1}, //湿度
{"Light","66",TYPE_STRING,1}, //光照强度
{"MQ2","66",TYPE_STRING,1}, //烟雾浓度
{"MQ5","66",TYPE_STRING,1}, //液化气浓度
};
char *WIFI_STAT; //WIFI状态指针
//u8 temp,humi;
char DisplayDataBuffer[20];
u8 GL5637_Info[10]; //光敏传感器信息
u8 TEMP_Info[10];
u8 HUMI_Info[10];
u8 MQ2_Info[10];
u8 MQ5_Info[10];
/*
工程内容介绍: 物联网开发平台全功能测试代码! 支持上位机控制
编写日期 : 20200403
版本 : v4.0
*/
int main(void)
{
int cnt_OneNet_time=0;
u32 time_cnt=0; //记录时间
u16 GL5637_temp=0; //光敏信息
u8 ESP8266_Stat;
u8 temp,humi;
u16 mq2_temp,mq5_temp;
LedInit();
KeyInit();
USART_X_Init(USART1,72,115200);
USART_X_Init(USART3,36,115200); //WIFI的波特率为115200
ADC1_Init(); //ADC初始化
Timer2Init(72,10000); //10ms中断一次，辅助串口3接收数据--WIFI数据
printf("DHT11=%d\r\n",DHT11_Init());
//连接至指定的WIFI
ESP8266_Stat=ESP8266_STA_TCP_ClientMode(WIFI_NAME,WIFI_PASSWORD,SERVER_IP,SERVER_PORT);
if(ESP8266_Stat)
{
printf("ESP8266_Stat=%d\r\n",ESP8266_Stat);
WIFI_STAT="WIFIConnectERROR";
}
else
{
WIFI_STAT="WIFI Connect OK";
//接入OneNET
while(OneNet_DevLink())
{
printf("Connect OneNet..\r\n");
DelayMs_72M(500);
LED=!LED;
}
}
while(1)
{
cnt_OneNet_time++;//用于控制向服务器上传数据点的频率
/*轮询扫描数据*/
if(USART3_RX_FLAG)
{
USART3_RX_BUFF[USART3_RX_CNT]='\0';
//解析平台返回的数据
OneNet_RevPro(USART3_RX_BUFF);
USART3_RX_CNT=0;
USART3_RX_FLAG=0;
memset(USART3_RX_BUFF,0,sizeof(USART3_RX_BUFF));
}
/*获取光敏数据*/
GL5637_temp=ADC1_GetCHxVal(8);
sprintf((char*)GL5637_Info,"%d",GL5637_temp); //保存光敏传感器信息，上传给上位机
/*获取烟雾浓度数据*/
mq2_temp=ADC1_GetCHxVal(1);
sprintf((char*)MQ2_Info,"%d",mq2_temp); //保存MQ2传感器信息，上传给上位机
/*获取液化气浓度数据*/
mq5_temp=ADC1_GetCHxVal(2);
sprintf((char*)MQ5_Info,"%d",mq5_temp); //保存MQ5传感器信息，上传给上位机
/*获取温湿度*/
if(DHT11_Read_Data(&temp,&humi)==0)
{
sprintf((char*)TEMP_Info,"%d",temp); //保存温度传感器信息，上传给上位机
sprintf((char*)HUMI_Info,"%d",humi); //保存温度传感器信息，上传给上位机
}
DelayMs_72M(1); //延时1ms
time_cnt++;
if(cnt_OneNet_time>=200 &&ESP8266_Stat==0)
{
cnt_OneNet_time=0; //清0
data_stream[0].dataPoint=TEMP_Info;
data_stream[1].dataPoint=HUMI_Info;
data_stream[2].dataPoint=GL5637_Info;
data_stream[3].dataPoint=MQ2_Info;
data_stream[4].dataPoint=MQ5_Info;
printf("GL5637_Info=%s\r\n",GL5637_Info);
printf("temp=%s,humi=%s\r\n",TEMP_Info,HUMI_Info);
printf("MQ2_Info=%s\r\n",MQ2_Info);
printf("MQ5_Info=%s\r\n",MQ5_Info);
//向OneNet云端服务器上传数据点
OneNet_SendData(FORMAT_TYPE1,OneNetDEVID,OneNetAPI_KEY,data_stream,5);
printf("发送成功\r\n");
}
/*轮询扫描数据*/
if(USART3_RX_FLAG)
{
USART3_RX_BUFF[USART3_RX_CNT]='\0';
//解析平台返回的数据
OneNet_RevPro(USART3_RX_BUFF);
USART3_RX_CNT=0;
USART3_RX_FLAG=0;
memset(USART3_RX_BUFF,0,sizeof(USART3_RX_BUFF));
}
}
}
版权声明：本文为CSDN博主「DS小龙哥」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。
原文链接：https://blog.csdn.net/xiaolong1126626497/article/details/118096332
暂无评论