ESP8266学习笔记（6）——HTTP客户端

一、背景


已知智能网关固定 IP 地址192.168.100.1，智能插座连上智能网关 AP 热点后，向网关发起心跳包 Post 请求，因此需要 ESP8266 作为 HTTP 客户端 角色。

Post请求和Get请求：

二、流程

2.1 定义相关变量及宏

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;     // 与云服务器TCP连接结构体

LOCAL os_timer_t s_sendHeartbeatTimer;      // 发送心跳包的定时器

#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 远程端口
 @return 无
*/
void ICACHE_FLASH_ATTR
user_httpclient_init(uint32 remote_port)
{
    connectCloudServer();          // 连接云服务器
    sendHeartbeatRequest();        // 发送心跳包Post请求
    startSendHeartbeatTimer();     // 开启发送心跳包定时器
}

/**
 @brief 发送心跳包请求
 @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);      // 发送POST请求
}

2.3 JSON封装心跳包Post请求

/**
 @brief JSON格式封装请求数据
 @param requestInfo -[in] 请求数据包
 @param pSendData   -[in&out] 要封装的发送数据
 @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分配出来的内存空间
    cJSON_Delete(root);                             // 释放cJSON_CreateObject分配出来的内存空间
}

2.4 解析URL

/**
 @brief 向云服务器发送POST请求
 @param pUrl 统一资源定位符
 @param pSendContent 要发送的内容
 @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);                                            // 连接服务器
}

// ------------------------- 这里没用到这个函数（需要修改解析出ip）-------------------------
/**
 @brief 解析URL
 @param URL 统一标识符
 @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结束
        }
        pHost[strlen(pPartA) - strlen(pPartB)] = 0;                 // Host结束
    }
    else
    {
        memcpy(pHost, pPartA, strlen(pPartA));
        pHost[strlen(pPartA)] = 0;
    }

    pPartA = strchr(pHost, ':');

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

2.5 连接服务器并发送Post请求

查看ESP8266学习笔记（5）——TCP/UDP接口使用

/**
 @brief 连接云服务器
 @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);                                          // 获取当前IP信息
    //remoteIp.addr = ipaddr_addr(ipBuffer);                                        // 目标IP点分十进制写入IP结构体
    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;                          // 设置目标端口

    espconn_regist_connectcb(&s_cloudTcpEspconn, connectServerCallback);            // 注册连接回调
    espconn_regist_reconcb(&s_cloudTcpEspconn, reconnectServerCallback);            // 注册重连回调
}

/**
 @brief 成功连接到服务器的回调函数
 @param arg 指向传入参数的指针
 @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发送数据
}

/**
 @brief 重新连接到服务器的回调函数
 @param arg 指向传入参数的指针
 @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 成功接收服务器返回数据的回调函数
 @param arg 指向传入参数的指针
 @param pData 接收数据缓冲区
 @param len 字符串数组长度
 @return 无
*/
LOCAL void ICACHE_FLASH_ATTR
httpClientReceiveDataCallback(void *arg, char *pData, unsigned short len)
{
    os_printf("httpclient_recvdata:\t%s\n", pData);
}

/**
 @brief 成功发送数据到服务器的回调函数
 @param arg 指向传入参数的指针
 @return 无
*/
LOCAL void ICACHE_FLASH_ATTR
httpClientSendDataCallback(void *arg)
{
    espconn_abort(&s_cloudTcpEspconn);
}

/**
 @brief 成功断开服务器连接的回调函数
 @param arg 指向传入参数的指针
 @return 无
*/
LOCAL void ICACHE_FLASH_ATTR
httpClientDisconnectCallback(void *arg)
{
    os_printf("httpclient_disconnect succeed!---------------------------------------\n");
}

2.6 定义发送心跳包定时器

查看ESP8266学习笔记（4）——定时器接口使用

/**
 @brief 开启发送心跳包请求定时器
 @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);           // 循环定时1min
}

/**
 @brief 发送心跳包定时器的回调函数
 @param 无
 @return 无
*/
LOCAL void ICACHE_FLASH_ATTR
sendHeartbeatTimerCallback(void)
{
    sendHeartbeatRequest();
}

• 由 Leung 写于 2018 年 11 月 27 日

• 参考：ESP8266 Non-OS SDK API参考[7qq6]
　　　　Esp8266学习之旅⑤ 8266原生乐鑫SDK高级使用之封装Post与Get请求云端，拿到“天气预报信息”

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 204,293评论 6赞 478
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 85,604评论 2赞 381
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 150,958评论 0赞 337
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 54,729评论 1赞 277
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 63,719评论 5赞 366
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,630评论 1赞 281
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 38,000评论 3赞 397
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,665评论 0赞 258
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 40,909评论 1赞 299
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,646评论 2赞 321
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,726评论 1赞 330
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,400评论 4赞 321
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 38,986评论 3赞 307
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,959评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,197评论 1赞 260
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 44,996评论 2赞 349
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,481评论 2赞 342