Chinaunix首页 | 论坛 | 博客

不忘初心，方得始终！c0732.blog.chinaunix.net

首页　| 　博文目录　| 　关于我

jsxthncn

  • 博客访问： 565200
  • 博文数量： 127
  • 博客积分： 1169
  • 博客等级： 少尉
  • 技术积分： 1298
  • 用 户 组： 普通用户
  • 注册时间： 2010-03-16 14:29
个人简介

空白

文章分类

全部博文（127）

推荐博文
相关博文
libcurl嵌入式Linux应用

分类： 嵌入式

2017-02-23 17:10:15

目的：使用libcurl与平台进行http通信，发送post和get请求。

1. 建立项目
建立包含如下内容的简单项目：

include: 包含libcurl头文件，将libcurl的头文件包含目录curl置于该include目录中；
lib: 将libcurl.a文件放入该目录下；
Makefile: 项目makefile文件；
MyCurl.h: libcurl接口封装声明文件；
MyCurl.cpp: libcurl接口封装实现文件；
main.cpp: main函数文件；

2. 代码编写
MyCurl.h内容如下：

  1. #ifndef NET_CURL_H
  2. #define NET_CURL_H

  4. #ifdef __cplusplus
  5. extern "C" {
  6. #endif

  8. #define SERV_REQ_LEN        64
  9. #define SERV_URL_LEN        256
  10. #define SERV_DOMAIN_LEN        64
  11. #define SERV_HOST_LEN        16
  12. #define SERV_RANGE_LEN        32

  14. /* 平台POST请求URL数据 */
  15. typedef struct PlatformPostUrl
  16. {
  17.     char servReq[SERV_REQ_LEN]; /* 请求名称 */
  18.     char servUrl[SERV_URL_LEN]; /* 保存URL */
  19.     char servDomain[SERV_DOMAIN_LEN]; /* HTTP头HOST字段值 */
  20.     char servHost[SERV_HOST_LEN]; /* 服务器IP地址 */
  21.     int servPort;      /* 服务器端口 */
  22.     char *data;      /* 数据 */
  23.     
  24. } PLATFORM_POST_URL;

  26. /* 平台GET请求URL数据 */
  27. typedef struct PlatformGetUrl
  28. {
  29.     int offset;          /* 下载文件偏移，用于断点下载升级文件 */
  30.     int flushSize;
  31.     char servUrl[SERV_URL_LEN]; /* 文件下载地址 */
  32.     char servDomain[SERV_DOMAIN_LEN]; /* 文件下载域名 */
  33.     char range[SERV_RANGE_LEN]; /* 下载文件内容范围 */
  34.     FILE *fp;      /* 文件保存文件指针 */
  35.     
  36. } PLATFORM_GET_URL;

  38. typedef size_t (*PARSE_FUN)(void *, size_t , size_t , void *);

  40. int CurlHttpPost(PLATFORM_POST_URL *url, PARSE_FUN parseFun, void *arg);

  42. int CurlHttpGet(PLATFORM_GET_URL *url, PARSE_FUN parseFun);

  44. void CurlPrintRspMsg(char *data, size_t dataLen);

  46. int CurlInit();

  48. void CurlDeinit();

  50. #ifdef __cplusplus
  51. }
  52. #endif

  54. #endif //NET_CURL_H
MyCurl.cpp内容如下：

  1. #include <stdio.h>
  2. #include <string.h>
  3. #include <stdlib.h>

  5. #include "curl.h"
  6. #include "MyCurl.h"

  8. #ifndef TRACE_PRT
  9. #define TRACE_PRT printf
  10. #endif
  11. #define MAX_RSP_MSG_LEN        (2048)
  12. #define RET_FAILURE     (-1)
  13. #define RET_SUCCESS     (0)
  14. #define POST_OPT_TIMEOUT    (30L)
  15. #define POST_CON_TIMEOUT    (10L)
  16. #define GET_OPT_TIMEOUT        (600L)
  17. #define GET_CON_TIMEOUT        (30L)
  18. #define HTTP_USER_AGENT        "CURLDE/"
  19. static char g_acRspMsgBuff[MAX_RSP_MSG_LEN] = {0};

  21. int CurlInit()
  22. {
  23.     CURLcode code = curl_global_init(CURL_GLOBAL_ALL);
  24.     if (code == CURLE_OK)
  25.         return RET_SUCCESS;
  26.     else
  27.         return RET_FAILURE;
  28. }

  30. char *CurlVersion()
  31. {
  32.     return curl_version();
  33. }

  35. void CurlDeinit()
  36. {
  37.     curl_global_cleanup();
  38. }

  40. static void CurlInitGetHead(CURL *curl, struct curl_slist *list, PLATFORM_GET_URL *url)
  41. {
  42.     return;
  43. }

  45. static void CurlInitPostHead(CURL *curl, struct curl_slist *list, PLATFORM_POST_URL *url)
  46. {
  47.     /* 修改content-Type */
  48.     list = curl_slist_append(list, "Content-Type: application/json");
  49.     /* 屏蔽Expect100-continue */
  50.     list = curl_slist_append(list, "Expect:");

  52.     curl_easy_setopt(curl, CURLOPT_HTTPHEADER, list);
  53. }

  55. void CurlPrintRspMsg(char *pMsgData, size_t uiDataLen)
  56. {
  57.     if (!pMsgData)
  58.         return;
  59.     
  60.     size_t uiTmpLen = uiDataLen;
  61.             
  62.     if (uiTmpLen > sizeof(g_acRspMsgBuff) - 1)
  63.     {
  64.         TRACE_PRT("warnning, recv data len(%u) too long.\r\n", uiTmpLen);
  65.         uiTmpLen = sizeof(g_acRspMsgBuff) - 1;
  66.     }
  67.     
  68.     char *token = strstr(pMsgData, "\r\n");
  69.     if (token != NULL)
  70.     {
  71.         uiTmpLen = token - pMsgData;
  72.         if (uiTmpLen > sizeof(g_acRspMsgBuff) - 1)
  73.             uiTmpLen = sizeof(g_acRspMsgBuff) - 1;
  74.     }

  76.     memset(g_acRspMsgBuff, 0, sizeof(g_acRspMsgBuff));
  77.     memcpy(g_acRspMsgBuff, pMsgData, uiTmpLen);
  78.     g_acRspMsgBuff[sizeof(g_acRspMsgBuff) - 1] = '\0';
  79.     
  80.     TRACE_PRT("%s\r\n", g_acRspMsgBuff);
  81. }

  83. int CurlHttpPost(PLATFORM_POST_URL *url, PARSE_FUN parseFun, void *arg)
  84. {
  85.     CURL *curl = NULL;
  86.     CURLcode res;
  87.     struct curl_slist *list = NULL;
  88.     
  89.     if (!url || !parseFun)
  90.     {
  91.         TRACE_PRT("ERROR, param is NULL\n");
  92.         return RET_FAILURE;
  93.     }
  94.     
  95.     curl = curl_easy_init();
  96.     if (curl == NULL)
  97.     {
  98.         TRACE_PRT("ERROR, http curl easy init FAIL\n");
  99.         return RET_FAILURE;
  100.     }

  102.     CurlInitPostHead(curl, list, url);
  103.     
  104.     curl_easy_setopt(curl, CURLOPT_URL, url->servUrl);    /* 设置请求url */
  105.     curl_easy_setopt(curl, CURLOPT_POSTFIELDS, url->data);        /* 设置请求发送给服务器数据 */        
  106.     curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, parseFun);        /* 服务器应答处理函数指针 */    
  107.     curl_easy_setopt(curl, CURLOPT_WRITEDATA, arg);        /* parseFun函数参数 */
  108.     curl_easy_setopt(curl, CURLOPT_POST, 1L);        /* 使用post请求 */    
  109.     curl_easy_setopt(curl, CURLOPT_TIMEOUT, POST_OPT_TIMEOUT); /* 整个请求处理的最大超时时间 */
  110.     curl_easy_setopt(curl, CURLOPT_CONNECTTIMEOUT, POST_CON_TIMEOUT);    /* connect服务器的最大超时时间 */
  111. #ifdef CURL_DEBUG
  112.     curl_easy_setopt(curl, CURLOPT_VERBOSE, 1L);        /* 调试开关 */
  113. #endif

  115.     res = curl_easy_perform(curl);
  116.     if (res != CURLE_OK)
  117.     {
  118.         TRACE_PRT("ERROR, http perform FAILED(%d:%s).\n", res, curl_easy_strerror(res));
  119.         curl_easy_cleanup(curl);
  120.         curl_slist_free_all(list); /* free the list again */
  121.         return RET_FAILURE;
  122.     }

  124.     curl_easy_cleanup(curl);
  125.     curl_slist_free_all(list); /* free the list again */
  126.     
  127.     return RET_SUCCESS;
  128. }

  130. int CurlHttpGet(PLATFORM_GET_URL *url, PARSE_FUN parseFun)
  131. {
  132.     CURL *curl = NULL;
  133.     CURLcode res;
  134.     struct curl_slist *list = NULL;
  135.     
  136.     if (!url || !parseFun)
  137.     {
  138.         TRACE_PRT("ERROR, param is NULL\n");
  139.         return -1;
  140.     }

  142.     curl = curl_easy_init();
  143.     if (curl == NULL)
  144.     {
  145.         TRACE_PRT("ERROR, curl_easy_init FAIL.\n");
  146.         return -1;
  147.     }

  149.     CurlInitGetHead(curl, list, url);

  151.     curl_easy_setopt(curl, CURLOPT_URL,         url->servUrl);
  152.     curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION,     parseFun);
  153.     curl_easy_setopt(curl, CURLOPT_WRITEDATA,         url);
  154.     curl_easy_setopt(curl, CURLOPT_RANGE,         url->range);                /* 下载文件的起始范围 */
  155.     //curl_easy_setopt(curl, CURLOPT_RESUME_FROM,     url->offset);          /* 从offset偏移开始下载文件 */
  156.     curl_easy_setopt(curl, CURLOPT_TIMEOUT,         GET_OPT_TIMEOUT);     /* 文件下载最长时间600s */
  157.     curl_easy_setopt(curl, CURLOPT_CONNECTTIMEOUT,     GET_CON_TIMEOUT);
  158.     
  159. #ifdef CURL_DEBUG
  160.     curl_easy_setopt(curl, CURLOPT_VERBOSE, 1);
  161. #endif

  163.     TRACE_PRT("connected to: %s.\n", url->servUrl);

  165.     res = curl_easy_perform(curl);
  166.     if (res != CURLE_OK)
  167.     {
  168.         TRACE_PRT("ERROR, http client perform FAILED: %d(%s).\n", res, curl_easy_strerror(res));
  169.         curl_easy_cleanup(curl);
  170.         curl_slist_free_all(list); /* free the list again */
  171.         return -1;
  172.     }

  174.     curl_easy_cleanup(curl);
  175.     curl_slist_free_all(list); /* free the list again */
  176.     
  177.     return 0;
  178. }
main.cpp内容如下：
  1. #include <stdio.h>
  2. #include <string.h>
  3. #include <stdlib.h>

  5. #include "MyCurl.h"

  7. #define TRACE_PRT printf
  8. #define Malloc malloc
  9. #define Free free
  10. #define MDL __FUNCTION__, __LINE__

  12. #define OTHER_DATA_LEN (512)
  13. #define PLATFORM_SERV_PORT (80)
  14. #define MAX_MSG_LEN (2048)
  15. #define PLATFORM_SERV_HOST "14.18.201.47"
  16. #define PLATFORM_SERV_NAME ""
  17. #define PLATFORM_SERV_URL "http://%s:%d/uid/%s"
  18. #define PLATFORM_REQ_HTML "20698826.html"

  20. static void InitPlatformUrl(PLATFORM_POST_URL *url, const char *servReq)
  21. {
  22.     memset(url->servReq, 0, sizeof(url->servReq));
  23.     strncpy(url->servReq, servReq, sizeof(url->servReq) - 1);

  25.     url->servPort = PLATFORM_SERV_PORT;
  26.     strncpy(url->servDomain, PLATFORM_SERV_NAME, sizeof(url->servDomain) - 1);
  27.     strncpy(url->servHost, PLATFORM_SERV_HOST, sizeof(url->servHost) - 1);
  28.     snprintf(url->servUrl, sizeof(url->servUrl) - 1,
  29.                         PLATFORM_SERV_URL,
  30.                         url->servDomain,
  31.                         url->servPort,
  32.                         url->servReq);

  34.     TRACE_PRT("%s\r\n", url->servUrl);
  35. }

  37. static size_t ParseResponseRequest(void *buffer, size_t size, size_t nmemb, void *stream)
  38. {
  39.     char *recvData = (char *)buffer;
  40.     
  41.     size_t dataSize = size * nmemb;
  42.     char *response = (char *)stream;
  43.     
  44.     if (dataSize <= 0)
  45.     {
  46.         return dataSize;
  47.     }

  49.     if (dataSize >= MAX_MSG_LEN - 1)
  50.         dataSize = MAX_MSG_LEN - 1;
  51.     
  52.     memcpy(response, recvData, dataSize);
  53.     
  54.     return dataSize;
  55. }

  57. static int DealCurlRequest(const char *reqName)
  58. {
  59.     int ret = -1;
  60.     PLATFORM_POST_URL url;
  61.     char *msgData = (char *)Malloc(sizeof(char) * MAX_MSG_LEN);
  62.     if (!msgData)
  63.     {
  64.         TRACE_PRT("Malloc memory FAIL.\n");
  65.         return -1;
  66.     }
  67.     memset(msgData, 0, MAX_MSG_LEN);
  68.     
  69.     memset(&url, 0, sizeof(url));
  70.     url.data = NULL;

  72.     InitPlatformUrl(&url, reqName);
  73.     
  74.     unsigned int dataLen = OTHER_DATA_LEN;
  75.     url.data = (char *)Malloc(dataLen);
  76.     if (!url.data)
  77.     {
  78.         TRACE_PRT("> ERROR, malloc FAIL. %s %d\r\n", MDL);
  79.         return -1;
  80.     }
  81.     
  82.     memset(url.data, 0, dataLen);
  83.     snprintf(url.data, dataLen - 1, "%s", "");

  85.     ret = CurlHttpPost(&url, ParseResponseRequest, msgData);
  86.     if (0 == ret)
  87.     {
  88.         ret = 0;
  89.     }
  90.     else
  91.     {
  92.         ret = -1;
  93.     }

  95.     if (0 == ret)
  96.     {
  97.         TRACE_PRT("response: %s\r\n", msgData);
  98.     }
  99.     
  100.     Free(url.data);
  101.     Free(msgData);
  102.     
  103.     return ret;
  104. }

  106. int main(int argc, char **argv)
  107. {
  108.     int ret = -1;

  110.     ret = CurlInit();
  111.     if (0 != ret)
  112.     {
  113.         TRACE_PRT("curl inti FAIL\n");
  114.         return -1;
  115.     }

  117.     ret = DealCurlRequest(PLATFORM_REQ_HTML);

  119.     CurlDeinit();

  121.     return ret;
  122. }
Makefile:
  1. TARGET = libcurl_demo

  3. CC=gcc
  4. CX=g++

  6. INCLUDE_CURL_DIR = ./include/curl
  7. LIBRARY_DIR += ./lib
  8. LIBRARY_FILE += $(LIBRARY_DIR)/libcurl.a
  9. LIBRARY_FILE += -lm
  10. LIBRARY_FILE += -lrt
  11. LIBRARY_FILE += -ldl

  13. OBJS = $(patsubst %.c, %.o, $(wildcard *.c))
  14. OBJS += $(patsubst %.cpp, %.o, $(wildcard *.cpp))

  16. CCFLAGS = -g -Wall -O2

  18. $(TARGET) : $(OBJS)    
  19.     $(CXX) $^ -o $@ $(CCFLAGS) -I$(INCLUDE_CURL_DIR) -L$(LIBRARY_DIR) $(LIBRARY_FILE)

  21. %.o : %.c    
  22.     $(CC) -c $< $(CCFLAGS) -I$(INCLUDE_CURL_DIR)

  24. %.o : %.cpp
  25.     $(CXX) -c $< $(CCFLAGS) -I$(INCLUDE_CURL_DIR)

  27. clean:    
  28.     rm *.o $(TARGET)

  30. .PHONY:clean
3. 编译
  1. root@sar:/code/mytest/libcurl_demo# make
  2. g++ -c main.cpp -g -Wall -O2 -I./include/curl
  3. g++ -c MyCurl.cpp -g -Wall -O2 -I./include/curl
  4. g++ main.o MyCurl.o -o libcurl_demo -g -Wall -O2 -I./include/curl -L./lib ./lib/libcurl.a -lm -lrt -ldl
4. 测试
  1. root@sar:/code/mytest/libcurl_demo# ./libcurl_demo
  2. http://www.baidu.com:80/uid/20698826.html
  3. response: <!DOCTYPE HTML PUBLIC "-//IETF//DTD HTML 2.0//EN">
  4. <html><head>
  5. <title>302 Found</title>
  6. </head><body>
  7. <h1>Found</h1>
  8. <p>The document has moved <a href="http:///search/error.html">here</a>.</p>
  9. </body></html>

  11. root@sar:/code/mytest/libcurl_demo#
阅读(2007) | 评论(0) | 转发(0) |
0

上一篇：libcurl嵌入式Linux移植

下一篇：Shell获取配置文件中一个字段的值

给主人留下些什么吧！~~
关于我们 | 关于IT168 | 联系方式 | 广告合作 | 法律声明 | 免费注册

Copyright 2001-2010 ChinaUnix.net All Rights Reserved 北京皓辰网域网络信息技术有限公司. 版权所有

感谢所有关心和支持过ChinaUnix的朋友们

16024965号-6