curl c++封裝 get/post

#pragma once

#include <map>

#include <string>

#include "curl/curl.h"

// Http get，post資料成功

#define HTTP_GET_OR_POST_SUCCESS_NOR 200

// Http get擷取post資料檔案

#define HTTP_GET_OR_POST_SUCCESS_DOWN_FILE 201

// Access token失效

#define HTTP_ACCESSTOKEN_INVALID 401

// 位址無效

#define HTTP_REQUEST_ADDR_NOT_FIND 404

// 伺服器錯誤

#define HTTP_SERVER_INTETFACE_ERROR 500

// 請求逾時

#define HTTP_REQUEST_TIME_OUT 0

// 伺服器連接配接失敗

#define HTTP_SERVER_CONNECT_FAIL 2

// 停止擷取資料（斷開連接配接）

#define HTTP_SERVER_DISCONNECT 3

typedef enum _HttpsClentErrorCode

{

ERR_SUCCESS = 0,

ERR_SOCKET_ERROR,

ERR_PARM_ERROR,

ERR_CURLRECV_ERROR,

ERR_CURLSEND_ERROR,

ERR_AGAGIN,

ERR_CURLINIT_ERROR

}HttpsErrorCode;

// 資料下載下傳進度

typedef void(*PFDataProgressCallBack)(INT64 & i64Downloaded, INT64 & i64CountSize, void * pUserData);

class CHttpsClient

{

public:

CHttpsClient();

~CHttpsClient();

int HttpsGet(std::string strUrl, std::string &strResponse, std::string & strHeader, std::vector<std::string> & vecHeaders, int & nStatus, const char * pSavePath = NULL);

int HttpsPost(std::string strUrl, std::string strPostData, std::vector<std::string> & vecHeaders, string &strResponse, int & nStatus, const char * pSavePath = NULL);

int HttpsPostEX(std::string strUrl, std::vector<std::string> & vecHeaders, std::multimap<std::string, std::string> mapPostData, std::multimap<std::string, std::string> mapPostFile, string &strResponse, int & nStatus, const char * pSavePath = NULL);

void RegiterCallBack(PFDataProgressCallBack cb, void *pUserData);

void StopRecvData();

std::string GetError();

bool IsStopRecvData();

size_t WirteData(void *ptr, size_t size, size_t nmemb);

private:

void InitParam(const char * pSavePath);

bool PostDataAndFile();

private:

PFDataProgressCallBack m_cb;

void *m_pUserData;

bool m_bStopRecvData;

INT64 m_i64DataSize;

INT64 m_i64CountSize;

std::string m_strError;

std::string m_strSavePath;

std::string m_strResponse;

FILE* m_pFile;

};

CPP

#include "..\Appobd\stdafx.h"

#include "HttpsClient.h"

#include "curl/curl.h"

#pragma comment(lib, "libcurl.lib")

CHttpsClient::CHttpsClient()

{

m_i64DataSize = 0;

m_i64CountSize = 0;

m_strError = "";

m_strSavePath = "";

m_bStopRecvData = false;

m_strResponse = "";

m_cb = NULL;

m_pFile = NULL;

}

CHttpsClient::~CHttpsClient()

{

}

size_t write_header(void *ptr, size_t size, size_t nmemb, void *stream)

{

std::string *str = (std::string*)stream;

(*str).append((char*)ptr, size*nmemb);

return size*nmemb;

}

size_t write_data(void *ptr, size_t size, size_t nmemb, void *stream)

{

// std::string *str = (std::string*)stream;

// (*str).append((char*)ptr, size*nmemb);

// curl_easy_pause(curl, CURLPAUSE_RECV);

// curl_easy_cleanup(curl);

//return -1; // <停止接收資料并退出>

if (stream)

{

CHttpsClient *pThis = (CHttpsClient *)stream;

if (pThis->IsStopRecvData())

{

return -1;

}

return pThis->WirteData(ptr, size, nmemb);

}

return 0;

}

std::string CHttpsClient::GetError()

{

return m_strError;

}

bool CHttpsClient::IsStopRecvData()

{

return m_bStopRecvData;

}

void CHttpsClient::StopRecvData()

{

m_bStopRecvData = true;

}

size_t CHttpsClient::WirteData(void *ptr, size_t size, size_t nmemb)

{

size_t written = 0;

if (m_strSavePath.length() > 0 && m_pFile)

{

written = fwrite(ptr, size, nmemb, (FILE *)m_pFile);

}

else

{

m_strResponse.append((char*)ptr, size * nmemb);

}

if (m_cb)

{

written = size * nmemb;

m_i64DataSize += written;

m_cb(m_i64DataSize, m_i64CountSize, m_pUserData);

}

return size * nmemb;

}

void CHttpsClient::RegiterCallBack(PFDataProgressCallBack cb, void *pUserData)

{

if (cb)

{

m_cb = cb;

}

if (pUserData)

{

m_pUserData = pUserData;

}

void CHttpsClient::InitParam(const char * pSavePath)

{

m_bStopRecvData = false;

m_i64DataSize = 0;

m_i64CountSize = 0;

m_strSavePath = "";

m_strResponse = "";

m_pFile = NULL;

if (pSavePath)

{

m_strSavePath = pSavePath;

fopen_s(&m_pFile, pSavePath, "wb");

}

int CHttpsClient::HttpsGet(std::string strUrl, std::string &strResponse, std::string & strHeader, std::vector<std::string> & vecHeaders, int & nStatus, const char * pSavePath)

{

int nRet = ERR_SUCCESS;

double size = 0.0;

CURLcode ret;

CURL *curl = curl_easy_init();

struct curl_slist *headers = NULL;

InitParam(pSavePath);

//增加HTTP header

for (size_t i = 0; i < vecHeaders.size(); i++)

{

headers = curl_slist_append(headers, vecHeaders[i].c_str());

}

{

if (curl)

{

ret = curl_easy_setopt(curl, CURLOPT_URL, strUrl.c_str());

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

if (headers)

{

curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headers);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_NOBODY, 1L);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_HEADERFUNCTION, write_header);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_WRITEHEADER, (void *)&strHeader);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_FOLLOWLOCATION, 1L);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_perform(curl);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_SOCKET_ERROR;

break;

}

ret = curl_easy_getinfo(curl, CURLINFO_CONTENT_LENGTH_DOWNLOAD, &size);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

}

m_i64CountSize = (INT64)size;

curl_easy_cleanup(curl);

}

curl = NULL;

curl = curl_easy_init();

if (curl)

{

// set params

ret = curl_easy_setopt(curl, CURLOPT_URL, strUrl.c_str()); // url

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

if (headers)

{

curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headers);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_SSL_VERIFYPEER, false); // if want to use https

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_SSL_VERIFYHOST, false); // set peer and host verify false

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_VERBOSE, 1);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_READFUNCTION, NULL);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, write_data);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_WRITEDATA, (void *)this);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_NOSIGNAL, 1);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_HEADER, 0);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_NOBODY, 0); //需求body

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_perform(curl);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

strResponse = m_strResponse;

long nState = 0;

ret = curl_easy_getinfo(curl, CURLINFO_RESPONSE_CODE, &nState);

if (ret == CURLE_OK)

{

nStatus = (int)nState;

}

// release curl

curl_easy_cleanup(curl);

m_strError = curl_easy_strerror(ret);

}

} while (false);

if (headers)

{

curl_slist_free_all(headers);

}

if (m_pFile)

{

fclose(m_pFile);

m_pFile = NULL;

}

return nRet;

}

int CHttpsClient::HttpsPost(std::string strUrl, std::string strPostData, std::vector<std::string> & vecHeaders, string &strResponse, int & nStatus, const char * pSavePath)

{

int nRet = ERR_SUCCESS;

double size = 0.0;

CURLcode ret;

CURL *curl = NULL;

struct curl_slist *headers = NULL;

struct curl_httppost *formpost = NULL;

struct curl_httppost *lastptr = NULL;

InitParam(pSavePath);

//增加HTTP header

for (size_t i = 0; i < vecHeaders.size(); i++)

{

headers = curl_slist_append(headers, vecHeaders[i].c_str());

}

{

curl = curl_easy_init();

if (curl)

{

// set params

ret = curl_easy_setopt(curl, CURLOPT_URL, strUrl.c_str()); // url

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_POST, 1L);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

if (headers)

{

curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headers);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

std::wstring wstrPostData = CStringHelper::s2ws(strPostData);

std::string strPostDataTmp = CStringHelper::UnicodeToUTF8(wstrPostData);

ret = curl_easy_setopt(curl, CURLOPT_POSTFIELDS, strPostDataTmp.c_str());

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_POSTFIELDSIZE, strPostDataTmp.length());

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_SSL_VERIFYPEER, false); // if want to use https

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_SSL_VERIFYHOST, false); // set peer and host verify false

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_VERBOSE, 1);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_READFUNCTION, NULL);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, write_data);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_WRITEDATA, (void *)this);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_NOSIGNAL, 1);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_HEADER, 0);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_perform(curl);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

strResponse = m_strResponse;

long nState = 0;

ret = curl_easy_getinfo(curl, CURLINFO_RESPONSE_CODE, &nState);

if (ret == CURLE_OK)

{

nStatus = (int)nState;

}

// release curl

curl_easy_cleanup(curl);

m_strError = curl_easy_strerror(ret);

}

} while (false);

if (headers)

{

curl_slist_free_all(headers);

}

if (m_pFile)

{

fclose(m_pFile);

m_pFile = NULL;

}

return nRet;

}

int CHttpsClient::HttpsPostEX(std::string strUrl, std::vector<std::string> & vecHeaders, std::multimap<std::string, std::string> mapPostData, std::multimap<std::string, std::string> mapPostFile, string &strResponse, int & nStatus, const char * pSavePath)

{

int nRet = ERR_SUCCESS;

double size = 0.0;

CURLcode ret;

CURLFORMcode form_ret;

CURL *curl = NULL;

struct curl_slist *headers = NULL;

struct curl_httppost *formpost = NULL;

struct curl_httppost *lastptr = NULL;

InitParam(pSavePath);

//增加HTTP header

for (size_t i = 0; i < vecHeaders.size(); i++)

{

headers = curl_slist_append(headers, vecHeaders[i].c_str());

}

{

curl_global_init(CURL_GLOBAL_ALL);

curl = curl_easy_init();

if (curl)

{

// set params

ret = curl_easy_setopt(curl, CURLOPT_URL, strUrl.c_str()); // url

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_POST, 1L);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

if (headers)

{

curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headers);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

std::multimap<std::string, std::string>::iterator it1;

for (it1 = mapPostData.begin(); it1 != mapPostData.end(); it1++)

{

std::string strKey = it1->first;

std::string strValue = it1->second;

std::vector<std::string> vecValue = CStringHelper::Split(strValue, ",");

if (vecValue.size() == 2)

{

int nValue = 0;

char csValue[16] = { 0 };

strcmp(vecValue[0].c_str(), "int") == 0 ? sprintf_s(csValue, "%s", vecValue[1].c_str()) : sprintf_s(csValue, "%s", vecValue[0].c_str());

nValue = atoi(csValue);

form_ret = curl_formadd(&formpost, &lastptr, CURLFORM_COPYNAME, strKey.c_str(), CURLFORM_COPYCONTENTS, nValue, CURLFORM_CONTENTSLENGTH, sizeof(nValue), CURLFORM_END);

}

else

{

std::wstring wstr = CStringHelper::s2ws(strValue);

strValue = CStringHelper::UnicodeToUTF8(wstr);

form_ret = curl_formadd(&formpost, &lastptr, CURLFORM_COPYNAME, strKey.c_str(), CURLFORM_COPYCONTENTS, strValue.c_str(), CURLFORM_CONTENTSLENGTH, strValue.length(), CURLFORM_END);

}

std::multimap<std::string, std::string>::iterator it2;

for (it2 = mapPostFile.begin(); it2 != mapPostFile.end(); it2++)

{

std::string strKey = it2->first;

std::string strValue = it2->second;

std::string strFileName = CStringHelper::GetFileName(strValue.c_str());

std::string strExtName = CStringHelper::GetExtName(strFileName.c_str());

if (0 == strcmp(strExtName.c_str(), "png"))

{

std::wstring wstr = CStringHelper::s2ws(strFileName);

strFileName = CStringHelper::UnicodeToUTF8(wstr);

form_ret = curl_formadd(&formpost, &lastptr, CURLFORM_COPYNAME, strKey.c_str(), CURLFORM_FILE, strValue.c_str(), CURLFORM_FILENAME, strFileName.c_str(), CURLFORM_CONTENTTYPE, "image/x-png", CURLFORM_END);

}

else if (0 == strcmp(strExtName.c_str(), "jpg"))

{

std::wstring wstr = CStringHelper::s2ws(strFileName);

strFileName = CStringHelper::UnicodeToUTF8(wstr);

}

else if (0 == strcmp(strExtName.c_str(), "bmp"))

{

std::wstring wstr = CStringHelper::s2ws(strFileName);

strFileName = CStringHelper::UnicodeToUTF8(wstr);

}

else

{

std::wstring wstr = CStringHelper::s2ws(strFileName);

strFileName = CStringHelper::UnicodeToUTF8(wstr);

}

ret = curl_easy_setopt(curl, CURLOPT_HTTPPOST, formpost);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_SSL_VERIFYPEER, false); // if want to use https

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_SSL_VERIFYHOST, false); // set peer and host verify false

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_VERBOSE, 1);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_READFUNCTION, NULL);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, write_data);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_WRITEDATA, (void *)this);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_NOSIGNAL, 1);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_setopt(curl, CURLOPT_HEADER, 0);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

ret = curl_easy_perform(curl);

if (ret != CURLE_OK)

{

m_strError = curl_easy_strerror(ret);

nRet = ERR_PARM_ERROR;

break;

}

strResponse = m_strResponse;

long nState = 0;

ret = curl_easy_getinfo(curl, CURLINFO_RESPONSE_CODE, &nState);

if (ret == CURLE_OK)

{

nStatus = (int)nState;

}

// release curl

curl_easy_cleanup(curl);

m_strError = curl_easy_strerror(ret);

}

} while (false);

if (headers)

{

curl_slist_free_all(headers);

}

if (m_pFile)

{

fclose(m_pFile);

m_pFile = NULL;

}

return nRet;

}

curl c++封裝 get/post

繼續閱讀

C語言第四章自述2第四章選擇結構程式設計

面試題:vector和map的差別，異同。空間分布，100萬資料存哪個比較合适。一、疊代器差別二、vector三、Map、Set四、vector_map 為什麼比map效率高五、如何選擇六、容器選擇原則七、效率對比

C++ 多線程用條件變量确定線程的執行順序而不是使用 sleep(1)

POJ 1284 Primitive Roots (歐拉函數&原根定理)

CQ V1.0分詞bates(基于雙數組tire樹)—應該是目前最快的中文分詞算法

成員函數初始化清單

2021-08-13c++——類之操作符重載

swmm與lisflood-fp源碼如何一起編譯 CMake指令

Windows下VS開發環境環境安裝工程項目設定關于Debug和Release的提示

一文看懂字元串的加減乘除

C++ 第十五周報告1--《冒泡法排序》

C++實作簡單順序表

C經典書籍筆記——C陷阱與缺陷②(文法陷阱之優先級)一、錯誤案列二、優先級規律

線性表之順序表的實作

C++判斷素數、求最大公約數代碼判斷一個數是否為素數求兩個數的最大公約數

SequoiaDB巨杉資料庫C++驅動概述