久久久久久久999_99精品久久精品一区二区爱城_成人欧美一区二区三区在线播放_国产精品日本一区二区不卡视频_国产午夜视频_欧美精品在线观看免费

 找回密碼
 立即注冊

QQ登錄

只需一步，快速開始

搜索
查看: 5764|回復: 4
收起左側(cè)

阿里云物聯(lián)網(wǎng)平臺，stm32，mqtt協(xié)議 源程序

  [復制鏈接]
ID:808464 發(fā)表于 2020-7-27 15:38 | 顯示全部樓層 |閱讀模式
使用stm32，ESP8266WiFi數(shù)據(jù)傳輸，mqtt協(xié)議，阿里云物聯(lián)網(wǎng)平臺，程序源碼，下載可用。附app應(yīng)用。

單片機源程序如下:
  1. /*-----------------------------------------------------*/
  2. /*                     程序結(jié)構(gòu)                        */
  3. /*-----------------------------------------------------*/
  4. /*USER     ：包含程序的main函數(shù)，是整個程序的入口      */
  5. /*HARDWARE ：包含開發(fā)板各種功能外設(shè)的驅(qū)動程序          */
  6. /*CORE     ：包含STM32的核心程序，官方提供，我們不修改 */
  7. /*STLIB    ：官方提供的庫文件，我們不修改              */
  8. /*-----------------------------------------------------*/
  9. /*                                                     */
  10. /*           程序main函數(shù)，入口函數(shù)源文件              */
  11. /*                                                     */
  12. /*-----------------------------------------------------*/

  14. #include "stm32f10x.h"  //包含需要的頭文件
  15. #include "main.h"       //包含需要的頭文件
  16. #include "delay.h"      //包含需要的頭文件
  17. #include "usart1.h"     //包含需要的頭文件
  18. #include "usart2.h"     //包含需要的頭文件
  19. #include "timer1.h"     //包含需要的頭文件
  20. #include "timer3.h"     //包含需要的頭文件
  21. #include "timer4.h"     //包含需要的頭文件
  22. #include "wifi.h"            //包含需要的頭文件
  23. #include "led.h"        //包含需要的頭文件
  24. #include "mqtt.h"       //包含需要的頭文件
  25. #include "key.h"        //包含需要的頭文件

  27. char *CMD1 = "APP+OneSW=C";    //開關(guān)控制命令，狀態(tài)翻轉(zhuǎn)，開->關(guān) 關(guān)->開  
  28. char *CMD2 = "APP+OneSW=?";    //開關(guān)查詢命令，回復服務(wù)器當前開關(guān)狀態(tài)
  29. char *CMD3 = "APP+OneSWCD";    //設(shè)置開關(guān)倒計時，倒計時時間到的時候，開關(guān)狀態(tài)翻轉(zhuǎn)
  30. int   CDTime= 0;               //記錄開關(guān)倒計時時間

  32. int main(void)
  33. {        
  34.         Delay_Init();                   //延時功能初始化              
  35.         Usart1_Init(9600);              //串口1功能初始化，波特率9600
  36.         Usart2_Init(115200);            //串口2功能初始化，波特率115200        
  37.         TIM4_Init(300,7200);            //TIM4初始化，定時時間 300*7200*1000/72000000 = 30ms
  38.         LED_Init();                            //LED初始化
  39.         KEY_Init();                     //按鍵初始化
  40.         WiFi_ResetIO_Init();            //初始化WiFi的復位IO
  41.     MQTT_Buff_Init();               //初始化接收,發(fā)送,命令數(shù)據(jù)的 緩沖區(qū) 以及各狀態(tài)參數(shù)
  42.         AliIoT_Parameter_Init();            //初始化連接阿里云IoT平臺MQTT服務(wù)器的參數(shù)               
  43.         while(1)                        //主循環(huán)
  44.         {               
  45.                 /*--------------------------------------------------------------------*/
  46.                 /*   Connect_flag=1同服務(wù)器建立了連接,我們可以發(fā)布數(shù)據(jù)和接收推送了    */
  47.                 /*--------------------------------------------------------------------*/
  48.                 if(Connect_flag==1){     
  49.                         /*-------------------------------------------------------------*/
  50.                         /*                     處理發(fā)送緩沖區(qū)數(shù)據(jù)                      */
  51.                         /*-------------------------------------------------------------*/
  52.                                 if(MQTT_TxDataOutPtr != MQTT_TxDataInPtr){                //if成立的話，說明發(fā)送緩沖區(qū)有數(shù)據(jù)了
  53.                                 //3種情況可進入if
  54.                                 //第1種：0x10 連接報文
  55.                                 //第2種：0x82 訂閱報文，且ConnectPack_flag置位，表示連接報文成功
  56.                                 //第3種：SubcribePack_flag置位，說明連接和訂閱均成功，其他報文可發(fā)
  57.                                 if((MQTT_TxDataOutPtr[1]==0x10)||((MQTT_TxDataOutPtr[1]==0x82)&&(ConnectPack_flag==1))||(SubcribePack_flag==1)){   
  58.                                         u1_printf("發(fā)送數(shù)據(jù):0x%x\r\n",MQTT_TxDataOutPtr[1]);  //串口提示信息
  59.                                         MQTT_TxData(MQTT_TxDataOutPtr);                       //發(fā)送數(shù)據(jù)
  60.                                         MQTT_TxDataOutPtr += BUFF_UNIT;                       //指針下移
  61.                                         if(MQTT_TxDataOutPtr==MQTT_TxDataEndPtr)              //如果指針到緩沖區(qū)尾部了
  62.                                                 MQTT_TxDataOutPtr = MQTT_TxDataBuf[0];            //指針歸位到緩沖區(qū)開頭
  63.                                 }                                 
  64.                         }//處理發(fā)送緩沖區(qū)數(shù)據(jù)的else if分支結(jié)尾
  65.                         
  66.                         /*-------------------------------------------------------------*/
  67.                         /*                     處理接收緩沖區(qū)數(shù)據(jù)                      */
  68.                         /*-------------------------------------------------------------*/
  69.                         if(MQTT_RxDataOutPtr != MQTT_RxDataInPtr){  //if成立的話，說明接收緩沖區(qū)有數(shù)據(jù)了                                                                                                               
  70.                                 u1_printf("接收到數(shù)據(jù):");
  71.                                 /*-----------------------------------------------------*/
  72.                                 /*                    處理CONNACK報文                  */
  73.                                 /*-----------------------------------------------------*/                                
  74.                                 //if判斷，如果一共接收了4個字節(jié)，第一個字節(jié)是0x20，表示收到的是CONNACK報文
  75.                                 //接著我們要判斷第4個字節(jié)，看看CONNECT報文是否成功
  76.                                 if((MQTT_RxDataOutPtr[0]==4)&&(MQTT_RxDataOutPtr[1]==0x20)){                                    
  77.                                     switch(MQTT_RxDataOutPtr[4]){                                       
  78.                                                 case 0x00 : u1_printf("CONNECT報文成功\r\n");                            //串口輸出信息        
  79.                                                                     ConnectPack_flag = 1;                                        //CONNECT報文成功，訂閱報文可發(fā)
  80.                                                                         break;                                                       //跳出分支case 0x00                                             
  81.                                                 case 0x01 : u1_printf("連接已拒絕，不支持的協(xié)議版本，準備重啟\r\n");     //串口輸出信息
  82.                                                                         Connect_flag = 0;                                            //Connect_flag置零，重啟連接
  83.                                                                         break;                                                       //跳出分支case 0x01   
  84.                                                 case 0x02 : u1_printf("連接已拒絕，不合格的客戶端標識符，準備重啟\r\n"); //串口輸出信息
  85.                                                                         Connect_flag = 0;                                            //Connect_flag置零，重啟連接
  86.                                                                         break;                                                       //跳出分支case 0x02
  87.                                                 case 0x03 : u1_printf("連接已拒絕，服務(wù)端不可用，準備重啟\r\n");         //串口輸出信息
  88.                                                                         Connect_flag = 0;                                            //Connect_flag置零，重啟連接
  89.                                                                         break;                                                       //跳出分支case 0x03
  90.                                                 case 0x04 : u1_printf("連接已拒絕，無效的用戶名或密碼，準備重啟\r\n");   //串口輸出信息
  91.                                                                         Connect_flag = 0;                                            //Connect_flag置零，重啟連接                                                
  92.                                                                         break;                                                       //跳出分支case 0x04
  93.                                                 case 0x05 : u1_printf("連接已拒絕，未授權(quán)，準備重啟\r\n");               //串口輸出信息
  94.                                                                         Connect_flag = 0;                                            //Connect_flag置零，重啟連接                                                
  95.                                                                         break;                                                       //跳出分支case 0x05                 
  96.                                                 default   : u1_printf("連接已拒絕，未知狀態(tài)，準備重啟\r\n");             //串口輸出信息
  97.                                                                         Connect_flag = 0;                                            //Connect_flag置零，重啟連接                                       
  98.                                                                         break;                                                       //跳出分支case default                                                                 
  99.                                         }                                
  100.                                 }                        
  101.                                 //if判斷，如果一共接收了5個字節(jié)，第一個字節(jié)是0x90，表示收到的是SUBACK報文
  102.                                 //接著我們要判斷訂閱回復，看看是不是成功
  103.                                 else if((MQTT_RxDataOutPtr[0]==5)&&(MQTT_RxDataOutPtr[1]==0x90)){
  104.                                                 switch(MQTT_RxDataOutPtr[5]){                                       
  105.                                                 case 0x00 :
  106.                                                 case 0x01 : u1_printf("訂閱成功\r\n");            //串口輸出信息
  107.                                                                 SubcribePack_flag = 1;                //SubcribePack_flag置1，表示訂閱報文成功，其他報文可發(fā)送
  108.                                                                         Ping_flag = 0;                        //Ping_flag清零
  109.                                                                        TIM3_ENABLE_30S();                    //啟動30s的PING定時器
  110.                                                                         break;                                //跳出分支                                             
  111.                                                 default   : u1_printf("訂閱失敗，準備重啟\r\n");  //串口輸出信息
  112.                                                                         Connect_flag = 0;                     //Connect_flag置零，重啟連接
  113.                                                                         break;                                //跳出分支                                                                 
  114.                                         }                                       
  115.                                 }
  116.                                 //if判斷，如果一共接收了2個字節(jié)，第一個字節(jié)是0xD0，表示收到的是PINGRESP報文
  117.                                 else if((MQTT_RxDataOutPtr[0]==2)&&(MQTT_RxDataOutPtr[1]==0xD0)){
  118.                                         u1_printf("PING報文回復\r\n");                   //串口輸出信息
  119.                                         if(Ping_flag==1){                     //如果Ping_flag=1，表示第一次發(fā)送
  120.                                                  Ping_flag = 0;                                      //要清除Ping_flag標志
  121.                                         }else if(Ping_flag>1){                                   //如果Ping_flag>1，表示是多次發(fā)送了，而且是2s間隔的快速發(fā)送
  122.                                                 Ping_flag = 0;                                       //要清除Ping_flag標志
  123.                                                 TIM3_ENABLE_30S();                                   //PING定時器重回30s的時間
  124.                                         }                                
  125.                                 }        
  126.                                 //if判斷，如果第一個字節(jié)是0x30，表示收到的是服務(wù)器發(fā)來的推送數(shù)據(jù)
  127.                                 //我們要提取控制命令
  128.                                 else if((MQTT_RxDataOutPtr[1]==0x30)){
  129.                                         u1_printf("服務(wù)器等級0推送\r\n");                    //串口輸出信息
  130.                                         MQTT_DealPushdata_Qs0(MQTT_RxDataOutPtr);  //處理等級0推送數(shù)據(jù)
  131.                                 }                                
  132.                                                                
  133.                                 MQTT_RxDataOutPtr += BUFF_UNIT;                     //指針下移
  134.                                 if(MQTT_RxDataOutPtr==MQTT_RxDataEndPtr)            //如果指針到緩沖區(qū)尾部了
  135.                                         MQTT_RxDataOutPtr = MQTT_RxDataBuf[0];          //指針歸位到緩沖區(qū)開頭                        
  136.                         }//處理接收緩沖區(qū)數(shù)據(jù)的else if分支結(jié)尾
  137.                         
  138.                         /*-------------------------------------------------------------*/
  139.                         /*                     處理命令緩沖區(qū)數(shù)據(jù)                      */
  140.                         /*-------------------------------------------------------------*/
  141.                         if(MQTT_CMDOutPtr != MQTT_CMDInPtr){                             //if成立的話，說明命令緩沖區(qū)有數(shù)據(jù)了                        
  142.                                 MQTT_CMDOutPtr[MQTT_CMDOutPtr[0]+1] = '\0';                  //加入字符串結(jié)束符        
  143.                                 u1_printf("命令:%s\r\n",&MQTT_CMDOutPtr[1]);                 //串口輸出信息
  144.                                 if(!memcmp(&MQTT_CMDOutPtr[1],CMD1,strlen(CMD1))){           //判斷指令，如果是CMD1
  145.                                         LED1_OUT(!LED1_IN_STA);                                  //開關(guān)1狀態(tài)翻轉(zhuǎn) 如果點亮就熄滅，反之如果熄滅就點亮
  146.                                         LED_CD_State();                                          //判斷開關(guān)和倒計時狀態(tài)，并發(fā)布給服務(wù)器
  147.                                 }else if(!memcmp(&MQTT_CMDOutPtr[1],CMD2,strlen(CMD2))){     //判斷指令，如果是CMD2，回復開關(guān)狀態(tài)
  148.                                         LED_CD_State();                                          //判斷開關(guān)和倒計時狀態(tài)，并發(fā)布給服務(wù)器                                
  149.                                 }else if(!memcmp(&MQTT_CMDOutPtr[1],CMD3,strlen(CMD3))){     //判斷指令，如果是CMD3，設(shè)置倒計時時間
  150.                                         CDTime = MQTT_CMDOutPtr[12];                             //記錄倒計時時間
  151.                                         if(CDTime!=0){                                           //如果CDTime不等于0，進入if
  152.                                                 u1_printf("倒計時:%d分鐘\r\n",CDTime);               //串口輸出信息
  153.                                                 TIM1_ENABLE_60S();                                   //啟動定時器1 60s鐘定時
  154.                                         }else{                                                   //反之CDTime等于0，進入else，取消定時
  155.                                             u1_printf("取消倒計時\r\n");                         //串口輸出信息
  156.                                                 TIM_Cmd(TIM1,DISABLE);                               //關(guān)閉TIM1
  157.                                         }
  158.                                         LED_CD_State();                                          //判斷開關(guān)和倒計時狀態(tài)，并發(fā)布給服務(wù)器                                                        
  159.                                 }else u1_printf("未知指令\r\n");                             //串口輸出信息
  160.                                 MQTT_CMDOutPtr += BUFF_UNIT;                                      //指針下移
  161.                                 if(MQTT_CMDOutPtr==MQTT_CMDEndPtr)                                //如果指針到緩沖區(qū)尾部了
  162.                                         MQTT_CMDOutPtr = MQTT_CMDBuf[0];                               //指針歸位到緩沖區(qū)開頭                                
  163.                         }//處理命令緩沖區(qū)數(shù)據(jù)的else if分支結(jié)尾        
  164.                 }//Connect_flag=1的if分支的結(jié)尾
  165.                
  166.                 /*--------------------------------------------------------------------*/
  167.                 /*      Connect_flag=0同服務(wù)器斷開了連接,我們要重啟連接服務(wù)器         */
  168.                 /*--------------------------------------------------------------------*/
  169.                 else{
  170.                         u1_printf("需要連接服務(wù)器\r\n");                 //串口輸出信息
  171.                         TIM_Cmd(TIM4,DISABLE);                           //關(guān)閉TIM4
  172.                         TIM_Cmd(TIM3,DISABLE);                           //關(guān)閉TIM3  
  173.                         WiFi_RxCounter=0;                                //WiFi接收數(shù)據(jù)量變量清零                        
  174.                         memset(WiFi_RX_BUF,0,WiFi_RXBUFF_SIZE);          //清空WiFi接收緩沖區(qū)
  175.                         if(WiFi_Connect_IoTServer()==0){                                //如果WiFi連接云服務(wù)器函數(shù)返回0，表示正確，進入if
  176.                                 u1_printf("建立TCP連接成功\r\n");            //串口輸出信息
  177.                                 Connect_flag = 1;                            //Connect_flag置1，表示連接成功        
  178.                                 WiFi_RxCounter=0;                            //WiFi接收數(shù)據(jù)量變量清零                        
  179.                                 memset(WiFi_RX_BUF,0,WiFi_RXBUFF_SIZE);      //清空WiFi接收緩沖區(qū)
  180.                                 MQTT_Buff_ReInit();                          //重新初始化發(fā)送緩沖區(qū)                    
  181.                         }                                
  182.                 }
  183.         }
  184. }
  185. /*-------------------------------------------------*/
  186. /*函數(shù)名：判斷開關(guān)和倒計時狀態(tài)，并發(fā)布給服務(wù)器     */
  187. /*參  數(shù)：無                                       */
  188. /*返回值：無                                       */
  189. /*-------------------------------------------------*/
  190. void LED_CD_State(void)
  191. {
  192.         char temp[20];                                  //定義一個臨時緩沖區(qū)
  193.         
  194.         memset(temp,0,20);                                 //清空臨時緩沖區(qū)
  195.         sprintf(temp,"+OneSW:");                      //構(gòu)建回復數(shù)據(jù)        
  196.         
  197.         if(LED1_IN_STA) temp[7] = '0';                  //如果LED1是高電平，說明是熄滅狀態(tài)，開關(guān)1狀態(tài)位置0
  198.         else            temp[7] = '1';                        //反之，說明是點亮狀態(tài)，開關(guān)1狀態(tài)位置1        
  199.         temp[8] = CDTime;                       //加入剩余倒計時時間

  201.         MQTT_PublishQs0(P_TOPIC_NAME,temp,9);   //添加數(shù)據(jù)，發(fā)布給服務(wù)器        
  202. }
復制代碼
51hei.png
所有資料51hei提供下載:
STM32代碼: 阿里云IoT物聯(lián)網(wǎng)平臺 MQTT 1路開關(guān)控制（手機APP）（WiFi例程）.7z (211.48 KB, 下載次數(shù): 337)

評分

參與人數(shù) 3黑幣 +66 收起 理由
peeta + 6
王者不可阻擋 + 10 共享資料的黑幣獎勵！至此表達我由衷的感謝
admin + 50 共享資料的黑幣獎勵！

查看全部評分

回復

使用道具 舉報

ID:911562 發(fā)表于 2021-4-24 21:25 | 顯示全部樓層
附件還是不完整,能分享一下apk的代碼嗎?
回復

使用道具 舉報

ID:836950 發(fā)表于 2022-5-23 14:08 | 顯示全部樓層
感謝作者的分享，你是分享給了我極大的幫助，由衷的表達我的感謝
回復

使用道具 舉報

ID:99525 發(fā)表于 2022-6-16 01:39 | 顯示全部樓層
上云啦，不錯不錯！
回復

使用道具 舉報

ID:25103 發(fā)表于 2024-3-3 17:43 | 顯示全部樓層
由衷的表達我的感謝
回復

使用道具 舉報

您需要登錄后才可以回帖 登錄 | 立即注冊

本版積分規(guī)則

手機版|小黑屋|51黑電子論壇 |51黑電子論壇6群 QQ 管理員QQ:125739409;技術(shù)交流QQ群281945664

Powered by 單片機教程網(wǎng)

快速回復 返回頂部 返回列表
主站蜘蛛池模板： 亚洲乱码国产乱码精品精的特点 | 欧美亚洲国产一区 | 亚洲精品一二三区 | 亚洲一区二区三区四区五区午夜 | 日韩欧美在线视频 | 五月天婷婷久久 | 欧美精品一区二区三区在线播放 | 色综合色综合色综合 | 国产7777 | 91精品国产欧美一区二区 | 国产精品久久久久免费 | 亚洲午夜精品一区二区三区他趣 | 成人精品在线观看 | 日韩一区二区在线观看视频 | 日韩中文字幕在线播放 | 亚洲美女天堂网 | 欧美成人精品二区三区99精品 | 99国内精品久久久久久久 | 成人一区二区在线 | 日韩av在线一区二区 | 在线欧美亚洲 | 亚洲精品自在在线观看 | 岛国精品 | 久久久久国色av免费观看性色 | 蜜桃av鲁一鲁一鲁一鲁 | 亚洲精彩视频在线观看 | 成人在线精品视频 | 国产特级毛片aaaaaa | 国产第一页在线观看 | 久久天天躁狠狠躁夜夜躁2014 | 国产精品一区二区三 | 久久久精品一区二区三区 | 色婷婷激情| www.日韩 | 日韩精品极品视频在线观看免费 | 欧美综合一区二区 | 男人的天堂在线视频 | 日韩福利| 国产激情视频在线观看 | 亚洲综合成人网 | 亚洲精品第一页 |