【智能家居入门2】（MQTT协议、微信小程序、STM32、ONENET云平台）

此篇智能家居入门与前两篇类似，但是是使用MQTT协议接入ONENET云平台，实现微信小程序与下位机的通信，这里相较于使用http协议的那两篇博客，在主程序中添加了独立看门狗防止程序卡死和服务器掉线问题。后续还有使用MQTT协议连接MQTT服务器的智能家居项目。

    • 前言
    • 一、硬件模块
    • 二、连接服务器测试
    • 三、两个协议的对比分析
      • 1、代码结构上：
      • 2、获取服务器数据上：
      • 3、架构上：
    • 四、下位机主要代码
      • 1、接收并解析云平台下发数据：
      • 2、传感器数据上云：
    • 五、微信小程序主要代码
      • 1、index.js
      • 2、index.wxml
    • 六、源码获取

前言

这里给出前两篇使用http协议博客的网址：
①实现数据上云：https://blog.csdn.net/m0_71523511/article/details/135892908
②实现小程序控制下位机：https://blog.csdn.net/m0_71523511/article/details/135907645
在第二篇的博客结尾提出了服务器经常掉线的问题，使用别人编写好的心跳包也没用，因为程序一直卡死在重连中，所以也可以参照本篇的解决办法：加上独立看门狗，隔一段时间喂狗，如果超过时间没喂狗，说明程序多半卡死，此时看门狗处理逻辑中执行初始化esp8266和连接服务器的操作。
③独立看门狗：https://www.bilibili.com/video/BV1th411z7sn/?p=46&spm_id_from=pageDriver&vd_source=2a10d30b8351190ea06d85c5d0bfcb2a
④由于使用到了MQTT协议，想深入了解源码的话可以看看之前的的博客，对MQTT协议进行详解：https://blog.csdn.net/m0_71523511/article/details/135905690

一、硬件模块

1、0.96寸OLED液晶显示屏
2、DHT11温湿度传感器
3、继电器
4、小风扇、小水泵
5、MQ-4、MQ-9
6、esp8266-01s或者esp-12f
7、JLink下载器
8、STM32F103C8T6
大部分在上面说的第一篇博客中有介绍，这里介绍一下继电器、小风扇、小水泵：
①继电器：
由于单片机的io口无法直接驱动小风扇和水泵，这里用继电器充当开关，使用继电器驱动小风扇和小水泵运动。
在这里插入图片描述输入端口：外接5V电源，黑色跳帽可以控制继电器是高电平触发还是低电平触发。
输出端口：从左往右看，分别是NO1/NO2,COM1/COM2,NC1/NC2，代表常开，公共端，常闭三种状态。
继电器的两种状态，开和关，当继电器触发时，为打开状态，NOn口就会被使能，当继电器为关闭状态时，NCn口就会被使能，中间作为公共端连接输出。

硬件连线：
继电器输出端：小风扇红黑两根线子，红线接入继电器的NO1/NO2口，继电器的COM1/COM2拿一根公母杜邦线引出来接入5V电源，小风扇的黑线接STM32的GND口。
在这里插入图片描述
继电器输入端：
在这里插入图片描述
原文链接：https://blog.csdn.net/qq_51868810/article/details/127792611

②小风扇、小水泵：
这两个小东西就只有电源线和底线，给5v输入即可转动起来：
在这里插入图片描述
在这里插入图片描述

二、连接服务器测试

如果想单独先使用esp8266测试是否能正常与服务器通信的话可以参考这篇博客，不会创建产品也可以看：
https://blog.csdn.net/m0_71523511/article/details/135887108
需要注意的点：
①创建产品时要选择MQTT协议那个目录下进行创建
②AT指令中的IP地址和端口号要换成：183.230.40.39 6002
③需要记住的有：产品ID、鉴权信息（创建产品时自己填写的）、Master-APIkey、设备ID

三、两个协议的对比分析

1、代码结构上：

相较于使用http协议连接onenet，使用mqtt协议需要多几个源文件：onenet.c、cJSON.c、MqttKit.c。
①onenet.c是与onenet平台的数据交互接口层，通过调用MqttKit.c和esp8266.c中的库函数实现与云平台的通信，
②MqttKit.c是MQTT协议库，是MQTT协议最底层，由onenet.c进行调用。前面两个都是大神张继瑞开源。
③cJSON.c是一个用于处理JSON数据格式的轻量级C语言库，JSON（JavaScript Object Notation）是一种轻量级的数据交换格式，常用于在不同系统之间传输和存储数据。在对云平台下发数据进行解析时会用到（onenet.c）。
在这里插入图片描述

2、获取服务器数据上：

******使用http协议和MQTT协议连接onenet，最大的不同就是获取onenet云平台数据的方式：
http协议：直接构建HTTP请求报文并调用esp8266_send_data函数发送HTTP请求，并获取返回的字符串。
mqtt协议：不主动发送请求，使用ESP8266_WaitRecive函数等待，如果云平台有数据下发，那就存起来当作变量传入OneNet_RevPro函数，进行消息解析。

3、架构上：

在这里插入图片描述
"请求/响应"和"发布/订阅"是两种不同的通信模式，它们在系统架构和通信方式上有所不同。
①请求/响应：
特点： 在请求/响应模式中，通信的一方发送请求，而另一方回复响应。通信是单向的，有一个明确的请求者和一个响应者。
用途： 这种模式常见于客户端和服务器之间的通信。客户端发送请求，服务器处理请求并返回相应的响应。
②发布/订阅：
特点： 在发布/订阅模式中，消息的发布者将消息发送到一个主题（topic），而订阅者可以选择订阅特定主题以接收相关消息。通信是多对多的，发布者和订阅者之间是松耦合的。
用途： 这种模式常见于事件驱动系统、消息中间件和实时数据更新场景。发布者发布消息到主题，所有订阅该主题的订阅者都会收到消息。
由以上分析很容易得出一个结论：在做环境信息检测这种实时数据更新的项目上，使用MQTT协议更具优势。

四、下位机主要代码

1、接收并解析云平台下发数据：

主循环中使用以下代码接收并跳转：

		dataPtr = ESP8266_GetIPD(10);if(dataPtr != NULL){timeCount = 0;OneNet_RevPro(dataPtr);}

接收到数据后跳转至onenet.c的OneNet_RevPro函数中进行mqtt数据包(报文)解包和数据解析：

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;cJSON *json , *json_value;cJSON *json1, *json_value1;cJSON *json2, *json_value2;type = MQTT_UnPacketRecv(cmd);switch(type){case MQTT_PKT_CMD:															//命令下发OLED_Refresh_Line("jinru111");result = MQTT_UnPacketCmd(cmd, &cmdid_topic, &req_payload, &req_len);	//解出topic和消息体if(result == 0){//打印收到的信息printf(  "cmdid: %s, req: %s, req_len: %d\r\n", cmdid_topic, req_payload, req_len);// 对数据包req_payload进行JSON格式解析json = cJSON_Parse(req_payload);if (!json)//如果json内容为空，则打印错误信息printf("Error before: [%s]\n",cJSON_GetErrorPtr());else{json_value = cJSON_GetObjectItem(json , "LED0");//提取对应属性的数值if((json_value->valueint)==1){GPIO_SetBits(GPIOB,GPIO_Pin_12);	}else if((json_value->valueint)==0)			GPIO_ResetBits(GPIOB,GPIO_Pin_12);	}//开关风扇json1 = cJSON_Parse(req_payload);if (!json1)printf("Error before: [%s]\n",cJSON_GetErrorPtr());else{json_value1 = cJSON_GetObjectItem(json1 , "feng");if((json_value1->valueint)==1)GPIO_SetBits(GPIOB,GPIO_Pin_5);	else if((json_value1->valueint)==0)GPIO_ResetBits(GPIOB,GPIO_Pin_5);	}//开关水泵json2 = cJSON_Parse(req_payload);if (!json2)printf("Error before: [%s]\n",cJSON_GetErrorPtr());else{json_value2 = cJSON_GetObjectItem(json2 , "shui");if((json_value2->valueint)==1){GPIO_SetBits(GPIOB,GPIO_Pin_6);	}else if((json_value2->valueint)==0)GPIO_ResetBits(GPIOB,GPIO_Pin_6);	}if(MQTT_PacketCmdResp(cmdid_topic, req_payload, &mqttPacket) == 0)	//命令回复组包{printf( "Tips:	Send CmdResp\r\n");ESP8266_SendData(mqttPacket._data, mqttPacket._len);			//回复命令MQTT_DeleteBuffer(&mqttPacket);									//删包}cJSON_Delete(json);//释放位于堆中cJSON结构体内存cJSON_Delete(json1);}break;case MQTT_PKT_PUBACK:														//发送Publish消息，平台回复的Ackif(MQTT_UnPacketPublishAck(cmd) == 0)//printf(  "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(type == MQTT_PKT_CMD || type == MQTT_PKT_PUBLISH){MQTT_FreeBuffer(cmdid_topic);MQTT_FreeBuffer(req_payload);}
}

2、传感器数据上云：

主函数中读取传感器数值，每隔一段时间上传：

		else if(timeCount >= 100)	//发送间隔{DHT11_Read_Data(&tempValue,&humidity);gas = AD_GetValue(ADC_Channel_2);ranqi = AD_GetValue(ADC_Channel_3);delay_ms(10);OneNet_SendData();//发送数据给onenetESP8266_Clear();	timeCount = 0;}

调用OneNet_SendData发送数据，在OneNet_SendData函数中又调用OneNet_FillBuf函数将要发送的数据拼接起来。

unsigned char OneNet_FillBuf(char *buf)
{char text[32];//LED0_FLAG=GPIO_ReadInputDataBit(GPIOB, GPIO_Pin_12);//读取LED的开关状态（即对应引脚的）//LED1_FLAG=GPIO_ReadInputDataBit(GPIOB, GPIO_Pin_13);memset(text, 0, sizeof(text));strcpy(buf, ",;");memset(text, 0, sizeof(text));sprintf(text, "Tempreture,%d;",tempValue);strcat(buf, text);memset(text, 0, sizeof(text));sprintf(text, "Humidity,%d;", humidity);strcat(buf, text);memset(text, 0, sizeof(text));sprintf(text, "tianranqi,%d;", gas);strcat(buf, text);memset(text, 0, sizeof(text));sprintf(text, "keranqiti,%d;", ranqi);strcat(buf, text);printf("buf_mqtt=%s\r\n",buf);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;//printf( "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)							数据点上传组包，将数据封装成mqtt协议所要求的数据包格式{{for(; i < body_len; i++)mqttPacket._data[mqttPacket._len++] = buf[i];ESP8266_SendData(mqttPacket._data, mqttPacket._len);									//上传数据到平台printf( "Send %d Bytes\r\n", mqttPacket._len);MQTT_DeleteBuffer(&mqttPacket);															//删包}else{printf(  "WARN:	EDP_NewBuffer Failed\r\n");}}}

五、微信小程序主要代码

在这里插入图片描述
图中圈起来的地方需要根据自己的数据进行填写，在下面的调试信息栏可以看到有数据上传，查看数据流即可：
在这里插入图片描述

1、index.js

主要是增加了控制风扇和水泵的代码：

feng_kai:function(){//按钮发送命令控制硬件wx.request({url:'https://api.heclouds.com/cmds?device_id=1108129261',header: {'content-type': 'application/json','api-key':'nV4Cso3uQMZR2EGQQiY49MRCfx8='},method: 'POST',data:{"feng":1},success(res){console.log("成功",res.data)},fail(res){console.log("失败",res)}})
},feng_guan:function(){//按钮发送命令控制硬件wx.request({url:'https://api.heclouds.com/cmds?device_id=1108129261',header: {'content-type': 'application/json','api-key':'nV4Cso3uQMZR2EGQQiY49MRCfx8='},method: 'POST',data:{"feng":0},success(res){console.log("成功",res.data)},fail(res){console.log("失败",res)}})
},shui_kai:function(){//按钮发送命令控制硬件wx.request({url:'https://api.heclouds.com/cmds?device_id=1108129261',header: {'content-type': 'application/json','api-key':'nV4Cso3uQMZR2EGQQiY49MRCfx8='},method: 'POST',data:{"shui":1},success(res){console.log("成功",res.data)},fail(res){console.log("失败",res)}})
},shui_guan:function(){//按钮发送命令控制硬件wx.request({url:'https://api.heclouds.com/cmds?device_id=1108129261',header: {'content-type': 'application/json','api-key':'nV4Cso3uQMZR2EGQQiY49MRCfx8='},method: 'POST',data:{"shui":0},success(res){console.log("成功",res.data)},fail(res){console.log("失败",res)}})
},

需要注意的是这里的url需要更换成：‘https://api.heclouds.com/cmds?device_id=11081xxxxxx’，并且文件开头的apikey和设备号也要换成自己的。

2、index.wxml

最后加上：

<button type="primary" style="margin-top: 20px;" bindtap="feng_kai">开风扇</button>
<button type="warn" bindtap="feng_guan">关风扇</button><button type="primary" style="margin-top: 20px;" bindtap="shui_kai">开水泵</button>
<button type="warn" bindtap="shui_guan">关水泵</button>

六、源码获取

我用夸克网盘分享了「智能家居（MQTT+ONENET）.rar」，点击链接即可保存。打开「夸克APP」，无需下载在线播放视频，畅享原画5倍速，支持电视投屏。
链接：https://pan.quark.cn/s/db251fd599bd
提取码：9sR9

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/657186.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

输入和输出

输入和输出

按字符输入输出 按字符输出putchar&#xff08;&#xff09; 格式 #include <stdio.h> int putchar(int c); 功能&#xff1a;向终端输出一个字符 参数&#xff1a;要输出的字符的ASCII码值 返回值&#xff1a; 成功&#xff0c;返回输出字符的ASCII码值 失败&#xff…
阅读更多...
基于springboot汽车租赁系统源码和论文

基于springboot汽车租赁系统源码和论文

首先,论文一开始便是清楚的论述了系统的研究内容。其次,剖析系统需求分析,弄明白“做什么”,分析包括业务分析和业务流程的分析以及用例分析,更进一步明确系统的需求。然后在明白了系统的需求基础上需要进一步地设计系统,主要包括软件架构模式、整体功能模块、数据库设计。本项…
阅读更多...
Missing or invalid credentials.(Git push报错解决方案)

Missing or invalid credentials.(Git push报错解决方案)

前言 本文主要讲解git push后报错Missing or invalid credentials的解决方案。这里针对的是windows的。 编程环境&#xff1a;VsCode 问题原因 问题翻译起来就是 凭据缺失或无效。这里我们解决方案是取消vscode里面默认的控制终端git凭据来解决,具体方案如下. 解决方案 1…
阅读更多...
3D效果图加树进去太卡，渲染太慢怎么办？

3D效果图加树进去太卡，渲染太慢怎么办？

周末的时候&#xff0c;有个朋友私信来问&#xff1a;3dmax模型加树进去打开时特别的卡&#xff0c;是怎么回事。 不知道有没有朋友遇上这么个情况。 3dmax加树建议就用代理&#xff0c;这样相比于直接加而言&#xff0c;会流畅许多。 在3D效果图中&#xff0c;“树代理”是…
阅读更多...
萝卜视频源码前后端带视频演示

萝卜视频源码前后端带视频演示

萝卜影视源码前端是用JAVA开发的全原生APP源码&#xff0c;后端用的是二次开发的苹果CMS&#xff0c;支持局域网投屏&#xff0c;视频软解硬解&#xff0c;播放器自带弹幕功能。支持解析官方视频&#xff0c;支持M3U8&#xff0c;MP4。 开屏广告&#xff0c;全局广告&#xff0…
阅读更多...
GitHub国内打不开（解决办法有效）

GitHub国内打不开（解决办法有效）

最近国内访问github.com经常打不开&#xff0c;无法访问。 github网站打不开的解决方法 1.打开网站http://tool.chinaz.com/dns/ &#xff0c;在A类型的查询中输入 github.com&#xff0c;找出最快的IP地址。 2.修改hosts文件。 在hosts文件中添加&#xff1a; # localhost n…
阅读更多...
从0开始搭建若依微服务项目 RuoYi-Cloud（保姆式教程完结）

从0开始搭建若依微服务项目 RuoYi-Cloud（保姆式教程完结）

文章接上一章&#xff1a; 从0开始搭建若依微服务项目 RuoYi-Cloud&#xff08;保姆式教程 一&#xff09;-CSDN博客 四. 项目配置与启动 当上面环境全部准备好之后&#xff0c;接下来就是项目配置。需要将项目相关配置修改成当前相关环境。 数据库配置 新建数据库&#xff…
阅读更多...
element ui组件 el-date-picker设置default-time的默认时间

element ui组件 el-date-picker设置default-time的默认时间

default-time &#xff1a;选择日期后的默认时间值。 如未指定则默认时间值为 00:00:00 默认值修改 <el-form-item label"计划开始时间" style"width: 100%;" prop"planStartTime"><el-date-picker v-model"formData.planStart…
阅读更多...
TortoiseSVN各版本汉化包下载

TortoiseSVN各版本汉化包下载

首先进入下载版本列表 1.下载地址&#xff1a;https://sourceforge.net/projects/tortoisesvn/files ​ 2.选择自己版本进入​ 3.选择Language Packs进入&#xff0c;选择对应语言包下载。 ​ 4.在TortoiseSVN根目录下点击安装即可。 ​
阅读更多...
解密数据清洗，SQL中的数据分析

解密数据清洗，SQL中的数据分析

大家好&#xff0c;数据库表中的数据经常会很杂乱。数据可能包含缺失值、重复记录、异常值、不一致的数据输入等&#xff0c;在使用SQL进行分析之前清洗数据是非常重要的。 当学习SQL时&#xff0c;可以随意地创建数据库表&#xff0c;更改它们&#xff0c;根据需要更新和删除…
阅读更多...
canvas测量文字长度（measureText）

canvas测量文字长度（measureText）

查看专栏目录 canvas实例应用100专栏&#xff0c;提供canvas的基础知识&#xff0c;高级动画&#xff0c;相关应用扩展等信息。canvas作为html的一部分&#xff0c;是图像图标地图可视化的一个重要的基础&#xff0c;学好了canvas&#xff0c;在其他的一些应用上将会起到非常重…
阅读更多...
数据结构——栈和队列（C语言）

数据结构——栈和队列（C语言）

栈种常见的数据结构&#xff0c;它用来解决一些数据类型的问题&#xff0c;那么好&#xff0c;我来带着大家来学习一下栈 文章目录 栈对栈的认识栈的模拟实现栈的练习方法一方法二 栈 对栈的认识 栈&#xff08;stack&#xff09;是限定只能在表的一端进行插入删除操作的线性…
阅读更多...
SpringCloud LoadBalancer

SpringCloud LoadBalancer

SpringCloud LoadBalancer 1.什么是LoadBalancer LoadBalancer&#xff08;负载均衡器&#xff09;是一种网络设备或软件机制&#xff0c;用于分发传入的网络流量负载请求到多个后端目标服务器上&#xff0c;从而实现系统资源的均衡利用和提高系统的可用性和性能。 负载均衡器…
阅读更多...
【Tomcat与网络4】Tomcat的连接器设计

【Tomcat与网络4】Tomcat的连接器设计

目录 1 如何设计一个灵活可靠的连接器 2 主要组件介绍 在上一篇&#xff0c;我们介绍了Tomcat提供服务的整体结构&#xff0c;本文我们一起来看一下Tomcat的连接器的设计。 在前面我们提到Tomcat主要完成两个功能&#xff1a; 处理 Socket 连接&#xff0c;负责网络字节流与…
阅读更多...
wifi配网(esp8266和esp32)-http get和post方式

wifi配网(esp8266和esp32)-http get和post方式

wifi配网(esp8266和esp32)-http get和post方式 通过http get和post方式来给esp芯片配网 步骤&#xff1a; 开机&#xff0c;指示灯亮起后(需要灯闪烁3下后)&#xff0c;需在3s内&#xff08;超过3s则会正常启动&#xff09;&#xff0c;按一下按键&#xff08;注&#xff1a;切…
阅读更多...
Springboot做查询数据库某个表的数据时，后台一切正常前台显示不了数据

Springboot做查询数据库某个表的数据时，后台一切正常前台显示不了数据

当我在用springboot做项目的时候查询整个表的数据或者条件查询的时候发现我的后台功能一切正常但是我的前台界面就是显示不了数据&#xff0c;这个问题解决也很简单&#xff0c;就是需要我们平时多加注意&#xff0c;不要漏代码&#xff01;&#xff01;&#xff01; Builder …
阅读更多...
Visual Studio 2022 打开“程序包管理器控制台”失败

Visual Studio 2022 打开“程序包管理器控制台”失败

Visual Studio 2022 打开“程序包管理器控制台”失败 昨天下午&#xff0c;正在用Visual studio 2022写代码&#xff0c;当使用EF core 做数据迁移时&#xff0c;需要用到“程序包管理器控制台”&#xff0c;打开失败&#xff0c;前一秒还好好的&#xff0c;怎么突然就用不了了…
阅读更多...
互联网加竞赛 基于深度学习的人脸性别年龄识别 - 图像识别 opencv

互联网加竞赛 基于深度学习的人脸性别年龄识别 - 图像识别 opencv

文章目录 0 前言1 课题描述2 实现效果3 算法实现原理3.1 数据集3.2 深度学习识别算法3.3 特征提取主干网络3.4 总体实现流程 4 具体实现4.1 预训练数据格式4.2 部分实现代码 5 最后 0 前言 &#x1f525; 优质竞赛项目系列&#xff0c;今天要分享的是 &#x1f6a9; 毕业设计…
阅读更多...
力扣136、只出现一次的数字（简单）

力扣136、只出现一次的数字（简单）

1 题目描述 图1 题目描述 2 题目解读 在非空整数数组nums中&#xff0c;有一个元素只出现了一次&#xff0c;其余元素均出现两次。要求找出那个只出现一次的元素。 3 解法一&#xff1a;位运算 位运算&#xff0c;是一种非常简便的方法。 3.1 解题思路 异或运算&#xff0c;有…
阅读更多...
CPN故障诊断(MATLAB)

CPN故障诊断(MATLAB)

CPN(Colored Petri Net,彩色Petri网)是在传统Petri网的基础上进行扩展的高级Petri网。它在故障诊断领域有着广泛的应用。 CPN故障诊断的主要思想和步骤如下: 建模:根据系统的结构和功能,采用CPN构建系统的模型。将系统不同组件表示为网的位置,数据/信号流表示为网的转换,故障…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023