找回密碼
 立即注冊

QQ登錄

只需一步，快速開始

帖子
查看: 3014|回復(fù): 1
打印 上一主題 下一主題
收起左側(cè)

stm32+ESP8266+OneNET移動云平臺+濕度的自動澆花系統(tǒng)源程序

[復(fù)制鏈接]
跳轉(zhuǎn)到指定樓層
樓主
基礎(chǔ)stm32+ESP8266+OneNET移動云平臺+濕度的自動澆花系統(tǒng)，在大學(xué)里面做的，突然逛下論壇發(fā)一發(fā)！
制作出來的實(shí)物圖如下：


單片機(jī)源程序如下:
  1. #include "main.h"
  2. #include "ds18b20.h"
  3. #include "dht11.h"
  4. #include "beep.h"

  6. int main()
  7. {
  8.         
  9.         u16 timeCount = 0;        //發(fā)送間隔變量
  10.         u8 *dataPtr = NULL;
  11. //        u8 data[10]={0x12,0x23,0x45,0x68,0x79,0xAB,0x00,0xEF};
  12.         u8 buf[256];
  13.         u8 t[4] = {12,34,56};
  14.         LED0 = 1;
  15.         LED1 = 1;
  16.         Stm32_Clock_Init(9);        //系統(tǒng)時(shí)鐘設(shè)置
  17.         uart_init(72,9600);                 //串口初始化為9600
  18.         delay_init(72);                            //延時(shí)初始化
  19.         LED_Init();                                  //初始化與LED連接的硬件接口        
  20.         DHT11_Init();
  21.         BEEP_Init();
  22. //        DS18B20_Init();
  23.         ESP8266_Init();                                        //初始化ESP8266
  24.         while(OneNET_DevLink())                        //接入OneNET
  25.                 delay_ms(100);
  26.         
  27.         while(1)
  28.         {
  29.                 dataPtr = ESP8266_GetIPD(0);
  30.                 if(dataPtr != NULL)
  31.                         OneNET_RevPro(dataPtr);
  32.                         
  33.                 if(++timeCount >= 1000)                                                                        //發(fā)送間隔5s
  34.                 {
  35.                         printf( "OneNET_SendData\r\n");
  36.                         OneNET_SendData(buf,5,t,4);                                                                        //發(fā)送數(shù)據(jù)
  37.                         
  38.                         timeCount = 0;
  39.                         ESP8266_ClearBuff();
  40.                 }
  41.                
  42.                

  44.                 delay_ms(10);
  45.         
  46.         }
  47. }
復(fù)制代碼

1.具體使用方法可參考：sample.c

SDK使用的三種類型：
    1.組包-發(fā)送-刪包
        只需要調(diào)用接口函數(shù)封裝一包數(shù)據(jù)，成發(fā)送即可。

    2.組包-發(fā)送-等待平臺返回-刪包
        連接平臺和心跳請求需要等待平臺的返回結(jié)果。

    3.數(shù)據(jù)點(diǎn)上傳
        數(shù)據(jù)點(diǎn)上傳分5步：1.獲取json格式數(shù)據(jù)流長度
                 2.根據(jù)長度封裝協(xié)議頭
                 3.封裝一包數(shù)據(jù)
                 4.發(fā)送數(shù)據(jù)
                 5.釋放內(nèi)存

內(nèi)存方案的三種方式
    1.動態(tài)分配
        只需要聲明 EDP_PACKET_STRUCTURE edpPacket = {NULL, 0, 0, 0};
        然后調(diào)用組包函數(shù)即可。

    2.全局?jǐn)?shù)
        聲明一個(gè)全局?jǐn)?shù)組，如 unsigned char dataMem[128]
        然后再調(diào)用組包函數(shù)之前
        edpPacket._data = dataMem;
        edpPacket._len = sizeof(dataMem);
        即可。

    3.局部數(shù)組
        方式同2，數(shù)組為局部變量。

  1. //協(xié)議頭文件
  2. #include "mqttkit.h"




  7. //==========================================================
  8. //        函數(shù)名稱：        EDP_NewBuffer
  9. //        函數(shù)功能：        申請內(nèi)存
  10. //        入口參數(shù)：        edpPacket：包結(jié)構(gòu)體
  11. //                                size：大小
  12. //        返回參數(shù)：        無
  13. //        說明：                1.可使用動態(tài)分配來分配內(nèi)存
  14. //                                2.可使用局部或全局?jǐn)?shù)組來指定內(nèi)存
  15. //==========================================================
  16. void MQTT_NewBuffer(MQTT_PACKET_STRUCTURE *mqttPacket, uint32 size)
  17. {
  18.         
  19.         uint32 i = 0;

  21.         if(mqttPacket->_data == NULL)
  22.         {
  23.                 mqttPacket->_memFlag = MEM_FLAG_ALLOC;
  24.                
  25.                 mqttPacket->_data = (uint8 *)MQTT_MallocBuffer(size);
  26.                 if(mqttPacket->_data != NULL)
  27.                 {
  28.                         mqttPacket->_len = 0;
  29.                         
  30.                         mqttPacket->_size = size;
  31.                         
  32.                         for(; i < mqttPacket->_size; i++)
  33.                                 mqttPacket->_data[i] = 0;
  34.                 }
  35.         }
  36.         else
  37.         {
  38.                 mqttPacket->_memFlag = MEM_FLAG_STATIC;
  39.                
  40.                 for(; i < mqttPacket->_size; i++)
  41.                         mqttPacket->_data[i] = 0;
  42.                
  43.                 mqttPacket->_len = 0;
  44.                
  45.                 if(mqttPacket->_size < size)
  46.                         mqttPacket->_data = NULL;
  47.         }

  49. }


  52. //==========================================================
  53. //        函數(shù)名稱：        MQTT_DeleteBuffer
  54. //        函數(shù)功能：        釋放數(shù)據(jù)內(nèi)存
  55. //        入口參數(shù)：        edpPacket：包結(jié)構(gòu)體
  56. //        返回參數(shù)：        無
  57. //        說明：               
  58. //==========================================================
  59. void MQTT_DeleteBuffer(MQTT_PACKET_STRUCTURE *mqttPacket)
  60. {

  62.         if(mqttPacket->_memFlag == MEM_FLAG_ALLOC)
  63.                 MQTT_FreeBuffer(mqttPacket->_data);
  64.         
  65.         mqttPacket->_data = NULL;
  66.         mqttPacket->_len = 0;
  67.         mqttPacket->_size = 0;
  68.         mqttPacket->_memFlag = MEM_FLAG_NULL;

  70. }


  73. int32 MQTT_DumpLength(size_t len, uint8 *buf)
  74. {
  75.         
  76.         int32 i = 0;
  77.         
  78.         for(i = 1; i <= 4; ++i)
  79.         {
  80.                 *buf = len % 128;
  81.                 len >>= 7;
  82.                 if(len > 0)
  83.                 {
  84.                         *buf |= 128;
  85.                         ++buf;
  86.                 }
  87.                 else
  88.                 {
  89.                         return i;
  90.                 }
  91.         }

  93.         return -1;
  94. }



  98. //==========================================================
  99. //        函數(shù)名稱：        MQTT_PacketConnect
  100. //        函數(shù)功能：        連接消息組包
  101. //        入口參數(shù)：        user：用戶名：產(chǎn)品ID
  102. //                                password：密碼：鑒權(quán)信息或apikey
  103. //                                devid：設(shè)備ID
  104. //                                cTime：連接保持時(shí)間
  105. //                                clean_session：離線消息清除標(biāo)志
  106. //                                qos：重發(fā)標(biāo)志
  107. //                                will_topic：異常離線topic
  108. //                                will_msg：異常離線消息
  109. //                                will_retain：消息推送標(biāo)志
  110. //                                mqttPacket：包指針
  111. //        返回參數(shù)：        0-成功                其他-失敗
  112. //
  113. //        說明：               
  114. //==========================================================
  115. uint8 MQTT_PacketConnect(const int8 *user, const int8 *password, const int8 *devid,
  116.                                                 uint16 cTime, uint1 clean_session, uint1 qos,
  117.                                                 const int8 *will_topic, const int8 *will_msg, int32 will_retain,
  118.                                                 MQTT_PACKET_STRUCTURE *mqttPacket)
  119. {
  120.         
  121.         uint8 flags = 0;
  122.         uint8 will_topic_len = 0;
  123.         uint16 total_len = 15;
  124.         int16 len = 0, devid_len = strlen(devid);
  125.         
  126.         if(!devid)
  127.                 return 1;
  128.         
  129.         total_len += devid_len + 2;
  130.         
  131.         //斷線后，是否清理離線消息：1-清理        0-不清理--------------------------------------------
  132.         if(clean_session)
  133.         {
  134.                 flags |= MQTT_CONNECT_CLEAN_SESSION;
  135.         }
  136.         
  137.         //異常掉線情況下，服務(wù)器發(fā)布的topic------------------------------------------------------
  138.         if(will_topic)
  139.         {
  140.                 flags |= MQTT_CONNECT_WILL_FLAG;
  141.                 will_topic_len = strlen(will_topic);
  142.                 total_len += 4 + will_topic_len + strlen(will_msg);
  143.         }
  144.         
  145.         //qos級別--主要用于PUBLISH（發(fā)布態(tài)）消息的，保證消息傳遞的次數(shù)-----------------------------
  146.         switch((unsigned char)qos)
  147.         {
  148.                 case MQTT_QOS_LEVEL0:
  149.                         flags |= MQTT_CONNECT_WILL_QOS0;                                                        //最多一次
  150.                 break;
  151.                
  152.                 case MQTT_QOS_LEVEL1:
  153.                         flags |= (MQTT_CONNECT_WILL_FLAG | MQTT_CONNECT_WILL_QOS1);        //最少一次
  154.                 break;
  155.                
  156.                 case MQTT_QOS_LEVEL2:
  157.                         flags |= (MQTT_CONNECT_WILL_FLAG | MQTT_CONNECT_WILL_QOS2);        //只有一次
  158.                 break;
  159.                
  160.                 default:
  161.                 return 2;
  162.         }
  163.         
  164.         //主要用于PUBLISH(發(fā)布態(tài))的消息，表示服務(wù)器要保留這次推送的信息，如果有新的訂閱者出現(xiàn)，就把這消息推送給它。如果不設(shè)那么推送至當(dāng)前訂閱的就釋放了
  165.         if(will_retain)
  166.         {
  167.                 flags |= (MQTT_CONNECT_WILL_FLAG | MQTT_CONNECT_WILL_RETAIN);
  168.         }
  169.         
  170.         //賬號為空 密碼為空---------------------------------------------------------------------
  171.         if(!user || !password)
  172.         {
  173.                 return 3;
  174.         }
  175.         flags |= MQTT_CONNECT_USER_NAME | MQTT_CONNECT_PASSORD;
  176.         
  177.         total_len += strlen(user) + strlen(password) + 4;
  178.         
  179.         //分配內(nèi)存-----------------------------------------------------------------------------
  180.         MQTT_NewBuffer(mqttPacket, total_len);
  181.         if(mqttPacket->_data == NULL)
  182.                 return 4;
  183.         
  184.         memset(mqttPacket->_data, 0, total_len);
  185.         
  186. /*************************************固定頭部***********************************************/
  187.         
  188.         //固定頭部----------------------連接請求類型---------------------------------------------
  189.         mqttPacket->_data[mqttPacket->_len++] = MQTT_PKT_CONNECT << 4;
  190.         
  191.         //固定頭部----------------------剩余長度值-----------------------------------------------
  192.         len = MQTT_DumpLength(total_len - 5, mqttPacket->_data + mqttPacket->_len);
  193.         if(len < 0)
  194.         {
  195.                 MQTT_DeleteBuffer(mqttPacket);
  196.                 return 5;
  197.         }
  198.         else
  199.                 mqttPacket->_len += len;
  200.         
  201. /*************************************可變頭部***********************************************/
  202.         
  203.         //可變頭部----------------------協(xié)議名長度 和 協(xié)議名--------------------------------------
  204.         mqttPacket->_data[mqttPacket->_len++] = 0;
  205.         mqttPacket->_data[mqttPacket->_len++] = 4;
  206.         mqttPacket->_data[mqttPacket->_len++] = 'M';
  207.         mqttPacket->_data[mqttPacket->_len++] = 'Q';
  208.         mqttPacket->_data[mqttPacket->_len++] = 'T';
  209.         mqttPacket->_data[mqttPacket->_len++] = 'T';
  210.         
  211.         //可變頭部----------------------protocol level 4-----------------------------------------
  212.         mqttPacket->_data[mqttPacket->_len++] = 4;
  213.         
  214.         //可變頭部----------------------連接標(biāo)志(該函數(shù)開頭處理的數(shù)據(jù))-----------------------------
  215.     mqttPacket->_data[mqttPacket->_len++] = flags;
  216.         
  217.         //可變頭部----------------------保持連接的時(shí)間(秒)----------------------------------------
  218.         mqttPacket->_data[mqttPacket->_len++] = MOSQ_MSB(cTime);
  219.         mqttPacket->_data[mqttPacket->_len++] = MOSQ_LSB(cTime);
  220.          
  221. /*************************************消息體************************************************/

  223.         //消息體----------------------------devid長度、devid-------------------------------------
  224.         mqttPacket->_data[mqttPacket->_len++] = MOSQ_MSB(devid_len);
  225.         mqttPacket->_data[mqttPacket->_len++] = MOSQ_LSB(devid_len);
  226.         
  227.         strncat((int8 *)mqttPacket->_data + mqttPacket->_len, devid, devid_len);
  228.         mqttPacket->_len += devid_len;
  229.         
  230.         //消息體----------------------------will_flag 和 will_msg---------------------------------
  231.         if(flags & MQTT_CONNECT_WILL_FLAG)
  232.         {
  233.                 unsigned short mLen = 0;
  234.                
  235.                 if(!will_msg)
  236.                         will_msg = "";
  237.                
  238.                 mLen = strlen(will_topic);
  239.                 mqttPacket->_data[mqttPacket->_len++] = MOSQ_MSB(mLen);
  240.                 mqttPacket->_data[mqttPacket->_len++] = MOSQ_LSB(mLen);
  241.                 strncat((int8 *)mqttPacket->_data + mqttPacket->_len, will_topic, mLen);
  242.                 mqttPacket->_len += mLen;
  243.                
  244.                 mLen = strlen(will_msg);
  245.                 mqttPacket->_data[mqttPacket->_len++] = MOSQ_MSB(mLen);
  246.                 mqttPacket->_data[mqttPacket->_len++] = MOSQ_LSB(mLen);
  247.                 strncat((int8 *)mqttPacket->_data + mqttPacket->_len, will_msg, mLen);
  248.                 mqttPacket->_len += mLen;
  249.         }
  250.         
  251.         //消息體----------------------------use---------------------------------------------------
  252.         if(flags & MQTT_CONNECT_USER_NAME)
  253.         {
  254.                 unsigned short user_len = strlen(user);
  255.                
  256.                 mqttPacket->_data[mqttPacket->_len++] = MOSQ_MSB(user_len);
  257.                 mqttPacket->_data[mqttPacket->_len++] = MOSQ_LSB(user_len);
  258.                 strncat((int8 *)mqttPacket->_data + mqttPacket->_len, user, user_len);
  259.                 mqttPacket->_len += user_len;
  260.         }

  262.         //消息體----------------------------password----------------------------------------------
  263.         if(flags & MQTT_CONNECT_PASSORD)
  264.         {
  265.                 unsigned short psw_len = strlen(password);
  266.                
  267.                 mqttPacket->_data[mqttPacket->_len++] = MOSQ_MSB(psw_len);
  268.                 mqttPacket->_data[mqttPacket->_len++] = MOSQ_LSB(psw_len);
  269.                 strncat((int8 *)mqttPacket->_data + mqttPacket->_len, password, psw_len);
  270.                 mqttPacket->_len += psw_len;
  271.         }

  273.         return 0;

  275. }


  278. //==========================================================
  279. //        函數(shù)名稱：        MQTT_PacketDisConnect
  280. //        函數(shù)功能：        斷開連接消息組包
  281. //        入口參數(shù)：        mqttPacket：包指針
  282. //        返回參數(shù)：        0-成功                1-失敗
  283. //        說明：               
  284. //==========================================================
  285. uint1 MQTT_PacketDisConnect(MQTT_PACKET_STRUCTURE *mqttPacket)
  286. {

  288.         MQTT_NewBuffer(mqttPacket, 2);
  289.         if(mqttPacket->_data == NULL)
  290.                 return 1;
  291.         
  292. /*************************************固定頭部***********************************************/
  293.         
  294.         //固定頭部----------------------頭部消息-------------------------------------------------
  295.         mqttPacket->_data[mqttPacket->_len++] = MQTT_PKT_DISCONNECT << 4;
  296.         
  297.         //固定頭部----------------------剩余長度值-----------------------------------------------
  298.         mqttPacket->_data[mqttPacket->_len++] = 0;
  299.         
  300.         return 1;

  302. }


  305. //==========================================================
  306. //        函數(shù)名稱：        MQTT_UnPacketConnectAck
  307. //        函數(shù)功能：        連接消息解包
  308. //        入口參數(shù)：        rev_data：接收的數(shù)據(jù)
  309. //        返回參數(shù)：        1、255-失敗                其他-平臺的返回碼
  310. //        說明：               
  311. //==========================================================
  312. uint8 MQTT_UnPacketConnectAck(uint8 *rev_data)
  313. {

  315.         if(rev_data[1] != 2)
  316.                 return 1;
  317.         
  318.         if(rev_data[2] == 0 || rev_data[2] == 1)
  319.                 return rev_data[3];
  320.         else
  321.                 return 255;

  323. }


  326. //==========================================================
  327. //        函數(shù)名稱：        MQTT_PacketSaveData
  328. //        函數(shù)功能：        數(shù)據(jù)點(diǎn)上傳組包
  329. //        入口參數(shù)：        devid：設(shè)備ID(可為空)
  330. //                                send_buf：json緩存buf
  331. //                                send_len：json總長
  332. //                                type_bin_head：bin文件的消息頭
  333. //                                type：類型
  334. //        返回參數(shù)：        0-成功                1-失敗
  335. //        說明：               
  336. //==========================================================
  337. uint1 MQTT_PacketSaveData(const int8 *devid, int16 send_len, int8 *type_bin_head, uint8 type, MQTT_PACKET_STRUCTURE *mqttPacket)
  338. {
  339.         if(type==5)//type=5，json類型的打包函數(shù)
  340.         {
  341.                 if(MQTT_PacketPublish(MQTT_PUBLISH_ID, "$dp", NULL, send_len + 3, MQTT_QOS_LEVEL1, 0, 1, mqttPacket) == 0)
  342.                 {
  343.                         mqttPacket->_data[mqttPacket->_len++] = type;                                        //類型
  344.                         
  345.                         mqttPacket->_data[mqttPacket->_len++] = MOSQ_MSB(send_len);
  346.                         mqttPacket->_data[mqttPacket->_len++] = MOSQ_LSB(send_len);
  347.                         
  348.                         return 0;
  349.                 }
  350.                 else
  351.                         return 1;
  352.         }
  353.         if(type==2)//type=2，二進(jìn)制類型的打包函數(shù)
  354.         {
  355.                 if(MQTT_PacketPublish(MQTT_PUBLISH_ID, "$dp", NULL, send_len, MQTT_QOS_LEVEL1, 0, 1, mqttPacket)==0)
  356.                         return 0;
  357.                 else
  358.                         return 1;
  359.         }

  361.         return 1;
  362. }


  365. //==========================================================
  366. //        函數(shù)名稱：        MQTT_UnPacketCmd
  367. //        函數(shù)功能：        命令下發(fā)解包
  368. //        入口參數(shù)：        rev_data：接收的數(shù)據(jù)指針
  369. //                                cmdid：cmdid-uuid
  370. //                                req：命令
  371. //        返回參數(shù)：        0-成功                其他-失敗原因
  372. //        說明：               
  373. //==========================================================
  374. uint8 MQTT_UnPacketCmd(uint8 *rev_data, int8 **cmdid, int8 **req)
  375. {

  377.         int8 *dataPtr = strchr((int8 *)rev_data + 3, '/');        //加3是跳過頭信息
  378.         
  379.         uint32 remain_len = 0;
  380.         uint16 req_len = 0;
  381.         
  382.         if(dataPtr == NULL)                                                                        //未找到'/'
  383.                 return 1;
  384.         dataPtr++;                                                                                        //跳過'/'
  385.         
  386.         MQTT_ReadLength(rev_data + 1, 4, &remain_len);                //讀取剩余字節(jié)
  387.         
  388.         *cmdid = (int8 *)MQTT_MallocBuffer(37);                                //cmdid固定36字節(jié)，多分配一個(gè)結(jié)束符的位置
  389.         if(*cmdid == NULL)
  390.                 return 2;
  391.         
  392.         memset(*cmdid, 0, 37);                                                                //全部清零
  393.         memcpy(*cmdid, (const int8 *)dataPtr, 36);                        //復(fù)制cmdid
  394.         dataPtr += 36;
  395.         
  396.         req_len = remain_len - 44;                                                        //命令長度 = 剩余長度(remain_len) - 2 - 5($creq) - 1(\) - cmdid長度
  397.         *req = (int8 *)MQTT_MallocBuffer(req_len + 1);                //分配命令長度+1
  398.         if(*req == NULL)
  399.         {
  400.                 MQTT_FreeBuffer(*cmdid);
  401.                 return 3;
  402.         }
  403.         
  404.         memset(*req, 0, req_len + 1);                                                //清零
  405.         memcpy(*req, (const int8 *)dataPtr, req_len);                //復(fù)制命令
  406.         
  407.         return 0;

  409. }




  414. //==========================================================
  415. //        函數(shù)名稱：        MQTT_PacketSubscribe
  416. //        函數(shù)功能：        Subscribe消息組包
  417. //        入口參數(shù)：        pkt_id：pkt_id
  418. //                                qos：消息重發(fā)次數(shù)
  419. //                                topics：訂閱的消息
  420. //                                topics_cnt：訂閱的消息個(gè)數(shù)
  421. //                                mqttPacket：包指針
  422. //        返回參數(shù)：        0-成功                其他-失敗
  423. //        說明：               
  424. //==========================================================
  425. uint8 MQTT_PacketSubscribe(uint16 pkt_id, enum MqttQosLevel qos, const int8 *topics[], uint8 topics_cnt, MQTT_PACKET_STRUCTURE *mqttPacket)
  426. {
  427.         
  428.         uint32 topic_len = 0, remain_len = 0;
  429.         int16 len = 0;
  430.         uint8 i = 0;
  431.         
  432.         if(pkt_id == 0)
  433.                 return 1;
  434.         
  435.         //計(jì)算topic長度-------------------------------------------------------------------------
  436.         for(; i < topics_cnt; i++)
  437.         {
  438.                 if(topics[i] == NULL)
  439.                         return 2;
  440.                
  441.                 topic_len += strlen(topics[i]);
  442.         }
  443.         
  444.         //2 bytes packet id + topic filter(2 bytes topic + topic length + 1 byte reserve)------
  445.         remain_len = 2 + 3 * topics_cnt + topic_len;
  446.         
  447.         //分配內(nèi)存------------------------------------------------------------------------------
  448.         MQTT_NewBuffer(mqttPacket, remain_len + 5);
  449.         if(mqttPacket->_data == NULL)
  450.                 return 3;
  451.         
  452. /*************************************固定頭部***********************************************/
  453.         
  454.         //固定頭部----------------------頭部消息-------------------------------------------------
  455.         mqttPacket->_data[mqttPacket->_len++] = MQTT_PKT_SUBSCRIBE << 4 | 0x02;
  456.         
  457.         //固定頭部----------------------剩余長度值-----------------------------------------------
  458.         len = MQTT_DumpLength(remain_len, mqttPacket->_data + mqttPacket->_len);
  459.         if(len < 0)
  460.         {
  461.                 MQTT_DeleteBuffer(mqttPacket);
  462.                 return 4;
  463.         }
  464.         else
  465.                 mqttPacket->_len += len;
  466.         
  467. /*************************************payload***********************************************/
  468.         
  469.         //payload----------------------pkt_id---------------------------------------------------
  470.         mqttPacket->_data[mqttPacket->_len++] = MOSQ_MSB(pkt_id);
  471.         mqttPacket->_data[mqttPacket->_len++] = MOSQ_LSB(pkt_id);
  472.         
  473.         //payload----------------------topic_name-----------------------------------------------
  474.         for(i = 0; i < topics_cnt; i++)
  475.         {
  476.                 topic_len = strlen(topics[i]);
  477.                 mqttPacket->_data[mqttPacket->_len++] = MOSQ_MSB(topic_len);
  478.                 mqttPacket->_data[mqttPacket->_len++] = MOSQ_LSB(topic_len);
  479.                
  480.                 strncat((int8 *)mqttPacket->_data + mqttPacket->_len, topics[i], topic_len);
  481.                 mqttPacket->_len += topic_len;
  482.                
  483.                 mqttPacket->_data[mqttPacket->_len++] = qos & 0xFF;
  484.         }

  486.         return 0;

  488. }


  491. //==========================================================
  492. //        函數(shù)名稱：        MQTT_UnPacketSubscrebe
  493. //        函數(shù)功能：        Subscribe的回復(fù)消息解包
  494. //        入口參數(shù)：        rev_data：接收到的信息
  495. //        返回參數(shù)：        0-成功                其他-失敗
  496. //        說明：               
  497. //==========================================================
  498. uint8 MQTT_UnPacketSubscribe(uint8 *rev_data)
  499. {
  500.         
  501.         uint8 result = 255;

  503.         if(rev_data[2] == MOSQ_MSB(MQTT_SUBSCRIBE_ID) && rev_data[3] == MOSQ_LSB(MQTT_SUBSCRIBE_ID))
  504.         {
  505.                 switch(rev_data[4])
  506.                 {
  507.                         case 0x00:
  508.                         case 0x01:
  509.                         case 0x02:
  510.                                 //MQTT Subscribe OK
  511.                                 result = 0;
  512.                         break;
  513.                         
  514.                         case 0x80:
  515.                                 //MQTT Subscribe Failed
  516.                                 result = 1;
  517.                         break;
  518.                         
  519.                         default:
  520.                                 //MQTT Subscribe UnKnown Err
  521.                                 result = 2;
  522.                         break;
  523.                 }
  524.         }
  525.         
  526.         return result;

  528. }




  533. //==========================================================
  534. //        函數(shù)名稱：        MQTT_PacketPublishAck
  535. //        函數(shù)功能：        Publish Ack消息組包
  536. //        入口參數(shù)：        pkt_id：packet id
  537. //                                mqttPacket：包指針
  538. //        返回參數(shù)：        0-成功                1-失敗原因
  539. //        說明：                當(dāng)收到的Publish消息的QoS等級為1時(shí)，需要Ack回復(fù)
  540. //==========================================================
  541. uint1 MQTT_PacketPublishAck(uint16 pkt_id, MQTT_PACKET_STRUCTURE *mqttPacket)
  542. {

  544.         MQTT_NewBuffer(mqttPacket, 4);
  545.         if(mqttPacket->_data == NULL)
  546.                 return 1;
  547.         
  548. /*************************************固定頭部***********************************************/
  549.         
  550.         //固定頭部----------------------頭部消息-------------------------------------------------
  551.         mqttPacket->_data[mqttPacket->_len++] = MQTT_PKT_PUBACK << 4;
  552.         
  553.         //固定頭部----------------------剩余長度-------------------------------------------------
  554.         mqttPacket->_data[mqttPacket->_len++] = 2;
  555.         
  556. /*************************************可變頭部***********************************************/
  557.         
  558.         //可變頭部----------------------pkt_id長度-----------------------------------------------
  559.         mqttPacket->_data[mqttPacket->_len++] = pkt_id >> 8;
  560.         mqttPacket->_data[mqttPacket->_len++] = pkt_id & 0xff;
  561.         
  562.         return 0;

  564. }


  567. //==========================================================
  568. //        函數(shù)名稱：        MQTT_UnPacketPublishAck
  569. //        函數(shù)功能：        Publish Ack消息解包
  570. //        入口參數(shù)：        rev_data：收到的數(shù)據(jù)
  571. //        返回參數(shù)：        0-成功                1-失敗原因
  572. //        說明：               
  573. //==========================================================
  574. uint1 MQTT_UnPacketPublishAck(uint8 *rev_data)
  575. {

  577.         if(rev_data[1] != 2)
  578.                 return 1;

  580.         if(rev_data[2] == MOSQ_MSB(MQTT_PUBLISH_ID) && rev_data[3] == MOSQ_LSB(MQTT_PUBLISH_ID))
  581.                 return 0;
  582.         else
  583.                 return 1;

  585. }


  588. //==========================================================
  589. //        函數(shù)名稱：        MQTT_PacketPublishRec
  590. //        函數(shù)功能：        Publish Rec消息組包
  591. //        入口參數(shù)：        pkt_id：packet id
  592. //                                mqttPacket：包指針
  593. //        返回參數(shù)：        0-成功                1-失敗原因
  594. //        說明：                當(dāng)收到的Publish消息的QoS等級為2時(shí)，先收到rec
  595. //==========================================================
  596. uint1 MQTT_PacketPublishRec(uint16 pkt_id, MQTT_PACKET_STRUCTURE *mqttPacket)
  597. {

  599.         MQTT_NewBuffer(mqttPacket, 4);
  600.         if(mqttPacket->_data == NULL)
  601.                 return 1;
  602.         
  603. /*************************************固定頭部***********************************************/
  604.         
  605.         //固定頭部----------------------頭部消息-------------------------------------------------
  606.         mqttPacket->_data[mqttPacket->_len++] = MQTT_PKT_PUBREC << 4;
  607.         
  608.         //固定頭部----------------------剩余長度-------------------------------------------------
  609.         mqttPacket->_data[mqttPacket->_len++] = 2;
  610.         
  611. /*************************************可變頭部***********************************************/
  612.         
  613.         //可變頭部----------------------pkt_id長度-----------------------------------------------
  614.         mqttPacket->_data[mqttPacket->_len++] = pkt_id >> 8;
  615.         mqttPacket->_data[mqttPacket->_len++] = pkt_id & 0xff;
  616.         
  617.         return 0;

  619. }


  622. //==========================================================
  623. //        函數(shù)名稱：        MQTT_UnPacketPublishRec
  624. //        函數(shù)功能：        Publish Rec消息解包
  625. //        入口參數(shù)：        rev_data：接收到的數(shù)據(jù)
  626. //        返回參數(shù)：        0-成功                1-失敗
  627. //        說明：               
  628. //==========================================================
  629. uint1 MQTT_UnPacketPublishRec(uint8 *rev_data)
  630. {

  632.         if(rev_data[1] != 2)
  633.                 return 1;

  635.         if(rev_data[2] == MOSQ_MSB(MQTT_PUBLISH_ID) && rev_data[3] == MOSQ_LSB(MQTT_PUBLISH_ID))
  636.                 return 0;
  637.         else
  638.                 return 1;

  640. }


  643. //==========================================================
  644. //        函數(shù)名稱：        MQTT_PacketPublishRel
  645. //        函數(shù)功能：        Publish Rel消息組包
  646. //        入口參數(shù)：        pkt_id：packet id
  647. //                                mqttPacket：包指針
  648. //        返回參數(shù)：        0-成功                1-失敗原因
  649. //        說明：                當(dāng)收到的Publish消息的QoS等級為2時(shí)，先收到rec，再回復(fù)rel
  650. //==========================================================
  651. uint1 MQTT_PacketPublishRel(uint16 pkt_id, MQTT_PACKET_STRUCTURE *mqttPacket)
  652. {

  654.         MQTT_NewBuffer(mqttPacket, 4);
  655.         if(mqttPacket->_data == NULL)
  656.                 return 1;
  657.         
  658. /*************************************固定頭部***********************************************/
  659.         
  660.         //固定頭部----------------------頭部消息-------------------------------------------------
  661.         mqttPacket->_data[mqttPacket->_len++] = MQTT_PKT_PUBREL << 4 | 0x02;
  662.         
  663.         //固定頭部----------------------剩余長度-------------------------------------------------
  664.         mqttPacket->_data[mqttPacket->_len++] = 2;
  665.         
  666. /*************************************可變頭部***********************************************/
  667.         
  668.         //可變頭部----------------------pkt_id長度-----------------------------------------------
  669.         mqttPacket->_data[mqttPacket->_len++] = pkt_id >> 8;
  670.         mqttPacket->_data[mqttPacket->_len++] = pkt_id & 0xff;
  671.         
  672.         return 0;

  674. }


  677. //==========================================================
  678. //        函數(shù)名稱：        MQTT_UnPacketPublishRel
  679. //        函數(shù)功能：        Publish Rel消息解包
  680. //        入口參數(shù)：        rev_data：接收到的數(shù)據(jù)
  681. //        返回參數(shù)：        0-成功                1-失敗
  682. //        說明：               
  683. //==========================================================
  684. uint1 MQTT_UnPacketPublishRel(uint8 *rev_data, uint16 pkt_id)
  685. {

  687.         if(rev_data[1] != 2)
  688.                 return 1;

  690.         if(rev_data[2] == MOSQ_MSB(pkt_id) && rev_data[3] == MOSQ_LSB(pkt_id))
  691.                 return 0;
  692.         else
  693.                 return 1;

  695. }


  698. //==========================================================
  699. //        函數(shù)名稱：        MQTT_PacketPublishComp
  700. //        函數(shù)功能：        Publish Comp消息組包
  701. //        入口參數(shù)：        pkt_id：packet id
  702. //                                mqttPacket：包指針
  703. //        返回參數(shù)：        0-成功                1-失敗原因
  704. //        說明：                當(dāng)收到的Publish消息的QoS等級為2時(shí)，先收到rec，再回復(fù)rel
  705. //==========================================================
  706. uint1 MQTT_PacketPublishComp(uint16 pkt_id, MQTT_PACKET_STRUCTURE *mqttPacket)
  707. {

  709.         MQTT_NewBuffer(mqttPacket, 4);
  710.         if(mqttPacket->_data == NULL)
  711.                 return 1;
  712.         
  713. /*************************************固定頭部***********************************************/
  714.         
  715.         //固定頭部----------------------頭部消息-------------------------------------------------
  716.         mqttPacket->_data[mqttPacket->_len++] = MQTT_PKT_PUBCOMP << 4;
  717.         
  718.         //固定頭部----------------------剩余長度-------------------------------------------------
  719.         mqttPacket->_data[mqttPacket->_len++] = 2;
  720.         
  721. /*************************************可變頭部***********************************************/
  722.         
  723.         //可變頭部----------------------pkt_id長度-----------------------------------------------
  724.         mqttPacket->_data[mqttPacket->_len++] = pkt_id >> 8;
  725.         mqttPacket->_data[mqttPacket->_len++] = pkt_id & 0xff;
  726.         
  727.         return 0;

  729. }


  732. //==========================================================
  733. //        函數(shù)名稱：        MQTT_UnPacketPublishComp
  734. //        函數(shù)功能：        Publish Comp消息解包
  735. //        入口參數(shù)：        rev_data：接收到的數(shù)據(jù)
  736. //        返回參數(shù)：        0-成功                1-失敗
  737. //        說明：               
  738. //==========================================================
  739. uint1 MQTT_UnPacketPublishComp(uint8 *rev_data)
  740. {

  742.         if(rev_data[1] != 2)
  743.                 return 1;

  745.         if(rev_data[2] == MOSQ_MSB(MQTT_PUBLISH_ID) && rev_data[3] == MOSQ_LSB(MQTT_PUBLISH_ID))
  746.                 return 0;
  747.         else
  748.                 return 1;

  750. }


  753. //==========================================================
  754. //        函數(shù)名稱：        MQTT_PacketPing
  755. //        函數(shù)功能：        心跳請求組包
  756. //        入口參數(shù)：        mqttPacket：包指針
  757. //        返回參數(shù)：        0-成功                1-失敗
  758. //        說明：               
  759. //==========================================================
  760. uint1 MQTT_PacketPing(MQTT_PACKET_STRUCTURE *mqttPacket)
  761. {

  763.         MQTT_NewBuffer(mqttPacket, 2);
  764.         if(mqttPacket->_data == NULL)
  765.                 return 1;
  766.         
  767. /*************************************固定頭部***********************************************/
  768.         
  769.         //固定頭部----------------------頭部消息-------------------------------------------------
  770.         mqttPacket->_data[mqttPacket->_len++] = MQTT_PKT_PINGREQ << 4;
  771.         
  772.         //固定頭部----------------------剩余長度-------------------------------------------------
  773.         mqttPacket->_data[mqttPacket->_len++] = 0;
  774.         
  775.         return 0;

  777. }
復(fù)制代碼

Keil代碼下載: ESP8266和MQTT協(xié)議.7z (107.22 KB, 下載次數(shù): 112)

評分

參與人數(shù) 1黑幣 +50 收起 理由
admin + 50 共享資料的黑幣獎勵！

查看全部評分

分享到:  QQ好友和群QQ好友和群 QQ空間QQ空間 騰訊微博騰訊微博 騰訊朋友騰訊朋友
收藏收藏6 分享淘帖 頂頂1 踩踩
回復(fù)

使用道具 舉報(bào)

沙發(fā)
ID:1039898 發(fā)表于 2022-7-19 15:45 | 只看該作者
寫的很好
回復(fù)

使用道具 舉報(bào)

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

本版積分規(guī)則

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

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

快速回復(fù) 返回頂部 返回列表