標(biāo)題: 基于STM32單片機(jī)SIM800C的MQTT實(shí)現(xiàn)源碼 [打印本頁]
作者: hg1234    時(shí)間: 2023-11-16 11:02
標(biāo)題: 基于STM32單片機(jī)SIM800C的MQTT實(shí)現(xiàn)源碼
  1. #include "./sys/sys.h"
  2. #include "./delay/delay.h"
  3. #include "./usart/usart.h"
  4. #include "./LED/led.h"                           
  5. #include "./LCD/lcd.h"  
  6. #include "./KEY/key.h"  
  7. #include "./RTC/rtc.h"
  8. //#include "./RTC/bsp_rtc.h"
  9. #include "./BEEP/beep.h"
  10. #include "usmart.h"
  11. #include "malloc.h"
  12. #include "./SDIO/sdio_sdcard.h"  
  13. #include "./W25QXX/w25qxx.h"   
  14. #include "./src/ff.h"  
  15. #include "./exfuns/exfuns.h"   
  16. #include "text.h"       
  17. #include "piclib.h"
  18. #include "./TOUCH/touch.h"        
  19. #include "./USART2/usart2.h"
  20. #include "./USART3/usart3.h"
  21. #include "./MPU6050/mpu6050.h"
  22. #include "sim800c.h"
  23. #include "./gps.h"
  24. #include "./OV7670/ov7670.h"
  25. #include "./NRF24L01/24l01.h"
  26. #include "./TIMER/timer.h"                         
  27. //#include "./OV7670/sccb.h"       
  28. #include "./OV2640/ov2640.h"
  29. #include "MQTTPacket.h"
  30. #include "StackTrace.h"
  31. #include "inv_mpu.h"
  32. #include "inv_mpu_dmp_motion_driver.h"

  34. #include "./T9INPUT/t9input.h"
  35. #include "stdarg.h"
  36. #include <string.h>
  37. #include <stdio.h>  
  38. #include <stdlib.h>

  40. /* 私有變量 ------------------------------------------------------------------*/
  41. FATFS mfs;                                                                                                        /* FatFs文件系統(tǒng)對(duì)象 */
  42. FIL mfile;                                                                                                        /* 文件對(duì)象 */
  43. FRESULT mf_res;                    /* 文件操作結(jié)果 */
  44. char mfpath[] = "0:TEXT";                  /* 保存當(dāng)前掃描路徑 */
  45. BYTE WriteBuffer[100] = "歡迎使用智能終端\r\n";
  46. UINT file_num;

  48. nmea_msg gpsx;                                                                                                                                                                                                        //GPS信息

  50. const u8 *port = (u8 *)"1883";                                                                                                                                        //端口固定為1883
  51. const u8 *ipaddr = (u8 *)"118.190.146.251";
  52. typedef struct
  53. {
  54.         float temp[3];
  55.         float humi[3];
  56.         float gps[3];
  57.         uint8_t door[4];
  58.         short mpu[6];
  59. }menu_message,*menu_message_;

  61. uint16_t screen_w = 800;                                                                                                                                                                //屏幕寬度
  62. uint16_t screen_h = 480;                                                                                                                                                                //屏幕高度
  63. uint8_t line_w = 3;                                                                                                                                                                                        //分界線寬
  64. uint8_t menu_num = 4;                                                                                                                                                                                //菜單組數(shù)
  65. uint8_t cur_menu_item,old_menu_item;                                                                                                                //當(dāng)前菜單

  67. uint8_t tmp_buf[33];                                                                                                                                                                                //NRF緩存

  69. u8 mqtt_msg[200]={0};                                                                                                                                                                                //MQTT消息包緩存
  70. u16 len;                                                                                                                                                                                                                                //消息包有效長度
  71. u8 gprs_tcp_flag;                                                                                                                                                                                                //TCP連接標(biāo)志
  72. u8 mqtt_data_flag;                                                                                                                                                                                        //MQTT消息類型標(biāo)志
  73. u8 send_data_flag;                                                                                                                                                                                        //發(fā)布消息標(biāo)志

  75. u8 temp_data[] = "##################------000000000000";                                //36字節(jié) MQTT消息內(nèi)容緩存
  76. u8 message_type;                                                                                                                                                                                //消息類型,區(qū)別TOPIC主題
  77. u8 about_text_size = 24;                                                                                                                                                                //關(guān)于字體大小
  78. u8* const Info_Show[13]=
  79.         {
  80.                 "溫度1","溫度2","溫度3",
  81.                 "濕度1","濕度2","濕度3",
  82.                 "GPS經(jīng)度","GPS緯度",
  83.                 "車門信息","陀螺儀狀態(tài)",
  84.                 "服務(wù)器IP","藍(lán)牙地址","閾值設(shè)置"
  85.         };

  87. menu_message menu_mess;
  88. //_t9_obj * t9in;                                                                                                                                                                                                //輸入法
  89. //私有函數(shù)聲明
  90. void sim800c_init(void);                                                                                                                                                                //SIM800C初始化

  92. void gprs_send_data(u8 * data,u8 lenth);                                                                                                        //GPRS發(fā)送數(shù)據(jù)
  93. u8 *my_strstr(const u8 *s1,u16 n1,const u8 *s2,u16 n2);                                                //字符串查找
  94. void Start_Gprs_TCP(void);                                                                                                                                                                //GPRS建立TCP連接
  95. void Stop_Gprs_Connect(void);                                                                                                                                                        //關(guān)閉GPRS連接
  96. void Gps_Msg_Show(void);                                                                                                                                                                        //顯示GPS定位信息
  97. void send_model_temp_humi(menu_message * mes,u8 * space,u8 type);        //MQTT發(fā)送內(nèi)容包裝

  99. int main(void)
  100. {
  101.         int sys_run_times=0;
  102.         unsigned char valtest=0;
  103.         u8 key,fontok=0;           

  105.         u8 *p1,*p2,*p3;
  106.         u8 hbeaterrcnt=0;                                                                                                                                //心跳錯(cuò)誤計(jì)數(shù)器,連續(xù)5次心跳信號(hào)無應(yīng)答,則重新連接
  107.        
  108. //        t9in = 0;
  109.         gprs_tcp_flag = 0;
  110.         mqtt_data_flag = 0;
  111.         send_data_flag = 0;
  112.         message_type = 0;

  114.         delay_init();                                                                                                                                                //延時(shí)函數(shù)初始化          
  115.   NVIC_PriorityGroupConfig(NVIC_PriorityGroup_2); //設(shè)置中斷優(yōu)先級(jí)分組為組2：2位搶占優(yōu)先級(jí)，2位響應(yīng)優(yōu)先級(jí)
  116.         uart_init(115200);                                                                                                                        //串口初始化為115200
  117.         usmart_dev.init(72);                                                                                                                //初始化USMART               
  118.        
  119.   GENERAL_TIMx_Configuration();                                                                                //通用定時(shí)器初始化：1ms中斷一次
  120.         LED_Init();                                                                                                                                                        //初始化與LED連接的硬件接口
  121.         KEY_Init();                                                                                                                                                        //初始化按鍵
  122.         LCD_Init();                                                                                                                                                        //初始化LCD  
  123.         BEEP_Init();                                                                                                                                                //蜂鳴器初始化
  124.         W25QXX_Init();                                                                                                                                        //初始化W25Q128
  125.         tp_dev.init();                                                                                                                                        //初始化觸摸屏
  126.         usart3_init(115200);                                                                                                                //初始化串口3
  127.         my_mem_init(SRAMIN);                                                                                                                //初始化內(nèi)部內(nèi)存池
  128.         exfuns_init();                                                                                                                                        //為fatfs相關(guān)變量申請(qǐng)內(nèi)存  
  129.         f_mount(fs[0],"0:",1);                                 //掛載SD卡
  130.         f_mount(fs[1],"1:",1);                                 //掛載FLASH.
  131.         key=KEY_Scan(0);  
  132.         if(key==KEY0_PRES&&((tp_dev.touchtype&0X80)==0))//強(qiáng)制校準(zhǔn)
  133.         {
  134.                 LCD_Clear(WHITE);                                                                                                                        //清屏0
  135.                 TP_Adjust();                                                                                                                                        //屏幕校準(zhǔn)
  136.                 TP_Save_Adjdata();          
  137.                 LCD_Clear(WHITE);                                                                                                                        //清屏
  138.         }
  139.         fontok=font_init();                                                                                                                        //檢查字庫是否OK
  140.         if(fontok||key==KEY1_PRES)                            //需要更新字庫                                 
  141.         {
  142.                 LCD_Clear(WHITE);                                                                                                                        //清屏
  143.                 POINT_COLOR=RED;                                                                                                                        //設(shè)置字體為紅色                                
  144.                 LCD_ShowString(60,50,200,16,16,(u8 *)"ALIENTEK STM32");
  145.                 while(SD_Init())                                                                                                                        //檢測(cè)SD卡
  146.                 {
  147.                         LCD_ShowString(60,70,200,16,16,(u8 *)"SD Card Failed!");
  148.                         delay_ms(200);
  149.                         LCD_Fill(60,70,200+60,70+16,WHITE);
  150.                         delay_ms(200);                    
  151.                 }
  152.                 LCD_ShowString(60,70,200,16,16,(u8 *)"SD Card OK");
  153.                 LCD_ShowString(60,90,200,16,16,(u8 *)"Font Updating...");
  154.                 key=update_font(20,110,16,(u8 *)"0:");                                //從SD卡更新
  155.                 while(key)                                                                                                                                                //更新失敗               
  156.                 {                                           
  157.                         LCD_ShowString(60,110,200,16,16,(u8 *)"Font Update Failed!");
  158.                         delay_ms(200);
  159.                         LCD_Fill(20,110,200+20,110+16,WHITE);
  160.                         delay_ms(200);                       
  161.                 }                   
  162.                 LCD_ShowString(60,110,200,16,16,(u8 *)"Font Update Success!");
  163.                 delay_ms(1500);       
  164.                 LCD_Clear(WHITE);                                                                                                                        //清屏               
  165.         }
  166.        
  167.         //RTC_CheckAndConfig(&systmtime);
  168.         RTC_Init();                                                                                                                                                        //RTC初始化
  169.         delay_ms(1000);
  170.         RTC_Get();
  171.         printf("time:%02d-%02d-%02d.%02d:%02d:%02d\r\n",calendar.w_year%100,calendar.w_month,calendar.w_date,calendar.hour,calendar.min,calendar.sec);
  172.        
  173.         init_gps();
  174.        
  175.         NRF24L01_Init();
  176.         while(NRF24L01_Check()){;}
  177.         NRF24L01_RX_Mode();
  178.        
  179.         LCD_Clear(BLACK);
  180.         key = 0;
  181.        
  182.         piclib_init();                                                                                                                                        //初始化畫圖
  183.        
  184.         //I2C初始化
  185.         i2c_CfgGpio();
  186.   //MPU6050初始化
  187.         MPU6050_Init();

  189.         //檢測(cè)MPU6050
  190. //        while(!MPU6050ReadID()){;}

  192.         while(sim800c_send_cmd((u8 *)"AT",(u8 *)"OK",100))//檢測(cè)是否應(yīng)答AT指令
  193.         {
  194.                 Show_Str(40,55,200,16,(u8 *)"未檢測(cè)到模塊!!!",16,0);
  195.                 delay_ms(800);
  196.                 Show_Str(40,55,200,16,(u8 *)"嘗試連接模塊...",16,0);
  197.                 delay_ms(400);  
  198.         }
  199.         printf("SIM800C Check OK\r\n");

  201.         p1=mymalloc(SRAMIN,100);                                                                                                //申請(qǐng)100字節(jié)內(nèi)存
  202.        
  203.         while(1)
  204.         {
  205.                 if(NRF24L01_RxPacket(tmp_buf)==0)
  206.     {
  207.       printf("NRF24L01:%s\r\n",(char *)tmp_buf);
  208.                         switch(tmp_buf[17])
  209.                         {
  210.                                 case '0'://終端1
  211.                                         menu_mess.temp[0] = tmp_buf[19] == '+' ? ((tmp_buf[20] - '0') * 10 + (tmp_buf[21] - '0') * 1 + (tmp_buf[23] - '0') * 0.1 + (tmp_buf[24] - '0') * 0.01) : \
  212.                                                                                                                                                                                                         -((tmp_buf[20] - '0') * 10 + (tmp_buf[21] - '0') * 1 + (tmp_buf[23] - '0') * 0.1 + (tmp_buf[24] - '0') * 0.01);
  213.                                         if(tmp_buf[27] != '#')
  214.                                         menu_mess.humi[0] = (tmp_buf[27] - '0') * 10 + (tmp_buf[28] - '0') * 1;
  215.                                         break;
  216.                                 case '1'://終端2
  217.                                         menu_mess.temp[1] = tmp_buf[19] == '+' ? ((tmp_buf[20] - '0') * 10 + (tmp_buf[21] - '0') * 1 + (tmp_buf[23] - '0') * 0.1 + (tmp_buf[24] - '0') * 0.01) : \
  218.                                                                                                                                                                                                         -((tmp_buf[20] - '0') * 10 + (tmp_buf[21] - '0') * 1 + (tmp_buf[23] - '0') * 0.1 + (tmp_buf[24] - '0') * 0.01);
  219.                                         if(tmp_buf[27] != '#')
  220.                                         menu_mess.humi[1] = (tmp_buf[27] - '0') * 10 + (tmp_buf[28] - '0') * 1;
  221.                                         break;
  222.                                 case '2'://終端3
  223.                                         menu_mess.temp[2] = tmp_buf[19] == '+' ? ((tmp_buf[20] - '0') * 10 + (tmp_buf[21] - '0') * 1 + (tmp_buf[23] - '0') * 0.1 + (tmp_buf[24] - '0') * 0.01) : \
  224.                                                                                                                                                                                                         -((tmp_buf[20] - '0') * 10 + (tmp_buf[21] - '0') * 1 + (tmp_buf[23] - '0') * 0.1 + (tmp_buf[24] - '0') * 0.01);
  225.                                         if(tmp_buf[27] != '#')
  226.                                         menu_mess.humi[2] = (tmp_buf[27] - '0') * 10 + (tmp_buf[28] - '0') * 1;
  227.                                         break;
  228.                                 case '3'://終端4
  229.                                         menu_mess.door[0] = tmp_buf[19] == 0x17 ? 0x11 : 0x10;
  230.                                         break;
  231.                                 default :
  232.                                         break;
  233.                         }
  234.     }
  235.        
  236.                 sys_run_times++;
  237.                 if(gprs_tcp_flag == 17)
  238.                 {
  239.                         //構(gòu)建MQTT連接
  240.                         switch(mqtt_data_flag)
  241.                         {
  242.                                 case 0:
  243.                                         sim800c_send_cmd("AT+CIPSTATUS","OK",500);        //查詢連接狀態(tài)
  244.                                         if(strstr((const char*)USART3_RX_BUF,"CONNECT OK"))
  245.                                         {
  246.                                                 len=mqtt_connect_message(mqtt_msg,"STM32","admin","public");//id=123456,用戶名和密碼為空
  247.                                                 gprs_send_data((u8 *)mqtt_msg,len);
  248.                                                 delay_ms(600);
  249.                                                 len=mqtt_subscribe_message(mqtt_msg,"home/temp",1,1);                        //訂閱test主題
  250.                                                 gprs_send_data((u8 *)mqtt_msg,len);
  251.                                                 printf("MQTT Connect and subscribe OK\r\n");
  252.                                         }
  253.                                         mqtt_data_flag = 1;
  254.                                         break;
  255.                                 case 1:
  256.                                         if(17 == send_data_flag)
  257.                                         {
  258.                                                 MQTTString topicString = MQTTString_initializer;
  259.                                                
  260.                                                 RTC_Get();
  261.                                                 send_model_temp_humi(&menu_mess,(u8 *)temp_data,message_type);
  262.                                                
  263.                                                 temp_data[24] = calendar.w_year%100/10+'0';
  264.                                                 temp_data[25] = calendar.w_year%10+'0';
  265.                                                
  266.                                                 temp_data[26] = calendar.w_month%100/10+'0';
  267.                                                 temp_data[27] = calendar.w_month%10+'0';
  268.                                                
  269.                                                 temp_data[28] = calendar.w_date%100/10+'0';
  270.                                                 temp_data[29] = calendar.w_date%10+'0';
  271.                                                
  272.                                                 temp_data[30] = calendar.hour%100/10+'0';
  273.                                                 temp_data[31] = calendar.hour%10+'0';
  274.                                        
  275.                                                 temp_data[32] = calendar.min%100/10+'0';
  276.                                                 temp_data[33] = calendar.min%10+'0';
  277.                                                
  278.                                                 temp_data[34] = calendar.sec%100/10+'0';
  279.                                                 temp_data[35] = calendar.sec%10+'0';
  280.                                                
  281.                                                 printf("數(shù)據(jù)發(fā)送中...\r\n");                                                //提示數(shù)據(jù)發(fā)送中
  282.                                                 if(0 == message_type)
  283.                                                 {
  284.                                                         topicString.cstring = "L180309001/YY0118050001/Temp";                                                                                                //發(fā)送的主題
  285.                                                 }
  286.                                                 else if(1 == message_type)
  287.                                                 {
  288.                                                         topicString.cstring = "L180309001/YY0118050001/EGps";
  289.                                                 }
  290.                                                 else if(2 == message_type)
  291.                                                 {
  292.                                                         topicString.cstring = "L180309001/YY0118050001/Gyro";
  293.                                                 }
  294.                                                 else if(3 == message_type)
  295.                                                 {
  296.                                                         topicString.cstring = "L180309001/YY0118050001/Door";
  297.                                                 }
  298.                                                 else if(4 == message_type)
  299.                                                 {
  300.                                                         topicString.cstring = "L180309001/YY0118050001/Point";
  301.                                                 }
  302.                                                 message_type++;
  303.                                                 if(message_type>=5)
  304.                                                         message_type = 0;
  305.                                                 len = MQTTSerialize_publish(mqtt_msg, 200, 0, 0, 0, 0, topicString, (u8 *)temp_data, strlen((const char *)temp_data)); /* 2 */
  306.                                                 gprs_send_data((u8 *)mqtt_msg,len);
  307.                                                 printf("MQTT Send data OK\r\n");
  308.                                                 send_data_flag = 0;GPIOB -> ODR ^= GPIO_Pin_5;
  309.                                         }
  310.                                         break;
  311.                         }
  312.                         if(USART3_RX_STA&0X8000)                                                                                                                                                                        //接收到一次數(shù)據(jù)了
  313.                         {
  314.                                 USART3_RX_BUF[USART3_RX_STA&0X7FFF]=0;                                                                                                        //添加結(jié)束符
  315.                                 printf("%s",USART3_RX_BUF);                                                                                                                                                        //發(fā)送到串口  
  316.                                 if(hbeaterrcnt)                                                                                                                                                                                                        //需要檢測(cè)心跳應(yīng)答
  317.                                 {
  318.                                         if(strstr((const char*)USART3_RX_BUF,"SEND OK"))hbeaterrcnt=0;//心跳正常
  319.                                 }
  320.                                 p2=(u8*)strstr((const char*)USART3_RX_BUF,"+IPD");
  321.                                 if(p2)                                                                                                                                                                                                                                        //接收到TCP/UDP數(shù)據(jù)
  322.                                 {
  323.                                         p3=(u8*)strstr((const char*)p2,",");
  324.                                         p2=(u8*)strstr((const char*)p2,":");
  325.                                         p2[0]=0;                                                                                                                                                                                                                        //加入結(jié)束符
  326.                                         sprintf((char*)p1,"收到%s字節(jié)",p3+1);                                                                                                        //接收到的字節(jié)數(shù)
  327.                                         printf("%s\r\n",(char*)p1);
  328.                                 }
  329.                                 USART3_RX_STA=0;
  330.                         }
  331.                        
  332.                 }
  333.                 else
  334.                 {
  335.                         Start_Gprs_TCP();                                                                                                                                                                                                        //創(chuàng)建TCP連接
  336.                 }
  337.                 if(17 == (sys_run_times%100))
  338.                 {
  339.                         menu_mess.gps[0] = (float)(gpsx.longitude/100000);
  340.                         menu_mess.gps[1] = (float)(gpsx.latitude/100000);
  341.                         menu_mess.gps[2] = (float)(gpsx.speed/1000);

  343.                         send_data_flag = 17;
  344.                         printf("Send flag OK\r\n");
  345.                         hbeaterrcnt++;
  346.                         printf("hbeaterrcnt:%d\r\n",hbeaterrcnt);                                                                                                        //方便調(diào)試代碼
  347.                 }
  348.                 else if(27 == (sys_run_times%5000))
  349.                 {
  350.                         len = mqtt_ping_message(mqtt_msg);                                                                                                                                /* 2 */
  351.                         gprs_send_data((u8 *)mqtt_msg,len);
  352.                         printf("heart Send OK\r\n");
  353.                 }
  354.                 switch(KEY_Scan(0))
  355.                 {
  356.                         case KEY0_PRES:
  357.                                 f_close(&mfile);
  358.                                 while(1)
  359.                                 {
  360.                                         printf("System Stop\r\n");
  361.                                         delay_ms(1000);
  362.                                 }
  363.                                 break;
  364.                         default:
  365.                                 break;
  366.                 }
  367.                
  368.                 delay_ms(6);
  369. //                printf("Sys_Time:%d \r\n",sys_run_times);
  370.         }
  371.        
  372.         while(1)
  373.         {
  374.                 printf("Error\r\n");
  375.                 delay_ms(500);
  376.         }
  377.           
  378. }

  380. void Start_Gprs_TCP(void)
  381. {
  382.         //
  383.         u8 *p1,p2[100];
  384.         u8 res=0;
  385.         p1=mymalloc(SRAMIN,100);                                                                                                                                                                        //申請(qǐng)50個(gè)字節(jié)的內(nèi)存
  386.         sim800c_send_cmd((u8 *)"ATE0",(u8 *)"OK",200);                                                                                //不回顯
  387.         USART3_RX_STA=0;
  388.         sim800c_send_cmd("AT+SAPBR=3,1,\"Contype\",\"GPRS\"","OK",200);                //配置承載場景1
  389.         sim800c_send_cmd("AT+SAPBR=3,1,\"APN\",\"CMNET\"","OK",200);
  390.         sim800c_send_cmd("AT+SAPBR=1,1",0,200);                                                                                                                //激活一個(gè)GPRS上下文
  391.         delay_ms(5);
  392.         sim800c_send_cmd("AT+CNTPCID=1","OK",200);                                                                                                //設(shè)置CNTP使用的CID
  393.         sim800c_send_cmd("AT+CNTP=\"202.120.2.101\",32","OK",200);                                //設(shè)置NTP服務(wù)器和本地時(shí)區(qū)(32時(shí)區(qū) 時(shí)間最準(zhǔn)確)
  394.         sim800c_send_cmd("AT+CNTP","+CNTP: 1",600);                                                                                                //同步網(wǎng)絡(luò)時(shí)間
  395.        
  396.         USART3_RX_STA=0;
  397.         if(sim800c_send_cmd("AT+CPIN?","OK",200))res|=1<<0;                                                                //查詢SIM卡是否在位
  398.         USART3_RX_STA=0;
  399.          
  400.         if(0 == res)
  401.         {
  402.                 sim800c_send_cmd("AT+CIPCLOSE=1","CLOSE OK",100);                                                                //關(guān)閉連接
  403.                 sim800c_send_cmd("AT+CIPSHUT","SHUT OK",100);                                                                                //關(guān)閉移動(dòng)場景
  404.                 if(sim800c_send_cmd("AT+CGCLASS=\"B\"","OK",1000))                                                        printf("SIM800C Init1 FAIL\r\n");        //設(shè)置GPRS移動(dòng)臺(tái)類別為B,支持包交換和數(shù)據(jù)交換
  405.                 if(sim800c_send_cmd("AT+CGDCONT=1,\"IP\",\"CMNET\"","OK",1000))        printf("SIM800C Init2 FAIL\r\n");        //設(shè)置PDP上下文,互聯(lián)網(wǎng)接協(xié)議,接入點(diǎn)等信息
  406.                 if(sim800c_send_cmd("AT+CGATT=1","OK",500))                                                                                        printf("SIM800C Init3 FAIL\r\n");        //附著GPRS業(yè)務(wù)
  407.                 if(sim800c_send_cmd("AT+CIPCSGP=1,\"CMNET\"","OK",500))                                        printf("SIM800C Init4 FAIL\r\n");        //設(shè)置為GPRS連接模式
  408.                 if(sim800c_send_cmd("AT+CIPHEAD=1","OK",500))                                                                                printf("SIM800C Init5 FAIL\r\n");        //設(shè)置接收數(shù)據(jù)顯示IP頭(方便判斷數(shù)據(jù)來源)
  409.                 printf("SIM800C Start OK\r\n");
  410.                
  411.                 USART3_RX_STA=0;
  412.                 sprintf((char*)p2,"AT+CIPSTART=\"%s\",\"%s\",\"%s\"","TCP",ipaddr,port);
  413.                
  414.                 if(0==sim800c_send_cmd(p2,"OK",500))                                                                                                                //發(fā)起連接
  415.                 {
  416.                         delay_ms(1500);delay_ms(1000);
  417.                         sim800c_send_cmd("AT+CIPSTATUS","OK",500);                                                                                //查詢連接狀態(tài)
  418.                         USART3_RX_STA = 0;
  419.                         if(strstr((const char*)USART3_RX_BUF,"CONNECT OK"))
  420.                         {
  421.                                 gprs_tcp_flag = 17;
  422.                                 printf("SIM800C TCP Connect OK\r\n");
  423.                         }
  424.                         else
  425.                         {
  426.                                 gprs_tcp_flag = 0;
  427.                                 printf("SIM800C TCP Connect Fail\r\n");
  428.                         }
  429.                 }
  430.         }
  431.         myfree(SRAMIN,p2);
  432. }
  433. void Stop_Gprs_Connect(void)
  434. {
  435.         sim800c_send_cmd("AT+CIPCLOSE=1","CLOSE OK",100);                                                                        //關(guān)閉連接
  436.         sim800c_send_cmd("AT+CIPSHUT","SHUT OK",100);                                                                                        //關(guān)閉移動(dòng)場景
  437. }

  439. void send_model_temp_humi(menu_message * mes,u8 * space,u8 type)
  440. {
  441.         long val;
  442.         u8 t;
  443.         //if(strlen(space)<36)return;
  444.         switch(type)
  445.         {
  446.                 case 0:                                                                                                                                                                //溫濕度+RTC
  447.                         for(t = 0;t < 3;t ++)
  448.                         {
  449.                                 val = (int)(mes->temp[t] * 100);
  450.                                 if(val<0)
  451.                                 {
  452.                                         space[t * 6] = '-';
  453.                                 }
  454.                                 else
  455.                                 {
  456.                                         space[t * 6] = '+';
  457.                                 }
  458.                                 val = val >= 0 ? val : -val;
  459.                                 space[t * 6 + 1] = val % 10000 /1000 + '0';
  460.                                 space[t * 6 + 2] = val % 1000 /100 + '0';
  461.                                 space[t * 6 + 3] = '.';
  462.                                 space[t * 6 + 4] = val % 100 /10 + '0';
  463.                                 space[t * 6 + 5] = val % 10 /1 + '0';
  464.                                
  465.                                 val = (int)(mes->humi[t]);
  466.                                 space[18 + t * 2] = val % 100 / 10 + '0';
  467.                                 space[18 + t * 2 + 1] = val % 10 / 1 + '0';
  468.                         }
  469.                         printf("Temp_Data:%s\r\n",(u8 *)space);
  470.                         break;
  471.                 case 1:                                                                                                                                                                //GPS+RTC
  472.                         for(t = 0;t < 2;t ++)
  473.                         {
  474.                                 val = (long)(mes->gps[t] * 100000);
  475.                                 if(val<0)
  476.                                 {
  477.                                         space[t * 10] = '-';
  478.                                 }
  479.                                 else
  480.                                 {
  481.                                         space[t * 10] = '+';
  482.                                 }
  483.                                 val = val >= 0 ? val : -val;
  484.                                 space[t * 10 + 1] = val % 100000000 /10000000 + '0';
  485.                                 space[t * 10 + 2] = val % 10000000 /1000000 + '0';
  486.                                 space[t * 10 + 3] = val % 1000000 /100000 + '0';
  487.                                 space[t * 10 + 5] = val % 100000 /10000 + '0';
  488.                                 space[t * 10 + 6] = val % 10000 /1000 + '0';
  489.                                 space[t * 10 + 7] = val % 1000 /100 + '0';
  490.                                 space[t * 10 + 8] = val % 100 /10 + '0';
  491.                                 space[t * 10 + 9] = val % 10 /1 + '0';
  492.                                 space[t * 10 + 4] = '.';
  493.                         }
  494.                         val = (int)(mes->gps[2] * 10);
  495.                         space[20] = val % 10000 / 1000 + '0';
  496.                         space[21] = val % 1000 / 100 + '0';
  497.                         space[22] = val % 100 / 10 + '0';
  498.                         space[23] = val % 10 / 1 + '0';
  499.                         printf("Gps_Data:%s\r\n",(u8 *)space);
  500.                         break;
  501.                 case 2:                                                                                                                                                                //陀螺儀+RTC
  502.                         MPU6050ReadAcc((short *)(mes->mpu));
  503.                         for(t = 0;t < 3;t ++)
  504.                         {
  505.                                 space[t * 2] = ((mes -> mpu[t]) >> 8) & 0xFF;
  506.                                 space[t * 2 + 1] = (mes -> mpu[t]) & 0xFF;
  507.                         }
  508.                         MPU6050ReadGyro((short *)(mes->mpu));
  509.                         for(t = 0;t < 3;t ++)
  510.                         {
  511.                                 space[6 + t * 2] = ((mes -> mpu[t]) >> 8) & 0xFF;
  512.                                 space[6 + t * 2 + 1] = (mes -> mpu[t]) & 0xFF;
  513.                         }
  514.                        
  515.                         for(t = 12;t < 24;t ++)
  516.                         {
  517.                                 space[t] = '#';
  518.                         }
  519.                         printf("Gyro_Data:%s\r\n",(u8 *)space);
  520.                         break;
  521.                 case 3:                                                                                                                                                                //開關(guān)門+RTC
  522.                         space[0] = mes->door[0] + '0';
  523.                         for(t = 1;t < 24;t ++)
  524.                         {
  525.                                 space[t] = '#';
  526.                         }
  527.                         printf("Door_Data:%s\r\n",(u8 *)space);
  528.                         break;
  529.                 case 4:                                                                                                                                                                //點(diǎn)熄火+RTC
  530.                         space[0] = mes->door[1] + '0';
  531.                         for(t = 1;t < 24;t ++)
  532.                         {
  533.                                 space[t] = '#';
  534.                         }
  535.                         printf("Point_Data:%s\r\n",(u8 *)space);
  536.                         break;
  537.                 default :
  538.                         break;
  539.         }
  540.        
  541. }


  544. //在str1字符串中找出str2字符串(不包括str2的串結(jié)束符,忽略str中的\0)
  545. //返回該位置的指針,如找不到,返回空指針
  546. u8 *my_strstr(const u8 *s1,u16 n1,const u8 *s2,u16 n2)  
  547. {  
  548.         int n,x=0,y=0;  
  549.         if (*s2)          
  550.         {
  551.                 while(1)                 
  552.                 {
  553.                         if(*s1==*s2)//找到s2第一次出現(xiàn)，兩種情況考慮
  554.                         {
  555.                                 for (n=0;n<n2;n++)  
  556.                                 {
  557.                                         if (*(s1+n)==*(s2+n))
  558.                                         {
  559.                                                 y++;
  560.                                                 if (y>=n2)
  561.                                                 //if (!*(s2+n+1))        //s2下一個(gè)字符是否為'\0'  
  562.                                                 {  
  563.                                                         return (u8 *)s1;  
  564.                                                 }
  565.                                                 if (x+n>=n1-1)        //防止數(shù)組越界
  566.                                                 {  
  567.                                                         return NULL;  
  568.                                                 }
  569.                                                 if (*(s1+n+1)!=*(s2+n+1))//查找的下一個(gè)字符不相等,一個(gè)字符相等
  570.                                                 {
  571.                                                         break;
  572.                                                 }
  573.                                         }
  574.                                         else
  575.                                         {  
  576.                                                 break;
  577.                                         }
  578.                                 }  
  579.                         }
  580.                         s1++;
  581.                         x++;
  582.                         if(x>=n1)
  583.                         {
  584.                                 break;
  585.                         }
  586.                 }  
  587.                 return NULL;  
  588.         }  
  589.         else  
  590.         {  
  591.                 return (u8*)s1;  
  592.         }  
  593. }


  596. void gprs_send_data(u8 *data,u8 lenth)
  597. {
  598.         if(sim800c_send_cmd("AT+CIPSEND",">",500)==0)                //發(fā)送數(shù)據(jù)
  599.         {
  600.                 //u3_printf("%s",(u8 *)data);
  601.                 my_u3_send((char *)mqtt_msg,lenth);
  602.                 delay_ms(10);
  603.                 if(sim800c_send_cmd((u8*)0X1A,"SEND OK",5000)==0)
  604.                         printf("GPRS數(shù)據(jù)發(fā)送成功!\r\n");//最長等待10s
  605.         }
  606.         else
  607.                 sim800c_send_cmd((u8*)0X1B,0,0);        //ESC,取消發(fā)送
  608. }
復(fù)制代碼

原理圖: 無
仿真: 無
代碼: GPRS MQTT STM32.7z (1.56 MB, 下載次數(shù): 32)
作者: wangxiangtan    時(shí)間: 2023-11-17 08:03
厲害領(lǐng)了，stm32也能搞mqtt了啊，是以太網(wǎng)通訊解析字符嗎？
作者: 柔和de黑星    時(shí)間: 2023-11-21 10:59
現(xiàn)在很多Dtu固件的 4G卡 比較方便
作者: wangxiangtan    時(shí)間: 2023-12-12 15:51
STM32怎么進(jìn)行TCP通訊呢老哥
作者: guguyu    時(shí)間: 2024-1-18 21:03
這是AT指令GSM模塊里的MQTT，不能做MQTT透傳



歡迎光臨 (http://www.torrancerestoration.com/bbs/) Powered by Discuz! X3.1