设为首页收藏本站
开启辅助访问 切换到宽版

 找回密码
 立即注册

QQ登录

只需一步，快速开始

热门： 51单片机 | 24小时必答区 | 单片机教程 | 单片机DIY制作 | STM32 | Cortex M3 | 模数电子 | 电子DIY制作 | 音响/功放 | 拆机乐园 | Arduino | 嵌入式OS | 程序设计

搜索
»论坛 › 嵌入式/单片机论坛 › STM32/8 › STM32F103C8 ESP8266 MQTT TEST源程序
返回列表 发新帖
查看: 3597|回复: 2
收起左侧

STM32F103C8 ESP8266 MQTT TEST源程序

  [复制链接]
ID:585455 发表于 2019-9-2 17:04 | 显示全部楼层 |阅读模式
首先說明，本人非原創。
程式是上網找到的，
不能設定MQTT帳號密碼，
本人僅稍微修改後，
可以設定MQTT帳號密碼。
-------------------------
測試方法，
ESP01 接USART2
TXD    ---  PA3/USART2_RX
RXD    ---  PA2/USART2_TX

RST    ---  PA0
EN     ---  PA1

VCC    ---  3.3V
GND    ---  GND

--------------------------
USART1 外接Realterm 或任何能調試com之軟件
TXD    ---  PA9/USART2_RX
RXD    ---  PA10/USART2_TX
MQTT.png

--------------------------
從USART1串口調試 發送help 可以看一些輸入方式
例如加入AP 請發送ssid=xxxx&pwd=xxxx
--------------------------
broker 伺服器需設定
ESP_StartMux(TCP,(char *)"192.xxx.xxx.xxx",1883,300)

MQTT帳號密碼在此設定
mqtt_connect_message(mqtt_msg,"123456","username","password")

MQTT連接成功後
手機下載MQTT免費appㄧ可測式
(我就是用MQTT Terminal測式)

appadvice点com/game/app/mqtt-terminal/1404331673

MQTT Terminal.png
----main.c----------------
  1. #include "bsp.h"
  2. #include "timer.h"
  3. #include "usart.h"
  4. #include "led.h"
  5. #include "esp8266.h"
  6. #include "connect.h"
  7. #include "md5.h"
  8. #include "MQTTPacket.h"

  10. u8 mqtt_msg[200]={0};
  11. u16 len;
  12. u8 *my_strstr(const u8 *s1,u16 n1,const u8 *s2,u16 n2);
  13.         
  14. void USART1_RecvData(void);

  16. unsigned char GetDataFixedHead(unsigned char MesType,unsigned char DupFlag,unsigned char QosLevel,unsigned char Retain)
  17. {
  18.         unsigned char dat = 0;
  19.         dat = (MesType & 0x0f) << 4;
  20.         dat |= (DupFlag & 0x01) << 3;
  21.         dat |= (QosLevel & 0x03) << 1;
  22.         dat |= (Retain & 0x01);
  23.         return dat;
  24. }


  27. u16 mqtt_connect_message(u8 *mqtt_message,char *client_id,char *username,char *password)
  28. {
  29.         u16 client_id_length = strlen(client_id);
  30.         u16 username_length = strlen(username);
  31.         u16 password_length = strlen(password);
  32.         u16 packetLen;
  33.         u16 i,baseIndex;
  34.         
  35.         packetLen = 12 + 2 + client_id_length;
  36.         if(username_length > 0)
  37.                 packetLen = packetLen + 2 + username_length;
  38.         if(password_length > 0)
  39.                 packetLen = packetLen+ 2 + password_length;
  40.         
  41.         mqtt_message[0] = GetDataFixedHead(1,0,0,0);                                //MQTT Message Type CONNECT
  42.         mqtt_message[1] = packetLen - 2;        
  43.         baseIndex = 2;
  44.         if(packetLen > 127)
  45.         {
  46.                 mqtt_message[2] = 1;                        //packetLen/127;   
  47.                 baseIndex = 3;
  48.         }
  49.         mqtt_message[baseIndex++] = 0;                // Protocol Name Length MSB   
  50.         mqtt_message[baseIndex++] = 4;                // Protocol Name Length LSB   
  51.         mqtt_message[baseIndex++] = 77;                // ASCII Code for M   
  52.         mqtt_message[baseIndex++] = 81;                // ASCII Code for Q   
  53.         mqtt_message[baseIndex++] = 84;                // ASCII Code for T   
  54.         mqtt_message[baseIndex++] = 84;                // ASCII Code for T   
  55.         mqtt_message[baseIndex++] = 4;                // MQTT Protocol version = 4   
  56.         mqtt_message[baseIndex++] = 0 | (0 << 1) | (0 << 1) | (0 << 3) | (0 << 5) | (1 << 6) |(1 << 7);                // conn flags
  57.         mqtt_message[baseIndex++] = 0;                // Keep-alive Time Length MSB   
  58.         mqtt_message[baseIndex++] = 60;                // Keep-alive Time Length LSB   
  59.         mqtt_message[baseIndex++] = (0xff00&client_id_length)>>8;// Client ID length MSB   
  60.         mqtt_message[baseIndex++] = 0xff&client_id_length;        // Client ID length LSB   
  61.         
  62.         // Client ID
  63.         for(i = 0; i < client_id_length; i++)
  64.         {
  65.                 mqtt_message[baseIndex + i] = client_id[i];   
  66.         }
  67.         baseIndex = baseIndex+client_id_length;
  68.                
  69.         if(username_length > 0)
  70.         {
  71.                 //username   
  72.                 mqtt_message[baseIndex++] = (0xff00&username_length)>>8;//username length MSB   
  73.                 mqtt_message[baseIndex++] = 0xff&username_length;        //username length LSB   
  74.                 for(i = 0; i < username_length ; i++)
  75.                 {
  76.                         mqtt_message[baseIndex + i] = username[i];   
  77.                 }
  78.                 baseIndex = baseIndex + username_length;
  79.         }
  80.                
  81.         if(password_length > 0)
  82.         {
  83.                 //password   
  84.                 mqtt_message[baseIndex++] = (0xff00&password_length)>>8;//password length MSB   
  85.                 mqtt_message[baseIndex++] = 0xff&password_length;        //password length LSB   
  86.                 for(i = 0; i < password_length ; i++)
  87.                 {
  88.                         mqtt_message[baseIndex + i] = password[i];   
  89.                 }
  90.                 baseIndex += password_length;
  91.         }        
  92.         
  93.         return baseIndex;   
  94. }

  96. //MQTT Publish
  97. u16 mqtt_publish_message(u8 *mqtt_message, char * topic, char * message, u8 qos)
  98. {  
  99.         u16 topic_length = strlen(topic);   
  100.         u16 message_length = strlen(message);  
  101.         u16 i,index=0;        
  102.         static u16 id=0;
  103.         
  104.         mqtt_message[index++] = 48;        //0x30 // MQTT Message Type PUBLISH   
  105.         if(qos)
  106.                 mqtt_message[index++] = 2 + topic_length + 2 + message_length;
  107.         else
  108.                 mqtt_message[index++] = 2 + topic_length + message_length;   // Remaining length   
  109.         mqtt_message[index++] = (0xff00&topic_length)>>8;
  110.         mqtt_message[index++] = 0xff&topic_length;
  111.                
  112.         // Topic   
  113.         for(i = 0; i < topic_length; i++)
  114.         {
  115.                 mqtt_message[index + i] = topic[i];
  116.         }
  117.         index += topic_length;
  118.                
  119.         if(qos)
  120.         {
  121.                 mqtt_message[index++] = (0xff00&id)>>8;
  122.                 mqtt_message[index++] = 0xff&id;
  123.                 id++;
  124.         }
  125.         
  126.         // Message
  127.         for(i = 0; i < message_length; i++)
  128.         {
  129.                 mqtt_message[index + i] = message[i];
  130.         }
  131.         index += message_length;
  132.                
  133.         return index;
  134.         
  135.         
  136. }


  139. u8 mqtt_puback_message(u8 *mqtt_message)
  140. {
  141.         static u16 id=0;
  142.         
  143.         mqtt_message[0] = 64;                                //0x40 //PUBACK
  144.         mqtt_message[1] = 2;
  145.         mqtt_message[2] = (0xff00&id)>>8;
  146.         mqtt_message[3] = 0xff&id;
  147.         id++;
  148.         
  149.         return 4;
  150. }


  153. u16 mqtt_subscribe_message(u8 *mqtt_message,char *topic,u8 qos,u8 whether)
  154. {
  155.         u16 topic_len = strlen(topic);
  156.         u16 i,index = 0;
  157.         static u16 id=0;
  158.         
  159.         id++;
  160.         if(whether)
  161.         {mqtt_message[index++] = 0x82;}                                //0x82 SUBSCRIBE
  162.         else
  163.         {mqtt_message[index++] = 162;        }                        //0xA2
  164.         mqtt_message[index++] = topic_len + 5;
  165.         mqtt_message[index++] = (0xff00&id)>>8;
  166.         mqtt_message[index++] = 0xff&id;
  167.         mqtt_message[index++] = (0xff00&topic_len)>>8;
  168.         mqtt_message[index++] = 0xff&topic_len;
  169.         
  170.         for (i = 0;i < topic_len; i++)
  171.         {
  172.                 mqtt_message[index + i] = topic[i];
  173.         }
  174.         index += topic_len;
  175.         
  176.         if(whether)
  177.         {
  178.                 mqtt_message[index] = qos;//QoS
  179.                 index++;
  180.         }
  181.         
  182.         return index;
  183.         
  184. }


  187. //MQTT PING
  188. u8 mqtt_ping_message(u8 *mqtt_message)
  189. {
  190.         mqtt_message[0] = 192;        //0xC0 PING
  191.         mqtt_message[1] = 0;
  192.         
  193.         return 2;
  194. }

  196. u8 mqtt_disconnect_message(u8 *mqtt_message)
  197. {
  198.         mqtt_message[0] = 224;        //0xE0 DISCONNECT
  199.         mqtt_message[1] = 0;
  200.         
  201.         return 2;
  202. }

  204. int main(void)
  205. {
  206.         u16 len;
  207.         u8 state=0,link=0;
  208.         BspInit();
  209.         printf("\r\ninitialize finish\r\n\r\n");
  210.          while(1)
  211.         {
  212.                 if(esp8266.state==254)//ESP8266
  213.                 {
  214.                         switch(state)
  215.                         {        
  216.                                 case 0:
  217.                                         if(ESP_StartMux(TCP,(char *)"xxx.xxx.xxx.xxx",1883,300))
  218.                                         {
  219.                                                 link=1;
  220.                                                 Delay10Ms(100);//1000ms
  221.                                                 //MQTT Connect
  222.                                                 len=mqtt_connect_message(mqtt_msg,"123456","","");//id=123456,username,password
  223.                                                 //for(i=0;i<len;i++)
  224.                                                 //{
  225.                                                 //        printf("%02X ",mqtt_msg[i]);
  226.                                                 //}
  227.                                                 if(ESP_SendTcpUdp(mqtt_msg,len,200))
  228.                                                 {
  229.                                                         
  230.                                                         printf("\r\nMQTT_Connect ...\r\n");
  231.                                                         Delay10Ms(100);//1000ms                                                
  232.                                                         //MQTT subscribe
  233.                                                         len=mqtt_subscribe_message(mqtt_msg,"test",1,1);//SUB Topic Qos1 1:ó†é†
  234.                                                         //PrintHex(mqtt_msg,len);
  235.                                                         if(ESP_SendTcpUdp(mqtt_msg,len,200))
  236.                                                         {
  237.                                                                 state=1;
  238.                                                                 printf("\r\nMQTT_Subscribe ...\r\n");
  239.                                                         }
  240.                                                 }
  241.                                                 
  242.                                         }
  243.                                         Delay10Ms(500);//5000ms
  244.                                 break;
  245.                                 case 1:
  246.                                         if(IS_TIMEOUT_10MS(eTim4, 6000))//60000ms
  247.                                         {
  248.                                                 if(link)
  249.                                                 {
  250.                                                         u8 ping[2];                                                
  251.                                                         ping[0]=0xc0;
  252.                                                         ping[1]=0x00;
  253.                                                         if(ESP_SendTcpUdp(ping,2,200))//PINGREQ
  254.                                                         {
  255.                                                                 printf("\r\nMQTT_Ping ...\r\n");
  256.                                                         }
  257.                                                         
  258.                                                         else
  259.                                                         {
  260.                                                                 link=0;
  261.                                                                 state=0;
  262.                                                                 printf("\r\nMQTT_Ping Fail\r\n");
  263.                                                         }
  264.                                                 }
  265.                                         }
  266.                                         break;
  267.                         }
  268.                         if(ESP_Recv_Len>0)
  269.                         {
  270.                                 char* position=NULL;
  271.                                 u8 data_len;
  272.                                 
  273.                                 printf("ESP_Recv=%s\r\n",ESP_Recv_Buff);
  274.                                 //PrintHex(ESP_Recv_Buff,ESP_Recv_Len);
  275.                                 ESP_Recv_Len=0;
  276.                                 if(strstr((char *)ESP_Recv_Buff,"CLOSED"))
  277.                                 {
  278.                                         link=0;
  279.                                         state=0;
  280.                                 }
  281.                                 
  282.                                 position=strstr((char *)ESP_Recv_Buff,"+IPD");
  283.                                 data_len=GetValue(position,",");
  284.                                 if(data_len>0)
  285.                                 {
  286.                                         printf("Recv_Data_Len=%d\r\n",data_len);
  287.                                         position=strstr((char *)ESP_Recv_Buff,":");
  288.                                         if(position!=0)
  289.                                         {
  290.                                                 memcpy(mqtt_msg,position+1,data_len);
  291.                                         }
  292.                                         //PrintHex(mqtt_msg,data_len);
  293.                                         if(mqtt_msg[0]==50||mqtt_msg[0]==58)
  294.                                         {
  295.                                                 /*
  296.                                                 if(strstr((char *)mqtt_msg,"ON"))
  297.                                                 {
  298.                                                         CONTROL_LED=1;
  299.                                                         printf("CONTROL_LED=ON\r\n");
  300.                                                 }
  301.                                                 */
  302.                                                 if(my_strstr(mqtt_msg,data_len,(u8 *)"ON",2))
  303.                                                 {
  304.                                                         CONTROL_LED=1;
  305.                                                         printf("CONTROL_LED=ON\r\n");
  306.                                                 }
  307.                                                 else
  308.                                                 {
  309.                                                         printf("Not Found ON\r\n");
  310.                                                 }
  311.                                                 if(my_strstr(mqtt_msg,data_len,(u8 *)"OFF",3))
  312.                                                 {
  313.                                                         CONTROL_LED=0;
  314.                                                         printf("CONTROL_LED=OFF\r\n");
  315.                                                 }
  316.                                                 else
  317.                                                 {
  318.                                                         printf("Not Found OFF\r\n");
  319.                                                 }

  321.                                                 len=mqtt_puback_message(mqtt_msg);
  322.                                                 //PrintHex(mqtt_msg,len);
  323.                                                 if(ESP_SendTcpUdp(mqtt_msg,len,200))
  324.                                                 {
  325.                                                         printf("\r\nMQTT_PUBACK ...\r\n");
  326.                                                 }
  327.                                         }
  328.                                         //PrintHex(mqtt_msg,data_len);
  329.                                 }
  330.                                 
  331.                         }
  332.                 }
  333.                 //ESP_RecvData();
  334.                 ESP_Connect();
  335.                 Idle();
  336.         }         
  337. }

  339. void USART1_RecvData(void)
  340. {
  341.         if(USART1_Recv_Flag)
  342.         {
  343.                 u16 value;
  344.                 u8 buf[PAYLOAD_DATA_LEN]={0};
  345.         
  346.                 USART1_Recv_Flag=0;
  347.                 value=GetValue((char *)USART1_Recv_Buff," ");
  348.                 CopyString((char *)buf,(char *)USART1_Recv_Buff," ");
  349.                 printf("buffer=%s value=%d\r\n",buf,value);
  350.                 if(strstr((char *)buf,"help"))
  351.                 {
  352.                         printf("\r\n========== Help Menu ==========\r\n\r\n");
  353.                         printf("var? (variable)\r\n");
  354.                         printf("rst-h (esp8266 hard reset)\r\n");
  355.                         printf("rst-s (esp8266 soft reset)\r\n");
  356.                         printf("state val (esp8266 state)\r\n");
  357.                         printf("ssid=xxx&pwd=xxx (set ssid or pwd)\r\n");
  358.                         printf("\r\n===============================\r\n");
  359.                 }
  360.                 else if(strstr((char *)USART1_Recv_Buff,"BubbleSort"))
  361.                 {
  362.                         u8 arr[5] = { 1,2,3,4,5 };
  363.                         u8 i;
  364.                         printf("\r\nFirst:\r\n");
  365.                         for(i = 0; i < 5; i++)  
  366.                         {  
  367.                                 printf("%d",arr[i]);  
  368.                         }  

  370.                         BubbleSort(arr, 5);//
  371.                         printf("\r\nBubble:\r\n");

  373.                         for(i = 0; i < 5; i++)  
  374.                         {  
  375.                                 printf("%d",arr[i]);  
  376.                         }
  377.                 }
  378.                 else if(strstr((char *)USART1_Recv_Buff,"MY-STRSTR"))
  379.                 {
  380.                         u8 *p=my_strstr(buf,strlen((char *)buf),(u8 *)"ON",2);
  381.                         if(p)
  382.                         {
  383.                                 printf("my_strstr=%s\r\n",p);
  384.                         }
  385.                         else
  386.                         {
  387.                                 printf("Not Found ON\r\n");
  388.                         }
  389.                 }
  390.                 else if(strstr((char *)USART1_Recv_Buff,"LINK"))
  391.                 {
  392.                         ESP_StartMux(TCP,(char *)"xxx.xxx.xxx.xxx",1883,300);
  393.                 }
  394.                 else if(strstr((char *)USART1_Recv_Buff,"COMM"))
  395.                 {
  396.                         len=mqtt_connect_message(mqtt_msg,"123456","","");
  397.                         PrintHex(mqtt_msg,len);
  398.                         if(ESP_SendTcpUdp(mqtt_msg,len,200))
  399.                         {
  400.                                 printf("\r\nMQTT_Connect ...\r\n");
  401.                         }
  402.                 }
  403.                 else if(strstr((char *)USART1_Recv_Buff,"PING"))
  404.                 {
  405.                         u8 ping[2];
  406.                                                 
  407.                         ping[0]=0xc0;
  408.                         ping[1]=0x00;
  409.                         if(ESP_SendTcpUdp(ping,2,200))
  410.                         {
  411.                                 printf("\r\nMQTT_Ping ...\r\n");
  412.                         }
  413.                 }
  414.                 else if(strstr((char *)USART1_Recv_Buff,"PUB"))
  415.                 {
  416.                         MQTTString topicString = MQTTString_initializer;
  417.         
  418.                         topicString.cstring = "test1";
  419.                         len = MQTTSerialize_publish(mqtt_msg, 200, 0, 0, 0, 0, topicString, (u8 *)"123456", 6); /* 2 */

  421.                         //len=mqtt_publish_message(mqtt_msg, "TEST", "OFF");
  422.                         PrintHex(mqtt_msg,len);
  423.                         if(ESP_SendTcpUdp(mqtt_msg,len,200))
  424.                         {
  425.                                 printf("\r\nMQTT_Publish ...\r\n");
  426.                         }
  427.                 }
  428.                 else if(strstr((char *)USART1_Recv_Buff,"SUB"))
  429.                 {
  430.                         len=mqtt_subscribe_message(mqtt_msg,"$DATETIME/",0,1);
  431.                         PrintHex(mqtt_msg,len);
  432.                         if(ESP_SendTcpUdp(mqtt_msg,len,200))
  433.                         {
  434.                                 printf("\r\nMQTT_Subscribe ...\r\n");
  435.                         }
  436.                 }
  437.                 else if(strstr((char *)USART1_Recv_Buff,"MD5-TEST"))
  438.                 {
  439.                         unsigned char dst[16];

  441.                         MD5_String(dst,(char *)buf);
  442.                         PrintHex((u8 *)dst,sizeof(dst));
  443.                 }

  445.                 else if(strstr((char *)USART1_Recv_Buff,"ssid"))
  446.                 {
  447.                         char *srcstr=USART1_Recv_Buff;
  448.                         char *ssid=(char *)Store_Data.ssid;
  449.                         char *pwd=(char *)Store_Data.pwd;
  450.                         u8 ssid_len=0,pwd_len=0;

  452.                         printf("ssid_len=%d\r\n",sizeof(Store_Data.ssid));
  453.                         printf("pwd_len=%d\r\n",sizeof(Store_Data.pwd));
  454.                         while(1)
  455.                         {                                                                                   
  456.                                 if(*srcstr=='=')
  457.                                 {
  458.                                         break;
  459.                                 }
  460.                                 if(*srcstr=='\0'||*srcstr=='\r'||*srcstr=='\n')
  461.                                 {
  462.                                         printf("ERROR\r\n");
  463.                                         return;
  464.                                 }
  465.                                 srcstr++;
  466.                         }
  467.                         srcstr++;
  468.                         while(1)
  469.                         {                                                                                   
  470.                                 if(*srcstr=='&')
  471.                                 {
  472.                                         *ssid='\0';
  473.                                         break;
  474.                                 }
  475.                                 if(*srcstr=='\0'||*srcstr=='\r'||*srcstr=='\n'||ssid_len>=sizeof(Store_Data.ssid))
  476.                                 {
  477.                                         printf("ERROR\r\n");
  478.                                         return;
  479.                                 }
  480.                                 *ssid=*srcstr;
  481.                                 srcstr++;
  482.                                 ssid++;
  483.                                 ssid_len++;
  484.                         }
  485.                         while(1)
  486.                         {                                                                                   
  487.                                 if(*srcstr=='=')
  488.                                 {
  489.                                         break;
  490.                                 }
  491.                                 if(*srcstr=='\0'||*srcstr=='\r'||*srcstr=='\n')
  492.                                 {
  493.                                         printf("ERROR\r\n");
  494.                                         return;
  495.                                 }
  496.                                 srcstr++;
  497.                         }
  498.                         srcstr++;
  499.                         MemSet((BYTE *)&Store_Data.pwd,0,sizeof(Store_Data.pwd));
  500.                         while(1)
  501.                         {                                                                                   
  502.                                 if(*srcstr=='\0'||*srcstr=='\r'||*srcstr=='\n'||pwd_len>=sizeof(Store_Data.pwd))
  503.                                 {
  504.                                         *pwd='\0';
  505.                                         break;
  506.                                 }
  507.                                 *pwd=*srcstr;
  508.                                 srcstr++;
  509.                                 pwd++;
  510.                                 pwd_len++;
  511.                         }
  512.                         if(pwd_len<8)
  513.                         {
  514.                                 u8 i;
  515.                                 
  516.                                 for(i=pwd_len;i<8;i++)
  517.                                 {
  518.                                         *pwd='*';
  519.                                         pwd++;
  520.                                 }
  521.                         }
  522.                         printf("ssid=%s\r\npwd=%s\r\n",Store_Data.ssid,Store_Data.pwd);
  523.                 }
  524.                 else if(strstr((char *)USART1_Recv_Buff,"apiKey"))
  525.                 {
  526.                         char *srcstr=USART1_Recv_Buff;
  527.                         char *apiKey=(char *)Store_Data.apiKey;
  528.                         u8 key_len=0;

  530.                         while(1)
  531.                         {                                                                                   
  532.                                 if(*srcstr=='=')
  533.                                 {
  534.                                         break;
  535.                                 }
  536.                                 if(*srcstr=='\0'||*srcstr=='\r'||*srcstr=='\n')
  537.                                 {
  538.                                         printf("ERROR\r\n");
  539.                                         return;
  540.                                 }
  541.                                 srcstr++;
  542.                         }
  543.                         srcstr++;
  544.                         while(1)
  545.                         {                                                                                   
  546.                                 if(*srcstr=='\0'||*srcstr=='\r'||*srcstr=='\n'||key_len>=16)
  547.                                 {
  548.                                         *apiKey='\0';
  549.                                         break;
  550.                                 }
  551.                                 *apiKey=*srcstr;
  552.                                 srcstr++;
  553.                                 apiKey++;
  554.                                 key_len++;
  555.                         }
  556.                         if(key_len<16)
  557.                         {
  558.                                 u8 i;
  559.                                 
  560.                                 for(i=key_len;i<16;i++)
  561.                                 {
  562.                                         *apiKey='*';
  563.                                         apiKey++;
  564.                                 }
  565.                         }
  566.                         printf("apiKey=%s\r\n",Store_Data.apiKey);
  567.                 }
  568.                 else if(strstr((char *)USART1_Recv_Buff,"server"))
  569.                 {
  570.                         char *srcstr=USART1_Recv_Buff;
  571.                         char *server=(char *)Store_Data.server;
  572.                         u8 server_len=0;

  574.                         while(1)
  575.                         {                                                                                   
  576.                                 if(*srcstr=='=')
  577.                                 {
  578.                                         break;
  579.                                 }
  580.                                 if(*srcstr=='\0'||*srcstr=='\r'||*srcstr=='\n')
  581.                                 {
  582.                                         printf("ERROR\r\n");
  583.                                         return;
  584.                                 }
  585.                                 srcstr++;
  586.                         }
  587.                         srcstr++;
  588.                         while(1)
  589.                         {
  590.                                 if(*srcstr=='\0'||*srcstr=='\r'||*srcstr=='\n'||server_len>=sizeof(Store_Data.server))
  591.                                 {
  592.                                         *server='\0';
  593.                                         break;
  594.                                 }
  595.                                 *server=*srcstr;
  596.                                 srcstr++;
  597.                                 server++;
  598.                                 server_len++;
  599.                         }
  600.                         printf("server=%s\r\n",Store_Data.server);
  601.                 }
  602.                 else if(strstr((char *)buf,"rst-h"))
  603.                 {
  604.                         ESP_HardReset();
  605.                 }
  606.                 else if(strstr((char *)buf,"rst-s"))
  607.                 {
  608.                         ESP_SoftReset();
  609.                 }
  610.                 else if(strstr((char *)buf,"state"))
  611.                 {
  612.                         esp8266.state=GetValue(USART1_Recv_Buff," ");
  613.                 }
  614.                 else if(strstr((char *)buf,"port"))
  615.                 {
  616.                         esp8266.port=GetValue(USART1_Recv_Buff," ");
  617.                 }
  618.                 else if(strstr((char *)buf,"mode"))
  619.                 {
  620.                         esp8266.mode=GetValue(USART1_Recv_Buff," ");
  621.                         if(esp8266.mode)
  622.                         {
  623.                                 if(ESP_StartServer(esp8266.port))
  624.                                 {
  625.                                         esp8266.login=FALSE;
  626.                                         esp8266.connect=FALSE;
  627.                                         esp8266.bind=FALSE;
  628.                                         esp8266.state=SERVER;
  629.                                         esp8266.ser_time=Get_RunTime();
  630.                                         SetLed(0xff,100,100);
  631.                                 }
  632.                         }
  633.                         if(!esp8266.mode)
  634.                         {
  635.                                 if(ESP_CloseServer())
  636.                                 {
  637.                                         esp8266.mode=ESP_CLIENT;
  638.                                         if(!esp8266.login)
  639.                                                 esp8266.state=WAIT_LOGIN;
  640.                                         else if(!esp8266.connect||!esp8266.bind)
  641.                                                 esp8266.state=SATRT_CONNECT;
  642.                                         else
  643.                                         {
  644.                                                 esp8266.state=LIVE;
  645.                                                 SetLed(0xff,10,500);
  646.                                         }
  647.                                 }
  648.                         }
  649.                 }

  651.                 else if(strstr((char *)buf,"add_routr_table"))
  652.                 {
  653.                         Payload tmp;
  654.                         u8 i,k,n;
  655.                         
  656.                         n=value;
  657.                         for(k=0; k<10; k++)//
  658.                         {
  659.                                 value=n;
  660.                                 MemSet((BYTE *)&tmp,0,sizeof(Payload));
  661.                                 tmp.header.the_addr=value+k;
  662.                                 tmp.header.hop_addr=(value+20)+k;
  663.                                 for(i=0; i<k; i++)
  664.                                 {
  665.                                         tmp.buf[i]=(value+10)+i;
  666.                                 }
  667.                         }
  668.                 }
  669.                 else if(strstr((char *)buf,"var?"))
  670.                 {
  671.                         printf("\r\n=========variable=========\r\n\r\n");
  672.                         printf("apiKey=%s\r\nserver=%s\r\n",Store_Data.apiKey,Store_Data.server);
  673.                         printf("ssid=%s\r\npwd=%s\r\n",Store_Data.ssid,Store_Data.pwd);
  674.                         printf("esp8266_state=%d\r\n",esp8266.state);
  675.                         printf("esp8266_mode=%d\r\n",esp8266.mode);
  676.                         printf("connect_port=%d\r\n",esp8266.port);
  677.                         printf("Run Day:%d Time:%02d:%02d:%02d\r\n",
  678.                                         run_time.date,run_time.hour,run_time.min,run_time.sec);
  679.                         printf("\r\n==========================\r\n");
  680.                 }

  682.                 else
  683.                 {
  684.                         ESP_SendString((u8 *)USART1_Recv_Buff,USART1_ReceDatalen);
  685.                 }
  686.         }
  687. }


  690. u8 *my_strstr(const u8 *s1,u16 n1,const u8 *s2,u16 n2)  
  691. {  
  692.     int n,x=0,y=0;  
  693.     if (*s2)         
  694.     {
  695.         while(1)                 
  696.         {
  697.                         if(*s1==*s2)
  698.                         {
  699.                                 for (n=0;n<n2;n++)  
  700.                                 {
  701.                                         if (*(s1+n)==*(s2+n))
  702.                                         {
  703.                                                 y++;
  704.                                                 if (y>=n2)
  705.                                                 //if (!*(s2+n+1))
  706.                                                 {  
  707.                                                         return (u8 *)s1;  
  708.                                                 }
  709.                                                 if (x+n>=n1-1)
  710.                                                 {  
  711.                                                         return NULL;  
  712.                                                 }
  713.                                                 if (*(s1+n+1)!=*(s2+n+1))
  714.                                                 {
  715.                                                         break;
  716.                                                 }
  717.                                         }
  718.                                         else
  719.                                         {  
  720.                                                 break;
  721.                                         }
  722.                                 }  
  723.                         }
  724.                         s1++;
  725.                         x++;
  726.                         if(x>=n1)
  727.                         {
  728.                                 break;
  729.                         }
  730.         }  
  731.         return NULL;  
  732.     }  
  733.     else  
  734.     {  
  735.         return (u8*)s1;  
  736.     }  
  737. }

复制代码

----------------------------
以下程式碼壓縮後打包上傳。

全部资料51hei下载地址：
stm32_mqtt_test.7z (252.57 KB, 下载次数: 121)

评分

参与人数 2黑币 +62 收起 理由
muzhi + 12 很给力！
admin + 50 共享资料的黑币奖励！

查看全部评分

回复

使用道具 举报

ID:376018 发表于 2020-2-22 08:28 | 显示全部楼层
谢谢分享，正好要用上
回复

使用道具 举报

ID:881442 发表于 2021-3-9 16:50 | 显示全部楼层
謝謝分享,最近有需求,先載來測試看看
回复

使用道具 举报

返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

手机版|小黑屋|51黑电子论坛 |51黑电子论坛6群 QQ 管理员QQ:125739409;技术交流QQ群281945664

Powered by 单片机教程网

快速回复 返回顶部 返回列表