STM32+ESP8266+ONENET+微信小程序上傳數據下發指令避坑指南

之前只做過類似的但是以為這種爛大街的功能應該不難結果還是踩了不少坑,記錄幾個需要注意的點

首先貼一個非常有用的視頻,里面講的很詳細,給的資料也很全【【新版OneNet云平臺】STM32+ESP8266上傳數據,簡單易上手!】?https://www.bilibili.com/video/BV1jS421A7Bk/?share_source=copy_web&vd_source=cfdb072e82eccc98495802cc5b56a05c

1、創建產品的時候選擇onejson,自定義方案。這樣選擇的就是物模型,之后可以去使用物模型的API調試。

2、設置物模型

大概有以下幾種比較常用的,int32,float,enum。enum設置的屬性都是到時候用來做指令下發的,其余是上傳傳感器數據的。要注意onenet平臺接受的是json格式數據,而且上傳的數據格式必須與你設置的對應上。下面給了個OneNet_FillBuf示例。id不用改,主要是temper標識符和value后面的格式 %d 需要和你設置的物模型對應上

unsigned char OneNet_FillBuf(char *buf)
{char text[48];strcpy(buf,"{\"id\":\"1124\",\"params\":{");memset(text,0,sizeof(text));sprintf(text,"\"temper\":{\"value\":%d},",sensorData.temp);strcat(buf,text);memset(text,0,sizeof(text));sprintf(text,"\"humidity\":{\"value\":%.2f},",sensorData.humidity);strcat(buf,text);memset(text,0,sizeof(text));sprintf(text,"\"tvoc\":{\"value\":%d},",sensorData.tvoc);strcat(buf,text);memset(text,0,sizeof(text));sprintf(text,"\"light\":{\"value\":%d},",sensorData.light);strcat(buf,text);memset(text,0,sizeof(text));sprintf(text,"\"water_level\":{\"value\":%.2f}",sensorData.water_level);strcat(buf,text);strcat(buf,"}}");return strlen(buf);}//==========================================================
//	函數名稱:	OneNet_SendData
//
//	函數功能:	上傳數據到平臺
//
//	入口參數:	type:發送數據的格式
//
//	返回參數:	無
//
//	說明:		
//==========================================================
void OneNet_SendData(void)
{MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0};												//協議包char buf[256];short body_len = 0, i = 0;memset(buf, 0, sizeof(buf));//清空數組內容body_len = OneNet_FillBuf(buf);	//獲取當前需要發送的數據流的總長度//printf("%s\r\n",buf);if(body_len){if(MQTT_PacketSaveData(DEVICE_NAME, body_len, NULL, 5, &mqttPacket) == 0)							//封包{for(; i < body_len; i++){mqttPacket._data[mqttPacket._len++] = buf[i];}ESP8266_SendData(mqttPacket._data, mqttPacket._len);									//上傳數據到平臺MQTT_DeleteBuffer(&mqttPacket);															//刪包}else;
//			//printf(  "WARN:EDP_NewBuffer Failed\r\n");}}

3、微信小程序實現傳感器數據的同步顯示和指令下發(微信小程序代碼)

這里主要用了這兩個API,可以現在onenet云平臺上調試一下,看正確的返回格式是什么樣。

設備屬性最新數據查詢示例代碼如下:

//OneNet接入信息配置
const MQTT_Product_Id = "";
const MQTT_Device_Name = "";// MQTT API配置
const MQTT_GET_URL = "https://iot-api.heclouds.com/thingmodel/query-device-property?product_id=" + MQTT_Product_Id + "&device_name=" + MQTT_Device_Name;const MQTT_POST_URL = "https://iot-api.heclouds.com/thingmodel/set-device-desired-property";//使用token工具生成
const MQTT_Authorization = "";onLoad: function() {// 頁面加載時立即獲取一次數據this.getinfo();// 設置定時器,每5秒獲取一次數據this.setData({timer: setInterval(() => {this.getinfo();}, 5000)});},getinfo: function() {var that = this;wx.request({url: MQTT_GET_URL,header: {"authorization": MQTT_Authorization},method: "GET",success: function(res) {console.log("獲取成功", res);if (res.data && res.data.code === 0) {// 解析設備數據const deviceData = {};res.data.data.forEach(item => {if (item && item.identifier) {deviceData[item.identifier] = item.value;}});// 更新頁面數據that.setData({soilHumidity: deviceData['humidity'] + '%',waterLevel: deviceData['water_level'] + 'm',lightIntensity: deviceData['light'] + 'lux',airQuality: deviceData['tvoc'],envTemper: deviceData['temper'] + '℃',lastUpdateTime: new Date().toLocaleTimeString()});}},fail: function(err) {console.error('獲取數據失敗:', err);}});}

指令下發的示例代碼如下:

toggleMode() {const newMode = !this.data.autoMode;const modeValue = newMode ? 0 : 2;wx.request({url: MQTT_POST_URL,method: 'POST',header: {"authorization": MQTT_Authorization},data: {"product_id": MQTT_Product_Id,"device_name": MQTT_Device_Name,"params": {"mode": modeValue}},success: res => {console.log("模式切換成功:", res);this.setData({autoMode: newMode});},fail: err => {console.error("模式切換失敗:", err);wx.showToast({title: '模式切換失敗',icon: 'none'});}});},

4、微信小程序指令下發之后,單片機那邊進行數據解析(單片機端代碼)

單片機收到的數據是json格式的,所以只需要去尋找目標字段,然后讀取后面的數值即可

void OneNet_RevPro(unsigned char *cmd)
{char *req_payload = NULL;char *cmdid_topic = NULL;unsigned short topic_len = 0;unsigned short req_len = 0;unsigned char qos = 0;static unsigned short pkt_id = 0;unsigned char type = 0;short result = 0;type = MQTT_UnPacketRecv(cmd);switch(type){case MQTT_PKT_PUBLISH:																//接收的Publish消息result = MQTT_UnPacketPublish(cmd, &cmdid_topic, &topic_len, &req_payload, &req_len, &qos, &pkt_id);if(result == 0){//				printf(  "topic: %s, topic_len: %d, payload: %s, payload_len: %d\r\n",
//																	cmdid_topic, topic_len, req_payload, req_len);				}case MQTT_PKT_PUBACK:														//發送Publish消息,平臺回復的Ackif(MQTT_UnPacketPublishAck(cmd) == 0){//printf(  "Tips:	MQTT Publish Send OK\r\n");}break;case MQTT_PKT_SUBACK:																//發送Subscribe消息的Ackif(MQTT_UnPacketSubscribe(cmd) == 0){//printf(  "Tips:	MQTT Subscribe OK\r\n");}else{//printf(  "Tips:	MQTT Subscribe Err\r\n");}break;default:result = -1;break;}ESP8266_Clear();									//清空緩存if(result == -1)return;//解析req_payload數組中的值即可char *pump_ptr = strstr(req_payload, "\"pump\":");if (pump_ptr != NULL) {}if(type == MQTT_PKT_CMD || type == MQTT_PKT_PUBLISH){MQTT_FreeBuffer(cmdid_topic);MQTT_FreeBuffer(req_payload);}}

5、(補充)如何使用token生成需要的MQTT鑒權信息

需要使用到這個token計算工具(上文的視頻提供的資料里有)

需要填寫的內容分別是:
res:products/你的產品id/devices/你的設備id
et:時間戳 盡量往后填就行了,可以使用這個網址轉換https://www.beijing-time.org/shijianchuo/

key:設備密鑰

method我使用的sha1,version不需要改
?

最后祝大家都調試順利~后續可能還會隨緣更新一些實現細節

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/906679.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/906679.shtml
英文地址,請注明出處:http://en.pswp.cn/news/906679.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

【知識點】關于vue3中markRow、shallowRef、shallowReactive的了解

首先我們先了解一下這三個函數的定義以及區別 markRow 定義&#xff1a; 一個用于標記對象為非響應式的工具函數 shallowRef 定義&#xff1a; 一個用于創建淺層響應式引用的函數&#xff0c;只對 .value 本身進行響應式處理&#xff0c;不會遞歸地將 .value 指向的對象或…

后端開發實習生-抖音生活服務

職位描述 ByteIntern&#xff1a;面向2026屆畢業生&#xff08;2025年9月-2026年8月期間畢業&#xff09;&#xff0c;為符合崗位要求的同學提供轉正機會。 團隊介紹&#xff1a;生活服務業務依托于抖音、抖音極速版等平臺&#xff0c;致力于促進用戶與本地服務的連接。過去一…

OceanBase 共享存儲:云原生數據庫的存儲

目錄 探會——第三屆 OceanBase 開發者大會 重磅發布&#xff1a;OceanBase 4.3 開發者生態全面升級 實戰演講&#xff1a;用戶案例與行業落地 OceanBase 共享存儲架構解析 什么是共享存儲架構&#xff1f; 云原生數據庫的架構 性能、彈性與多云的統一 為何OceanBase能…

C++ 結構體封裝模式與 Promise 鏈式調用:設計思想的異曲同工

C 結構體封裝模式與 Promise 鏈式調用&#xff1a;設計思想的異曲同工 在軟件開發中&#xff0c;我們常常追求代碼的可維護性、可擴展性和可讀性。不同的編程語言和場景下&#xff0c;雖然實現方式各異&#xff0c;但背后的設計思想往往存在著奇妙的相似性。本文將探討 C 中結…

【Go】1、Go語言基礎

前言 本系列文章參考自稀土掘金上的 【字節內部課】公開課&#xff0c;做自我學習總結整理。 Go語言的特點 Go語言由Google團隊設計&#xff0c;以簡潔、高效、并發友好為核心目標。 具有以下優點&#xff1a; 語法簡單、學習曲線平緩&#xff1a;語法關鍵字很少&#xff0c;且…

AI時代的新營銷范式:生成式引擎優化(GEO)的崛起——品牌如何被大模型收錄

在數字化浪潮席卷全球的今天&#xff0c;我們正站在一個前所未有的歷史拐點。如果說過去二十年&#xff0c;搜索引擎優化&#xff08;SEO&#xff09;重塑了企業與消費者的連接方式&#xff0c;那么未來二十年&#xff0c;生成式引擎優化&#xff08;GEO&#xff09;將徹底顛覆…

實用藍牙耳機哪款好?先做好使用場景分析!

市面上的藍牙耳機款式繁多&#xff0c;618到來之際&#xff0c;消費者如何選擇適合自己的藍牙耳機&#xff1f;實用藍牙耳機哪款好&#xff1f;關鍵在于做好使用場景分析&#xff01;今天&#xff0c;就帶大家結合不同的使用場景&#xff0c;分享三款倍思音頻的精品藍牙耳機。 …

PTA刷題筆記3(微難,有詳解)

7-15 計算圓周率 代碼如下&#xff1a; #include <stdio.h>int main() {double threshold;scanf("%lf", &threshold);double pi_over_2 1.0; // π/2的初始值&#xff08;第一項1&#xff09;double term 1.0; // 當前項的值int n 1; …

基于SpringBoot+Vue的社區醫院信息平臺設計與實現

項目背景與概述 隨著醫療健康信息化的發展&#xff0c;社區醫院的管理逐漸由傳統的手工模式轉向信息化管理。為了提高醫院的管理效率、減少人工操作、提升服務質量&#xff0c;開發一個高效且實用的社區醫院信息平臺顯得尤為重要。本系統基于Spring Boot框架與MySQL數據庫設計…

舊物回收小程序:讓閑置煥發光彩,為生活增添價值

你是否常常為家中堆積如山的閑置物品而煩惱&#xff1f;那些曾經心愛的物品&#xff0c;如今卻成了占據空間的“雞肋”&#xff0c;丟棄可惜&#xff0c;留著又無處安放。別擔心&#xff0c;一款舊物二手回收小程序將為你解決這一難題&#xff0c;讓閑置物品重新煥發光彩&#…

掩碼與網關是什么?

1. 子網掩碼&#xff08;Subnet Mask&#xff09; 作用&#xff1a;劃分“小區”范圍 想象你住在一個小區&#xff08;子網&#xff09;里&#xff1a; 小區門牌號 IP地址&#xff08;如 192.168.1.10&#xff09; 小區邊界 子網掩碼&#xff08;如 255.255.255.0&#xf…

【Bluedroid】藍牙HID Host disconnect流程源碼解析

本文基于 Android 藍牙 HID&#xff08;Human Interface Device&#xff09;Host 模塊的源碼&#xff0c;深入解析 HID 設備斷開連接的完整流程。重點覆蓋從應用層觸發斷開請求&#xff0c;到 BTIF 層&#xff08;接口適配層&#xff09;狀態校驗與異步傳遞、BTA 層&#xff08…

python定時刪除指定索引

腳本 import logging from datetime import datetime, timedelta from elasticsearch import Elasticsearch# 配置日志記錄 logging.basicConfig(filenamedelete_uat_indices.log,levellogging.INFO,format%(asctime)s - %(levelname)s - %(message)s )# Elasticsearch 集群的…

GESP編程等級認證C++三級7-字符、字符數組與字符串2

2.3 用字符串定義字符數組的好處 使用字符串定義字符數組需要額外考慮其末尾的“\0”&#xff0c;為什么還要使用這種看上去“麻煩”的方法呢&#xff1f;從圖5所示的代碼就能看出原因。 圖5 用字符串定義字符數組好處的代碼 從圖5中可以看出&#xff0c;a4是用字符串進行初始…

EasyRTC音視頻實時通話WebP2P技術賦能的全場景實時通信解決方案

一、技術背景 在數字化浪潮席卷全球的當下&#xff0c;實時通信技術憑借其即時性、高效性的優勢&#xff0c;已然成為推動各行業創新發展的核心動能。EasyRTC深度融合WebP2P技術&#xff0c;構建起去中心化的通信架構&#xff0c;實現了低延遲、高可靠的數據傳輸&#xff0c;為…

Claude MCP協議從入門到精通

目錄 一、什么是MCP協議? 二、Function Calling 和 MCP 協議的區別? 三、MCP相關網站 3.1 官方文檔 3.2 綜合型 MCP 資源聚合平臺 3.3 垂直領域 MCP Server 工具 3.4 開發者工具與社區 3.5 企業級服務與數據庫集成 3.6 新手友好型平臺 四、MCP 架構 4.1. MCP Hosts…

YOLOv11改進 | Conv/卷積篇 | 2024 ECCV最新大感受野的小波卷積WTConv助力YOLOv11有效漲點

YOLOv11改進 | Conv/卷積篇 | 2024 ECCV最新大感受野的小波卷積WTConv助力YOLOv11有效漲點 引言 在計算機視覺領域&#xff0c;卷積神經網絡&#xff08;CNN&#xff09;的核心操作——卷積運算正經歷著革命性的變革。2024年ECCV會議提出的**小波卷積&#xff08;WTConv, Wav…

英偉達CEO黃仁勛COMPUTEX 2025演講實錄:AI工廠時代已來,Blackwell架構全面投產

5月19日&#xff0c;英偉達創始人兼首席執行官黃仁勛在臺北國際電腦展&#xff08;COMPUTEX 2025&#xff09;發表主題演講&#xff0c;系統闡述了英偉達從芯片設計向AI基礎設施服務商的戰略轉型&#xff0c;并披露了包括Blackwell架構升級、新一代AI計算平臺及機器人技術在內的…

RabbitMQ的核心原理及應用

在分布式系統架構中&#xff0c;消息中間件是實現服務解耦、流量緩沖的關鍵組件。RabbitMQ 作為基于 AMQP 協議的開源消息代理&#xff0c;憑借高可靠性、靈活路由和跨平臺特性&#xff0c;被廣泛應用于企業級開發和微服務架構中。本文將系統梳理 RabbitMQ 的核心知識&#xff…

服務攻防矩陣

4.1 中間件漏洞利用 WebLogic反序列化漏洞&#xff08;CVE-2023-21839&#xff09; 漏洞原理&#xff1a; T3協議反序列化未嚴格校驗&#xff0c;攻擊者可注入惡意序列化對象執行任意代碼。 攻擊流程&#xff1a; 使用ysoserial生成CommonsCollections6 payload&#xff1…