欧美极品高清xxxxhd,国产日产欧美最新,无码AV国产东京热AV无码,国产精品人与动性XXX,国产传媒亚洲综合一区二区,四库影院永久国产精品,毛片免费免费高清视频,福利所导航夜趣136

標題: ESP8266和MQTT協議修改版 源程序 [打印本頁]
作者: 君陌笑    時間: 2020-5-5 23:38
標題: ESP8266和MQTT協議修改版 源程序
ESP8266+MQTT
  1. #include "onenet.h"


  4. extern unsigned char esp8266_buf[256];


  7. //==========================================================
  8. //        函數名稱：        OneNET_DevLink
  9. //        函數功能：        與onenet創建連接
  10. //        入口參數：        無
  11. //        返回參數：        1-成功        0-失敗
  12. //        說明：                與onenet平臺建立連接
  13. //==========================================================
  14. _Bool OneNET_DevLink(void)
  15. {
  16.        
  17.         MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0};                                        //協議包

  19.         unsigned char *dataPtr;
  20.        
  21.         _Bool status = 1;
  22.        
  23.         printf("OneNET_DevLink\r\n");
  24.         printf("PROID: %s,        AUIF: %s,        DEVID:%s\r\n", PROID, AUTH_INFO, DEVID);
  25.        
  26.         if(MQTT_PacketConnect(PROID, AUTH_INFO, DEVID, 256, 0, MQTT_QOS_LEVEL0, NULL, NULL, 0, &mqttPacket) == 0)
  27.         {
  28.                 ESP8266_SendData(mqttPacket._data, mqttPacket._len);                        //上傳平臺
  29.                
  30.                 dataPtr = ESP8266_GetIPD(250);                                                                        //等待平臺響應
  31.                 if(dataPtr != NULL)
  32.                 {
  33.                         if(MQTT_UnPacketRecv(dataPtr) == MQTT_PKT_CONNACK)
  34.                         {
  35.                                 switch(MQTT_UnPacketConnectAck(dataPtr))
  36.                                 {
  37.                                         case 0:printf("Tips:        連接成功\r\n");status = 0;
  38.                                                 break;
  39.                                        
  40.                                         case 1:printf("WARN:        連接失敗：協議錯誤\r\n");
  41.                                                 break;
  42.                                         case 2:printf("WARN:        連接失敗：非法的clientid\r\n");
  43.                                                 break;
  44.                                         case 3:printf("WARN:        連接失敗：服務器失敗\r\n");
  45.                                                 break;
  46.                                         case 4:printf("WARN:        連接失敗：用戶名或密碼錯誤\r\n");
  47.                                                 break;
  48.                                         case 5:printf("WARN:        連接失敗：非法鏈接(比如token非法)\r\n");
  49.                                                 break;
  50.                                        
  51.                                         default:printf("ERR:        連接失敗：未知錯誤\r\n");
  52.                                                 break;
  53.                                 }
  54.                         }
  55.                 }
  56.                
  57.                 MQTT_DeleteBuffer(&mqttPacket);                                                                //刪包
  58.         }
  59.         else
  60.                 printf( "WARN:        MQTT_PacketConnect Failed\r\n");
  61.        
  62.         return status;
  63.        
  64. }


  67. unsigned char OneNET_FillBuf(char *buf)
  68. {
  69.        
  70.         char text[32];
  71.        
  72.         memset(text, 0, sizeof(text));
  73.        
  74.         strcpy(buf, ",;");
  75.        
  76.         memset(text, 0, sizeof(text));
  77.         sprintf(text, "Tempreture,%2.1f;", 23.4);
  78.         strcat(buf, text);
  79.        
  80.         memset(text, 0, sizeof(text));
  81.         sprintf(text, "Humidity,%2.1f;", 66.8);
  82.         strcat(buf, text);
  83.        
  84.         return strlen(buf);

  86. }


  89. //json格式打包函數，type=5的方式
  90. int MqttSample_PackDataByJson5(char *buf)
  91. {
  92.        
  93.         char text[32];
  94.        
  95.         memset(text, 0, sizeof(text));
  96.        
  97.         strcpy(buf, ",;");
  98.        
  99.         memset(text, 0, sizeof(text));
  100.         sprintf(text, "Tempreture,%2.1f;", 23.4);
  101.         strcat(buf, text);
  102.        
  103.         memset(text, 0, sizeof(text));
  104.         sprintf(text, "Humidity,%2.1f;", 66.8);
  105.         strcat(buf, text);
  106.        
  107.         return strlen(buf);

  109. }


  112. //MQTT協議采用type=2方式封裝數據函數（二進制發送數據）
  113. //payload:存儲打包的數據
  114. //bin是發送的數組的首地址
  115. //size是數組的長度
  116. int MqttSample_PackDataByBinary2(u8 *payload,u8 *bin, uint32_t size)
  117. {
  118.         int payload_len;
  119.     char json[]="{\"ds_id\":\"binary\"}";
  120.     unsigned short json_len;
  121.    
  122.     payload_len = 1 + 2 + strlen(json)/sizeof(char);
  123.     json_len = strlen(json)/sizeof(char);
  124.    

  126.     //Byte1，數據點類型指示：type=2,二進制數據
  127.     payload[0] = '\x02';

  129.     //Byte2、Byte3指示后面json字符串長度
  130.     payload[1] = (json_len & 0xFF00) >> 8;
  131.     payload[2] = json_len & 0xFF;

  133.         //把json復制到t_payload數組中
  134.         memcpy(payload+3, json, json_len);
  135.        
  136.        
  137.         payload[payload_len] = (size & 0xFF000000)>>24;
  138.         payload[payload_len+1]=(size & 0x00FF0000)>>16;
  139.         payload[payload_len+2]=(size & 0x0000FF00)>>8;
  140.         payload[payload_len+3]=(size & 0x000000FF);
  141.        
  142.         for(u32 i=0; i<size+4; i++)
  143.         {
  144.                 payload[payload_len+4+i]=bin[i];
  145.         }
  146.        
  147.         return payload_len+size+4;
  148. }


  151. //==========================================================
  152. //        函數名稱：        OneNET_SendData
  153. //        函數功能：        上傳數據到平臺
  154. //        入口參數：        buf: 存儲打包數據的數組
  155. //              type: 發送數據的格式
  156. //              bin: 要發送的二進制數組的首地址
  157. //              size: 要發送的二進制數組大長度
  158. //        返回參數：        無
  159. //        說明：               
  160. //==========================================================
  161. void OneNET_SendData(u8 *buf,u8 type,u8 *bin,u16 size)
  162. {
  163.        
  164.         MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0};                        //協議包
  165.        
  166.         short body_len = 0;   
  167.        
  168.         switch(type)
  169.         {
  170.                 case 5:body_len = OneNET_FillBuf((char *)buf); //獲取當前需要發送的json數據流的總長度
  171.                         break;
  172.                 case 2:body_len = MqttSample_PackDataByBinary2(buf,bin, size); //獲取當前需要發送的二進制打包數組的長度
  173.                         break;
  174.                
  175.                 default:
  176.                         break;       
  177.         }

  179.        
  180.         if(body_len)
  181.         {
  182.                         if(MQTT_PacketSaveData(DEVID,body_len, NULL, type, &mqttPacket) == 0)                //封包
  183.                         {
  184.                                 for(int i=0; i < body_len; i++)
  185.                                         mqttPacket._data[mqttPacket._len++] = buf[i];
  186.                                
  187.                                 ESP8266_SendData(mqttPacket._data, mqttPacket._len);        //上傳數據到平臺
  188.                                 printf("Send %d Bytes\r\n", mqttPacket._len);
  189.                                
  190.                                 MQTT_DeleteBuffer(&mqttPacket);                                                        //刪包
  191.                         }
  192.                         else
  193.                                 printf("WARN:        EDP_NewBuffer Failed\r\n");
  194.         }       
  195. }


  198. //==========================================================
  199. //        函數名稱：        OneNET_RevPro
  200. //        函數功能：        平臺返回數據檢測
  201. //        入口參數：        dataPtr：平臺返回的數據
  202. //        返回參數：        無
  203. //        說明：               
  204. //==========================================================
  205. void OneNET_RevPro(unsigned char *cmd)
  206. {
  207.        
  208.         MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0};                                //協議包
  209.        
  210.         char *req_payload = NULL;
  211.         char *cmdid_topic = NULL;
  212.         unsigned char type = 0;
  213.        
  214.         short result = 0;

  216.         char *dataPtr = NULL;
  217.         char numBuf[10];
  218.         int num = 0;
  219.        
  220.         type = MQTT_UnPacketRecv(cmd);
  221.         switch(type)
  222.         {
  223.                 case MQTT_PKT_CMD:                                                                                        //命令下發
  224.                        
  225.                         result = MQTT_UnPacketCmd(cmd, &cmdid_topic, &req_payload);        //解出topic和消息體
  226.                         if(result == 0)
  227.                         {
  228.                                 printf("cmdid: %s, req: %s\r\n", cmdid_topic, req_payload);
  229.                                
  230.                                 if(MQTT_PacketCmdResp(cmdid_topic, req_payload, &mqttPacket) == 0)        //命令回復組包
  231.                                 {
  232.                                         printf("Tips:        Send CmdResp\r\n");
  233.                                        
  234.                                         ESP8266_SendData(mqttPacket._data, mqttPacket._len);        //回復命令
  235.                                         MQTT_DeleteBuffer(&mqttPacket);                                                        //刪包
  236.                                 }
  237.                         }
  238.                
  239.                 break;
  240.                        
  241.                 case MQTT_PKT_PUBACK:                                                                           //發送Publish消息，平臺回復的Ack
  242.                
  243.                         if(MQTT_UnPacketPublishAck(cmd) == 0)
  244.                                 printf("Tips:        MQTT Publish Send OK\r\n");
  245.                        
  246.                 break;
  247.                
  248.                 default:
  249.                         result = -1;
  250.                 break;
  251.         }
  252.        
  253.         ESP8266_ClearBuff();                                                                        //清空緩存
  254.        
  255.         if(result == -1)
  256.                 return;
  257.        
  258.         dataPtr = strchr(req_payload, '{');                                        //搜索'}'

  260.         if(dataPtr != NULL && result != -1)                                        //如果找到了
  261.         {
  262.                 dataPtr++;
  263.                
  264.                 while(*dataPtr >= '0' && *dataPtr <= '9')                //判斷是否是下發的命令控制數據
  265.                 {
  266.                         numBuf[num++] = *dataPtr++;
  267.                 }
  268.                
  269.                 num = atoi((const char *)numBuf);                                //轉為數值形式
  270.                
  271.                 if(strstr((char *)req_payload, "redled"))                //搜索"redled"
  272.                 {
  273.                         if(num == 1)                                                                //控制數據如果為1，代表開
  274.                         {
  275.                                 LED0 = 0;
  276.                         }
  277.                         else if(num == 0)                                                        //控制數據如果為0，代表關
  278.                         {
  279.                                 LED0 = 1;
  280.                         }
  281.                 }
  282.                                                                                                                 //下同
  283.                 else if(strstr((char *)req_payload, "greenled"))
  284.                 {
  285.                         if(num == 1)
  286.                         {
  287.                                 LED1 = 0;
  288.                         }
  289.                         else if(num == 0)
  290.                         {
  291.                                 LED1 = 1;
  292.                         }
  293.                 }
  294.                 else if(strstr((char *)req_payload, "allled"))
  295.                 {
  296.                         if(num == 1)
  297.                         {
  298.                                 LED0 = 0;
  299.                                 LED1 = 0;
  300.                         }
  301.                         else if(num == 0)
  302.                         {
  303.                                 LED0 = 1;
  304.                                 LED1 = 1;
  305.                         }
  306.                 }       
  307.         }

  309.         if(type == MQTT_PKT_CMD || type == MQTT_PKT_PUBLISH)
  310.         {
  311.                 MQTT_FreeBuffer(cmdid_topic);
  312.                 MQTT_FreeBuffer(req_payload);
  313.         }
  314. }
復制代碼
  1. #include "main.h"


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


ESP8266和MQTT協議.7z

103.88 KB, 下載次數: 29, 下載積分: 黑幣 -5





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