http 客户端

http 客户端

http 客户端

源码

/* * File : httpclient.c * * Copyright (c) 2006-2018, RT-Thread Development Team * * SPDX-License-Identifier: Apache-2.0 * * Change Logs: * Date Author Notes * 2018-07-20 flybreak first version * 2018-09-05 flybreak Upgrade API to webclient latest version */#include <webclient.h> /* 使用 HTTP 协议与服务器通信需要包含此头文件 */#include <sys/socket.h> /* 使用BSD socket，需要包含socket.h头文件 */#include <netdb.h>#include <cJSON.h>#include <finsh.h>#define GET_HEADER_BUFSZ 1024 //头部大小#define GET_RESP_BUFSZ 1024 //响应缓冲区大小#define GET_URL_LEN_MAX 256 //网址最大长度#define GET_URI "http://mobile.weather.com.cn/data/sk/%s.html" //获取天气的 API#define AREA_ID "101021300" //上海浦东地区 ID/* 天气数据解析 */void weather_data_parse(rt_uint8_t *data){ cJSON *root = RT_NULL, *object = RT_NULL, *item = RT_NULL; root = cJSON_Parse((const char *)data); if (!root) { rt_kprintf("No memory for cJSON root!\n"); return; } object = cJSON_GetObjectItem(root, "sk_info"); item = cJSON_GetObjectItem(object, "cityName"); rt_kprintf("\ncityName:%s ", item->valuestring); item = cJSON_GetObjectItem(object, "temp"); rt_kprintf("\ntemp :%s ", item->valuestring); item = cJSON_GetObjectItem(object, "wd"); rt_kprintf("\nwd :%s ", item->valuestring); item = cJSON_GetObjectItem(object, "ws"); rt_kprintf("\nws :%s ", item->valuestring); item = cJSON_GetObjectItem(object, "sd"); rt_kprintf("\nsd :%s ", item->valuestring); item = cJSON_GetObjectItem(object, "date"); rt_kprintf("\ndate :%s", item->valuestring); item = cJSON_GetObjectItem(object, "time"); rt_kprintf("\ntime :%s \n", item->valuestring); if (root != RT_NULL) cJSON_Delete(root);}void weather(int argc, char **argv){ rt_uint8_t *buffer = RT_NULL; int resp_status; struct webclient_session *session = RT_NULL; char *weather_url = RT_NULL; int content_length = -1, bytes_read = 0; int content_pos = 0; /* 为 weather_url 分配空间 */ weather_url = rt_calloc(1, GET_URL_LEN_MAX); if (weather_url == RT_NULL) { rt_kprintf("No memory for weather_url!\n"); goto __exit; } /* 拼接 GET 网址 */ rt_snprintf(weather_url, GET_URL_LEN_MAX, GET_URI, AREA_ID); /* 创建会话并且设置响应的大小 */ session = webclient_session_create(GET_HEADER_BUFSZ); if (session == RT_NULL) { rt_kprintf("No memory for get header!\n"); goto __exit; } /* 发送 GET 请求使用默认的头部 */ if ((resp_status = webclient_get(session, weather_url)) != 200) { rt_kprintf("webclient GET request failed, response(%d) error.\n", resp_status); goto __exit; } /* 分配用于存放接收数据的缓冲 */ buffer = rt_calloc(1, GET_RESP_BUFSZ); if (buffer == RT_NULL) { rt_kprintf("No memory for data receive buffer!\n"); goto __exit; } content_length = webclient_content_length_get(session); if (content_length < 0) { /* 返回的数据是分块传输的. */ do { bytes_read = webclient_read(session, buffer, GET_RESP_BUFSZ); if (bytes_read <= 0) { break; } }while (1); } else { do { bytes_read = webclient_read(session, buffer, content_length - content_pos > GET_RESP_BUFSZ ? GET_RESP_BUFSZ : content_length - content_pos); if (bytes_read <= 0) { break; } content_pos += bytes_read; }while (content_pos < content_length); } /* 天气数据解析 */ weather_data_parse(buffer);__exit: /* 释放网址空间 */ if (weather_url != RT_NULL) rt_free(weather_url); /* 关闭会话 */ if (session != RT_NULL) webclient_close(session); /* 释放缓冲区空间 */ if (buffer != RT_NULL) rt_free(buffer);}MSH_CMD_EXPORT(weather, Get weather by webclient);