在线观看www成人影院-在线观看www日本免费网站-在线观看www视频-在线观看操-欧美18在线-欧美1级

0
  • 聊天消息
  • 系統(tǒng)消息
  • 評論與回復(fù)
登錄后你可以
  • 下載海量資料
  • 學(xué)習(xí)在線課程
  • 觀看技術(shù)視頻
  • 寫文章/發(fā)帖/加入社區(qū)
會員中心
創(chuàng)作中心

完善資料讓更多小伙伴認識你,還能領(lǐng)取20積分哦,立即完善>

3天內(nèi)不再提示

STM32 + ESP8266 + MQTT協(xié)議連接阿里云物聯(lián)網(wǎng)平臺

1126626497 ? 來源:DS小龍哥-嵌入式技術(shù) ? 作者:DS小龍哥-嵌入式技 ? 2022-02-28 13:31 ? 次閱讀

?

一、環(huán)境介紹

單片機采用:STM32F103C8T6

上網(wǎng)方式:采用ESP8266,也可以使用其他設(shè)備代替,只要支持TCP協(xié)議即可。比如:GSM模塊、有線網(wǎng)卡等。

開發(fā)軟件:keil5

硬件連接功能:ESP8266接在STM32的串口3上。通過AT指令與ESP8266進行通信

通過阿里云物聯(lián)網(wǎng)服務(wù)器實現(xiàn)設(shè)備數(shù)據(jù)遠程上傳、下發(fā),實現(xiàn)數(shù)據(jù)交互。

在當(dāng)前使用的開發(fā)板上有4盞LED燈、一個蜂鳴器、4個按鍵。

實現(xiàn)步驟阿里云官方提供了很詳細的文檔和對應(yīng)的SDK,可以參考一下。

文檔地址:阿里云登錄 - 歡迎登錄阿里云,安全穩(wěn)定的云計算服務(wù)平臺

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

三、阿里云物聯(lián)網(wǎng)服務(wù)器創(chuàng)建步驟

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

說明:如果沒有賬號的話,先點擊網(wǎng)頁右上角,注冊一個賬號,并完成實名認證再繼續(xù)下一步。

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

產(chǎn)品名稱根據(jù)自己情況填寫。

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

設(shè)備信息根據(jù)自己情況填寫。

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

下面參數(shù)根據(jù)自己情況填寫。

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

四、向服務(wù)器上傳的數(shù)據(jù)效果

完成網(wǎng)頁端服務(wù)器的創(chuàng)建之后,下面使用STM32開發(fā)板按下按鍵通過ESP8266將煙霧傳感器數(shù)據(jù)上傳到阿里云服務(wù)器。

如果連接成功的話,網(wǎng)頁會顯示在線狀態(tài)。

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

上傳的數(shù)據(jù)可以在這里查看。

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

五、STM32端的MQTT協(xié)議核心代碼

代碼是標(biāo)準(zhǔn)的MQTT協(xié)議代碼,實現(xiàn)過程可以參考MQTT協(xié)議官方文檔。

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

5.1 mqtt.c代碼

#include "aliyun_mqtt.h"

char MQTT_ClientID[100]; //MQTT_客戶端ID
char MQTT_UserName[100]; //MQTT_用戶名
char MQTT_PassWord[100]; //MQTT_密碼

u8 *mqtt_rxbuf;
u8 *mqtt_txbuf;
u16 mqtt_rxlen;
u16 mqtt_txlen;
u8 _mqtt_txbuf[256];//發(fā)送數(shù)據(jù)緩存區(qū)
u8 _mqtt_rxbuf[256];//接收數(shù)據(jù)緩存區(qū)

typedef enum
{
	//名字 	    值 			報文流動方向 	描述
	M_RESERVED1	=0	,	//	禁止	保留
	M_CONNECT		,	//	客戶端到服務(wù)端	客戶端請求連接服務(wù)端
	M_CONNACK		,	//	服務(wù)端到客戶端	連接報文確認
	M_PUBLISH		,	//	兩個方向都允許	發(fā)布消息
	M_PUBACK		,	//	兩個方向都允許	QoS 1消息發(fā)布收到確認
	M_PUBREC		,	//	兩個方向都允許	發(fā)布收到(保證交付第一步)
	M_PUBREL		,	//	兩個方向都允許	發(fā)布釋放(保證交付第二步)
	M_PUBCOMP		,	//	兩個方向都允許	QoS 2消息發(fā)布完成(保證交互第三步)
	M_SUBSCRIBE		,	//	客戶端到服務(wù)端	客戶端訂閱請求
	M_SUBACK		,	//	服務(wù)端到客戶端	訂閱請求報文確認
	M_UNSUBSCRIBE	,	//	客戶端到服務(wù)端	客戶端取消訂閱請求
	M_UNSUBACK		,	//	服務(wù)端到客戶端	取消訂閱報文確認
	M_PINGREQ		,	//	客戶端到服務(wù)端	心跳請求
	M_PINGRESP		,	//	服務(wù)端到客戶端	心跳響應(yīng)
	M_DISCONNECT	,	//	客戶端到服務(wù)端	客戶端斷開連接
	M_RESERVED2		,	//	禁止	保留
}_typdef_mqtt_message;

//連接成功服務(wù)器回應(yīng) 20 02 00 00
//客戶端主動斷開連接 e0 00
const u8 parket_connetAck[] = {0x20,0x02,0x00,0x00};
const u8 parket_disconnet[] = {0xe0,0x00};
const u8 parket_heart[] = {0xc0,0x00};
const u8 parket_heart_reply[] = {0xc0,0x00};
const u8 parket_subAck[] = {0x90,0x03};

/*
函數(shù)功能: 初始化阿里云物聯(lián)網(wǎng)服務(wù)器的登錄參數(shù)
*/


//密碼
//clientId*deviceName*productKey#
// *替換為DeviceName  #替換為ProductKey  加密密鑰是DeviceSecret  加密方式是HmacSHA1  
//PassWord明文=clientIdmq2_iotdeviceNamemq2_iotproductKeya1WLC5GuOfx
//hmacsha1加密網(wǎng)站:http://encode.chahuo.com/
//加密的密鑰:DeviceSecret

void Aliyun_LoginInit(char *ProductKey,char *DeviceName,char *DeviceSecret)
{
    sprintf(MQTT_ClientID,"%s|securemode=3,signmethod=hmacsha1|",DeviceName);
    sprintf(MQTT_UserName,"%s&%s",DeviceName,ProductKey);
    sprintf(MQTT_PassWord,"%s","ebc042f42a9d73ba9ead8456b652e7756895b79d");
}

void MQTT_Init(void)
{
    //緩沖區(qū)賦值
	mqtt_rxbuf = _mqtt_rxbuf;
    mqtt_rxlen = sizeof(_mqtt_rxbuf);
	mqtt_txbuf = _mqtt_txbuf;
    mqtt_txlen = sizeof(_mqtt_txbuf);
	memset(mqtt_rxbuf,0,mqtt_rxlen);
	memset(mqtt_txbuf,0,mqtt_txlen);
	
	//無條件先主動斷開
	MQTT_Disconnect();
    delay_ms(100);
	MQTT_Disconnect();
    delay_ms(100);
}

/*
函數(shù)功能: 登錄服務(wù)器
函數(shù)返回值: 0表示成功 1表示失敗
*/
u8 MQTT_Connect(char *ClientID,char *Username,char *Password)
{
    u8 i,j;
    int ClientIDLen = strlen(ClientID);
    int UsernameLen = strlen(Username);
    int PasswordLen = strlen(Password);
    int DataLen;
	mqtt_txlen=0;
	//可變報頭+Payload  每個字段包含兩個字節(jié)的長度標(biāo)識
    DataLen = 10 + (ClientIDLen+2) + (UsernameLen+2) + (PasswordLen+2);
	
	//固定報頭
	//控制報文類型
    mqtt_txbuf[mqtt_txlen++] = 0x10;		//MQTT Message Type CONNECT
	//剩余長度(不包括固定頭部)
	do
	{
		u8 encodedByte = DataLen % 128;
		DataLen = DataLen / 128;
		// if there are more data to encode, set the top bit of this byte
		if ( DataLen > 0 )
			encodedByte = encodedByte | 128;
		mqtt_txbuf[mqtt_txlen++] = encodedByte;
	}while ( DataLen > 0 );
    	
	//可變報頭
	//協(xié)議名
    mqtt_txbuf[mqtt_txlen++] = 0;        	// Protocol Name Length MSB    
    mqtt_txbuf[mqtt_txlen++] = 4;           // Protocol Name Length LSB    
    mqtt_txbuf[mqtt_txlen++] = 'M';        	// ASCII Code for M    
    mqtt_txbuf[mqtt_txlen++] = 'Q';        	// ASCII Code for Q    
    mqtt_txbuf[mqtt_txlen++] = 'T';        	// ASCII Code for T    
    mqtt_txbuf[mqtt_txlen++] = 'T';        	// ASCII Code for T    
	//協(xié)議級別
    mqtt_txbuf[mqtt_txlen++] = 4;        		// MQTT Protocol version = 4    
	//連接標(biāo)志
    mqtt_txbuf[mqtt_txlen++] = 0xc2;        	// conn flags 
    mqtt_txbuf[mqtt_txlen++] = 0;        		// Keep-alive Time Length MSB    
    mqtt_txbuf[mqtt_txlen++] = 100;        	// Keep-alive Time Length LSB  100S心跳包  
	
    mqtt_txbuf[mqtt_txlen++] = BYTE1(ClientIDLen);// Client ID length MSB    
    mqtt_txbuf[mqtt_txlen++] = BYTE0(ClientIDLen);// Client ID length LSB  	
	memcpy(&mqtt_txbuf[mqtt_txlen],ClientID,ClientIDLen);
    mqtt_txlen += ClientIDLen;
    
    if(UsernameLen > 0)
    {   
        mqtt_txbuf[mqtt_txlen++] = BYTE1(UsernameLen);		//username length MSB    
        mqtt_txbuf[mqtt_txlen++] = BYTE0(UsernameLen);    	//username length LSB    
		memcpy(&mqtt_txbuf[mqtt_txlen],Username,UsernameLen);
        mqtt_txlen += UsernameLen;
    }
    
    if(PasswordLen > 0)
    {    
        mqtt_txbuf[mqtt_txlen++] = BYTE1(PasswordLen);		//password length MSB    
        mqtt_txbuf[mqtt_txlen++] = BYTE0(PasswordLen);    	//password length LSB  
		memcpy(&mqtt_txbuf[mqtt_txlen],Password,PasswordLen);
        mqtt_txlen += PasswordLen; 
    }    
	
    for(i=0;i<10;i++)
    {
        memset(mqtt_rxbuf,0,mqtt_rxlen);
		MQTT_SendBuf(mqtt_txbuf,mqtt_txlen);
        for(j=0;j<10;j++)
        {
            delay_ms(50);
            if(USART3_RX_FLAG)
			{
				USART3_RX_BUFFER[USART3_RX_CNT]='\0';
				sprintf((char *)mqtt_rxbuf,"%s",USART3_RX_BUFFER);
				USART3_RX_FLAG=0;
				USART3_RX_CNT=0;
			}
			//CONNECT
			if(mqtt_rxbuf[0]==parket_connetAck[0] && mqtt_rxbuf[1]==parket_connetAck[1]) //連接成功			   
			{
				return 0;//連接成功
			}
        }
    }
	return 1;
}

/*
函數(shù)功能: MQTT訂閱/取消訂閱數(shù)據(jù)打包函數(shù)
函數(shù)參數(shù):
    topic       主題   
    qos         消息等級 0:最多分發(fā)一次  1: 至少分發(fā)一次  2: 僅分發(fā)一次
    whether     訂閱/取消訂閱請求包 (1表示訂閱,0表示取消訂閱)
返回值: 0表示成功 1表示失敗
*/
u8 MQTT_SubscribeTopic(char *topic,u8 qos,u8 whether)
{    
    u8 i,j;
	mqtt_txlen=0;
    int topiclen = strlen(topic);
	
	int DataLen = 2 + (topiclen+2) + (whether?1:0);//可變報頭的長度(2字節(jié))加上有效載荷的長度
	//固定報頭
	//控制報文類型
    if(whether)mqtt_txbuf[mqtt_txlen++] = 0x82; //消息類型和標(biāo)志訂閱
    else	mqtt_txbuf[mqtt_txlen++] = 0xA2;    //取消訂閱

	//剩余長度
	do
	{
		u8 encodedByte = DataLen % 128;
		DataLen = DataLen / 128;
		// if there are more data to encode, set the top bit of this byte
		if ( DataLen > 0 )
			encodedByte = encodedByte | 128;
		mqtt_txbuf[mqtt_txlen++] = encodedByte;
	}while ( DataLen > 0 );	
	
	//可變報頭
    mqtt_txbuf[mqtt_txlen++] = 0;			//消息標(biāo)識符 MSB
    mqtt_txbuf[mqtt_txlen++] = 0x01;        //消息標(biāo)識符 LSB
	//有效載荷
    mqtt_txbuf[mqtt_txlen++] = BYTE1(topiclen);//主題長度 MSB
    mqtt_txbuf[mqtt_txlen++] = BYTE0(topiclen);//主題長度 LSB   
	memcpy(&mqtt_txbuf[mqtt_txlen],topic,topiclen);
    mqtt_txlen += topiclen;
    
    if(whether)
    {
       mqtt_txbuf[mqtt_txlen++] = qos;//QoS級別
    }
    
    for(i=0;i<10;i++)
    {
        memset(mqtt_rxbuf,0,mqtt_rxlen);
		MQTT_SendBuf(mqtt_txbuf,mqtt_txlen);
        for(j=0;j<10;j++)
        {
            delay_ms(50);
            if(USART3_RX_FLAG)
			{
				USART3_RX_BUFFER[USART3_RX_CNT]='\0';
                strcpy((char *)mqtt_rxbuf,(char*)USART3_RX_BUFFER);
				USART3_RX_FLAG=0;
				USART3_RX_CNT=0;
			}
			
			if(mqtt_rxbuf[0]==parket_subAck[0] && mqtt_rxbuf[1]==parket_subAck[1]) //訂閱成功			   
			{
				return 0;//訂閱成功
			}
        }
    }
	return 1; //失敗
}

//MQTT發(fā)布數(shù)據(jù)打包函數(shù)
//topic   主題 
//message 消息
//qos     消息等級 
u8 MQTT_PublishData(char *topic, char *message, u8 qos)
{  
    int topicLength = strlen(topic);    
    int messageLength = strlen(message);     
    static u16 id=0;
	int DataLen;
	mqtt_txlen=0;
	//有效載荷的長度這樣計算:用固定報頭中的剩余長度字段的值減去可變報頭的長度
	//QOS為0時沒有標(biāo)識符
	//數(shù)據(jù)長度             主題名   報文標(biāo)識符   有效載荷
    if(qos)	DataLen = (2+topicLength) + 2 + messageLength;       
    else	DataLen = (2+topicLength) + messageLength;   

    //固定報頭
	//控制報文類型
    mqtt_txbuf[mqtt_txlen++] = 0x30;    // MQTT Message Type PUBLISH  

	//剩余長度
	do
	{
		u8 encodedByte = DataLen % 128;
		DataLen = DataLen / 128;
		// if there are more data to encode, set the top bit of this byte
		if ( DataLen > 0 )
			encodedByte = encodedByte | 128;
		mqtt_txbuf[mqtt_txlen++] = encodedByte;
	}while ( DataLen > 0 );	
	
    mqtt_txbuf[mqtt_txlen++] = BYTE1(topicLength);//主題長度MSB
    mqtt_txbuf[mqtt_txlen++] = BYTE0(topicLength);//主題長度LSB 
	memcpy(&mqtt_txbuf[mqtt_txlen],topic,topicLength);//拷貝主題
    mqtt_txlen += topicLength;
        
	//報文標(biāo)識符
    if(qos)
    {
        mqtt_txbuf[mqtt_txlen++] = BYTE1(id);
        mqtt_txbuf[mqtt_txlen++] = BYTE0(id);
        id++;
    }
	memcpy(&mqtt_txbuf[mqtt_txlen],message,messageLength);
    mqtt_txlen += messageLength;
        
	MQTT_SendBuf(mqtt_txbuf,mqtt_txlen);
    return mqtt_txlen;
}

void MQTT_SentHeart(void)
{
	MQTT_SendBuf((u8 *)parket_heart,sizeof(parket_heart));
}

void MQTT_Disconnect(void)
{
	MQTT_SendBuf((u8 *)parket_disconnet,sizeof(parket_disconnet));
}

void MQTT_SendBuf(u8 *buf,u16 len)
{
	USARTx_DataSend(USART3,buf,len);
}	
poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

5.2 mqtt.h代碼

#ifndef __FY_MQTT_H_
#define __FY_MQTT_H_

#include "stm32f10x.h"
#include "string.h"
#include "stdio.h"
#include "stdlib.h"
#include "stdarg.h"
#include "delay.h"
#include "usart.h"

#define BYTE0(dwTemp)       (*( char *)(&dwTemp))
#define BYTE1(dwTemp)       (*((char *)(&dwTemp) + 1))
#define BYTE2(dwTemp)       (*((char *)(&dwTemp) + 2))
#define BYTE3(dwTemp)       (*((char *)(&dwTemp) + 3))
    
extern char MQTT_ClientID[100]; //MQTT_客戶端ID
extern char MQTT_UserName[100]; //MQTT_用戶名
extern char MQTT_PassWord[100]; //MQTT_密碼

//阿里云用戶名初始化
void Aliyun_LoginInit(char *ProductKey,char *DeviceName,char *DeviceSecret);
//MQTT協(xié)議相關(guān)函數(shù)聲明
u8 MQTT_PublishData(char *topic, char *message, u8 qos);
u8 MQTT_SubscribeTopic(char *topic,u8 qos,u8 whether);
void MQTT_Init(void);
u8 MQTT_Connect(char *ClientID,char *Username,char *Password);
void MQTT_SentHeart(void);
void MQTT_Disconnect(void);
void MQTT_SendBuf(u8 *buf,u16 len);
#endif
poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

5.3 main.c代碼

#include "stm32f10x.h"
#include "led.h"
#include "delay.h"
#include "key.h"
#include "usart.h"
#include 
#include "timer.h"
#include "bluetooth.h"
#include "esp8266.h"
#include "aliyun_mqtt.h"

//阿里云物聯(lián)網(wǎng)服務(wù)器的設(shè)備證書
#define ProductKey "a1GLM2BFQK0"
#define DeviceName "iot_mq2"
#define DeviceSecret "caa5b2684101072f3dfe0f04688e0a7f"

//訂閱與發(fā)布的主題
#define SET_TOPIC  "/sys/a1GLM2BFQK0/iot_mq2/thing/service/property/set"
#define POST_TOPIC "/sys/a1GLM2BFQK0/iot_mq2/thing/event/property/post"

char mqtt_message[200];//上報數(shù)據(jù)緩存區(qū)

int main()
{
   u32 time_cnt=0;
   u32 i;
   u8 key;
   LED_Init();
   BEEP_Init();
   KEY_Init();
   USART1_Init(115200);
   TIMER1_Init(72,20000); //超時時間20ms
   USART2_Init(9600);//串口-藍牙
   TIMER2_Init(72,20000); //超時時間20ms
   USART3_Init(115200);//串口-WIFI
   TIMER3_Init(72,20000); //超時時間20ms
   USART1_Printf("正在初始化WIFI請稍等.\n");
   if(ESP8266_Init())
   {
      USART1_Printf("ESP8266硬件檢測錯誤.\n");  
   }
   else
   {
      USART1_Printf("WIFI:%d\n",ESP8266_STA_TCP_Client_Mode("ChinaNet-wbyq","12345678","a1WLC5GuOfx.iot-as-mqtt.cn-shanghai.aliyuncs.com",1883,1));
   }
   
    //1. 初始化阿里云登錄參數(shù)
    Aliyun_LoginInit(ProductKey,DeviceName,DeviceSecret);
    //2. MQTT協(xié)議初始化	
    MQTT_Init(); 
    //3. 連接阿里云服務(wù)器        
    while(MQTT_Connect(MQTT_ClientID,MQTT_UserName,MQTT_PassWord))
    {
        USART1_Printf("阿里云服務(wù)器連接失敗,正在重試...\n");
        delay_ms(500);
    }
    USART1_Printf("阿里云服務(wù)器連接成功.\n");
    
    //3. 訂閱主題
    if(MQTT_SubscribeTopic(SET_TOPIC,0,1))
    {
        USART1_Printf("主題訂閱失敗.\n");
    }
    else
    {
        USART1_Printf("主題訂閱成功.\n");
    }        
    
    while(1)
    {    
        key=KEY_Scan(0);
        if(key==2)
        {
            time_cnt=0;
            sprintf(mqtt_message,"{"method":"thing.event.property.post","id":"0000000001","params":{"mq2":55},"version":"1.0.0"}");
            MQTT_PublishData(POST_TOPIC,mqtt_message,0);
            USART1_Printf("發(fā)送狀態(tài)1\r\n");
        }
        else if(key==3)
        {
            time_cnt=0;
            sprintf(mqtt_message,"{"method":"thing.event.property.post","id":"0000000001","params":{"mq2":66},"version":"1.0.0"}");
            MQTT_PublishData(POST_TOPIC,mqtt_message,0);
            USART1_Printf("發(fā)送狀態(tài)0\r\n");
        }  

        if(USART3_RX_FLAG)
        {
            USART3_RX_BUFFER[USART3_RX_CNT]='\0';
            for(i=0;i;i++)>
poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

六、代碼參數(shù)解釋

6.1 設(shè)備證書與發(fā)布訂閱主題

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

設(shè)備證書在創(chuàng)建設(shè)備時保存過,如果沒有保存可以在下面的頁面里查看對應(yīng)的值。

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

訂閱的主題在下面頁面可以看到。

SET,GET,POST,ERR。 SET 用于設(shè)置(一般由單片機端使用), GET 用于獲取(一般由 APP 端使用), Post 用于回復(fù)機制, ERR 用于錯誤。
作為單片機端用的最多的兩個 TOPIC 就是 SET 與 POST

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

6.2 MQTT登錄的密碼、ID、用戶名、端口號、域名

MQTT標(biāo)準(zhǔn)的3個參數(shù)格式在官方文檔有介紹:使用MQTT.fx接入物聯(lián)網(wǎng)平臺 - 阿里云物聯(lián)網(wǎng)平臺 - 阿里云

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

密碼的組成格式:

clientId*deviceName*productKey#
其中: *替換為DeviceName  #替換為ProductKey  加密密鑰是DeviceSecret  加密方式是HmacSHA1  

PassWord明文=clientIdmq2_iotdeviceNamemq2_iotproductKeya1WLC5GuOfx
hmacsha1加密網(wǎng)站:http://encode.chahuo.com/
加密的密鑰:DeviceSecret
poYBAGDYdXCAWkKMAAAAK8RNs4s030.pngpoYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

6.3 上傳數(shù)據(jù)

poYBAGDYdXCAWkKMAAAAK8RNs4s030.png

?

這是上傳數(shù)據(jù)的格式:

第一個參數(shù)是 method:后面所跟的參數(shù)可以由物模型看到。

第二個參數(shù)id : 因為云端會連接很多個用戶,所以他所下發(fā)的數(shù)據(jù)會有一個ID 編號,我們這里任意值都行,我用的 0000000001,這里有要注意的,這個 ID 是多少不重要但是位數(shù)一定不能少。

第三個是 params:表示上傳的具體數(shù)據(jù),根據(jù)自己云端訂閱的類型上傳。

第四個是版本號:可以根據(jù)自己實際版本填。


注意:本篇文章沒有貼ESP8266的底層編程代碼,如果不會ESP8266底層編程,請看這里:

https://blog.csdn.net/xiaolong1126626497/article/details/107379554

想了解STM32+ESP8266使用MQTT協(xié)議連接OneNET 中國移動服務(wù)器的看這里:

https://blog.csdn.net/xiaolong1126626497/article/details/107385118

工程完整源碼下載: https://download.csdn.net/download/xiaolong1126626497/15803494

審核編輯:符乾江

聲明:本文內(nèi)容及配圖由入駐作者撰寫或者入駐合作網(wǎng)站授權(quán)轉(zhuǎn)載。文章觀點僅代表作者本人,不代表電子發(fā)燒友網(wǎng)立場。文章及其配圖僅供工程師學(xué)習(xí)之用,如有內(nèi)容侵權(quán)或者其他違規(guī)問題,請聯(lián)系本站處理。 舉報投訴
  • 物聯(lián)網(wǎng)
    +關(guān)注

    關(guān)注

    2927

    文章

    45949

    瀏覽量

    388589
  • STM32
    +關(guān)注

    關(guān)注

    2290

    文章

    11017

    瀏覽量

    362634
收藏 人收藏

    評論

    相關(guān)推薦
    熱點推薦

    【RA-Eco-RA4M2開發(fā)板評測】使用RA4M2和ESP8266實現(xiàn)MQTT協(xié)議上傳傳感器數(shù)據(jù)到服務(wù)器并反向點燈控制

    人遠在千里之外的異國他鄉(xiāng),在ESP8266接入互聯(lián)網(wǎng)的條件下,都可以遠程點燈,不限制距離和IP地址,服務(wù)器確實是個好東西呀! 在這個萬互聯(lián)的時代,互
    發(fā)表于 05-29 15:29

    工業(yè)智能網(wǎng)關(guān)與MQTT聯(lián)網(wǎng)平臺的關(guān)系

    工業(yè)智能網(wǎng)關(guān)與 MQTT 聯(lián)網(wǎng)平臺聯(lián)網(wǎng)架構(gòu)中
    的頭像 發(fā)表于 03-21 09:44 ?321次閱讀

    《DNESP32S3使用指南-IDF版_V1.6》第五十五章 基于MQTT協(xié)議連接阿里服務(wù)器

    進行相應(yīng)的修改。55.4 下載驗證程序下載成功后,打開阿里平臺聯(lián)網(wǎng)平臺設(shè)備管理,可以看到此
    發(fā)表于 03-18 09:22

    MQTT聯(lián)網(wǎng)平臺有哪些?有哪些功能?

    (IoT)。關(guān)于MQTT聯(lián)網(wǎng)平臺及其功能,可以歸納如下: MQTT
    的頭像 發(fā)表于 03-15 14:23 ?728次閱讀
    <b class='flag-5'>MQTT</b><b class='flag-5'>物</b><b class='flag-5'>聯(lián)網(wǎng)</b><b class='flag-5'>平臺</b>有哪些?有哪些功能?

    esp8266連接阿里平臺mqtt連接超時

    esp8266nodemcu在使用arduino.ide連接阿里平臺的時候,wifi配置正常但連接
    發(fā)表于 10-26 21:39

    MQTT聯(lián)網(wǎng)平臺有什么功能

    關(guān)鍵作用。MQTT聯(lián)網(wǎng)平臺基于MQTT協(xié)議,為
    的頭像 發(fā)表于 10-09 14:15 ?625次閱讀

    ESP8266 通過 MQTT 協(xié)議實現(xiàn) LED 的遠程控制

    本文簡要介紹了搭建 EMQX 服務(wù)器實現(xiàn)基于 MQTT 協(xié)議遠程控制 NodeMCU ESP8266 板載 LED 的解決方案。
    的頭像 發(fā)表于 09-25 09:11 ?2884次閱讀
    <b class='flag-5'>ESP8266</b> 通過 <b class='flag-5'>MQTT</b> <b class='flag-5'>協(xié)議</b>實現(xiàn) LED 的遠程控制

    STM32 ESP8266阿里鏈接源碼

    stm32F103C8T6 ESP8266 聯(lián)網(wǎng)電表 登錄阿里
    發(fā)表于 08-29 14:21 ?9次下載

    esp8266esp32區(qū)別是什么

    的內(nèi)存選項,包括最小512KB的RAM和最大16MB的閃存。 Wi-Fi和藍牙 : ESP8266 :支持2.4GHz Wi-Fi。 ESP32 :支持2.4GHz Wi-Fi和藍牙5.0,這使得ESP32在
    的頭像 發(fā)表于 08-19 18:16 ?6988次閱讀

    esp8266不燒錄可以使用嗎

    ESP8266是一款非常流行的Wi-Fi模塊,廣泛應(yīng)用于聯(lián)網(wǎng)項目中。然而,如果不進行燒錄,ESP8266將無法正常工作。 1. ESP8266
    的頭像 發(fā)表于 08-19 17:28 ?1571次閱讀

    esp8266wifi模塊怎么連接手機

    和密碼)。 配置成功后,ESP8266將能夠通過路由器連接到互聯(lián)網(wǎng)。 手機連接同一WiFi網(wǎng)絡(luò) : 在手機上打開WiFi設(shè)置,
    的頭像 發(fā)表于 08-19 17:27 ?7258次閱讀

    MQTT聯(lián)網(wǎng)平臺是什么

    MQTT聯(lián)網(wǎng)平臺是一種軟件平臺,它基于MQTT(Message Queuing Telemet
    的頭像 發(fā)表于 07-18 14:22 ?1085次閱讀

    esp8266運行REMOTE_OTA_TASK出錯的原因?

    官方整合阿里聯(lián)網(wǎng)套件的程序,然后在樂鑫官網(wǎng)下載了RTOS,放到了esp8266-rtos-sdk 目錄下,修改了
    發(fā)表于 07-10 06:32

    求助,請問如何在RTOS SDK 1.5的PlatformIO IDE ESP8266實現(xiàn)MQTT

    ESP8266設(shè)備連接mqtt 代理。但 PlatformIO IDE 內(nèi)置的 RTOS SDK 1.5 版本不支持 mqtt。此 SDK 沒有
    發(fā)表于 07-08 06:22

    MQTT聯(lián)網(wǎng)平臺是什么

    及可視化等功能,為連接到互聯(lián)網(wǎng)的物理設(shè)備提供支持和服務(wù)。 結(jié)合這兩個概念,MQTT聯(lián)網(wǎng)
    的頭像 發(fā)表于 06-25 15:32 ?1034次閱讀
    主站蜘蛛池模板: 国产内地激情精品毛片在线一 | 最近2018中文字幕免费视频 | 日本色图在线 | 寡妇一级a毛片免费播放 | 国产精品午夜寂寞视频 | 干干干日日日 | 日本免费黄色大片 | 九九51精品国产免费看 | 欧美色视频网 | 久久久婷婷 | 亚洲视频一区在线 | 欧美大片一区二区三区 | 福利99| 五月激情五月婷婷 | 天天舔天天干天天操 | 生活片毛片 | 丁香婷婷在线观看 | 日韩第二页 | 久久综合性 | 三级黄网 | 性生i活一级一片 | 天天摸天天碰天天碰 | 最新在线网址 | 亚洲欧美色中文字幕 | 狠狠躁夜夜躁人人爽天天3 狠狠躁夜夜躁人人爽天天段 | 婷婷六月丁香 | 国产一级一级片 | xxxxx日本69| 侵犯希崎中文字幕在线 | 日本黄色片在线观看 | 国内自拍2021 | 国产国产成人人免费影院 | 国产三片理论电影在线 | 欧美一级淫片免费播放口 | 一级黄视频 | 色色色色色色色色色色色色色色 | 在线免费观看h视频 | 色综合社区 | 男人的午夜影院 | 丁香六月五月婷婷 | 男人边吃奶边爱边做视频日韩 |