基于STM32与ESP8266的AT命令实现利用MQTT协议与服务器实现订阅与上报数据 ...

 一.给ESP8266烧录带有MQTT协议的AT固件：

     1.   乐鑫官方固件下载：
    ESP-AT｜乐鑫科技 (espressif.com.cn)

https://www.espressif.com.cn/zh-hans/support/download/at?keys&field_type_tid%5B%5D=14      2.安信可官方固件下载：
  安可信

https://docs.ai-thinker.com/esp8266/sdk3.固件烧录工具：
开辟工具清单 | 安信可科技 (ai-thinker.com)

https://docs.ai-thinker.com/%E5%BC%80%E5%8F%91%E5%B7%A5%E5%85%B72
二.测试ESP8266的AT指令是否可以利用：

1.利用串口调试助手与ESP8266的RX,TX相连,在串口调试助手发以下命令举行测试：
AT：测试AT是否启动启动
AT+GMR：检察版本信息
AT+CMD?：查询当前固件支持的所有命令及命令类型
2.将串口的USART设置为如下(如果串口波特率为115200可以不用设置)：
AT+UART_DEF=115200,8,1,0,3：设置串口的波特率、数据位、停止位、校验位、流控
三.初始化一个STM32的USART串口并将其RX,TX分别与ESP8266的TX,RX相连后

1.ESP8266初始化

1. void ESP8266_Init(void)
2. {
3.        
5.        
6.         ESP8266_Clear();
7.        
8.         printf( "0. AT\r\n");
9.         while(ESP8266_SendCmd("AT\r\n", "OK"))
10.                 HAL_Delay(500);
11.        
12.         printf( "1. RST\r\n");
13.         ESP8266_SendCmd("AT+RST\r\n", "");
14.          HAL_Delay(500);       
15.        
16.   ESP8266_SendCmd("AT+CIPCLOSE\r\n", "");
17.                 HAL_Delay(500);       
18.        
19.         printf( "2. CWMODE\r\n");
20.         while(ESP8266_SendCmd("AT+CWMODE=1\r\n", "OK"))
21.                 HAL_Delay(500);
22.        
23.         printf( "3. AT+CWDHCP\r\n");
24.         while(ESP8266_SendCmd("AT+CWDHCP=1,1\r\n", "OK"))
25.                 HAL_Delay(500);
26.        
27.         printf("4. CWJAP\r\n");
28.         while(ESP8266_SendCmd(ESP8266_WIFI_INFO, "GOT IP"))
29.                 HAL_Delay(500);
30.        
31.         printf( "5. CIPSTART\r\n");
32. //        while(ESP8266_SendCmd(ESP8266_ONENET_INFO, "CONNECT"))
33. //                HAL_Delay(500);
34.        
35.         printf( "6. ESP8266 Init OK\r\n");
37. }

复制代码

2.界说WIFI名称和密码：

1. #define   ESP8266_WIFI_INFO                "AT+CWJAP="名称","密码"\r\n"

复制代码

3.连接WIFI:

1. uint8_t atk_mw8266d_join_ap(char *ssid, char *pwd)
2. {
3.     uint8_t ret;
4.     char cmd[64];
5.    
6.     sprintf(cmd, "AT+CWJAP="%s","%s"", ssid, pwd);
7.     ret = atk_mw8266d_send_at_cmd(cmd, "WIFI GOT IP", 10000);
8.     if (ret == ATK_MW8266D_EOK)
9.     {
10.         return ATK_MW8266D_EOK;
11.     }
12.     else
13.     {
14.         return ATK_MW8266D_ERROR;
15.     }
16. }

复制代码

4.MQTT服务配置和连接：

1. const char* ClintID="";//连接ID
2. const char* username="";//连接的用户名
3. const char* passwd="";//连接的密码
4. const char* Url="";//连接的地址
5. const char* pubtopic="";//订阅的位置
6. const char* subtopic="";//发布的位置
8. uint8_t atk_mw8266d_mqtt_user(void)//mqtt_user配置
9. {                char cmd[200];
10.     uint8_t ret;
11.           
12.     sprintf(cmd, "AT+MQTTUSERCFG=0,1,"%s","%s","%s",0,0,""\r\n",ClintID,username,passwd);
13.     ret = atk_mw8266d_send_at_cmd(cmd,"OK", 500);
14.     if (ret == ATK_MW8266D_EOK)
15.     {
16.         delay_ms(1000);
17.         return ATK_MW8266D_EOK;
18.     }
19.     else
20.     {
21.         return ATK_MW8266D_ERROR;
22.     }
23. }
25. uint8_t atk_mw8266d_mqtt_CONN(void)//mqtt连接
26. {                char cmd[200];
27.     uint8_t ret;
28.                
29.     sprintf(cmd, "AT+MQTTCONN=0,"%s",端口号,1\r\n",Url);
30.     ret = atk_mw8266d_send_at_cmd(cmd,"OK", 500);
31.     if (ret == ATK_MW8266D_EOK)
32.     {
33.         delay_ms(1000);
34.         return ATK_MW8266D_EOK;
35.     }
36.     else
37.     {
38.         return ATK_MW8266D_ERROR;
39.     }
40. }

复制代码

5.订阅消息:

1. uint8_t atk_mw8266d_mqtt_SUB(void)//mqtt订阅
2. {                char cmd[200];
3.     uint8_t ret;
4.     sprintf(cmd, "AT+MQTTSUB=0,"%s",1\r\n",subtopic);
5.     ret = atk_mw8266d_send_at_cmd(cmd,"OK", 500);
6.     if (ret == ATK_MW8266D_EOK)
7.     {
8.         delay_ms(1000);
9.         return ATK_MW8266D_EOK;
10.     }
11.     else
12.     {
13.         return ATK_MW8266D_ERROR;
14.     }
15. }

复制代码

6.发布消息(发布的消息布局利用的是JSON)：

1. const char* func1="recycle";
2. uint8_t re_atk_mw8266d_mqtt_pub(void)//mqtt发布
3. {                char cmd[500];
4.     uint8_t ret;
5.                 func2=temp;//
6.     sprintf(cmd, "AT+MQTTPUB=0,"%s","{\\"%s\\":%d\\}",0,0\r\n",pubtopic,func1,100-(func2/20));
7.     ret = atk_mw8266d_send_at_cmd(cmd,"OK", 500);
8.     if (ret == ATK_MW8266D_EOK)
9.     {
10.         delay_ms(1000);
11.         return ATK_MW8266D_EOK;
12.     }
13.     else
14.     {
15.         return ATK_MW8266D_ERROR;
16.     }
17.         }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。