本實(shí)驗(yàn)以熱釋電傳感器感應(yīng)人體為例,介紹如何將 STM32+ESP8266通過(guò)MQTT協(xié)議接入阿里云物聯(lián)網(wǎng)平臺(tái)。
1.前期準(zhǔn)備
硬件:野火指南者STM32F103VET6開發(fā)板,HC-SR501熱釋電傳感器
軟件:Keil5
平臺(tái):阿里云
2.具體操作
阿里云物聯(lián)網(wǎng)平臺(tái)配置
創(chuàng)建產(chǎn)品
1.png (150.15 KB, 下載次數(shù): 56)
下載附件
2021-4-27 23:25 上傳
此次實(shí)驗(yàn)通過(guò)阿里云平臺(tái)接收熱釋電傳感器的信號(hào),所以選擇帶有布爾型的紅外檢測(cè)狀態(tài)的產(chǎn)品模型就能夠滿足需求。 創(chuàng)建設(shè)備
2.png (54.92 KB, 下載次數(shù): 67)
下載附件
2021-4-27 23:25 上傳
產(chǎn)品選擇剛剛創(chuàng)建的demo,點(diǎn)擊新增設(shè)備。 獲得三元組
3.png (38.83 KB, 下載次數(shù): 63)
下載附件
2021-4-27 23:25 上傳
在設(shè)備建立完成后系統(tǒng)會(huì)自動(dòng)生成一個(gè)ProductKey,DeviceName和DeviceSecret,簡(jiǎn)稱為三元組。
通信Topic
實(shí)驗(yàn)基于MQTT(V3.1.1)協(xié)議與平臺(tái)進(jìn)行通信,MQTT協(xié)議是基于代理的”發(fā)布/訂閱“模式的消息傳輸協(xié)議,在這個(gè)協(xié)議中,有發(fā)布者,訂閱者和代理(broker)三種角色,消息由發(fā)布者通過(guò)topic發(fā)布,由訂閱者對(duì)感興趣的topic進(jìn)行訂閱,一個(gè)發(fā)布者可以對(duì)應(yīng)多個(gè)訂閱者。
在設(shè)備的物模型通信Topic中選擇后綴為post與set的Topic,分別代表發(fā)布與訂閱,當(dāng)然也可以自定義通信Topic。在獲取三元組和通信Topic后,可以先將其保存在文本中,方便以后使用。這樣,物聯(lián)網(wǎng)平臺(tái)的配置基本完成了。
硬件配置
HC-SR501熱釋電傳感器與STM32的連接較為簡(jiǎn)單,只需要將GND接地,VCC接3.3V-5V電源,OUT接I/O口即可。左邊的旋鈕用來(lái)調(diào)節(jié)靈敏度,順時(shí)針靈敏度高,逆時(shí)針靈敏度低;右側(cè)的旋鈕用來(lái)調(diào)節(jié)延時(shí)感應(yīng),順時(shí)針延時(shí)加長(zhǎng),逆時(shí)針延時(shí)減短。
軟件配置
熱釋電傳感器配置
#include "sensor.h"
void HCSR501_Config(void)
{
GPIO_InitTypeDef GPIO_InitStructure;
RCC_APB2PeriphClockCmd(HCSR501_INT_GPIO_CLK ,ENABLE);
GPIO_InitStructure.GPIO_Pin = HCSR501_INT_GPIO_PIN;
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_IN_FLOATING;
GPIO_Init(HCSR501_INT_GPIO_PORT, &GPIO_InitStructure);
}
uint8_t HCSR501_Statue(void)
{
if(GPIO_ReadInputDataBit(HCSR501_INT_GPIO_PORT, HCSR501_INT_GPIO_PIN)==Bit_SET)
return 1;
else return 0;
}
ESP8266連接WiFi
AT+CWMODE=1:設(shè)置工作模式(STA模式)
bool ESP8266_Net_Mode_Choose ( ENUM_Net_ModeTypeDef enumMode )
{
switch ( enumMode )
{
case STA:
return ESP8266_Cmd ( "AT+CWMODE=1", "OK", "no change", 10);
case AP:
return ESP8266_Cmd ( "AT+CWMODE=2", "OK", "no change", 10);
case STA_AP:
return ESP8266_Cmd ( "AT+CWMODE=3", "OK", "no change", 10);
default:
return false;
}
}
AT+CWJAP=“SSID”,“PASSWORD”:連接當(dāng)前環(huán)境的WIFI熱點(diǎn)(熱點(diǎn)名,密碼)
bool ESP8266_JoinAP ( char * pSSID, char * pPassWord )
{
char cCmd [120];
sprintf ( cCmd, "AT+CWJAP=\"%s\",\"%s\"", pSSID, pPassWord );
return ESP8266_Cmd ( cCmd, "OK", NULL, 150 );
}
AT+CIPMODE=1:開啟透?jìng)髂J?br />
bool ESP8266_UnvarnishSend ( void )
{
if ( ! ESP8266_Cmd ( "AT+CIPMODE=1", "OK", NULL, 100 ) )
return false;
return
ESP8266_Cmd ( "AT+CIPSEND", "OK", ">", 100 );
}
MQTT移植
在Github上下載paho mqtt開源代碼Github代碼鏈接,解壓后將paho.mqtt.embedded-c-master\MQTTPacket\src中的MQTT源碼以及paho.mqtt.embedded-c-master\MQTTPacket\samples中的transport文件復(fù)制到自己的項(xiàng)目中。修改transport.c文件中的transport_sendPacketBuffer()和transport_getdata()函數(shù)用于發(fā)送和接收TCP數(shù)據(jù)。
修改MQTT協(xié)議相關(guān)參數(shù)
#define HOST_NAME "a12Dg3Gsw50.iot-as-mqtt.cn-shanghai.aliyuncs.com" //服務(wù)器域名
#else
#define HOST_NAME "139.196.135.135" //服務(wù)器IP地址
#endif
#define HOST_PORT 1883 //由于是TCP連接,端口必須是1883
#define CLIENT_ID "test01|securemode=3,signmethod=hmacsha1|" //ID
#define USER_NAME "test01&a12Dg3Gsw50" //用戶名
#define PASSWORD "ce046a566db6047561024d89b99b898f98c39648" //秘鑰
#define TOPIC "/sys/a12Dg3Gsw50/test01/thing/service/property/set" //訂閱的主題
#define PUBTOPIC "/sys/a12Dg3Gsw50/test01/thing/event/property/post" //發(fā)布的主題
HOST_NAME 固定格式:{YourProductKey}.iot-as-mqtt.{YourRegionId}.aliyuncs.com。 {YourProductKey}為設(shè)備的ProductKey。 {YourRegionId}為區(qū)域ID。
HOST_PORT 1883
Client ID 固定格式:{YourDeviceName}|securemode=3,signmethod=hmacsha1|。 {YourDeviceName}為三元組中的DeviceName。
User Name 固定格式:{YourDeviceName}&{YourProductKey}。 {YourDeviceName}和{YourProductKey}分別為三元組中的DeviceName和ProductKey。
Password 格式:clientId{YourDeviceName}deviceName{YourDeviceName}productKey{YourProductKey} {YourDeviceName}和{YourProductKey}分別為三元組中的DeviceName和ProductKey。 加密方式是HmacSHA1; 加密的密鑰:DeviceSecret ; hmacsha1加密網(wǎng)站:encode.chahuo點(diǎn)com
上傳數(shù)據(jù)
if(HCSR501_Statue()==1)
{
sprintf(mqtt_message,"{\"method\":\"thing.event.property.post\",\"id\":\"0000000001\",\"params\":{\"MotionAlarmState\":1},\"version\":\"1.0.0\"}");
MQTTMsgPublish(PUBTOPIC,QOS0,mqtt_message);
printf( "\r\nsomeone inside\r\n");
}
else
{
sprintf(mqtt_message,"{\"method\":\"thing.event.property.post\",\"id\":\"0000000001\",\"params\":{\"MotionAlarmState\":0},\"version\":\"1.0.0\"}");
MQTTMsgPublish(PUBTOPIC,QOS0,mqtt_message);
printf( "\r\nnoone inside\r\n");
} 參數(shù) 類型 說(shuō)明
method String 請(qǐng)求方法,取值thing.event.property.post。
id String 消息ID號(hào)。String類型的數(shù)字,取值范圍0~4294967295,且每個(gè)消息ID在當(dāng)前設(shè)備中具有唯一性。
params bool MotionAlarmState狀態(tài)標(biāo)識(shí)符,取值為0或1。
version String 協(xié)議版本號(hào),目前協(xié)議版本號(hào)取值為1.0.0。
總結(jié)
ESP8266連接阿里云的順序大致可以分為以下幾個(gè)步驟:配置模塊為STA模式➡連接熱點(diǎn)➡連接TCP➡配置傳輸模式為透?jìng)髂J?#10145;驗(yàn)證用戶名與密鑰➡訂閱主題➡發(fā)送心跳包➡接收/發(fā)送數(shù)據(jù)
程序中登錄MQTT,ID及密碼的格式,發(fā)送消息的格式都要嚴(yán)格按照MQTT協(xié)議來(lái)執(zhí)行,多一個(gè)空格都可能導(dǎo)致無(wú)法連接上阿里云;發(fā)送消息的參數(shù)id取值并不固定,只需要在范圍內(nèi)容易取值即可,但是需要保證id的長(zhǎng)度;QOS表示通信的服務(wù)質(zhì)量,因?yàn)閳?bào)文在發(fā)送的過(guò)程可能存在數(shù)據(jù)丟失的情況,最直接的解決方法就是重新發(fā)送,阿里云等物聯(lián)網(wǎng)平臺(tái)大都不支持QOS2,在實(shí)際開發(fā)過(guò)程中使用QOS0大都可滿足需求。
|