devbox
Cpp五条
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

stm32F407+ESP8266+AT指令+阿里云+代码进阶版（4）_stm32f407 esp8266

作者：Cpp五条 | 2024-05-30 10:59:35

赞

踩

stm32f407 esp8266

(1)esp8266.c

  1. #include "esp8266.h"
  2.  
  3. char *wifi="317";
  4. char *wifiPasswd="88888888";
  5.  
  6. //返回值:0,发送成功;1,发送失败
  7. u8 esp8266_send_cmd(u8 *cmd,u8 *ack,u16 waittime)
  8. {
  9. 	u8 res=0; 
  10. 	USART3_RX_STA=0;
  11. 	u3_printf("%s\r\n",cmd);	//发送命令
  12. 	if(ack&&waittime)		//需要等待应答
  13. 	{
  14. 		while(--waittime)	//等待倒计时
  15. 		{
  16. 			delay_ms(10);
  17. 			if(USART3_RX_STA&0X8000)//接收到期待的应答结果
  18. 			{
  19. 				if(esp8266_check_cmd(ack))
  20. 				{
  21. 					printf("sendcmd_OK\r\n");
  22. 					break;//得到有效数据 
  23. 				}
  24. 				USART3_RX_STA=0;
  25. 			} 
  26. 		}
  27. 		if(waittime==0)
  28. 		{
  29. 			res=1; 
  30. 			printf("sendcmd_ERR\r\n");
  31. 		}
  32. 	}
  33. 	return res;
  34. } 
  35.  
  36. u8* esp8266_check_cmd(u8 *str)
  37. {
  38. 	char *strx=0;
  39. 	if(USART3_RX_STA&0X8000)		//接收到一次数据了
  40. 	{ 
  41. 		USART3_RX_BUF[USART3_RX_STA&0X7FFF]=0;//添加结束符
  42. 		strx=strstr((const char*)USART3_RX_BUF,(const char*)str);
  43. 	} 
  44. 	return (u8*)strx;
  45. }
  46.  
  47. //连接wifi
  48. void esp8266_init(char *url)
  49. {
  50. 	char tempBuf[100]={0};
  51. 	
  52. 	esp8266_send_cmd("AT+RST","ready",100);//让Wifi模块重启的命令
  53. 	
  54. 	delay_ms(1000);         //延时3S等待重启成功
  55. 	delay_ms(1000);
  56. 	delay_ms(1000);
  57.  
  58. 	//设置工作模式 1：station模式   2：AP模式  3：兼容 AP+station模式
  59. 	esp8266_send_cmd("AT+CWMODE=1","OK",100);
  60. 	
  61. 	esp8266_send_cmd("AT+CWAUTOCONN=0","OK",100);
  62. 	
  63. 	sprintf(tempBuf,"AT+CWJAP=\"%s\",\"%s\"",wifi,wifiPasswd);
  64. 	while(esp8266_send_cmd(tempBuf,"WIFI GOT IP",600));
  65. 	
  66. 	esp8266_send_cmd("AT+CIPMODE=1","OK",20);
  67. 	
  68. 	esp8266_send_cmd("AT+CIPMUX=0","OK",20);
  69. 	
  70. 	sprintf(tempBuf,"AT+CIPSTART=\"TCP\",\"%s\",1883,1",url);
  71. 	while(esp8266_send_cmd(tempBuf,"CONNECT",1000));
  72. 	
  73. 	esp8266_send_cmd("AT+CIPMODE=1","OK",200);//是否开启透传模式  0：表示关闭 1：表示开启透传
  74. 	
  75. 	esp8266_send_cmd("AT+CIPSEND","OK",50);//透传模式下 开始发送数据的指令 这个指令之后就可以直接发数据了
  76. }

(2)esp8266.h

  1. #ifndef __ESP8266_H
  2. #define __ESP8266_H
  3.  
  4. #include "string.h"
  5. #include "stdio.h"
  6. #include "stdlib.h"
  7. #include "usart3.h"
  8. #include "stm32f4xx_conf.h"
  9. #include "delay.h"
  10.  
  11. extern char *wifi;
  12. extern char *wifiPasswd;
  13.  
  14. u8 esp8266_send_cmd(u8 *cmd,u8 *ack,u16 waittime);
  15. u8* esp8266_check_cmd(u8 *str);
  16. void esp8266_init(char *url);
  17.  
  18. #endif
  19.

(3)aliyun_mqtt.c

  1. #include "aliyun_mqtt.h"
  2.  
  3. u8 *mqtt_rxbuf;
  4. u8 *mqtt_txbuf;
  5. u16 mqtt_rxlen;
  6. u16 mqtt_txlen;
  7. u8 _mqtt_txbuf[256];//发送数据缓存区
  8. u8 _mqtt_rxbuf[256];//接收数据缓存区
  9.  
  10. const u8 parket_connetAck[] = {0x20,0x02,0x00,0x00};
  11. const u8 parket_disconnet[] = {0xe0,0x00};
  12. const u8 parket_heart[] = {0xc0,0x00};
  13. const u8 parket_heart_reply[] = {0xc0,0x00};
  14. const u8 parket_subAck[] = {0x90,0x03};
  15.  
  16. void MQTT_Init(void)
  17. {
  18. 	mqtt_rxbuf = _mqtt_rxbuf;
  19. 	mqtt_rxlen = sizeof(_mqtt_rxbuf);
  20. 	mqtt_txbuf = _mqtt_txbuf;
  21. 	mqtt_txlen = sizeof(_mqtt_txbuf);
  22. 	memset(mqtt_rxbuf,0,mqtt_rxlen);
  23. 	memset(mqtt_txbuf,0,mqtt_txlen);
  24. 	memset(USART3_RX_BUF,0,sizeof(USART3_RX_BUF));
  25. 	USART3_RX_STA=0;  	
  26. 	
  27. 	MQTT_Disconnect();
  28. 	delay_ms(100);
  29. 	MQTT_Disconnect();
  30. 	delay_ms(100);
  31. }
  32.  
  33. u8 MQTT_Connect(char *ClientID,char *Username,char *Password)
  34. {
  35. 	u8 i,j;
  36. 	int ClientIDLen = strlen(ClientID);
  37. 	int UsernameLen = strlen(Username);
  38. 	int PasswordLen = strlen(Password);
  39. 	int DataLen;
  40. 	mqtt_txlen=0;
  41. 	memset(mqtt_txbuf,0,mqtt_txlen);
  42. 	DataLen = 10 + (ClientIDLen+2) + (UsernameLen+2) + (PasswordLen+2);
  43. 	
  44. 	mqtt_txbuf[mqtt_txlen++] = 0x10;   
  45. 	do
  46. 	{
  47. 		u8 encodedByte = DataLen % 128;
  48. 		DataLen = DataLen / 128;
  49. 		if ( DataLen > 0 )
  50. 			encodedByte = encodedByte | 128;
  51. 		mqtt_txbuf[mqtt_txlen++] = encodedByte;
  52. 	}while ( DataLen > 0 );
  53. 	
  54. 	mqtt_txbuf[mqtt_txlen++] = 0;         	// Protocol Name Length MSB    
  55. 	mqtt_txbuf[mqtt_txlen++] = 4;           // Protocol Name Length LSB    
  56. 	mqtt_txbuf[mqtt_txlen++] = 'M';         // ASCII Code for M    
  57. 	mqtt_txbuf[mqtt_txlen++] = 'Q';         // ASCII Code for Q    
  58. 	mqtt_txbuf[mqtt_txlen++] = 'T';         // ASCII Code for T    
  59. 	mqtt_txbuf[mqtt_txlen++] = 'T';         // ASCII Code for T    
  60.  
  61. 	mqtt_txbuf[mqtt_txlen++] = 4;           // MQTT Protocol version = 4    
  62.  
  63. 	mqtt_txbuf[mqtt_txlen++] = 0xc2;          // conn flags 
  64. 	
  65. 	mqtt_txbuf[mqtt_txlen++] = 0;           // Keep-alive Time Length MSB    
  66. 	mqtt_txbuf[mqtt_txlen++] = 100;         // Keep-alive Time Length LSB  100S心跳包  
  67.  
  68. 	mqtt_txbuf[mqtt_txlen++] = BYTE1(ClientIDLen);// Client ID length MSB    
  69. 	mqtt_txbuf[mqtt_txlen++] = BYTE0(ClientIDLen);// Client ID length LSB   
  70. 	memcpy(&mqtt_txbuf[mqtt_txlen],ClientID,ClientIDLen);
  71. 	mqtt_txlen += ClientIDLen;
  72.  
  73. 	if(UsernameLen > 0)
  74. 	{   
  75. 		mqtt_txbuf[mqtt_txlen++] = BYTE1(UsernameLen);    //username length MSB    
  76. 		mqtt_txbuf[mqtt_txlen++] = BYTE0(UsernameLen);      //username length LSB    
  77. 		memcpy(&mqtt_txbuf[mqtt_txlen],Username,UsernameLen);
  78. 		mqtt_txlen += UsernameLen;
  79. 	}
  80.  
  81. 	if(PasswordLen > 0)
  82. 	{    
  83. 		mqtt_txbuf[mqtt_txlen++] = BYTE1(PasswordLen);    //password length MSB    
  84. 		mqtt_txbuf[mqtt_txlen++] = BYTE0(PasswordLen);      //password length LSB  
  85. 		memcpy(&mqtt_txbuf[mqtt_txlen],Password,PasswordLen);
  86. 		mqtt_txlen += PasswordLen; 
  87. 	}    
  88. 	
  89. 	for(i=0;i<10;i++)
  90. 	{
  91. 		memset(mqtt_rxbuf,0,mqtt_rxlen);
  92. 		MQTT_SendBuf(mqtt_txbuf,mqtt_txlen);
  93. 		for(j=0;j<10;j++)
  94. 		{
  95. 			delay_ms(50);
  96. 			if(USART3_RX_STA&0x8000)
  97. 			{
  98. 				USART3_RX_BUF[USART3_RX_STA&0X7FFF]='\0';
  99. 				sprintf((char *)mqtt_rxbuf,"%s",USART3_RX_BUF);
  100. 				USART3_RX_STA=0;
  101. 				memset(USART3_RX_BUF,0,sizeof(USART3_RX_BUF));
  102. 			}
  103. 			if(mqtt_rxbuf[0]==parket_connetAck[0] && mqtt_rxbuf[1]==parket_connetAck[1]) //连接成功        
  104. 			{
  105. 				return 0;//连接成功
  106. 			}
  107. 		}
  108. 	}
  109. 	return 1;
  110. }
  111.  
  112. /*
  113. 函数功能: MQTT订阅/取消订阅数据打包函数
  114. 函数参数:
  115.     topic       主题   
  116.     qos         消息等级 0:最多分发一次  1: 至少分发一次  2: 仅分发一次
  117.     whether     订阅/取消订阅请求包 (1表示订阅,0表示取消订阅)
  118. 返回值: 0表示成功 1表示失败
  119. */
  120. u8 MQTT_SubscribeTopic(char *topic,u8 qos,u8 whether)
  121. {    
  122.     u8 i,j;
  123.  
  124.     int topiclen = strlen(topic);
  125.    
  126.   int DataLen = 2 + (topiclen+2) + (whether?1:0);//可变报头的长度（2字节）加上有效载荷的长度
  127.   //固定报头
  128.   //控制报文类型
  129. 	mqtt_txlen=0;
  130.     if(whether)mqtt_txbuf[mqtt_txlen++] = 0x82; //消息类型和标志订阅
  131.     else  mqtt_txbuf[mqtt_txlen++] = 0xA2;    //取消订阅
  132.  
  133.   //剩余长度
  134.   do
  135.   {
  136.     u8 encodedByte = DataLen % 128;
  137.     DataLen = DataLen / 128;
  138.     // if there are more data to encode, set the top bit of this byte
  139.     if ( DataLen > 0 )
  140.       encodedByte = encodedByte | 128;
  141.     mqtt_txbuf[mqtt_txlen++] = encodedByte;
  142.   }while ( DataLen > 0 ); 
  143.   
  144.   //可变报头
  145.     mqtt_txbuf[mqtt_txlen++] = 0;     //消息标识符 MSB
  146.     mqtt_txbuf[mqtt_txlen++] = 0x01;        //消息标识符 LSB
  147.   //有效载荷
  148.     mqtt_txbuf[mqtt_txlen++] = BYTE1(topiclen);//主题长度 MSB
  149.     mqtt_txbuf[mqtt_txlen++] = BYTE0(topiclen);//主题长度 LSB   
  150.   memcpy(&mqtt_txbuf[mqtt_txlen],topic,topiclen);
  151.     mqtt_txlen += topiclen;
  152.     
  153.     if(whether)
  154.     {
  155.        mqtt_txbuf[mqtt_txlen++] = qos;//QoS级别
  156.     }
  157.     
  158.     for(i=0;i<10;i++)
  159.     {
  160. 		memset(mqtt_rxbuf,0,mqtt_rxlen);
  161. 		MQTT_SendBuf(mqtt_txbuf,mqtt_txlen);
  162. 		for(j=0;j<10;j++)
  163. 		{
  164. 			delay_ms(50);
  165. 			if((USART3_RX_STA&(1<<15))==1)
  166. 			{
  167. 				USART3_RX_BUF[USART3_RX_STA&0X7FFF]='\0';
  168. 				sprintf((char *)mqtt_rxbuf,"%s",USART3_RX_BUF);
  169. 				USART3_RX_STA=0;
  170. 			}
  171. 			if(mqtt_rxbuf[0]==parket_subAck[0] && mqtt_rxbuf[1]==parket_subAck[1]) //订阅成功        
  172. 			{
  173. 			return 0;//订阅成功
  174. 			}
  175. 		}
  176.     }
  177.   return 1; //失败
  178. }
  179.  
  180. //MQTT发布数据打包函数
  181. //topic   主题 
  182. //message 消息
  183. //qos     消息等级 
  184. u8 MQTT_PublishData(char *topic, char *message, u8 qos)
  185. {  
  186.     int topicLength = strlen(topic);    
  187.     int messageLength = strlen(message);     
  188.     static u16 id=0;
  189.   int DataLen;
  190.   mqtt_txlen=0;
  191.   //有效载荷的长度这样计算：用固定报头中的剩余长度字段的值减去可变报头的长度
  192.   //QOS为0时没有标识符
  193.   //数据长度             主题名   报文标识符   有效载荷
  194.     if(qos) DataLen = (2+topicLength) + 2 + messageLength;       
  195.     else  DataLen = (2+topicLength) + messageLength;   
  196.  
  197.     //固定报头
  198.   //控制报文类型
  199.     mqtt_txbuf[mqtt_txlen++] = 0x30;    // MQTT Message Type PUBLISH  
  200.  
  201.   //剩余长度
  202.   do
  203.   {
  204.     u8 encodedByte = DataLen % 128;
  205.     DataLen = DataLen / 128;
  206.     // if there are more data to encode, set the top bit of this byte
  207.     if ( DataLen > 0 )
  208.       encodedByte = encodedByte | 128;
  209.     mqtt_txbuf[mqtt_txlen++] = encodedByte;
  210.   }while ( DataLen > 0 ); 
  211.   
  212.     mqtt_txbuf[mqtt_txlen++] = BYTE1(topicLength);//主题长度MSB
  213.     mqtt_txbuf[mqtt_txlen++] = BYTE0(topicLength);//主题长度LSB 
  214.   memcpy(&mqtt_txbuf[mqtt_txlen],topic,topicLength);//拷贝主题
  215.     mqtt_txlen += topicLength;
  216.         
  217.   //报文标识符
  218.     if(qos)
  219.     {
  220.         mqtt_txbuf[mqtt_txlen++] = BYTE1(id);
  221.         mqtt_txbuf[mqtt_txlen++] = BYTE0(id);
  222.         id++;
  223.     }
  224.   memcpy(&mqtt_txbuf[mqtt_txlen],message,messageLength);
  225.     mqtt_txlen += messageLength;
  226.         
  227.   MQTT_SendBuf(mqtt_txbuf,mqtt_txlen);
  228.     return mqtt_txlen;
  229. }
  230.  
  231. void MQTT_SentHeart(void)
  232. {
  233.   MQTT_SendBuf((u8 *)parket_heart,sizeof(parket_heart));
  234. }
  235.  
  236. void MQTT_Disconnect(void)
  237. {
  238.   MQTT_SendBuf((u8 *)parket_disconnet,sizeof(parket_disconnet));
  239. }
  240.  
  241. void MQTT_SendByte(u8 val)
  242. {
  243.     USART_SendData(USART3, val);
  244.     while (USART_GetFlagStatus(USART3, USART_FLAG_TC) == RESET);	//等待发送完成
  245. }
  246.  
  247. void MQTT_SendBuf(u8 *buf,u16 len)
  248. {
  249. 	 while(len--)	MQTT_SendByte(*buf++);
  250. }

(4)aliyun_mqtt.h

  1. #ifndef __ALIYUN_MQTT_H_
  2. #define __ALIYUN_MQTT_H_
  3.  
  4. #include "string.h"
  5. #include "stdio.h"
  6. #include "stdlib.h"
  7. #include "stm32f4xx_conf.h"
  8. #include "usart3.h"
  9. #include "delay.h"
  10.  
  11. #define BYTE0(dwTemp)       (*( char *)(&dwTemp))
  12. #define BYTE1(dwTemp)       (*((char *)(&dwTemp) + 1))
  13. #define BYTE2(dwTemp)       (*((char *)(&dwTemp) + 2))
  14. #define BYTE3(dwTemp)       (*((char *)(&dwTemp) + 3))
  15. 	
  16. //阿里云用户名初始化
  17. void Aliyun_LoginInit(char *ProductKey,char *DeviceName,char *DeviceSecret);
  18.  
  19. //MQTT协议相关函数声明
  20. u8 MQTT_PublishData(char *topic, char *message, u8 qos);
  21. u8 MQTT_SubscribeTopic(char *topic,u8 qos,u8 whether);
  22. void MQTT_Init(void);
  23. u8 MQTT_Connect(char *ClientID,char *Username,char *Password);
  24. void MQTT_SentHeart(void);
  25. void MQTT_Disconnect(void);
  26. void MQTT_SendBuf(u8 *buf,u16 len);
  27.  
  28. #endif
  29.

(5)main.h

  1. #include "sys.h"
  2. #include "delay.h"
  3. #include "usart.h"
  4. #include "led.h"
  5. #include "beep.h"
  6. #include "key.h"
  7. #include "esp8266.h"
  8.  
  9. char *clientId = "k0wih08FdYq.ESP8266|securemode=2,signmethod=hmacsha256,timestamp=1710944829520|";
  10. char *username = "ESP8266&k0wih08FdYq";
  11. char *passwd = "7d293f515f969ddb5631f85eed895d823d32c6e9f865b0762957b519ab5b8c26";
  12. char *mqttHostUrl = "iot-06z00jb2hfkrh6y.mqtt.iothub.aliyuncs.com";
  13.  
  14. int main(void)
  15. { 
  16.  
  17. 	NVIC_PriorityGroupConfig(NVIC_PriorityGroup_2);//设置系统中断优先级分组2
  18. 	delay_init(168);		//延时初始化 
  19. 	uart_init(115200);	//串口初始化波特率为115200
  20. 	LED_Init();		  		//初始化与LED连接的硬件接口  
  21. 	usart3_init(115200);
  22. 	
  23. 	esp8266_init(mqttHostUrl);
  24. 	printf("esp8266初始化成功\r\n");
  25. 	MQTT_Init();
  26. 	if(MQTT_Connect(clientId,username,passwd))
  27. 	{
  28. 		printf("阿里云连接失败\r\n");
  29. 	}
  30. 	else
  31. 	{
  32. 		printf("阿里云连接成功\r\n");
  33. 	}
  34. 	
  35. 	while(1){}
  36. }

(6)完整工程代码

链接：https://pan.baidu.com/s/1LoOh5QivNyKUwPd3Mje0IA
提取码：生日

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/Cpp五条/article/detail/646657
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号