前兩篇文章內容點下面連接跳轉(看本篇博客前先看前兩篇會有很大幫助,如果完成第二篇博客的代碼整合并縷清思路后,再做這一個會容易很多,前兩篇寫的也相對來說比較詳細,同樣的知識不會再來一遍的)
1-ESP8266-AT指令初試化及部分基礎知識
2-STM32+ESP8266連接onenet并上傳資料(HTTP)
3-STM32+ESP8266連接onenet上傳資料(MQTT)
MQTT協議介紹–點我
開發流程–點我
素材獲取請點我-提取碼dz91
一、onnet云平臺創建產品和設備
1、在控制臺首頁切換舊版本
控制臺首頁–請點我

2、選擇全部產品-多協議接入

3、創建MQTT協議下的產品和設備
在MQTT協議下自己創建產品,在產品之下再對應創建一個設備即可(下方為官方檔案)-也可以自行百度新建產品和設備的博客
創建產品和設備–官方檔案

在產品下添加設備的時候會提示添加鑒權資訊(隨便寫就可以),在后續會用到

4、查看產品ID,設備ID,鑒權資訊


準備資訊完畢,接下來即可開始
二、STM32+ESP8266上傳溫濕度到onenet云平臺
如若看懂了并整合了上一篇的博客內容,此部分相當簡單,需要修改的地方很少
1、8266初試化(此函式無需修改)
主要是初始化使能引腳,模式設定,連接路由器,開啟單連接,連接TCP服務器(初始化同上一篇)
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_13; //GPIOC13-復位
GPIO_Initure.GPIO_Speed = GPIO_Speed_50MHz;
GPIO_Init(GPIOC, &GPIO_Initure);
GPIO_WriteBit(GPIOC, GPIO_Pin_13, Bit_RESET);
delay_ms(250);
GPIO_WriteBit(GPIOC, GPIO_Pin_13, Bit_SET);
delay_ms(500);
ESP8266_Clear();
printf("1. AT\r\n");
while(ESP8266_SendCmd("AT\r\n", "OK"))
delay_ms(500);
printf("2. CWMODE\r\n");
while(ESP8266_SendCmd("AT+CWMODE=1\r\n", "OK"))
delay_ms(500);
printf( "3. AT+CWDHCP\r\n");
while(ESP8266_SendCmd("AT+CWDHCP=1,1\r\n", "OK"))
delay_ms(500);
printf("4. CWJAP\r\n");
while(ESP8266_SendCmd(ESP8266_WIFI_INFO, "GOT IP"))
delay_ms(500);
printf( "5. CIPSTART\r\n");
while(ESP8266_SendCmd(ESP8266_ONENET_INFO, "CONNECT"))
delay_ms(500);
printf("6. ESP8266 Init OK\r\n");
}
2、 與onenet創建連接(此函式無需修改)
如果8266成功連接到onenet云平臺會列印“Tips: 連接成功”資訊提示語,如果連接失敗會列印出連接失敗的原因
_Bool OneNet_DevLink(void)
{
MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0}; //協議包
unsigned char *dataPtr;
_Bool status = 1;
//列印一下資訊產品id,鑒權資訊,設備ID
printf("OneNet_DevLink\r\nPROID: %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)// MQTT資料接收型別判斷(connack報文)
{
switch(MQTT_UnPacketConnectAck(dataPtr))//列印是否連接成功及連接失敗的原因
{
case 0:printf( "Tips: 連接成功\r\n");status = 0;break;
case 1:printf( "WARN: 連接失敗:協議錯誤\r\n");break;
case 2:printf( "WARN: 連接失敗:非法的clientid\r\n");break;
case 3:printf( "WARN: 連接失敗:服務器失敗\r\n");break;
case 4:printf( "WARN: 連接失敗:用戶名或密碼錯誤\r\n");break;
case 5:printf( "WARN: 連接失敗:非法鏈接(比如token非法)\r\n");break;
default:printf( "ERR: 連接失敗:未知錯誤\r\n");break;
}
}
}
MQTT_DeleteBuffer(&mqttPacket); //刪包
}
else
printf( "WARN: MQTT_PacketConnect Failed\r\n");
return status;
}
3、發送資料給onenet
上傳資料到平臺(此函式無需修改)
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) //封包
{
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");
}
}
4、資料封裝函式(此函式需要修改)—重點
此函式是將我們想上傳的資料進行包裝整合到一個陣列中
和上篇思路是一樣的,把溫濕度的屬性名稱和數值存盤到陣列中
unsigned char OneNet_FillBuf(char *buf)
{
char text[32];
memset(text, 0, sizeof(text));
strcpy(buf, ",;");
memset(text, 0, sizeof(text));
sprintf(text, "Tempreture,%d.%d;",temperatureH,temperatureL);
strcat(buf, text);
memset(text, 0, sizeof(text));
sprintf(text, "Humidity,%d.%d;", humidityH,humidityL);
strcat(buf, text);
}
5、ESP8266發送資料
發送資料的指令發出,收到>后即可發送一條資料(并沒有開啟透傳模式),每次根據資料長度發送資料
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); //發送設備連接請求資料
}
}
6、平臺回傳資料檢測(重要)-目前此處不用修改,在下面第三部分使用
此函式在下面的遠程控制部分會用到,訂閱決議云端下發的控制指令,進而使ESP8266執行對應的操作
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)
{
//列印收到的資訊
printf( "cmdid: %s, req: %s, req_len: %d\r\n", cmdid_topic, req_payload, req_len);
if(MQTT_PacketCmdResp(cmdid_topic, req_payload, &mqttPacket) == 0) //命令回復組包
{
printf( "Tips: Send CmdResp\r\n");
ESP8266_SendData(mqttPacket._data, mqttPacket._len); //回復命令
MQTT_DeleteBuffer(&mqttPacket); //刪包
}
}
break;
case MQTT_PKT_PUBACK: //發送Publish訊息,平臺回復的Ack
if(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);
}
}
7、主函式部分
int main(void)
{
unsigned char *dataPtr = NULL;
unsigned short timeCount = 0; //發送間隔變數
delay_init(); //延時函式初始化
NVIC_Configuration(); //設定NVIC中斷分組2:2位搶占優先級,2位回應優先級
LED_Init(); //LED埠初始化
OLED_Init(); //初始化OLED
OLED_Clear();
uart_init(115200);//串口1初始化
uart2_init(115200);//串口2初始化
DHT11_Init();//DHT11初始化
ESP8266_Init(); //初始化ESP8266
printf("8266_INIT_END\n");
while(OneNet_DevLink()) //接入OneNET
delay_ms(500);
printf("接入onenet成功");
while(1)
{
if(++timeCount >= 500) //時間間隔5s
{
if( Read_DHT11(&DHT11_Data)==SUCCESS)
{
//printf("temp %d hum %d",DHT11_Data.temp_int,DHT11_Data.humi_int);
OLED_ShowString(8,4,"TEMP:");
OLED_ShowNum(48,4,DHT11_Data.temp_int,2,16);
OLED_ShowChar(70,4,'.');
OLED_ShowNum(85,4,DHT11_Data.temp_deci,1,16);
printf("hum=%d.%d\n",DHT11_Data.humi_int,DHT11_Data.humi_deci);
OLED_ShowString(8,2,"HUM:");
OLED_ShowNum(48,2,DHT11_Data.humi_int,2,16);
OLED_ShowChar(70,2,'%');
delay_ms(100);
//主要用于資料上傳使用
humidityH=DHT11_Data.humi_int; //濕度整數部分
humidityL=DHT11_Data.humi_deci; //濕度小數部分
temperatureH=DHT11_Data.temp_int; //溫度整數部分
temperatureL=DHT11_Data.temp_deci; //溫度小數部分
printf("hum temp=%d .%d %d .%d\r\n",humidityH,humidityL,temperatureH,temperatureL);
}
printf( "OneNet_SendData\r\n");//通過串口1發送提示資訊(要開始發送資料了)
OneNet_SendData();//發送資料給onenet
printf("send_data_end\n");
timeCount = 0;
ESP8266_Clear();
}
dataPtr = ESP8266_GetIPD(0);//獲取平臺回傳的資料
if(dataPtr != NULL)//如果回傳資料不為空
OneNet_RevPro(dataPtr);//平臺回傳資料檢測
delay_ms(10);
}
}
8、在onenet.c檔案中修改設備ID,產品ID,鑒權資訊(在上面所復制保存的資訊)

9、在esp8266.c檔案中修改wifi名和密碼,連接tcp服務器的IP地址和埠號


將采集到的溫濕度在本地顯示并上傳云端已經完成,在onenet云平臺的資料流可以查看資料
三、云平臺實作指令下發對Led燈的控制–兩種方法
(一)方法一:使用json方法
是決議出屬性值并執行LED亮滅
cjson函式介紹及使用方法–請點我
所修改函式正是上面第二部分的第六個函式
1、平臺回傳資料檢測
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;
type = MQTT_UnPacketRecv(cmd);
switch(type)
{
case MQTT_PKT_CMD: //命令下發
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");//提取對應屬性的數值
// printf("json_value: [%s]\r\n",json_value->string);//轉化為字串數值
// printf("json_value: [%d]\r\n",json_value->valueint);//轉化為數值型數值
if((json_value->valueint)==1)
LED0=1;
else if((json_value->valueint)==0)
LED0=0;
}
//同上
json1 = cJSON_Parse(req_payload);
if (!json1)
printf("Error before: [%s]\n",cJSON_GetErrorPtr());
else
{
json_value1 = cJSON_GetObjectItem(json1 , "LED1");
if((json_value1->valueint)==1)//整數值
LED1=1;
else if((json_value1->valueint)==0)
LED1=0;
}
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訊息,平臺回復的Ack
if(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);
}
}
下面這是從代碼中提取的重要部分
//將一個JSON資料包,按照cJSON結構體的結構序列化整個資料包,并在堆中開辟一塊記憶體存盤cJSON結構體
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)
LED0=1;
else if((json_value->valueint)==0)
LED0=0;
}
對訂閱資料的指令決議完畢
2、資料封裝函式
接下來執行第二步在資料封裝函式里面添加讀取LED0和LED1引腳電平的函式,以及將高低電平上傳回云端,實作云下和云上狀態的同步
讀取引腳電平(第二部分的第四個函式中添加)
LED0_FLAG=GPIO_ReadInputDataBit(GPIOB, GPIO_Pin_5);//讀取LED的開關狀態(即對應引腳的)
LED1_FLAG=GPIO_ReadInputDataBit(GPIOE, GPIO_Pin_5);
將LED的開關狀態添加到上傳的資料中去
memset(text, 0, sizeof(text));
sprintf(text, "LED0,%d;", LED0_FLAG);
strcat(buf, text);
memset(text, 0, sizeof(text));
sprintf(text, "LED1,%d;", LED1_FLAG);
strcat(buf, text);
printf("buf_mqtt=%s\r\n",buf);
封裝函式整合后為(包含溫濕度上傳及開關的狀態)
unsigned char OneNet_FillBuf(char *buf)
{
char text[32];
LED0_FLAG=GPIO_ReadInputDataBit(GPIOB, GPIO_Pin_5);//讀取LED的開關狀態(即對應引腳的)
LED1_FLAG=GPIO_ReadInputDataBit(GPIOE, GPIO_Pin_5);
printf("LED0_FLAG_TYPE=%d\n",sizeof(LED0_FLAG));
memset(text, 0, sizeof(text));
strcpy(buf, ",;");
memset(text, 0, sizeof(text));
sprintf(text, "Tempreture,%d.%d;",temperatureH,temperatureL);
strcat(buf, text);
memset(text, 0, sizeof(text));
sprintf(text, "Humidity,%d.%d;", humidityH,humidityL);
strcat(buf, text);
memset(text, 0, sizeof(text));
sprintf(text, "LED0,%d;", LED0_FLAG);
strcat(buf, text);
memset(text, 0, sizeof(text));
sprintf(text, "LED1,%d;", LED1_FLAG);
strcat(buf, text);
printf("buf_mqtt=%s\r\n",buf);
return strlen(buf);
}
3、云端下發指令資料格式及效果展示
燒寫程式后,接下來通過云端實作遠程對LED0和LED1的開關控制
最初的狀態兩個小燈都是關閉的
找到右邊的下發指令并打開發送控制指令

發送的資料格式為
{“LED0”:0}
LED0是屬性名稱,:后面的數值0是表示打開LED0,如若關閉的話把屬性的值0修改為1即可

我們可以看到串口助手已經將接收到的資料列印出來,而且有接受指令前和接收指令后LED0的開關狀態對比

效果顯示

測驗LED1(同上,資料格式中屬性的名稱只需要修改為LED1即可)

此時也可以通過串口助手看到LED1在接收指令前的前后變化,并且LED0依舊保持上一次打開的狀態

狀態效果顯示

接下來除了利用剛才的下發命令控制還可以通過應用管理中的可視化進行實行控制,和前者相比有顯著的優點,溫濕度顯示效果更佳,下發控制指令只需要點一下開或者關的按鈕即可實作對應控制指令的下發,實作對LED0和LED1的開關控制
LED0打開,LED1關閉狀態

LED0和LED1都保持打開的狀態

LED0關閉,LED1打開狀態

(二)方法二:使用字串匹配函式來實作
和上面講到的方法一中所要修改的函式是一樣的
1、平臺回傳資料檢測
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);//MQTT資料接收型別判斷
switch(type)
{
case MQTT_PKT_CMD: //命令下發
//引數1收到的
result = MQTT_UnPacketCmd(cmd, &cmdid_topic, &req_payload, &req_len); //解出topic和訊息體
if(result == 0)
{
//列印收到的資訊,引數2資料,引數3資料長度
printf( "cmdid: %s, req: %s, req_len: %d\r\n", cmdid_topic, req_payload, req_len);
if(MQTT_PacketCmdResp(cmdid_topic, req_payload, &mqttPacket) == 0) //命令回復組包
{
printf( "Tips: Send CmdResp\r\n");
ESP8266_SendData(mqttPacket._data, mqttPacket._len); //回復命令
MQTT_DeleteBuffer(&mqttPacket); //刪包
}
}
break;
case MQTT_PKT_PUBACK: //發送Publish訊息,平臺回復的Ack
if(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(strstr((char *)req_payload, "led1")) //搜索"led1"
{
if(num == 1) //控制資料如果為1,代表開
{
LED1=1;
}
else if(num == 0) //控制資料如果為0,代表關
{
LED1=0;
}
}
//下同
else if(strstr((char *)req_payload, "led0"))
{
if(num == 1)
{
LED0=1;
}
else if(num == 0)
{
LED0=0;
}
}
}
if(type == MQTT_PKT_CMD || type == MQTT_PKT_PUBLISH)
{
MQTT_FreeBuffer(cmdid_topic);
MQTT_FreeBuffer(req_payload);
}
}
2、封裝函式整合后為(包含溫濕度上傳及開關的狀態)
unsigned char OneNet_FillBuf(char *buf)
{
char text[32];
LED0_FLAG=GPIO_ReadInputDataBit(GPIOB, GPIO_Pin_5);//讀取LED的開關狀態(即對應引腳的)
LED1_FLAG=GPIO_ReadInputDataBit(GPIOE, GPIO_Pin_5);
printf("LED0_FLAG_TYPE=%d\n",sizeof(LED0_FLAG));
memset(text, 0, sizeof(text));
strcpy(buf, ",;");
memset(text, 0, sizeof(text));
sprintf(text, "Tempreture,%d.%d;",temperatureH,temperatureL);
strcat(buf, text);
memset(text, 0, sizeof(text));
sprintf(text, "Humidity,%d.%d;", humidityH,humidityL);
strcat(buf, text);
memset(text, 0, sizeof(text));
sprintf(text, "LED0,%d;", LED0_FLAG);
strcat(buf, text);
memset(text, 0, sizeof(text));
sprintf(text, "LED1,%d;", LED1_FLAG);
strcat(buf, text);
printf("buf_mqtt=%s\r\n",buf);
return strlen(buf);
}
在云端下發指令測驗中只需要把原來下發的資料格式中屬性名稱修改一下即可
下發資料格式為
led0:0
led0:1
led1:0
led1:1
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/287689.html
標籤:其他
