ESP8266學習筆記（13）——HTTP服務器（NONOS SDK）

一、背景

首先手機APP連接智能插座熱點（AP）將網(wǎng)關的SSID和密碼通過HTTP協(xié)議配置到插座梁丘，完成配置后智能插座連接網(wǎng)關侵浸。

Post請求和Get請求：

二、流程

2.1 定義相關變量及宏

/*********************************************************************
 * LOCAL VARIABLES
 */
static struct espconn s_httpSvrTcpEspconn;  // HTTP服務器TCP連接結構體

/*********************************************************************
 * DEFINITIONS
 */
#define URL_SIZE                    20
#define REQUEST_DATA_SIZE           1024
#define RESPONSE_DATA_SIZE          256

#define GET     0
#define POST    1

#define HTTP_SERVER_RESPONSE_FRAME "HTTP/1.0 %s\r\n\
Content-Length: %d\r\n\
Server: lwIP/1.4.0\r\n\
Content-type: application/json\r\n\
Expires: Fri, 10 Apr 2008 14:00:00 GMT\r\n\
Pragma: no-cache\r\n\r\n\
%s"

/*********************************************************************
 * TYPEDEFS
 */
typedef struct urlFrame_t
{
    uint8 type;
    char select[URL_SIZE];
    char command[URL_SIZE];
    char filename[URL_SIZE];
} UrlFrame_t;

2.2 初始化HTTP服務器

/*********************************************************************
 * PUBLIC FUNCTIONS
 */
/**
 @brief HTTP服務器初始化
 @param 無
 @return 無
*/
void ICACHE_FLASH_ATTR
HttpServerInit(void)
{
    s_httpSvrTcpEspconn.type = ESPCONN_TCP;
    s_httpSvrTcpEspconn.state = ESPCONN_NONE;
    s_httpSvrTcpEspconn.proto.tcp = (esp_tcp *) os_zalloc(sizeof(esp_tcp));
    s_httpSvrTcpEspconn.proto.tcp->local_port = 80;
    espconn_regist_connectcb(&s_httpSvrTcpEspconn, connectCallback);

    espconn_accept(&s_httpSvrTcpEspconn);    // 開啟監(jiān)聽
}

/*********************************************************************
 * LOCAL FUNCTIONS
 */
/**
 @brief 連接成功的回調函數(shù)
 @param arg -[in] 指向傳遞給這個回調函數(shù)來使用的參數(shù)
 @return 無
*/
static void ICACHE_FLASH_ATTR
connectCallback(void *arg)
{
    struct espconn *pEspconn = arg;

    espconn_regist_recvcb(pEspconn, receiveDataCallback);
    espconn_regist_disconcb(pEspconn, disconnectCallback);
}

/**
 @brief 接收數(shù)據(jù)的回調函數(shù)
 @param arg -[in] 指向傳遞給這個回調函數(shù)來使用的參數(shù)
 @param pData -[in] 接收的數(shù)據(jù)
 @param len -[in] 接收的數(shù)據(jù)長度
 @return 無
*/
static void ICACHE_FLASH_ATTR
receiveDataCallback(void *arg, char *pData, unsigned short len)
{
    if(checkDataIntegrity(pData, len) == false)
    {
        return ;
    }
    os_printf("recvData:  %s\n", pData);

    UrlFrame_t urlFrame;
    char requestData[REQUEST_DATA_SIZE] = {0};

    findRequestData(pData, requestData);
    parseUrl(pData, &urlFrame);

    switch(urlFrame.type)
    {
    case GET:
        os_printf("We have a GET request.\n");
        handleGetUrlPath(&urlFrame, requestData);
        break;
    case POST:
        os_printf("We have a POST request.\n");
        handlePostUrlPath(&urlFrame, requestData);
        break;
    default:
        break;
    }
}

/**
 @brief 斷連的回調函數(shù)
 @param arg -[in] 指向傳遞給這個回調函數(shù)來使用的參數(shù)
 @return 無
*/
static void ICACHE_FLASH_ATTR
disconnectCallback(void *arg)
{
    struct espconn *pEspconn = arg;

    os_printf("httpserver's %d.%d.%d.%d:%d disconnect\n",
                pEspconn->proto.tcp->remote_ip[0], pEspconn->proto.tcp->remote_ip[1],
                pEspconn->proto.tcp->remote_ip[2], pEspconn->proto.tcp->remote_ip[3],
                pEspconn->proto.tcp->remote_port);
}

2.3 處理接收數(shù)據(jù)

2.3.1 檢查數(shù)據(jù)完整性

/**
 @brief 檢查數(shù)據(jù)完整性
 @param pRecvData -[in] 接收的數(shù)據(jù)
 @param recvDatalen -[in] 接收的數(shù)據(jù)長度
 @return 1 - 數(shù)據(jù)完整氛谜；0 - 數(shù)據(jù)缺失
*/
static bool ICACHE_FLASH_ATTR
checkDataIntegrity(char *pRecvData, uint16 recvDatalen)
{
    if(!pRecvData)
    {
        return false;
    }

    char lenBuffer[10] = {0};
    char *pTemp = NULL;
    char *pData = NULL;
    char *pTempRecvData;
    uint16 tempLen = recvDatalen;
    uint32 tempTotalLen = 0;
    uint32 dataSumLen = 0;

    pTemp = (char *) os_strstr(pRecvData, "\r\n\r\n");

    if(pTemp != NULL)
    {
        tempLen -= pTemp - pRecvData;
        tempLen -= 4;
        tempTotalLen += tempLen;

        pData = (char *) os_strstr(pRecvData, "Content-Length: ");

        if(pData != NULL)
        {
            pData += 16;
            pTempRecvData = (char *) os_strstr(pData, "\r\n");

            if(pTempRecvData != NULL)
            {
                os_memcpy(lenBuffer, pData, pTempRecvData - pData);
                dataSumLen = atoi(lenBuffer);
                os_printf("A_dat:%u,total:%u,lenght:%u\n",dataSumLen, tempTotalLen, tempLen);

                if(dataSumLen != tempTotalLen)
                {
                    return false;
                }

                return true;
            }
        }
        else
        {
            return true;
        }
    }

    return false;
}

2.3.2 查找請求數(shù)據(jù)

/**
 @brief 查找請求數(shù)據(jù)
 @param pRecvData -[in] 接收的數(shù)據(jù)
 @param pRequestData -[in&out] 請求的數(shù)據(jù)
 @return 無
*/
static void ICACHE_FLASH_ATTR
findRequestData(char *pRecvData, char *pRequestData)
{
    char *pRequestDataStart = NULL;
    char *pRequestDataEnd = NULL;

    pRequestDataStart = strchr(pRecvData, '{');
    if(pRequestDataStart != NULL)
    {
        pRequestDataEnd = strrchr(pRecvData, '}');
        if(pRequestDataEnd != NULL)
        {
            os_memcpy(pRequestData, pRequestDataStart, pRequestDataEnd - pRequestDataStart + 1);
        }
    }

    pRequestData[pRequestDataEnd - pRequestDataStart + 1] = '\0';
}

2.3.3 解析URL

/**
 @brief 解析URL
 @param pRecvData -[in] 接收的數(shù)據(jù)
 @param pUrlFrame -[in&out] URL框架
 @return 無
*/
static void ICACHE_FLASH_ATTR
parseUrl(char *pRecvData, UrlFrame_t *pUrlFrame)
{
    if(pUrlFrame == NULL || pRecvData == NULL)
    {
        return ;
    }

    char *pStr = NULL;
    uint8 length = 0;
    char *pBuffer = NULL;
    char *pBuf = NULL;

    pBuffer = (char *) os_strstr(pRecvData, "Host:");

    if(pBuffer != NULL)
    {
        length = pBuffer - pRecvData;
        pBuf = (char *)os_zalloc(length + 1);
        pBuffer = pBuf;
        os_memcpy(pBuffer, pRecvData, length);
        os_memset(pUrlFrame->select, 0, URL_SIZE);
        os_memset(pUrlFrame->command, 0, URL_SIZE);
        os_memset(pUrlFrame->filename, 0, URL_SIZE);

        if(os_strncmp(pBuffer, "GET ", 4) == 0)
        {
            pUrlFrame->type = GET;
            pBuffer += 4;
        }
        else if(os_strncmp(pBuffer, "POST ", 5) == 0)
        {
            pUrlFrame->type = POST;
            pBuffer += 5;
        }

        pBuffer++;
        pStr = (char *) os_strstr(pBuffer, "?");

        if(pStr != NULL)
        {
            length = pStr - pBuffer;
            os_memcpy(pUrlFrame->select, pBuffer, length);
            pStr++;
            pBuffer = (char *) os_strstr(pStr, "=");

            if(pBuffer != NULL)
            {
                length = pBuffer - pStr;
                os_memcpy(pUrlFrame->command, pStr, length);
                pBuffer++;
                pStr = (char *) os_strstr(pBuffer, "&");

                if(pStr != NULL)
                {
                    length = pStr - pBuffer;
                    os_memcpy(pUrlFrame->filename, pBuffer, length);
                }
                else
                {
                    pStr = (char *) os_strstr(pBuffer, " HTTP");

                    if(pStr != NULL)
                    {
                        length = pStr - pBuffer;
                        os_memcpy(pUrlFrame->filename, pBuffer, length);
                    }
                }
            }
        }

        os_free(pBuf);
    }
}

2.3.4 解析GET請求URL

cJSON使用查看 ESP8266學習筆記（8）——第三方庫cJSON使用

以查詢繼電器狀態(tài)為例
HTTP Header中
GET /config?command=switch HTTP/1.1

/**
 @brief 處理GET請求URL路徑
 @param pUrlFrame -[in] URL框架
 @param pRequestData -[in] 請求的數(shù)據(jù)
 @return 無
*/
static void ICACHE_FLASH_ATTR
handleGetUrlPath(UrlFrame_t *pUrlFrame, char *pRequestData)
{
    os_printf("Type:%d, Select:%s, Command:%s, Filename:%s ",
    pUrlFrame->type, pUrlFrame->select, pUrlFrame->command, pUrlFrame->filename);
    if(os_strcmp(pUrlFrame->select, "config") == 0)
    {
        if(os_strcmp(pUrlFrame->command, "command") == 0)
        {
            if(os_strcmp(pUrlFrame->filename, "switch") == 0)
            {
                sendRelayStatusResponse();
            }
        }
    }
}

2.3.4.1 封裝繼電器狀態(tài)響應包

/**
 @brief 發(fā)送繼電器狀態(tài)響應
 @param pRequestData -[in] 請求的數(shù)據(jù)
 @return 無
*/
static void ICACHE_FLASH_ATTR
sendRelayStatusResponse(void)
{
    char sendData[RESPONSE_DATA_SIZE] = {0};
    jsonPackageRelayStatusData(true, sendData);
    sendGetResponse(true, sendData);
}

/**
 @brief JSON格式封裝繼電器狀態(tài)數(shù)據(jù)
 @param responseOk -[in] 響應是否成功
 @param pSendData -[in&out] 要封裝的發(fā)送數(shù)據(jù)
 @return 無
*/
static void ICACHE_FLASH_ATTR
jsonPackageRelayStatusData(bool responseOk, char *pSendData)
{
    if(!pSendData)
    {
        return ;
    }

    cJSON *pRoot = cJSON_CreateObject();

    uint16 statusCode;

    if(responseOk)
    {
        statusCode = 200;
    }
    else
    {
        statusCode = 400;
    }

    cJSON_AddNumberToObject(pRoot, "status", statusCode);
    cJSON_AddNumberToObject(pRoot, "switch", GetRelayStatus()); // 加入自己的獲取繼電器狀態(tài)函數(shù)
    char *tempBuffer = cJSON_Print(pRoot);
    os_sprintf(pSendData, "%s", tempBuffer);

    os_free((void *) tempBuffer);
    cJSON_Delete(pRoot);
}

2.3.4.2 發(fā)送繼電器狀態(tài)響應包

/**
 @brief 發(fā)送GET請求HTTP響應
 @param responseOk -[in] 響應是否成功
 @param pResponseData -[in] 響應數(shù)據(jù)
 @return 無
*/
static void ICACHE_FLASH_ATTR
sendGetResponse(bool responseOk, char *pResponseData)
{
    char sendData[RESPONSE_DATA_SIZE] = {0};
    char responseCode[15] = {0};

    if(responseOk)
    {
        os_sprintf(responseCode, "200 OK", os_strlen(responseCode));
    }
    else
    {
        os_sprintf(responseCode, "400 BadRequest", os_strlen(responseCode));
    }

    os_sprintf(sendData, HTTP_SERVER_RESPONSE_FRAME, responseCode, os_strlen(pResponseData), pResponseData);

    espconn_sent(&s_httpSvrTcpEspconn, sendData, os_strlen(sendData));
}

2.3.5 解析POST請求URL

cJSON使用查看 ESP8266學習筆記（8）——第三方庫cJSON使用
以設置繼電器狀態(tài)為例
HTTP Header中
POST /config?command=switch HTTP/1.1

/**
 @brief 處理POST請求URL路徑
 @param pUrlFrame -[in] URL框架
 @param pRequestData -[in] 請求的數(shù)據(jù)
 @return 無
*/
static void ICACHE_FLASH_ATTR
handlePostUrlPath(UrlFrame_t *pUrlFrame, char *pRequestData)
{
    os_printf("Type:%d, Select:%s, Command:%s, Filename:%s ",
    pUrlFrame->type, pUrlFrame->select, pUrlFrame->command, pUrlFrame->filename);

    if(os_strcmp(pUrlFrame->select, "config") == 0)
    {
        if(os_strcmp(pUrlFrame->command, "command") == 0)
        {
            if(os_strcmp(pUrlFrame->filename, "switch") == 0)
            {
                configRelayStatus(pRequestData);
            }
        }
    }
}

2.3.5.1 解析設置繼電器狀態(tài)

/**
 @brief 配置繼電器開關接口
 @param pRequestData -[in] 請求的數(shù)據(jù)
 @return 無
*/
static void ICACHE_FLASH_ATTR
configRelayStatus(char *pRequestData)
{
    if(!pRequestData)
    {
        return ;
    }

    cJSON *pRoot = cJSON_Parse(pRequestData);
    if(!pRoot)
    {
        return ;
    }

    char sendData[RESPONSE_DATA_SIZE] = {0};
    cJSON *pRequest = cJSON_GetObjectItem(pRoot, "request");                        // 解析request字段內容
    if(!pRequest)
    {
        os_sprintf(sendData, "%s", "No request Item");
        sendPostResponse(false, sendData);
        cJSON_Delete(pRoot);
        return ;
    }

    cJSON *pStatus = cJSON_GetObjectItem(pRequest, "status");                       // 解析request子節(jié)點status字段內容
    if(!pStatus)
    {
        os_sprintf(sendData, "%s", "No status Item");
        sendPostResponse(false, sendData);
        cJSON_Delete(pRoot);
        return ;
    }

    uint8 relayStatus = pStatus->valueint;
    SetRelayStatus(relayStatus);      // 加入自己設置繼電器狀態(tài)函數(shù)                                              // 設置繼電器狀態(tài)

    os_sprintf(sendData, "%s", "Config switch succeed");
    sendPostResponse(true, sendData);
    cJSON_Delete(pRoot);
}

2.3.5.2 發(fā)送響應包

/**
 @brief 發(fā)送POST請求的HTTP響應
 @param responseOk -[in] 響應是否成功
 @param pResponseData -[in] 響應數(shù)據(jù)
 @return 無
*/
static void ICACHE_FLASH_ATTR
sendPostResponse(bool responseOk, char *pResponseData)
{
    char sendData[RESPONSE_DATA_SIZE] = {0};
    char responseCode[15] = {0};

    jsonPackageResponseData(responseOk, pResponseData);

    if(responseOk)
    {
        os_sprintf(responseCode, "200 OK", os_strlen(responseCode));
    }
    else
    {
        os_sprintf(responseCode, "400 BadRequest", os_strlen(responseCode));
    }

    os_sprintf(sendData, HTTP_SERVER_RESPONSE_FRAME, responseCode, os_strlen(pResponseData), pResponseData);

    espconn_sent(&s_httpSvrTcpEspconn, sendData, os_strlen(sendData));
}

三掏觉、使用方法

? 由 Leung 寫于 2019 年 8 月 15 日

最后編輯于 ：
?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
  • 人面猴
    序言：七十年代末，一起剝皮案震驚了整個濱河市值漫，隨后出現(xiàn)的幾起案子澳腹，更是在濱河造成了極大的恐慌，老刑警劉巖，帶你破解...
    沈念sama閱讀 221,635評論 6贊 515
  • 死咒
    序言：濱河連續(xù)發(fā)生了三起死亡事件遵湖，死亡現(xiàn)場離奇詭異悔政，居然都是意外死亡，警方通過查閱死者的電腦和手機延旧，發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 94,543評論 3贊 399
  • 救了他兩次的神仙讓他今天三更去死
    文/潘曉璐 我一進店門谋国，熙熙樓的掌柜王于貴愁眉苦臉地迎上來，“玉大人迁沫，你說我怎么就攤上這事芦瘾。” “怎么了集畅？”我有些...
    開封第一講書人閱讀 168,083評論 0贊 360
  • 道士緝兇錄：失蹤的賣姜人
    文/不壞的土叔 我叫張陵近弟，是天一觀的道長。 經(jīng)常有香客問我挺智，道長祷愉，這世上最難降的妖魔是什么？ 我笑而不...
    開封第一講書人閱讀 59,640評論 1贊 296
  • ?港島之戀（遺憾婚禮）
    正文 為了忘掉前任赦颇，我火速辦了婚禮二鳄，結果婚禮上，老公的妹妹穿的比我還像新娘媒怯。我一直安慰自己订讼，他們只是感情好，可當我...
    茶點故事閱讀 68,640評論 6贊 397
  • 惡毒庶女頂嫁案：這布局不是一般人想出來的
    文/花漫 我一把揭開白布扇苞。 她就那樣靜靜地躺著欺殿，像睡著了一般。 火紅的嫁衣襯著肌膚如雪鳖敷。 梳的紋絲不亂的頭發(fā)上脖苏，一...
    開封第一講書人閱讀 52,262評論 1贊 308
  • 城市分裂傳說
    那天，我揣著相機與錄音哄陶，去河邊找鬼帆阳。 笑死，一個胖子當著我的面吹牛屋吨，可吹牛的內容都是我干的。 我是一名探鬼主播山宾，決...
    沈念sama閱讀 40,833評論 3贊 421
  • 雙鴛鴦連環(huán)套：你想象不到人心有多黑
    文/蒼蘭香墨 我猛地睜開眼至扰，長吁一口氣：“原來是場噩夢啊……” “哼！你這毒婦竟也來了资锰？” 一聲冷哼從身側響起敢课，我...
    開封第一講書人閱讀 39,736評論 0贊 276
  • 萬榮殺人案實錄
    序言：老撾萬榮一對情侶失蹤，失蹤者是張志新（化名）和其女友劉穎，沒想到半個月后直秆，有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體濒募，經(jīng)...
    沈念sama閱讀 46,280評論 1贊 319
  • ?護林員之死
    正文 獨居荒郊野嶺守林人離奇死亡，尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內容為張勛視角 年9月15日...
    茶點故事閱讀 38,369評論 3贊 340
  • ?白月光啟示錄
    正文 我和宋清朗相戀三年圾结，在試婚紗的時候發(fā)現(xiàn)自己被綠了瑰剃。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 40,503評論 1贊 352
  • 活死人
    序言：一個原本活蹦亂跳的男人離奇死亡筝野，死狀恐怖晌姚，靈堂內的尸體忽然破棺而出，到底是詐尸還是另有隱情歇竟，我是刑警寧澤挥唠，帶...
    沈念sama閱讀 36,185評論 5贊 350
  • ?日本核電站爆炸內幕
    正文 年R本政府宣布，位于F島的核電站焕议，受9級特大地震影響宝磨，放射性物質發(fā)生泄漏。R本人自食惡果不足惜盅安，卻給世界環(huán)境...
    茶點故事閱讀 41,870評論 3贊 333
  • 男人毒藥：我在死后第九天來索命
    文/蒙蒙 一唤锉、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧宽堆，春花似錦腌紧、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,340評論 0贊 24
  • 一樁弒父案壁肋，背后竟有這般陰謀
    文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至籽慢，卻和暖如春浸遗，著一層夾襖步出監(jiān)牢的瞬間，已是汗流浹背箱亿。 一陣腳步聲響...
    開封第一講書人閱讀 33,460評論 1贊 272
  • 情欲美人皮
    我被黑心中介騙來泰國打工跛锌， 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留，地道東北人届惋。 一個月前我還...
    沈念sama閱讀 48,909評論 3贊 376
  • 代替公主和親
    正文 我出身青樓髓帽，卻偏偏與公主長得像，于是被迫代替她去往敵國和親脑豹。 傳聞我的和親對象是個殘疾皇子郑藏，可洞房花燭夜當晚...
    茶點故事閱讀 45,512評論 2贊 359

推薦閱讀更多精彩內容