【智能家居入门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.rhkb.cn/news/259779.html

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

相关文章

LabVIEW焊缝缺陷超声检测与识别

LabVIEW焊缝缺陷超声检测与识别

LabVIEW焊缝缺陷超声检测与识别 介绍基于LabVIEW的焊缝缺陷超声检测与识别系统。该系统利用LabVIEW软件和数据采集卡的强大功能&#xff0c;实现了焊缝缺陷的在线自动检测&#xff0c;具有通用性、模块化、功能化和网络化的特点&#xff0c;显著提高了检测的效率和准确性。 随…
阅读更多...
Qt的基本操作

Qt的基本操作

文章目录 1. Qt Hello World 程序1.1 通过图形化界面的方式1.2 通过代码的方式实现 2. Qt 的编码问题3. 使用输入框实现hello world4. 使用按钮实现hello world5. Qt 编程注意事项6. 查询文档的方式7. 认识Qt坐标系 1. Qt Hello World 程序 1.1 通过图形化界面的方式 我们先讲…
阅读更多...
8、内网安全-横向移动RDPKerberos攻击SPN扫描WinRMWinRS

8、内网安全-横向移动RDPKerberos攻击SPN扫描WinRMWinRS

用途&#xff1a;个人学习笔记&#xff0c;有所借鉴&#xff0c;欢迎指正 目录 一、域横向移动-RDP-明文&NTLM 1.探针服务&#xff1a; 2.探针连接&#xff1a; 3.连接执行&#xff1a; 二、域横向移动-WinRM&WinRS-明文&NTLM 1.探针可用&#xff1a; 2.连接…
阅读更多...
每日一练：LeeCode-501、二叉搜索树中的众数【二叉搜索树+pre辅助节点+DFS】

每日一练：LeeCode-501、二叉搜索树中的众数【二叉搜索树+pre辅助节点+DFS】

本文是力扣LeeCode-LeeCode-501、二叉搜索树中的众数【二叉搜索树pre辅助节点DFS】 学习与理解过程&#xff0c;本文仅做学习之用&#xff0c;对本题感兴趣的小伙伴可以出门左拐LeeCode。 给你一个含重复值的二叉搜索树&#xff08;BST&#xff09;的根节点 root &#xff0c;…
阅读更多...
Android Compose 一个音视频APP——Magic Music Player

Android Compose 一个音视频APP——Magic Music Player

Magic Music APP Magic Music APP Magic Music APP概述效果预览-视频资源功能预览Library歌曲播放效果预览歌曲播放依赖注入设置播放源播放进度上一首&下一首UI响应 歌词歌词解析解析成行逐行解析 视频播放AndroidView引入Exoplayer自定义Exoplayer样式横竖屏切换 歌曲多任…
阅读更多...
如何根据需求理解CPU、SoC和MCU的区别

如何根据需求理解CPU、SoC和MCU的区别

在当今数字化的世界中&#xff0c;我们经常听到关于CPU、SoC和MCU的名词&#xff0c;它们都是计算机科学和电子工程领域中的重要组成部分。然而&#xff0c;这三者之间存在着明显的区别。本文将深入探讨CPU&#xff08;中央处理器&#xff09;、SoC&#xff08;系统芯片&#x…
阅读更多...
一、部署Oracle

一、部署Oracle

部署Oracle 一、Docker部署1.Oracle11g1.1 测试环境1.1.1 拉取镜像1.1.2 启动容器1.1.3 配置容器环境变量1.1.4 修改sys、system用户密码1.1.5 创建表空间1.1.6 创建用户并授权1.1.5 使用DBeaver测试连接 二、安装包部署 一、Docker部署 1.Oracle11g 1.1 测试环境 当前只能用…
阅读更多...
练习题解（关于最短路径）

练习题解（关于最短路径）

目录 1.租用游艇 2.邮递员送信 3.【模板】单源最短路径&#xff08;标准版&#xff09; 1.租用游艇 P1359 租用游艇 - 洛谷 | 计算机科学教育新生态 (luogu.com.cn) 输入数据&#xff1a; 3 5 15 7 因为这道题数据不大&#xff0c;所有我们直接使用Floyd 算法。 这道题大…
阅读更多...
OpenAI：Sora视频生成模型技术报告（中文）

OpenAI：Sora视频生成模型技术报告（中文）

概述 视频生成模型作为世界模拟器 我们探索视频数据生成模型的大规模训练。具体来说&#xff0c;我们在可变持续时间、分辨率和宽高比的视频和图像上联合训练文本条件扩散模型。我们利用transformer架构&#xff0c;在视频和图像潜在代码的时空补丁上运行。我们最大的模型Sor…
阅读更多...
《苍穹外卖》知识梳理6-缓存商品，购物车功能

《苍穹外卖》知识梳理6-缓存商品，购物车功能

苍穹外卖实操笔记六—缓存商品&#xff0c;购物车功能 一.缓存菜品 可以使用redis进行缓存&#xff1b;另外&#xff0c;在实现缓存套餐时可以使用spring cache提高开发效率&#xff1b;   通过缓存数据&#xff0c;降低访问数据库的次数&#xff1b; 使用的缓存逻辑&#…
阅读更多...
C#，二进制数的按位旋转（Bits Rotate）算法与源代码

C#，二进制数的按位旋转（Bits Rotate）算法与源代码

1 二进制数的按位旋转 二进制数的按位旋转&#xff08;翻转&#xff09;是编程中常见的按位运算方法。 二进制数的按位旋转分为左转、右转。 左转意味着数据变大&#xff0c;右转意味着数据变小&#xff08;有损&#xff09;。 2 源程序 using System; using System.Text; us…
阅读更多...
k8s核心概念

k8s核心概念

Kubernetes 的 Master 包含四个主要的组件&#xff1a;API Server、Controller、Scheduler 以及 etcd Kubernetes 的架构&#xff1a;Master API Server&#xff1a;顾名思义是用来处理 API 操作的&#xff0c;Kubernetes 中所有的组件都会和 API Server 进行连接&#xff0…
阅读更多...
BGP 邻居建立

BGP 邻居建立

拓扑图 配置 BGP进程号及为AS号 使用环回口建立BGP邻居关系时&#xff0c;需要指定更新源地址 EBGP在使用环回口建立邻居关系时&#xff0c;需配置EBGP多跳&#xff0c;环回口路由可达 EBGP的路由器存在IBGP邻居时&#xff0c;需要配置next-hop-local&#xff0c;保证下一跳…
阅读更多...
Linux超详细笔记

Linux超详细笔记

文章目录 Linux学习笔记操作系统Linux初识Linux的诞生Linux内核Linux发行版 虚拟机VMware安装远程连接Linux系统FinalShellFinalShell连接Linux WSL配置UbuntuLinux常用命令1.入门2.ls命令cd命令3.pwd命令4.相对路径和绝对路径5.mkdir命令6.文件操作命令&#xff08;1&#xff…
阅读更多...
Android 基础技术——Binder 机制

Android 基础技术——Binder 机制

笔者希望做一个系列&#xff0c;整理 Android 基础技术&#xff0c;本章是关于Binder 机制 什么是Binder 机制&#xff1a;Binder 是一种进程间通信机制 驱动&#xff1a;Binder 是一个虚拟物理设备驱动 应用层&#xff1a;Binder 是一个能发起通信的 Java 类 为什么要使用Bind…
阅读更多...
腾讯云OSS文件上传功能

腾讯云OSS文件上传功能

腾讯云COS介绍 腾讯云COS&#xff08;Cloud Object Storage&#xff09;是一种基于对象的存储服务&#xff0c;用于存储和管理海量的非结构化数据&#xff0c;如图片、音视频文件、备份数据等。它具有以下特点和优势&#xff1a; 高可靠性&#xff1a;采用分布式存储架构&…
阅读更多...
Kotlin基本语法3集合

Kotlin基本语法3集合

1.List集合 1.1 只读List fun main() {val list listOf("Jason", "Jack", "Jacky")println(list.getOrElse(3){"Unknown"})println(list.getOrNull(3)?:"Unknown") } 1.2 可变List fun main() {val mutableList mutabl…
阅读更多...
MySQL的备份与恢复案例

MySQL的备份与恢复案例

新建数据库 数据库备份&#xff0c;数据库为school&#xff0c;素材如下1.创建student和score表CREATE TABLE student ( id INT(10) NOT NULL UNIQUE PRIMARY KEY , name VARCHAR(20) NOT NULL , sex VARCHAR(4) , birth YEAR, department VARCHAR(20) , address…
阅读更多...
ubuntu22.04@laptop OpenCV Get Started: 010_blob_detection

ubuntu22.04@laptop OpenCV Get Started: 010_blob_detection

ubuntu22.04laptop OpenCV Get Started: 010_blob_detection 1. 源由2. blob应用Demo2.1 C应用Demo2.2 Python应用Demo 3. 重点分析3.1 Threshold3.2 Area3.3 Circularity3.4 Convexity3.5 Inertia Ratio 4. 总结5. 参考资料6. 补充 1. 源由 Blob是图像中的一组连接像素&#…
阅读更多...
LiveGBS流媒体平台GB/T28181常见问题-基础配置流媒体服务配置中本地|内网IP外网IP(可选)外网IP收流如何配置

LiveGBS流媒体平台GB/T28181常见问题-基础配置流媒体服务配置中本地|内网IP外网IP(可选)外网IP收流如何配置

LiveGBS常见问题基础配置流媒体服务配置中本地|内网IP外网IP外网IP收流如何配置&#xff1f; 1、流媒体服务配置2、播放提示none rtp data receive3、多网卡服务器4、收流端口配置5、端口区间可以如何配置6、搭建GB28181视频直播平台 1、流媒体服务配置 LiveGBS中基础配置-》流…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023