天天综合网久久,亚洲一区二区三区精品视频,最新中文字幕日本

一、環(huán)境介紹

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

開發(fā)軟件：keil5

物聯(lián)網(wǎng)平臺(tái): 騰訊IOT物聯(lián)網(wǎng)物聯(lián)網(wǎng)平臺(tái)。騰訊的物聯(lián)網(wǎng)平臺(tái)比起其他廠家的物聯(lián)網(wǎng)平臺(tái)更加有優(yōu)勢，騰訊物聯(lián)網(wǎng)平臺(tái)可以將數(shù)據(jù)推到微信小程序上，用戶可以直接使用小程序綁定設(shè)備，完成與設(shè)備之間交互，現(xiàn)在用戶基本都會(huì)使用微信，所以使用起來非常方便。

二、功能介紹

本文章接下會(huì)介紹如何在騰訊物聯(lián)網(wǎng)平臺(tái)上創(chuàng)建設(shè)備、配置設(shè)備、推送到微信小程序、并編寫STM32設(shè)備端代碼，使用ESP8266聯(lián)網(wǎng)登錄騰訊物聯(lián)網(wǎng)平臺(tái)，完成數(shù)據(jù)交互。

功能: STM32采集環(huán)境溫度、濕度、光照強(qiáng)度實(shí)時(shí)上傳至物聯(lián)網(wǎng)平臺(tái)，在微信小程序頁面上，用戶可以實(shí)時(shí)查看這些數(shù)據(jù)，并且可以通過界面上的按鈕控制設(shè)備端的電機(jī)、LED燈的開關(guān)，完成數(shù)據(jù)上傳和遠(yuǎn)程控制。

說明: STM32設(shè)備端所有代碼均有自己全部編寫，沒有使用任何廠家的SDK，MQTT協(xié)議也是參考MQTT官方文檔編寫；ESP8266也沒有使用任何專用固件，所以代碼的移植性非常高。任何能夠聯(lián)網(wǎng)的設(shè)備都可以參考本篇文章代碼連接騰訊物聯(lián)網(wǎng)平臺(tái)，達(dá)到相同的效果。

?

三、登錄騰訊物聯(lián)網(wǎng)平臺(tái)創(chuàng)建設(shè)備

騰訊云官網(wǎng):騰訊云 - 產(chǎn)業(yè)智變云啟未來

下面是手機(jī)上的截圖：操作過程

現(xiàn)在設(shè)備是離線狀態(tài),是無法查看的，接下來就使用MQTT客戶端模擬設(shè)備，登錄測試。

四、使用MQTT客戶端模擬設(shè)備--測試

4.1 下載MQTT客戶端

MQTT客戶端可執(zhí)行文件下載地址(.exe): MQTT客戶端_v2.4(協(xié)議3.1.1).exe_stc15單片機(jī)+esp8266+騰訊連連小程序(三)-桌面系統(tǒng)文檔類資源-CSDN下載

這個(gè)MQTT客戶端采用QT開發(fā)，如果需要了解它的源碼，請(qǐng)看這里：QT應(yīng)用編程: 編寫MQTT客戶端登錄OnetNet服務(wù)器完成主題訂閱與發(fā)布_DS小龍哥的專欄-CSDN博客_onenet topic訂閱與發(fā)布

4.2 查看物聯(lián)網(wǎng)平臺(tái)端口號(hào)與域名(IP地址)

官方文檔:物聯(lián)網(wǎng)通信設(shè)備基于 TCP 的 MQTT 接入 - 開發(fā)者手冊(cè) - 文檔中心 - 騰訊云

通過這里得到信息: 如果是廣州域的設(shè)備(其實(shí)哪里都一樣,只是服務(wù)器距離的遠(yuǎn)近)，就填入 <產(chǎn)品ID>.iotcloud.tencentdevices.com ，端口號(hào)是 1883(這是密匙認(rèn)證的端口號(hào)，如果是證書認(rèn)證就是另一個(gè))。

查看產(chǎn)品ID的方法：

得打產(chǎn)品ID之后，那么要連接我的設(shè)備，域名就填:8O76VHCU7Y.iotcloud.tencentdevices.com 端口就填: 1883

由于我的測試用的MQTT客戶端不支持域名輸入，只支持IP地址輸入，所有我這里需要先將域名轉(zhuǎn)為IP地址在進(jìn)行下面的測試，ESP8266內(nèi)部支持域名解析的，所有可以直接輸入域名即可，不需要做這一步。

在線解析域名的網(wǎng)址：ip地址查詢 ip查詢查ip 公網(wǎng)ip地址歸屬地查詢網(wǎng)站ip查詢同ip網(wǎng)站查詢 iP反查域名 iP查域名同ip域名

得到廣州騰訊云的IP地址為: 106.55.124.154

4.3 生成MQTT登錄參數(shù)

就像我們登錄QQ、登錄微信需要賬號(hào)密碼一樣，設(shè)備登錄物聯(lián)網(wǎng)平臺(tái)也需要類似的東西。

官方文檔地址：物聯(lián)網(wǎng)通信設(shè)備基于 TCP 的 MQTT 接入 - 開發(fā)者手冊(cè) - 文檔中心 - 騰訊云

上面需要的參數(shù)，在設(shè)備調(diào)試頁面，點(diǎn)擊具體的設(shè)備進(jìn)行查看：

Python源代碼：

#!/usr/bin/python
# -*- coding: UTF-8 -*-
import base64
import hashlib
import hmac
import random
import string
import time
import sys
# 生成指定長度的隨機(jī)字符串
def RandomConnid(length):
    return  ''.join(random.choice(string.ascii_uppercase + string.digits) for _ in range(length))
# 生成接入物聯(lián)網(wǎng)通信平臺(tái)需要的各參數(shù)
def IotHmac(productID, devicename, devicePsk):
     # 1. 生成 connid 為一個(gè)隨機(jī)字符串，方便后臺(tái)定位問題
     connid   = RandomConnid(5)
     # 2. 生成過期時(shí)間，表示簽名的過期時(shí)間,從紀(jì)元1970年1月1日 00:00:00 UTC 時(shí)間至今秒數(shù)的 UTF8 字符串
     expiry   = int(time.time()) + 30*24*60 * 60
     # 3. 生成 MQTT 的 clientid 部分, 格式為 ${productid}${devicename}
     clientid = "{}{}".format(productID, devicename)
     # 4. 生成 MQTT 的 username 部分, 格式為 ${clientid};${sdkappid};${connid};${expiry}
     username = "{};12010126;{};{}".format(clientid, connid, expiry)
     # 5. 對(duì) username 進(jìn)行簽名，生成token
     secret_key = devicePsk.encode('utf-8')  # convert to bytes
     data_to_sign = username.encode('utf-8')  # convert to bytes
     secret_key = base64.b64decode(secret_key)  # this is still bytes
     token = hmac.new(secret_key, data_to_sign, digestmod=hashlib.sha256).hexdigest()
     # 6. 根據(jù)物聯(lián)網(wǎng)通信平臺(tái)規(guī)則生成 password 字段
     password = "{};{}".format(token, "hmacsha256")
     return {
        "clientid" : clientid,
        "username" : username,
        "password" : password
     }
if __name__ == '__main__':
    # 參數(shù)分別填入: 產(chǎn)品ID,設(shè)備名稱,設(shè)備密匙
    print(IotHmac("8O76VHCU7Y","SmartAgriculture","OHXqYLklNBU4xLqqoZbXMQ=="))

得到的登錄信息如下：

clientid: 8O76VHCU7YSmartAgriculture
username: 8O76VHCU7YSmartAgriculture;12010126;J4MCD;1623766532
password: a962b484079864239148b255281d54372aa66247aa8d6259d11aa6fef650fd5b;hmacsha256

4.4 了解主題上報(bào)和訂閱的格式

登錄之前需要先了解如何訂閱設(shè)備的主題和上報(bào)的數(shù)據(jù)流格式。

如果設(shè)備端想要得到APP頁面的按鈕狀態(tài)就需要訂閱屬性下發(fā)和屬性上報(bào)的響應(yīng)，主題格式就是這樣的：

格式:
$thing/down/property/8O76VHCU7Y/設(shè)備名稱
示例:
$thing/down/property/8O76VHCU7Y/SmartAgriculture

如果設(shè)備端想要像APP頁面上傳數(shù)據(jù)，那么就需要使用屬性上報(bào)--發(fā)布主題：

格式:
$thing/up/property/8O76VHCU7Y/${deviceName}
示例:
$thing/up/property/8O76VHCU7Y/SmartAgriculture

設(shè)備端向APP頁面上報(bào)屬性時(shí)，需要上傳具體的數(shù)據(jù)，數(shù)據(jù)流的格式如下：

官方文檔: 物聯(lián)網(wǎng)開發(fā)平臺(tái) 物模型協(xié)議 - 云端開發(fā)指南 - 文檔中心 - 騰訊云

比如：我的產(chǎn)品里有溫度、濕度、電機(jī)三個(gè)設(shè)備，我可以選擇一次上傳3個(gè)設(shè)備的信息，數(shù)據(jù)格式就這樣寫：

{"method":"report","clientToken":"123","params":{"temperature":20.23,"humidity":50,"Motor":1}}

其中:"temperature"、"humidity"、"Motor" 是設(shè)備的標(biāo)識(shí)符，根據(jù)自己的情況修改，冒號(hào)后面就是給這個(gè)設(shè)備上傳的具體數(shù)據(jù)。

4.5使用MQTT客戶端登錄設(shè)備測試

萬事俱備，下面就使用MQTT客戶端進(jìn)行登錄測試。

MQTT客戶端操作步驟：

1. 填寫相關(guān)參數(shù)

2. 點(diǎn)擊登錄

3. 訂閱主題

4. 發(fā)布主題

5. 去APP頁面查看信息

4.6 微信小程序效果

已經(jīng)收到MQTT客戶端上傳的數(shù)據(jù)，點(diǎn)擊按鈕，MQTT客戶端也會(huì)收到按鈕下發(fā)的數(shù)據(jù)。

五、STM32設(shè)備端代碼

本文章配套使用的STM32設(shè)備端完整源代碼下載地址: STM32+MQTT協(xié)議連接騰訊物聯(lián)網(wǎng)平臺(tái)_完成主題訂閱與發(fā)布(MQTT).zip_騰訊物聯(lián)網(wǎng)平臺(tái)-桌面系統(tǒng)文檔類資源-CSDN下載

5.1 下載程序

5.2 連接狀態(tài)

STM32設(shè)備上按下按鍵后，手機(jī)打開微信小程序可以看到實(shí)時(shí)上傳的數(shù)據(jù)，速度非?？臁?/p>

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 "mqtt.h"

//騰訊物聯(lián)網(wǎng)服務(wù)器的設(shè)備信息
#define MQTT_ClientID "8O76VHCU7YSmartAgriculture"
#define MQTT_UserName "8O76VHCU7YSmartAgriculture;12010126;J4MCD;1623766532"
#define MQTT_PassWord "a962b484079864239148b255281d54372aa66247aa8d6259d11aa6fef650fd5b;hmacsha256"

//訂閱與發(fā)布的主題
#define SET_TOPIC  "$thing/down/property/8O76VHCU7Y/SmartAgriculture"  //訂閱
#define POST_TOPIC "$thing/up/property/8O76VHCU7Y/SmartAgriculture"  //發(fā)布

char mqtt_message[200];//上報(bào)數(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); //超時(shí)時(shí)間20ms
   USART2_Init(9600);//串口-藍(lán)牙
   TIMER2_Init(72,20000); //超時(shí)時(shí)間20ms
   USART3_Init(115200);//串口-WIFI
   TIMER3_Init(72,20000); //超時(shí)時(shí)間20ms
   USART1_Printf("正在初始化WIFI請(qǐng)稍等.\n");
   if(ESP8266_Init())
   {
      USART1_Printf("ESP8266硬件檢測錯(cuò)誤.\n");  
   }
   else
   {
      //加密端口
      //USART1_Printf("WIFI:%d\n",ESP8266_STA_TCP_Client_Mode("OnePlus5T","1126626497","183.230.40.16",8883,1));
      
      //非加密端口
      USART1_Printf("WIFI:%d\n",ESP8266_STA_TCP_Client_Mode("CMCC-Cqvn","99pu58cb","106.55.124.154",1883,1));
  
   }
   
    //2. MQTT協(xié)議初始化	
    MQTT_Init(); 
    //3. 連接OneNet服務(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":"report","clientToken":"123","params":{"temperature":20.23,"humidity":50,"Motor":1}}");
            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":"report","clientToken":"123","params":{"temperature":10.23,"humidity":60,"Motor":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

`5.4 mqtt.c`

#include "mqtt.h"

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

//連接成功服務(wù)器回應(yīng) 20 02 00 00
//客戶端主動(dòng)斷開連接 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};

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);
	
	//無條件先主動(dòng)斷開
	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;
	//可變報(bào)頭+Payload  每個(gè)字段包含兩個(gè)字節(jié)的長度標(biāo)識(shí)
    DataLen = 10 + (ClientIDLen+2) + (UsernameLen+2) + (PasswordLen+2);
	
	//固定報(bào)頭
	//控制報(bào)文類型
    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 );
    	
	//可變報(bào)頭
	//協(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é)議級(jí)別
    mqtt_txbuf[mqtt_txlen++] = 4;        		// MQTT Protocol version = 4   對(duì)于 3.1.1 版協(xié)議，協(xié)議級(jí)別字段的值是 4(0x04)   
	//連接標(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心跳包    ?；顣r(shí)間
	
    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; 
    }    
	
  
    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)
        {
            memcpy((char *)mqtt_rxbuf,USART3_RX_BUFFER,USART3_RX_CNT);
            
            //memcpy
           
             for(i=0;i 0 )
			encodedByte = encodedByte | 128;
		mqtt_txbuf[mqtt_txlen++] = encodedByte;
	}while ( DataLen > 0 );	
	
	//可變報(bào)頭
    mqtt_txbuf[mqtt_txlen++] = 0;			//消息標(biāo)識(shí)符 MSB
    mqtt_txbuf[mqtt_txlen++] = 0x0A;        //消息標(biāo)識(shí)符 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級(jí)別
    }
    
    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)
			{
                memcpy((char *)mqtt_rxbuf,(char*)USART3_RX_BUFFER,USART3_RX_CNT);
				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     消息等級(jí) 
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;
	//有效載荷的長度這樣計(jì)算：用固定報(bào)頭中的剩余長度字段的值減去可變報(bào)頭的長度
	//QOS為0時(shí)沒有標(biāo)識(shí)符
	//數(shù)據(jù)長度             主題名   報(bào)文標(biāo)識(shí)符   有效載荷
    if(qos)	DataLen = (2+topicLength) + 2 + messageLength;       
    else	DataLen = (2+topicLength) + messageLength;   

    //固定報(bào)頭
	//控制報(bào)文類型
    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;
        
	//報(bào)文標(biāo)識(shí)符
    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);
}

本文章配套使用的STM32設(shè)備端完整源代碼下載地址: https://download.csdn.net/download/xiaolong1126626497/18785807

STM32+ESP8266使用MQTT協(xié)議連接OneNET 中國移動(dòng)物聯(lián)網(wǎng)開發(fā)平臺(tái)：https://blog.csdn.net/xiaolong1126626497/article/details/107385118

STM32+ESP8266使用MQTT協(xié)議連接阿里云物聯(lián)網(wǎng)開發(fā)平臺(tái)：https://blog.csdn.net/xiaolong1126626497/article/details/107311897 審核編輯：符乾江

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

物聯(lián)網(wǎng)

物聯(lián)網(wǎng)

+關(guān)注

關(guān)注
2910

文章
44752

瀏覽量
374587
STM32

STM32

+關(guān)注

關(guān)注
2270

文章
10910

瀏覽量
356591

評(píng)論

相關(guān)推薦

esp8266連接阿里云平臺(tái)時(shí)mqtt連接超時(shí)

esp8266nodemcu在使用arduino.ide連接阿里云平臺(tái)的時(shí)候，wifi配置正常但連接不上mqtt，顯示報(bào)錯(cuò)如下： Attem

發(fā)表于 10-26 21:39

ESP8266 太空人動(dòng)畫的 OLED 顯示

ESP8266 太空人動(dòng)畫的 OLED 顯示

發(fā)表于 10-08 15:06 ?297次閱讀

<b class='flag-5'>ESP8266</b> 太空人動(dòng)畫的 OLED 顯示

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

本文簡要介紹了搭建 EMQX 服務(wù)器實(shí)現(xiàn)基于 MQTT 協(xié)議遠(yuǎn)程控制 NodeMCU ESP8266 板載 LED 的解決方案。

發(fā)表于 09-25 09:11 ?2097次閱讀

<b class='flag-5'>ESP8266</b> 通過 <b class='flag-5'>MQTT</b> <b class='flag-5'>協(xié)議</b>實(shí)現(xiàn) LED 的遠(yuǎn)程控制

STM32 ESP8266阿里云鏈接源碼

stm32F103C8T6 ESP8266 物聯(lián)網(wǎng)電表登錄阿里云

發(fā)表于 08-29 14:21 ?6次下載

esp32和esp8266代碼共用嗎

本文將介紹ESP32和ESP8266兩款流行的微控制器在代碼共用性方面的可能性與差異性。一、引言隨著物聯(lián)網(wǎng)技術(shù)的飛速發(fā)展，越來越多的智能設(shè)備開始進(jìn)入我們的生活。其中，ESP32和ESP82

發(fā)表于 08-19 18:23 ?1218次閱讀

esp8266和esp32區(qū)別是什么

以下是關(guān)于ESP8266和ESP32的主要區(qū)別：處理器和架構(gòu) ： ESP8266 ：使用一個(gè)Tensilica L106 80MHz的處理器，屬于Xtensa架構(gòu)。 ESP32 ：使

發(fā)表于 08-19 18:16 ?5579次閱讀

esp8266不燒錄可以使用嗎

，可以方便地與其他硬件設(shè)備進(jìn)行連接。 2. ESP8266的硬件特性處理器：Tensilica L106，最高頻率160MHz 內(nèi)存：64KB SRAM，1MB Flash Wi-Fi ：支持802.11 b/g/n協(xié)議，

發(fā)表于 08-19 17:28 ?887次閱讀

esp8266wifi模塊怎么連接手機(jī)

ESP8266 WiFi模塊連接手機(jī)主要可以通過兩種方式實(shí)現(xiàn)：通過路由器連接（STA模式）和直接作為熱點(diǎn)連接（AP模式）。以下是兩種連接

發(fā)表于 08-19 17:27 ?3216次閱讀

ESP8266作Client建立TCP連接出現(xiàn)報(bào)錯(cuò)？

請(qǐng)教下，ESP8266作Client建立TCP連接，出現(xiàn)錯(cuò)誤是按照《4B-ESP8266__AT Command Examples__CN_v1.3》文檔上操作的 AT+CIPSTART

發(fā)表于 07-17 07:16

ESP8266 IoT_Demo行不通的原因？

的開發(fā)板在 AI Thinker 的引導(dǎo)下無限閃爍。以下是日志： al@pc：~/Desktop/sdk_201_esp8266/sdk/IoT_Demo$ esptool.py --port /dev

發(fā)表于 07-11 08:13

求助，請(qǐng)問如何在RTOS SDK 1.5的PlatformIO IDE ESP8266實(shí)現(xiàn)MQTT？

ESP8266設(shè)備連接到 mqtt 代理。但 PlatformIO IDE 內(nèi)置的 RTOS SDK 1.5 版本不支持 mqtt。此 SDK 沒有

發(fā)表于 07-08 06:22

國產(chǎn)低成本W(wǎng)i-Fi SoC解決方案芯片ESP8266與ESP8285對(duì)比差異

ESP8266與ESP8285對(duì)比差異 ESP8285相當(dāng)于在ESP8266基礎(chǔ)上多加了1/2MB Flash， ESP8285與

發(fā)表于 05-17 11:44 ?1391次閱讀

確定ESP8266固件下載成功的方法

在物聯(lián)網(wǎng)設(shè)備的開發(fā)過程中，確定esp8266固件是否成功下載至設(shè)備十分關(guān)鍵。以下是一種簡單有效的確認(rèn)方法：機(jī)智云物聯(lián)網(wǎng)平臺(tái)首先，確保你的ESP8266模塊已經(jīng)正確連接至計(jì)算機(jī)，并通過串

發(fā)表于 05-16 08:10 ?634次閱讀

使用Wi-Fi ESP8266方案模組接入云平臺(tái)

ESP8266的模塊芯片是基于無線通信協(xié)議的UARTWi-Fi透傳模塊芯片，支持802.11b/g/n的無線標(biāo)準(zhǔn)，并帶有三種可選擇的工作模式。ESP8266模塊的控制是通過AT指令的形式控制，例如

發(fā)表于 05-10 08:20 ?1880次閱讀

STM32、ESP8266與MQTT連接阿里云物聯(lián)網(wǎng)的串口通信異常解析

STM32、ESP8266與MQTT協(xié)議連接阿里云物聯(lián)網(wǎng)平臺(tái)時(shí)常見的串口通信異常介紹在構(gòu)建物聯(lián)

發(fā)表于 04-19 17:19 ?1490次閱讀

色哟哟视频在线观看-色哟哟视频在线-色哟哟欧美15最新在线-色哟哟免费在线观看-国产l精品国产亚洲区在线观看-国产l精品国产亚洲区久久

搜索歷史

STM32 + ESP8266 + MQTT協(xié)議連接騰訊IOT平臺(tái)

一、環(huán)境介紹

二、功能介紹

?

?

三、登錄騰訊物聯(lián)網(wǎng)平臺(tái)創(chuàng)建設(shè)備

四、使用MQTT客戶端模擬設(shè)備--測試

4.1 下載MQTT客戶端

4.2 查看物聯(lián)網(wǎng)平臺(tái)端口號(hào)與域名(IP地址)

4.3 生成MQTT登錄參數(shù)

4.4 了解主題上報(bào)和訂閱的格式

4.5使用MQTT客戶端登錄設(shè)備測試

4.6 微信小程序效果

五、STM32設(shè)備端代碼

5.1 下載程序

5.2 連接狀態(tài)

5.3 main.c文件

`5.4 mqtt.c`

評(píng)論

esp8266連接阿里云平臺(tái)時(shí)mqtt連接超時(shí)

ESP8266 太空人動(dòng)畫的 OLED 顯示

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

STM32 ESP8266阿里云鏈接源碼

esp32和esp8266代碼共用嗎

esp8266和esp32區(qū)別是什么

esp8266不燒錄可以使用嗎

esp8266wifi模塊怎么連接手機(jī)

ESP8266作Client建立TCP連接出現(xiàn)報(bào)錯(cuò)？

ESP8266 IoT_Demo行不通的原因？

求助，請(qǐng)問如何在RTOS SDK 1.5的PlatformIO IDE ESP8266實(shí)現(xiàn)MQTT？

國產(chǎn)低成本W(wǎng)i-Fi SoC解決方案芯片ESP8266與ESP8285對(duì)比差異

確定ESP8266固件下載成功的方法

使用Wi-Fi ESP8266方案模組接入云平臺(tái)

STM32、ESP8266與MQTT連接阿里云物聯(lián)網(wǎng)的串口通信異常解析

搜索歷史

STM32 + ESP8266 + MQTT協(xié)議連接騰訊IOT平臺(tái)

一、環(huán)境介紹

二、功能介紹

?

?

三、登錄騰訊物聯(lián)網(wǎng)平臺(tái)創(chuàng)建設(shè)備

四、使用MQTT客戶端模擬設(shè)備--測試

4.1 下載MQTT客戶端

4.2 查看物聯(lián)網(wǎng)平臺(tái)端口號(hào)與域名(IP地址)

4.3 生成MQTT登錄參數(shù)

4.4 了解主題上報(bào)和訂閱的格式

4.5使用MQTT客戶端登錄設(shè)備測試

4.6 微信小程序效果

五、STM32設(shè)備端代碼

5.1 下載程序

5.2 連接狀態(tài)

5.3 main.c文件

5.4 mqtt.c

評(píng)論

二、功能介紹

三、登錄騰訊物聯(lián)網(wǎng)平臺(tái)創(chuàng)建設(shè)備

四、使用MQTT客戶端模擬設(shè)備--測試

`5.4 mqtt.c`