一弓坞、背景
已知智能網(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ù)報信息”