ESP8266學(xué)習(xí)筆記(6)——HTTP客戶端

一弓坞、背景


已知智能網(wǎng)關(guān)固定 IP 地址192.168.100.1故爵,智能插座連上智能網(wǎng)關(guān) AP 熱點后筐咧,向網(wǎng)關(guān)發(fā)起心跳包 Post 請求斜棚,因此需要 ESP8266 作為 HTTP 客戶端 角色。

Post請求和Get請求:

二何鸡、流程

2.1 定義相關(guān)變量及宏

typedef struct serverUrl_t
{
    ip_addr_t ip;
    uint16 port;
    char fileName[32];
} ServerUrl_t;
ServerUrl_t g_cloudServerUrl = {637577408, 8080, "public/glegw/api"};

LOCAL char s_httpSendBuffer[1024] = {0};

LOCAL struct espconn s_cloudTcpEspconn;     // 與云服務(wù)器TCP連接結(jié)構(gòu)體

LOCAL os_timer_t s_sendHeartbeatTimer;      // 發(fā)送心跳包的定時器

#define GET_FRAME "GET /%s HTTP/1.1\r\nContent-Type: text/html;charset=utf-8\r\nAccept: */*\r\nHost: %s\r\nConnection: Keep-Alive\r\n\r\n"
#define POST_FRAME "POST /%s HTTP/1.1\r\n\
Host: %s\r\n\
Accept: */*\r\n\
Content-Length: %d\r\n\
Content-Type: application/json\r\n\
Connection: Keep-Alive\r\n\r\n\
%s"

2.2 初始化HTTP客戶端

/**
 @brief 初始化HTTP客戶端
 @param remote_port 遠(yuǎn)程端口
 @return 無
*/
void ICACHE_FLASH_ATTR
user_httpclient_init(uint32 remote_port)
{
    connectCloudServer();          // 連接云服務(wù)器
    sendHeartbeatRequest();        // 發(fā)送心跳包Post請求
    startSendHeartbeatTimer();     // 開啟發(fā)送心跳包定時器
}

/**
 @brief 發(fā)送心跳包請求
 @param 無
 @return 無
*/
LOCAL void ICACHE_FLASH_ATTR
sendHeartbeatRequest(void)
{
    char sendData[200] = {0};
    char url[50] = "http://192.168.0.51:8080/public/glegw/api";

    jsonPackageRequestInfo(sendData);               // JSON封裝請求信息 
    SendHttpPostRequestToCloud(url, sendData);      // 發(fā)送POST請求
}

2.3 JSON封裝心跳包Post請求

/**
 @brief JSON格式封裝請求數(shù)據(jù)
 @param requestInfo -[in] 請求數(shù)據(jù)包
 @param pSendData   -[in&out] 要封裝的發(fā)送數(shù)據(jù)
 @return 無
*/
LOCAL void ICACHE_FLASH_ATTR
jsonPackageRequestInfo(char *pSendData)
{
    cJSON *root = cJSON_CreateObject();

    cJSON_AddStringToObject(root, "msgId", "111111");

    char *tempBuffer = cJSON_Print(root);
    os_sprintf(pSendData, "%s", tempBuffer);

    os_free((void *) tempBuffer);                   // 釋放cJSON_Print分配出來的內(nèi)存空間
    cJSON_Delete(root);                             // 釋放cJSON_CreateObject分配出來的內(nèi)存空間
}

2.4 解析URL

/**
 @brief 向云服務(wù)器發(fā)送POST請求
 @param pUrl 統(tǒng)一資源定位符
 @param pSendContent 要發(fā)送的內(nèi)容
 @return 無
*/
void ICACHE_FLASH_ATTR
SendHttpPostRequestToCloud(char *pUrl, char *pSendContent)
{
    if((!pUrl) || (!pSendContent))
    {
        return ;
    }

    os_printf("SendHttpPostRequestToCloud========================\r\n");
    char host[50] = {0};
    char ip[32] = {0};
    char fileName[32] = {0};
    os_sprintf(ip, IPSTR, IP2STR(&g_cloudServerUrl.ip));
    os_sprintf(host, "%s:%d", ip, g_cloudServerUrl.port);
    os_sprintf(fileName, "%s", g_cloudServerUrl.fileName);

    os_sprintf(s_httpSendBuffer, POST_FRAME, fileName, host, strlen(pSendContent), pSendContent);
    espconn_connect(&s_cloudTcpEspconn);                                            // 連接服務(wù)器
}

// ------------------------- 這里沒用到這個函數(shù)(需要修改解析出ip)-------------------------
/**
 @brief 解析URL
 @param URL 統(tǒng)一標(biāo)識符
 @param host 主機
 @param filename 路徑名
 @param port 端口
 @return 無
*/
LOCAL void ICACHE_FLASH_ATTR
httpParseRequestUrl(char *pUrl, char *pHost, uint16 *pPort, char *pFileName)
{
    if(!(*pUrl))
    {
        return ;
    }

    char *pPartA = NULL;
    char *pPartB = NULL;
    memset(pHost, 0, sizeof(pHost));
    memset(pFileName, 0, sizeof(pFileName));
    *pPort = 0;

    pPartA = pUrl;

    if(!strncmp(pPartA, "http://", strlen("http://")))              // 檢查頭部
    {
        pPartA = pUrl + strlen("http://");
    }
    else if(!strncmp(pPartA, "https://", strlen("https://")))
    {
        pPartA = pUrl + strlen("https://");
    }

    pPartB = strchr(pPartA, '/');

    if(pPartB)                                                      // 如果有URI
    {
        memcpy(pHost, pPartA, strlen(pPartA) - strlen(pPartB));     // 將Host提取出來
        if(pPartB + 1)
        {
            memcpy(pFileName, pPartB  + 1, strlen(pPartB  - 1));    // 將FileName提取出來
            pFileName[strlen(pPartB) - 1] = 0;                      // FileName結(jié)束
        }
        pHost[strlen(pPartA) - strlen(pPartB)] = 0;                 // Host結(jié)束
    }
    else
    {
        memcpy(pHost, pPartA, strlen(pPartA));
        pHost[strlen(pPartA)] = 0;
    }

    pPartA = strchr(pHost, ':');

    if(pPartA)
    {
        *pPort = atoi(pPartA + 1);
    }
    else
    {
        *pPort = 80;
    }
}

2.5 連接服務(wù)器并發(fā)送Post請求

查看ESP8266學(xué)習(xí)筆記(5)——TCP/UDP接口使用

/**
 @brief 連接云服務(wù)器
 @param 無
 @return 無
*/
LOCAL void ICACHE_FLASH_ATTR
connectCloudServer(void)
{
    struct ip_info ipInfo;
    struct ip_addr remoteIp;
    uint16 remotePort = g_cloudServerUrl.port;
    //char ipBuffer[20] = OPENIOTS_IP;

    s_cloudTcpEspconn.type = ESPCONN_TCP;
    s_cloudTcpEspconn.state = ESPCONN_NONE;
    s_cloudTcpEspconn.proto.tcp = (esp_tcp *) os_zalloc(sizeof(esp_tcp));
    wifi_get_ip_info(STATION_IF, &ipInfo);                                          // 獲取當(dāng)前IP信息
    //remoteIp.addr = ipaddr_addr(ipBuffer);                                        // 目標(biāo)IP點分十進(jìn)制寫入IP結(jié)構(gòu)體
    memcpy(s_cloudTcpEspconn.proto.tcp->local_ip, &ipInfo.ip, 4);
    memcpy(s_cloudTcpEspconn.proto.tcp->remote_ip, &g_cloudServerUrl.ip, 4);
    s_cloudTcpEspconn.proto.tcp->local_port = espconn_port();                       // 獲取可用端口作為本地端口
    s_cloudTcpEspconn.proto.tcp->remote_port = remotePort;                          // 設(shè)置目標(biāo)端口

    espconn_regist_connectcb(&s_cloudTcpEspconn, connectServerCallback);            // 注冊連接回調(diào)
    espconn_regist_reconcb(&s_cloudTcpEspconn, reconnectServerCallback);            // 注冊重連回調(diào)
}

/**
 @brief 成功連接到服務(wù)器的回調(diào)函數(shù)
 @param arg 指向傳入?yún)?shù)的指針
 @return 無
*/
LOCAL void ICACHE_FLASH_ATTR
connectServerCallback(void *arg)
{
    struct espconn *pEspconn = (struct espconn *)arg;
    espconn_regist_recvcb(pEspconn, httpClientReceiveDataCallback);
    espconn_regist_sentcb(pEspconn, httpClientSendDataCallback);
    espconn_regist_disconcb(pEspconn, httpClientDisconnectCallback);

    os_printf("httpclient_data:\r\n%s\n", s_httpSendBuffer);
    espconn_sent(pEspconn, s_httpSendBuffer, strlen(s_httpSendBuffer));                 // TCP發(fā)送數(shù)據(jù)
}

/**
 @brief 重新連接到服務(wù)器的回調(diào)函數(shù)
 @param arg 指向傳入?yún)?shù)的指針
 @param err 錯誤代碼
 @return 無
*/
LOCAL void ICACHE_FLASH_ATTR
reconnectServerCallback(void *arg, sint8 err)
{
    os_printf("Err:httpclient connect failed, error number:%d\r\n", err);
    espconn_disconnect((struct espconn *) arg);                                     // 連接失敗就斷開連接,不重連
}

/**
 @brief 成功接收服務(wù)器返回數(shù)據(jù)的回調(diào)函數(shù)
 @param arg 指向傳入?yún)?shù)的指針
 @param pData 接收數(shù)據(jù)緩沖區(qū)
 @param len 字符串?dāng)?shù)組長度
 @return 無
*/
LOCAL void ICACHE_FLASH_ATTR
httpClientReceiveDataCallback(void *arg, char *pData, unsigned short len)
{
    os_printf("httpclient_recvdata:\t%s\n", pData);
}

/**
 @brief 成功發(fā)送數(shù)據(jù)到服務(wù)器的回調(diào)函數(shù)
 @param arg 指向傳入?yún)?shù)的指針
 @return 無
*/
LOCAL void ICACHE_FLASH_ATTR
httpClientSendDataCallback(void *arg)
{
    espconn_abort(&s_cloudTcpEspconn);
}

/**
 @brief 成功斷開服務(wù)器連接的回調(diào)函數(shù)
 @param arg 指向傳入?yún)?shù)的指針
 @return 無
*/
LOCAL void ICACHE_FLASH_ATTR
httpClientDisconnectCallback(void *arg)
{
    os_printf("httpclient_disconnect succeed!---------------------------------------\n");
}

2.6 定義發(fā)送心跳包定時器

查看ESP8266學(xué)習(xí)筆記(4)——定時器接口使用

/**
 @brief 開啟發(fā)送心跳包請求定時器
 @param 無
 @return 無
*/
LOCAL void ICACHE_FLASH_ATTR
startSendHeartbeatTimer(void)
{
    os_timer_disarm(&s_sendHeartbeatTimer);
    os_timer_setfn(&s_sendHeartbeatTimer, (os_timer_func_t *)sendHeartbeatTimerCallback, NULL);
    os_timer_arm(&s_sendHeartbeatTimer, 60000, true);           // 循環(huán)定時1min
}

/**
 @brief 發(fā)送心跳包定時器的回調(diào)函數(shù)
 @param 無
 @return 無
*/
LOCAL void ICACHE_FLASH_ATTR
sendHeartbeatTimerCallback(void)
{
    sendHeartbeatRequest();
}

? 由 Leung 寫于 2018 年 11 月 27 日

? 參考:ESP8266 Non-OS SDK API參考[7qq6]
    Esp8266學(xué)習(xí)之旅⑤ 8266原生樂鑫SDK高級使用之封裝Post與Get請求云端,拿到“天氣預(yù)報信息”

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末栗菜,一起剝皮案震驚了整個濱河市,隨后出現(xiàn)的幾起案子蹄梢,更是在濱河造成了極大的恐慌疙筹,老刑警劉巖,帶你破解...
    沈念sama閱讀 219,188評論 6 508
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件禁炒,死亡現(xiàn)場離奇詭異而咆,居然都是意外死亡,警方通過查閱死者的電腦和手機幕袱,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,464評論 3 395
  • 文/潘曉璐 我一進(jìn)店門暴备,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人们豌,你說我怎么就攤上這事涯捻。” “怎么了望迎?”我有些...
    開封第一講書人閱讀 165,562評論 0 356
  • 文/不壞的土叔 我叫張陵障癌,是天一觀的道長。 經(jīng)常有香客問我擂煞,道長混弥,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 58,893評論 1 295
  • 正文 為了忘掉前任,我火速辦了婚禮蝗拿,結(jié)果婚禮上晾捏,老公的妹妹穿的比我還像新娘。我一直安慰自己哀托,他們只是感情好惦辛,可當(dāng)我...
    茶點故事閱讀 67,917評論 6 392
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著仓手,像睡著了一般胖齐。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上嗽冒,一...
    開封第一講書人閱讀 51,708評論 1 305
  • 那天呀伙,我揣著相機與錄音,去河邊找鬼添坊。 笑死剿另,一個胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的贬蛙。 我是一名探鬼主播雨女,決...
    沈念sama閱讀 40,430評論 3 420
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼阳准!你這毒婦竟也來了氛堕?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 39,342評論 0 276
  • 序言:老撾萬榮一對情侶失蹤野蝇,失蹤者是張志新(化名)和其女友劉穎讼稚,沒想到半個月后,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體浪耘,經(jīng)...
    沈念sama閱讀 45,801評論 1 317
  • 正文 獨居荒郊野嶺守林人離奇死亡乱灵,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,976評論 3 337
  • 正文 我和宋清朗相戀三年,在試婚紗的時候發(fā)現(xiàn)自己被綠了七冲。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片痛倚。...
    茶點故事閱讀 40,115評論 1 351
  • 序言:一個原本活蹦亂跳的男人離奇死亡,死狀恐怖澜躺,靈堂內(nèi)的尸體忽然破棺而出蝉稳,到底是詐尸還是另有隱情,我是刑警寧澤掘鄙,帶...
    沈念sama閱讀 35,804評論 5 346
  • 正文 年R本政府宣布耘戚,位于F島的核電站,受9級特大地震影響操漠,放射性物質(zhì)發(fā)生泄漏收津。R本人自食惡果不足惜饿这,卻給世界環(huán)境...
    茶點故事閱讀 41,458評論 3 331
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望撞秋。 院中可真熱鬧长捧,春花似錦、人聲如沸吻贿。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,008評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽舅列。三九已至肌割,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間帐要,已是汗流浹背把敞。 一陣腳步聲響...
    開封第一講書人閱讀 33,135評論 1 272
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留榨惠,地道東北人先巴。 一個月前我還...
    沈念sama閱讀 48,365評論 3 373
  • 正文 我出身青樓,卻偏偏與公主長得像冒冬,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子摩渺,可洞房花燭夜當(dāng)晚...
    茶點故事閱讀 45,055評論 2 355