STM32玩转物联网实战篇：5.ESP8266 WIFI模块MQTT通信示例详解

news/2024/5/18 19:37:23

1、准备开发板

开发板功能区分布图
在这里插入图片描述

开发板俯视图
在这里插入图片描述

2、实验讲解

    在之前的章节中，已经讲解过了MQTT的通讯原理和组包过程，现在开始手把手的教大家用代码来实现连接MQTT平台以及数据的交互，实际上这篇文章已经拖更接近两年了，非常感谢那些默默支持我的朋友们。代码的实现过程主要参考了MQTT中文网[https://mqtt.p2hp.com/mqtt311]，大家感兴趣的话可以打开进行学习，你们的点赞和支持是我持续更新的动力。

    大家不要被我的代码量给吓到了，下面的代码无非是封装好的AT指令，在下面我也会贴出AT指令实现的过程帮助大家理解，另外我也会贴出逆向后的报文，让大家知道在明文情况下，黑客抓包会获得哪些数据。那些复杂指令集和实现过程也是通过一些重复且简单的指令组成的，希望你能够保持你的自信心，抱着良好的心态去对待生活。

提前准备的数据（Ready）

服务器地址 broker-cn.emqx.io
服务器端口	1883WIFI名称 MCSCV		
WIFI密码 jnszstmOBB	//鉴权三元组
客户端ID	111|hmvcfu	
用户名		hmvcfu
密码		a02d6361531c2dae941d5b022982d944MQTT上报主题		sys/hmvcfu/post"				MQTT下发主题		sys/hmvcfu/control"

初始化并连接服务器（Init）

//设置STA模式
ESP8266> AT+CWMODE=1
//设置单连接模式
ESP8266> AT+CIPMUX=0
//连接路由器WIFI
ESP8266> AT+CWJAP="MCSCV","jnszstmOBB"
//连接服务器
ESP8266> AT+CIPSTART="TCP","broker-cn.emqx.io",1883

发送MQTT连接报文（Connect）

//发送连接报文
ESP8266> AT+CIPSEND=66
ESP8266> 10 40 00 04 4D 51 54 54 04 C0 00 78 00 0A 31 31 31 7C 68 6D 76 63 66 75 00 06 68 6D 76 63 66 75 00 20 61 30 32 64 36 33 36 31 35 33 31 63 32 64 61 65 39 34 31 64 35 62 30 32 32 39 38 32 64 39 34 34 
//逆向后的连接报文
◇@\0MQTT繺0x\0
111|hmvcfu\0hmvcfu\0 a02d6361531c2dae941d5b022982d944□
//发送后回应
ESP8266< +IPD,5: 20 02 00 00

发送MQTT订阅主题报文（Subscribe）

//发送订阅主题报文
ESP8266> AT+CIPSEND=25
ESP8266> 82 17 00 01 00 12 73 79 73 2F 68 6D 76 63 66 75 2F 63 6F 6E 74 72 6F 6C 00   
//逆向后的订阅主题报文
?\0\0sys/hmvcfu/control\0□
//发送后回应
ESP8266< +IPD,5:90 03 00 01 00

发送MQTT发布主题报文（Publish）

//发送发布主题报文
ESP8266> AT+CIPSEND=64
ESP8266> 30 3E 00 0F 73 79 73 2F 68 6D 76 63 66 75 2F 70 6F 73 74 7B 22 6D 73 67 22 3A 7B 22 70 61 72 61 6D 64 61 74 61 22 3A 5B 7B 22 74 65 6D 70 22 3A 32 30 2C 22 68 75 6D 69 22 3A 39 38 7D 5D 7D 7D 
//逆向后的发布主题报文
0>\0sys/hmvcfu/post{"msg":{"paramdata":[{"temp":20,"humi":98}]}}□
//接收到SEND OK说明发布成功
ESP8266< SEND OK

接收来自MQTT发布者发布的报文（Receive）

//接收到openLed指令
ESP8266< +IPD,29:30 1B 00 12 73 79 73 2F 68 6D 76 63 66 75 2F 63 6F 6E 74 72 6F 6C 6F 70 65 6E 4C 65 64 
//逆向后的接收指令
0\0sys/hmvcfu/controlopenLed□
//接收到CloseLed指令
ESP8266< +IPD,30:30 1C 00 12 73 79 73 2F 68 6D 76 63 66 75 2F 63 6F 6E 74 72 6F 6C 63 6C 6F 73 65 4C 65 64 
//逆向后的接收指令
0\0sys/hmvcfu/controlcloseLed□

3、在MDK中编写代码

MQTT组包函数
MQTT_PacketConnect连接服务器的组包函数
MQTT_UnPacketConnectAck连接消息解包
MQTT_PacketPublishMQTT发布消息组包函数
MQTT_UnPacketPublishAckMQTT发布回复消息解包函数
MQTT_UnPacketPublishMQTT收到发布消息解包函数
MQTT_PacketSubscribeMQTT订阅消息组包函数
MQTT_UnPacketSubscribeMQTT订阅回复消息解包函数
MQTT_UnPacketUnSubscribeMQTT取消订阅回复消息解包函数
MQTT_PacketUnSubscribeMQTT取消订阅消息组包函数
MQTT_PacketDisConnect断开连接消息组包
MQTT_PacketPingMQTT心跳请求组包函数
MQTT_UnPacketRecvMQTT接收消息解包函数
MQTT基础函数
MQTTClient_DevLinkMQTT连接函数
MQTTClient_SubscribeMQTT订阅函数
MQTTClient_PublishMQTT客户端发布函数
MQTTClient_RevProMQTT客户端协议接收函数
MQTTClient_HeartBeatMQTT客户端心跳函数

新建GloalConfig.h文件，添加以下代码

#ifndef __GLOAL_CONFIG_H_
#define __GLOAL_CONFIG_H_#define SERVER_IP "broker-cn.emqx.io"	//服务器地址
#define SERVER_PORT	"1883"//服务器端口#define WIFI_NAME "MCSCV"		//WIFI名称
#define WIFI_PSWD "jnszstmOBB"	//WIFI密码//鉴权三元组
#define MQTT_CLIENTID	"111|hmvcfu"	//客户端ID
#define MQTT_USERNAME	"hmvcfu"	//用户名
#define MQTT_PASSWORD	"a02d6361531c2dae941d5b022982d944"	//密码#define MQTT_PUB_TOPIC		"sys/hmvcfu/post"				//MQTT上报主题
#define MQTT_SUB_TOPIC		"sys/hmvcfu/control"			//MQTT下发主题#endif

新建shfm_mqtt.c文件，添加以下代码

#include "shfm_mqtt.h"/*
*@brief		连接服务器的组包函数
*@param		Username       用户名
*					Password       密码
*					ClientID       客户端ID
*					mqttPacket     数据包指针
*@return	数据包长度
*/
uint16_t MQTT_PacketConnect(char *Username,char *Password,char *ClientID,uint8_t *mqttPacket)
{int16_t  len;int16_t  ClientIDLen;int16_t  UsernameLen;int16_t  PasswordLen;uint16_t mqttPacketLen = 0;ClientIDLen = strlen(ClientID);UsernameLen = strlen(Username);PasswordLen = strlen(Password);//可变报头(10)+Payload  每个字段包含两个字节的长度标识len = 10 + (ClientIDLen + 2) + (UsernameLen + 2) + (PasswordLen + 2);	//加2是因为每个字段占两个字节//固定报头//控制报文类型mqttPacket[mqttPacketLen++] = 0x10;		//MQTT Message Type CONNECT//剩余长度(不包括固定头部)，剩余长度最多可以用四个字节来表示do{uint8_t encodedByte = len % 128;len = len / 128;// 如果有更多的数据要编码，请设置该字节的最高位if ( len > 0 )encodedByte = encodedByte | 128;mqttPacket[mqttPacketLen++] = encodedByte;} while ( len > 0 );//可变报头//协议名mqttPacket[mqttPacketLen++] = 0;        		// 协议名长度高位mqttPacket[mqttPacketLen++] = 4;        		// 协议名长度低位mqttPacket[mqttPacketLen++] = 'M';        	// ASCII 字符 MmqttPacket[mqttPacketLen++] = 'Q';        	// ASCII 字符 QmqttPacket[mqttPacketLen++] = 'T';        	// ASCII 字符 TmqttPacket[mqttPacketLen++] = 'T';        	// ASCII 字符 T//协议级别mqttPacket[mqttPacketLen++] = 4;        		// MQTT协议版本号 4//连接标志mqttPacket[mqttPacketLen++] = MQTT_CONNECT_WILL_QOS0|MQTT_CONNECT_USER_NAME|MQTT_CONNECT_PASSORD;        	// 连接标志mqttPacket[mqttPacketLen++] = WORD_MSB(MQTT_KEEP_LIVE_TIME);        		// 保活时间长度高位mqttPacket[mqttPacketLen++] = WORD_LSB(MQTT_KEEP_LIVE_TIME);        		// 保活时间长度低位mqttPacket[mqttPacketLen++] = WORD_MSB(ClientIDLen);// 客户端ID长度高位mqttPacket[mqttPacketLen++] = WORD_LSB(ClientIDLen);// 客户端ID长度低位memcpy(&mqttPacket[mqttPacketLen],ClientID,ClientIDLen);mqttPacketLen += ClientIDLen;if(UsernameLen > 0){mqttPacket[mqttPacketLen++] = WORD_MSB(UsernameLen);		//用户名长度高位mqttPacket[mqttPacketLen++] = WORD_LSB(UsernameLen);    	//用户名长度低位memcpy(&mqttPacket[mqttPacketLen],Username,UsernameLen);mqttPacketLen += UsernameLen;}if(PasswordLen > 0){mqttPacket[mqttPacketLen++] = WORD_MSB(PasswordLen);		//密码长度高位mqttPacket[mqttPacketLen++] = WORD_LSB(PasswordLen);    	//密码长度低位memcpy(&mqttPacket[mqttPacketLen],Password,PasswordLen);mqttPacketLen += PasswordLen;}return mqttPacketLen;
}/*
*@brief		连接消息解包
*@param		rev_data       接收的数据
*@return	数据包长度
*/
uint8_t MQTT_UnPacketConnectAck(uint8_t *rev_data)
{if(rev_data[1] != 0x02)return 1;if(rev_data[2] == 0x00 || rev_data[2] == 0x01)return rev_data[3];elsereturn 255;}/*
*@brief		断开连接消息组包
*@param		mqttPacket       数据包指针
*@return	数据包长度
*/
uint8_t MQTT_PacketDisConnect(uint8_t *mqttPacket)
{uint16_t mqttPacketLen = 0;//固定报头mqttPacket[mqttPacketLen++] = M_DISCONNECT << 4;//剩余长度值mqttPacket[mqttPacketLen++] = 0;return 0;}/*
*@brief		MQTT订阅消息组包函数
*@param		topic       主题名称
*					qos					消息等级
*					mqttPacket  数据包指针
*@return	数据包长度
*/
uint16_t MQTT_PacketSubscribe(char *topic,uint8_t qos,uint8_t *mqttPacket)
{int16_t len;int16_t topiclen;uint16_t mqttPacketLen = 0;topiclen = strlen(topic);len = 2 + (topiclen + 2) + 1;	//可变报头的长度（2字节）加上有效载荷的长度//固定报头//控制报文类型mqttPacket[mqttPacketLen++] = 0x82; //消息类型和标志订阅//剩余长度do{unsigned char  encodedByte = len % 128;len = len / 128;// 如果有更多的数据要编码，请设置该字节的最高位if ( len > 0 )encodedByte = encodedByte | 128;mqttPacket[mqttPacketLen++] = encodedByte;} while ( len > 0 );//可变报头mqttPacket[mqttPacketLen++] = 0;				//消息标识符 MSBmqttPacket[mqttPacketLen++] = 0x01;           //消息标识符 LSB//有效载荷mqttPacket[mqttPacketLen++] = WORD_MSB(topiclen);//主题长度 MSBmqttPacket[mqttPacketLen++] = WORD_LSB(topiclen);//主题长度 LSBmemcpy(&mqttPacket[mqttPacketLen],topic,topiclen);mqttPacketLen += topiclen;mqttPacket[mqttPacketLen++] = qos;//QoS级别return mqttPacketLen;
}/*
*@brief		MQTT订阅回复消息解包函数
*@param		rev_data       接收的数据
*@return	0-成功		其他-失败
*/
uint8_t MQTT_UnPacketSubscribe(uint8_t *rev_data)
{uint8_t result = 255;if(rev_data[2] == WORD_MSB(MQTT_SUBSCRIBE_ID) && rev_data[3] == WORD_LSB(MQTT_SUBSCRIBE_ID)){switch(rev_data[4]){case 0x00:case 0x01:case 0x02://MQTT订阅成功result = 0;break;case 0x80://MQTT订阅失败result = 1;break;default://MQTT未知错误result = 2;break;}}return result;
}/*
*@brief		MQTT取消订阅消息组包函数
*@param		topic       主题名称
*					qos					消息等级
*					mqttPacket  数据包指针
*@return	数据包长度
*/
uint16_t MQTT_PacketUnSubscribe(char *topic,uint8_t qos,uint8_t *mqttPacket)
{int16_t topiclen;int16_t len;uint16_t mqttPacketLen = 0;topiclen = strlen(topic);len = 2 + (topiclen + 2);//可变报头的长度（2字节）加上有效载荷的长度//固定报头//控制报文类型mqttPacket[mqttPacketLen++] = 0xA2;    //取消订阅//剩余长度do{uint8_t encodedByte = len % 128;len = len / 128;// if there are more data to encode, set the top bit of this byteif ( len > 0 )encodedByte = encodedByte | 128;mqttPacket[mqttPacketLen++] = encodedByte;} while ( len > 0 );//可变报头mqttPacket[mqttPacketLen++] = 0;				//消息标识符 MSBmqttPacket[mqttPacketLen++] = 0x01;           //消息标识符 LSB//有效载荷mqttPacket[mqttPacketLen++] = WORD_MSB(topiclen);//主题长度 MSBmqttPacket[mqttPacketLen++] = WORD_LSB(topiclen);//主题长度 LSBmemcpy(&mqttPacket[mqttPacketLen],topic,topiclen);mqttPacketLen += topiclen;return mqttPacketLen;
}/*
*@brief		MQTT取消订阅回复消息解包函数
*@param		rev_data       接收的数据
*@return	0-成功		其他-失败
*/
uint8_t MQTT_UnPacketUnSubscribe(uint8_t *rev_data)
{uint8_t result = 1;if(rev_data[2] == WORD_MSB(MQTT_UNSUBSCRIBE_ID) && rev_data[3] == WORD_LSB(MQTT_UNSUBSCRIBE_ID)){result = 0;}return result;}/*
*@brief		MQTT发布消息组包函数
*@param		topic       主题
*					message     消息
*					qos       	消息等级
*					mqttPacket  数据包指针
*@return	0-成功		其他-失败
*/
uint16_t MQTT_PacketPublish(char *topic, char *message, uint8_t qos,uint8_t *mqttPacket)
{int16_t len;int16_t topicLength = strlen(topic);int16_t messageLength = strlen(message);static uint16_t id=0;uint16_t  mqttPacketLen = 0;//有效载荷的长度这样计算：用固定报头中的剩余长度字段的值减去可变报头的长度//QOS为0时没有标识符//数据长度             主题名   报文标识符   有效载荷if(qos)	len = (2+topicLength) + 2 + messageLength;else	len = (2+topicLength) + messageLength;//固定报头//控制报文类型mqttPacket[mqttPacketLen++] = 0x30;    // MQTT 消息类型是 PUBLISH//剩余长度do{uint8_t  encodedByte = len % 128;len = len / 128;// 如果有更多的数据要编码，请设置该字节的最高位if ( len > 0 )encodedByte = encodedByte | 128;mqttPacket[mqttPacketLen++] = encodedByte;} while ( len > 0 );mqttPacket[mqttPacketLen++] = WORD_MSB(topicLength);//主题长度MSBmqttPacket[mqttPacketLen++] = WORD_LSB(topicLength);//主题长度LSBmemcpy(&mqttPacket[mqttPacketLen],topic,topicLength);//拷贝主题mqttPacketLen += topicLength;//报文标识符if(qos){mqttPacket[mqttPacketLen++] = WORD_MSB(id);mqttPacket[mqttPacketLen++] = WORD_LSB(id);id++;}memcpy(&mqttPacket[mqttPacketLen],message,messageLength);mqttPacketLen += messageLength;return mqttPacketLen;
}/*
*@brief		MQTT发布回复消息解包函数
*@param		rev_data       接收的数据
*@return	0-成功		其他-失败
*/
uint8_t MQTT_UnPacketPublishAck(uint8_t *rev_data)
{if(rev_data[1] != 2)return 1;if(rev_data[2] == WORD_MSB(MQTT_PUBLISH_ID) && rev_data[3] == WORD_LSB(MQTT_PUBLISH_ID))return 0;elsereturn 1;}/*
*@brief		MQTT收到发布消息解包函数
*@param		rev_data    接收的数据
*					topic     	主题
*					topic_len   主题长度
*					payload  		有效载荷payload_len 有效载荷长度
*@return	0-成功		其他-失败
*/
uint8_t MQTT_UnPacketPublish(uint8_t *rev_data, int8_t *topic, uint16_t *topic_len, int8_t *payload, uint16_t *payload_len)
{int i = 0;uint8_t *msgPtr;uint32_t remain_len = 0;uint32_t multiplier = 1;uint8_t *in;in = rev_data+1;for(i = 0; i < 4; ++i){remain_len += (in[i] & 0x7f) * multiplier;if(!(in[i] & 0x80)){
//					return i + 1;i += 1;break;}multiplier <<= 7;if(multiplier >= 2097152)		//128 * 128 * 128{return -2;					// error, out of range}}msgPtr = rev_data + i + 1;if(remain_len < 2)							//retainreturn 255;*topic_len = (uint16_t)msgPtr[0] << 8 | msgPtr[1];if(remain_len < *topic_len + 2)return 255;memcpy(topic, (int8_t *)msgPtr + 2, *topic_len);		//复制数据*payload_len = remain_len - 2 - *topic_len;memcpy(payload, (int8_t *)msgPtr + 2 + *topic_len, *payload_len);return 0;
}/*
*@brief		MQTT心跳请求组包函数
*@param		mqttPacket       数据包指针
*@return	0-成功		其他-失败
*/
uint8_t MQTT_PacketPing(uint8_t *mqttPacket)
{uint8_t mqttPacketLen = 0;/*************************************固定头部***********************************************///固定头部----------------------头部消息-------------------------------------------------mqttPacket[mqttPacketLen++] = M_PINGREQ << 4;//固定头部----------------------剩余长度-------------------------------------------------mqttPacket[mqttPacketLen++] = 0;return mqttPacketLen;}/*
*@brief		MQTT接收消息解包函数
*@param		dataPtr       消息包指针
*@return	0-成功		其他-失败
*/
uint8_t MQTT_UnPacketRecv(uint8_t *dataPtr)
{uint8_t status = 255;uint8_t type = dataPtr[0] >> 4;				//类型检查if(type < 1 || type > 14)return status;if(type == M_PUBLISH)status = type;elsestatus = type;return status;
}

新建shfm_mqtt.h文件，添加以下代码

#ifndef __MQTTData_H
#define __MQTTData_H//C库
#include <string.h>
#include <stdio.h>
#include <stdlib.h>
#include <stdint.h>#define WORD_MSB(A)         (uint8_t)((A & 0xFF00) >> 8)
#define WORD_LSB(A)         (uint8_t)(A & 0x00FF)#define MQTT_PUBLISH_ID			10
#define MQTT_SUBSCRIBE_ID		20
#define MQTT_UNSUBSCRIBE_ID		30#define MQTT_CONNECT_WILL_QOS0    0x00
#define MQTT_CONNECT_PASSORD      0x40
#define MQTT_CONNECT_USER_NAME    0x80#define MQTT_KEEP_LIVE_TIME		120	//单位 S#define _DEBUG_MQTT 1typedef enum
{//名字 	    值 			报文流动方向 	描述M_RESERVED1	=0	,	//	禁止	保留M_CONNECT		,	//	客户端到服务端	客户端请求连接服务端M_CONNACK		,	//	服务端到客户端	连接报文确认M_PUBLISH		,	//	两个方向都允许	发布消息M_PUBACK		,	//	两个方向都允许	QoS 1消息发布收到确认M_PUBREC		,	//	两个方向都允许	发布收到（保证交付第一步）M_PUBREL		,	//	两个方向都允许	发布释放（保证交付第二步）M_PUBCOMP		,	//	两个方向都允许	QoS 2消息发布完成（保证交互第三步）M_SUBSCRIBE		,	//	客户端到服务端	客户端订阅请求M_SUBACK		,	//	服务端到客户端	订阅请求报文确认M_UNSUBSCRIBE	,	//	客户端到服务端	客户端取消订阅请求M_UNSUBACK		,	//	服务端到客户端	取消订阅报文确认M_PINGREQ		,	//	客户端到服务端	心跳请求M_PINGRESP		,	//	服务端到客户端	心跳响应M_DISCONNECT	,	//	客户端到服务端	客户端断开连接M_RESERVED2		,	//	禁止	保留
} _typdef_mqtt_message;uint16_t MQTT_PacketConnect(char *Username,char *Password,char *ClientID,uint8_t *mqttPacket);
uint8_t MQTT_UnPacketConnectAck(uint8_t *rev_data);
uint16_t MQTT_PacketPublish(char *topic, char *message, uint8_t qos,uint8_t *mqttPacket);
uint8_t MQTT_UnPacketPublishAck(uint8_t *rev_data);
uint8_t MQTT_UnPacketPublish(uint8_t *rev_data, int8_t *topic, uint16_t *topic_len, int8_t *payload, uint16_t *payload_len);
uint16_t MQTT_PacketSubscribe(char *topic,uint8_t qos,uint8_t *mqttPacket);
uint8_t MQTT_UnPacketSubscribe(uint8_t *rev_data);
uint8_t MQTT_UnPacketUnSubscribe(uint8_t *rev_data);
uint16_t MQTT_PacketUnSubscribe(char *topic,uint8_t qos,uint8_t *mqttPacket);
uint8_t MQTT_PacketDisConnect(uint8_t *mqttPacket);
uint8_t MQTT_PacketPing(uint8_t *mqttPacket);
uint8_t MQTT_UnPacketRecv(uint8_t *dataPtr);
#endif

新建mqttclient.h文件，添加以下代码

#ifndef __MQTT_CLIENT_H_
#define __MQTT_CLIENT_H_#include "sys.h"#ifndef MQTTCLIENT_OK
#define MQTTCLIENT_OK                                              0
#endif#ifndef MQTTCLIENT_NOK
#define MQTTCLIENT_NOK                                             1
#endif#define  MQTTCLIENT_RETTYPE		unsigned char MQTTCLIENT_RETTYPE MQTTClient_DevLink(void);
MQTTCLIENT_RETTYPE MQTTClient_Subscribe(const char *topic);
MQTTCLIENT_RETTYPE MQTTClient_Publish(const char *topic, const char *msg);
MQTTCLIENT_RETTYPE MQTTClient_HeartBeat(void);
void MQTTClient_RevPro(uint8_t *cmd);
#endif

新建mqttclient.c文件，编写以下代码

#include "mqttclient.h"
#include "shfm_mqtt.h"
#include "ESP8266.h"
#include "stdio.h"
#include "GloalConfig.h"
#include "gpio.h"/*
*@brief		MQTT连接函数
*@param		void
*@return	MQTTCLIENT_OK-成功	其余-失败	
*/
MQTTCLIENT_RETTYPE MQTTClient_DevLink(void)
{uint8_t mqttPacket[100]= {0};uint16_t mqttPacketLen = 0;uint8_t *dataPtr = NULL;UsartPrintf(USART_DEBUG,"Tips: Connect Mqtt\r\n");UsartPrintf(USART_DEBUG,"Tips: UserName:%s\r\n",MQTT_USERNAME);UsartPrintf(USART_DEBUG,"Tips: Password:%s\r\n",MQTT_PASSWORD);UsartPrintf(USART_DEBUG,"Tips: ClientId:%s\r\n",MQTT_CLIENTID);mqttPacketLen = MQTT_PacketConnect(MQTT_USERNAME,MQTT_PASSWORD,MQTT_CLIENTID,mqttPacket);if(mqttPacketLen < 2)return MQTTCLIENT_NOK;ESP8266_SendData(DISABLE,mqttPacket, mqttPacketLen,Single_ID_0);			//上传平台dataPtr = ESP8266_GetIPD(DISABLE,200);									//等待平台响应if(dataPtr != NULL){if(MQTT_UnPacketRecv(dataPtr) == M_CONNACK){return MQTT_UnPacketConnectAck(dataPtr); //返回0为连接成功}}return MQTTCLIENT_NOK;
}/*
*@brief		MQTT订阅函数
*@param		topic			主题
*@return	MQTTCLIENT_OK-成功	其余-失败	
*/
MQTTCLIENT_RETTYPE MQTTClient_Subscribe(const char *topic)
{uint8_t mqttPacket[100]= {0};uint16_t mqttPacketLen = 0;uint8_t *dataPtr = NULL;UsartPrintf(USART_DEBUG,"Tips: Subscribe Topic:%s\r\n",topic);mqttPacketLen = MQTT_PacketSubscribe((char*)topic,MQTT_CONNECT_WILL_QOS0,mqttPacket);if(mqttPacketLen < 2)return MQTTCLIENT_NOK;ESP8266_SendData(DISABLE,mqttPacket, mqttPacketLen,Single_ID_0);			//上传平台dataPtr = ESP8266_GetIPD(DISABLE,200);									//等待平台响应if(dataPtr != NULL){if(MQTT_UnPacketRecv(dataPtr) == M_SUBACK){return MQTT_UnPacketSubscribe(dataPtr); //返回0为连接成功}}return MQTTCLIENT_NOK;}/*
*@brief		MQTT客户端发布函数
*@param		topic			主题
*					msg				发布消息
*@return	MQTTCLIENT_OK-成功	其余-失败	
*/
MQTTCLIENT_RETTYPE MQTTClient_Publish(const char *topic, const char *msg)
{uint8_t mqttPacket[100]= {0};uint16_t mqttPacketLen = 0;uint8_t *dataPtr = NULL;uint8_t ucExecRes = MQTTCLIENT_NOK;UsartPrintf(USART_DEBUG,"Tips: Publish Topic:%s,Message:%s\r\n",topic,msg);mqttPacketLen = MQTT_PacketPublish((char*)topic,(char*)msg,MQTT_CONNECT_WILL_QOS0,mqttPacket);if(mqttPacketLen < 2)return MQTTCLIENT_NOK;if(ESP8266_SendData(DISABLE,mqttPacket, mqttPacketLen,Single_ID_0) == ESP8266_OK)					//向平台发送订阅请求ucExecRes = MQTTCLIENT_OK;return ucExecRes;
}/*
*@brief		MQTT客户端心跳函数
*@param		void
*@return	MQTTCLIENT_OK-成功	其余-失败	
*/
MQTTCLIENT_RETTYPE MQTTClient_HeartBeat(void)
{uint8_t mqttPacket[2]= {0};uint16_t mqttPacketLen = 0;uint8_t *dataPtr = NULL;UsartPrintf(USART_DEBUG,"Tips: HearBeat\r\n");mqttPacketLen = MQTT_PacketPing(mqttPacket);ESP8266_SendData(DISABLE,mqttPacket, sizeof(mqttPacket),Single_ID_0);						//向平台上传心跳请求dataPtr = ESP8266_GetIPD(DISABLE,200);if(dataPtr != NULL){if(dataPtr[0] == M_PINGRESP){return MQTTCLIENT_OK;}}return MQTTCLIENT_NOK;
}/*
*@brief		MQTT客户端协议接收函数
*@param		cmd				接收到的命令
*@return	MQTTCLIENT_OK-成功	其余-失败	
*/
void MQTTClient_RevPro(uint8_t *cmd)
{uint8_t type = 0;uint8_t result = 0;int8_t cmdid_topic[50] = {0};int8_t req_payload[100] = {0};uint16_t topic_len = 0;uint16_t req_len = 0;type = MQTT_UnPacketRecv(cmd); //进行解包if(type == M_PUBLISH){result = MQTT_UnPacketPublish(cmd, cmdid_topic,&topic_len,req_payload, &req_len);if(result == 0){UsartPrintf(USART_DEBUG, "topic: %s, topic_len: %d, payload: %s, payload_len: %d\r\n",cmdid_topic, topic_len, req_payload, req_len);if(strstr((char*)req_payload,"openLed")){LED_Set(LED_ON);	//打开LED灯}else if(strstr((char*)req_payload,"closeLed")){LED_Set(LED_OFF);	//关闭LED灯}}}
}

打开main.c文件，在main函数输入以下代码

/* Private typedef -----------------------------------------------------------*/
/* USER CODE BEGIN PTD */
ESP8266_RETTYPE netStatus = ESP8266_NOK;
unsigned char netErrCount = 0;
/* USER CODE END PTD */

/* USER CODE BEGIN 1 */unsigned char *dataPtr = NULL;uint32_t send_time = 0;ESP8266_RETTYPE ucExecRes = MQTTCLIENT_NOK;uint8_t mqttWork = 0;char sendData[100];/* USER CODE END 1 *//* MCU Configuration--------------------------------------------------------*//* Reset of all peripherals, Initializes the Flash interface and the Systick. */HAL_Init();/* USER CODE BEGIN Init *//* USER CODE END Init *//* Configure the system clock */SystemClock_Config();/* USER CODE BEGIN SysInit *//* USER CODE END SysInit *//* Initialize all configured peripherals */MX_GPIO_Init();MX_DMA_Init();MX_LPUART1_UART_Init();MX_USART1_UART_Init();MX_TIM2_Init();/* USER CODE BEGIN 2 */USART_Interupt_Enable();		//使能串口中断TIM_Interupt_Enable();			//使能定时器中断/* USER CODE END 2 *//* Infinite loop *//* USER CODE BEGIN WHILE */while (1){/* USER CODE END WHILE *//* USER CODE BEGIN 3 */if(!netDeviceInfo.netWork)	//如果网络未初始化{if(!NET_DEVICE_Init())	//进行网络初始化{mqttWork = MQTTClient_DevLink() == 0 ? 1 : 0;		//连接MQTT服务器if(mqttWork == 1)	//如果连接MQTT成功{printf("连接服务器成功\r\n");MQTTClient_Subscribe(MQTT_SUB_TOPIC);	//订阅MQTT下发主题}}}if(mqttWork){dataPtr = ESP8266_GetIPD(DISABLE,0);									//等待平台响应if(dataPtr != NULL){if(MQTT_UnPacketRecv(dataPtr) == M_PUBLISH){MQTTClient_RevPro(dataPtr);}}}if(time2Count - send_time >= 10000)		//（1ms * 10000)相当于延时10秒钟{send_time = time2Count;				//记下当前定时器的数值if(mqttWork){sprintf(sendData,"{\"msg\":{\"paramdata\":[{\"temp\":20,\"humi\":98}]}}");	//ucExecRes = MQTTClient_Publish(MQTT_PUB_TOPIC,sendData);if(ucExecRes == MQTTCLIENT_NOK){netErrCount++;	//错误次数进行累加if(netErrCount >= 3)	//超过三次,进行自检{netStatus = ESP8266_Get_LinkStatus();	//检查连接状态if(netStatus == 4)		//网络已经断开{netErrCount = 0;		//将错误清零netDeviceInfo.netWork = 0;	//标志网络断开netDeviceInfo.initStep = 0;	//将初始化步骤清零}}}else{netErrCount = 0;	//无错误,清除错误计数}}}}/* USER CODE END 3 */

4、实验现象

实现的功能
1、上电自动连接WIFI
2、连接WIFI成功后，连接MQTT服务器
3、连接MQTT服务器后，接收来自服务器的指令，并执行指令中的开关灯操作
4、每10秒向服务器上传一次数据
5、上传数据失败超过3次，自动进行网络初始化

客户端连接服务器并上传数据

在这里插入图片描述
在这里插入图片描述

MQTT.fx发送开关灯指令

在这里插入图片描述

客户端接收到数据并执行

在这里插入图片描述


http://www.mrgr.cn/p/36025286

相关文章

Part-DB 配置流程

Part-DB 配置流程

介绍 Part-DB是一个开源的器件管理工具，博主用于管理个人的电子器材，最近捣鼓了一下这个工具，由于手头还有一块闲置的赛昉星光2的开发板，所以我打算一起拿来捣鼓一下，如果不成功，就用树莓派（生气😠） 1.安装 大家可以直接按照 官方安装指导 来安装即可，我也是参考官方…
阅读更多...
【已解决简单好用】notepad++怎么设置中文

【已解决简单好用】notepad++怎么设置中文

打开Notepad软件。点击软件界面顶部菜单栏中的“Settings”选项。在下拉菜单中选择“Preferences”进行语言设置。在打开的设置窗口中&#xff0c;找到“General”选项。在“General”选项中&#xff0c;找到“Localization”&#xff08;界面语言&#xff09;项。在下拉菜单中…
阅读更多...
『 论文解读 』大语言模型（LLM）代理能够自主地利用1 day漏洞，利用成功率竟高达87%，单次利用成本仅8.8美元

『 论文解读 』大语言模型（LLM）代理能够自主地利用1 day漏洞，利用成功率竟高达87%，单次利用成本仅8.8美元

1. 概览 该论文主要展示了大语言模型LLM代理能够自主利用现实世界的 1 day 漏洞。研究我发现&#xff0c; GPT-4 在提供了CVE描述的情况下&#xff0c;能够成功利用 87% 的漏洞。 这与其他测试模型&#xff08;如 GPT-3.5 和其他开源 LLM &#xff09;以及开源漏洞扫描器&…
阅读更多...
面试：ThreadLocal

面试：ThreadLocal

目录 1、ThreadLocal可以实现〔资源对象】的线程隔离&#xff0c;让每个线程各用各的【资源对象】&#xff0c;避免争用引发的线程安全问题 2、ThreadLocal同时实现了线程内的资源共享 3、原理 4、为什么ThreadLocalMap 中的 key (即 ThreadLocal &#xff09;要设计为弱引用…
阅读更多...
双向循环链表

双向循环链表

双向循环链表的原理及相应功能的代码实现。双向循环链表 原理与应用 双向循环链表与双向链表的区别：指的是双向循环链表的首结点中的prev指针成员指向链表的尾结点，并且双向循环链表的尾结点里的next指针成员指向链表的首结点，所以双向循环链表也属于环形结构。双向循环链表…
阅读更多...
选择企业文件同步备份系统 需要注意这几点

选择企业文件同步备份系统 需要注意这几点

企业文件同步备份系统，是几乎每个企业都会用到的，都是为了保障业务数据的连续性、提高数据的可用性，让数据价值最大化。 企业在进行文件同步备份时可能会面临的问题包括： 1、数据传输效率低下：在面对海量小文件时，传统备份方式需要对每个文件进行打开、读取、关闭操作，…
阅读更多...
基于python+django+mysql农业生产可视化系统

基于python+django+mysql农业生产可视化系统

博主介绍&#xff1a; 大家好&#xff0c;本人精通Java、Python、C#、C、C编程语言&#xff0c;同时也熟练掌握微信小程序、Php和Android等技术&#xff0c;能够为大家提供全方位的技术支持和交流。 我有丰富的成品Java、Python、C#毕设项目经验&#xff0c;能够为学生提供各类…
阅读更多...
Django中间件的源码解析流程（上）——中间件载入的前置

Django中间件的源码解析流程（上）——中间件载入的前置

目录 1. ​前言​ 2. 请求的入口 3. 中间件加载的入口 4. 源码中的闭包实现 5. 最后 1. 前言 哈喽&#xff0c;大家好&#xff0c;我是小K,今天咋们分享的内容是&#xff1a;在学会Django中间件之后&#xff0c; 我们继续深入底层源码。 在执行中间件时请求到来总是从前往后…
阅读更多...
华北电力大学 2024 校历

华北电力大学 2024 校历

参考：https://gs.ncepu.edu.cn/qrzpy/zlxz/2f26c800a68c48658dcdc13d389bb15f.htm 虽是两个校区，教学应是同步的。
阅读更多...
恶意软件狩猎新途径：使用.NET元数据分析跟踪恶意软件

恶意软件狩猎新途径：使用.NET元数据分析跟踪恶意软件

本文由Blaze于2024年3月25日发表于其个人博客网站上。 就在不久前&#xff0c;我们意外发现了一个PureCrypter样本&#xff0c;而PureCrypter则是一款适用于各种类型恶意软件&#xff08;例如Agent Tesla和RedLine&#xff09;的加载器和混淆处理工具。深入分析之后&#xff0c…
阅读更多...
WPF 已知问题 开启 IsManipulationEnabled 之后触摸长按 RepeatButton 不会触发连续的 Click 事件

WPF 已知问题 开启 IsManipulationEnabled 之后触摸长按 RepeatButton 不会触发连续的 Click 事件

本文记录 WPF 的一个已知问题，在 RepeatButton 上开启 IsManipulationEnabled 漫游支持之后，将会导致触摸长按到 RepeatButton 之上时，不会收到源源不断的 Click 事件这是有个伙伴在 WPF 官方仓库报告的问题，详细请看 https://github.com/dotnet/wpf/issues/8223 原始的问题…
阅读更多...
修复 Debian 安装 dotnet 失败 depends on ca-certificates

修复 Debian 安装 dotnet 失败 depends on ca-certificates

本文记录我在 Debian 安装 dotnet 失败，报错信息是 packages-microsoft-prod depends on ca-certificates; however: Package ca-certificates is not installed.一开始按照官方的以下代码例子进行安装 packages-microsoft-prod.deb 文件，命令如下 sudo dpkg -i packages-mi…
阅读更多...
[已解决]react打包部署

[已解决]react打包部署

react打包部署 问题 npm install 命令无反应 思路 换成 yarn install 安装完hadoop的环境后&#xff0c;使用node的yarn会报错&#xff1a; 我们在cmd使用where yarn&#xff0c;如下&#xff1a; 看你想保留哪一个&#xff0c;我平时node用的多&#xff0c;就把hadoop的y…
阅读更多...
【04-提升模型性能：集成学习与超参数优化】

【04-提升模型性能：集成学习与超参数优化】

文章目录 前言集成学习BaggingBoosting超参数优化随机搜索贝叶斯优化总结前言 在前几篇博文中，我们已经介绍了一些机器学习的基础知识、Scikit-learn的核心工具与技巧，以及如何评估模型性能。本篇博文将重点讲解两个可以显著提升机器学习模型性能的高级策略：集成学习和超参数…
阅读更多...
Qt/C++音视频开发71-指定mjpeg/h264格式采集本地摄像头/存储文件到mp4/设备推流/采集推流

Qt/C++音视频开发71-指定mjpeg/h264格式采集本地摄像头/存储文件到mp4/设备推流/采集推流

一、前言 用ffmpeg采集本地摄像头，如果不指定格式的话，默认小分辨率比如640x480使用rawvideo格式，大分辨率比如1280x720使用mjpeg格式，当然前提是这个摄像头设备要支持这些格式。目前市面上有一些厂家做的本地设备支持264格式，这个压缩率极高，由于采集到的就是264格式的裸…
阅读更多...
Llama-7b-Chinese本地推理

Llama-7b-Chinese本地推理

Llama-7b-Chinese 本地推理 基础环境信息&#xff08;wsl2安装Ubuntu22.04 miniconda&#xff09; 使用miniconda搭建环境 (base) :~$ conda create --name Llama-7b-Chinese python3.10 Channels:- defaults Platform: linux-64 Collecting package metadata (repodata.js…
阅读更多...
合伙人1号企业工程项目管理软件相比传统软件的优势

合伙人1号企业工程项目管理软件相比传统软件的优势

合伙人1号 VS 传统管理方式 有需求欢迎联系项目经理：17704072381（微信/手机）
阅读更多...
21.3K star！推荐一款可视化自动化测试/爬虫/数据采集神器！功能免费且强大！

21.3K star！推荐一款可视化自动化测试/爬虫/数据采集神器！功能免费且强大！

大家好，我是狂师！ 在大数据时代，信息的获取与分析变得尤为重要。对于开发者、数据分析师乃至非技术人员来说，能够高效地采集网络数据并进行分析是一个强有力的工具。今天，我要向大家推荐的是一款功能强大、操作简单且完全免费的数据采集工具——EasySpider。 一个可视化浏…
阅读更多...
基于萤石云实现的九宫格视频监控效果

基于萤石云实现的九宫格视频监控效果

萤石云九宫格监控实现流程说在最前面将海康录像机添加到萤石云控制台开始进行开发代码中所用接口获取accessToken获取设备列表获取摄像头（录像机的通道）列表获取当前摄像头的监控地址实现完整代码展示效果（出于隐私不显示视频）额外总结1、上、下、左、右、放大、缩小是用来…
阅读更多...
TCP详解

TCP详解

2.1TCP 由IETF的RFC793定义的传输控制协议&#xff08;Transmission Control Protocol&#xff0c;TCP&#xff09;是一种基于字节流的传输层通信协议。在传输数据前需要在发送与接收者之间建立连接&#xff0c;通过相应机制保证其建立连接的可靠性。 TCP协议具备以下特性&am…
阅读更多...
推荐文章

Copyright @ 2022~2023