server_common/a8
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

添加headers

Browse Source
This commit is contained in:
aozhiwei 2019-01-12 14:29:46 +08:00
parent 972852f335
commit 3d34fc3fbe
2 changed files with 20 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
a8/curl.cc
View File

@ -15,7 +15,8 @@ namespace a8
return size * nmemb; return size * nmemb;
} }
bool Post(const char* url, const std::string& content, std::string& response, const char* headers) bool Post(const char* url, const std::string& content, std::string& response, a8::XObject* headers,
int timeout)
{ {
CURL *curl = curl_easy_init(); CURL *curl = curl_easy_init();
curl_easy_setopt(curl, CURLOPT_TIMEOUT, 10); curl_easy_setopt(curl, CURLOPT_TIMEOUT, 10);
@ -23,30 +24,42 @@ namespace a8
curl_easy_setopt(curl, CURLOPT_HEADER, 0); curl_easy_setopt(curl, CURLOPT_HEADER, 0);
curl_easy_setopt(curl, CURLOPT_HTTPPOST, 1); curl_easy_setopt(curl, CURLOPT_HTTPPOST, 1);
curl_slist* list = nullptr; curl_slist* list = nullptr;
if (headers) { if (headers && headers->GetType() == a8::XOT_ARRAY) {
list = curl_slist_append(list, headers); for (int i = 0; i < headers->Size(); ++i) {
list = curl_slist_append(list, headers->At(i)->AsXValue().GetString().c_str());
}
curl_easy_setopt(curl, CURLOPT_HTTPHEADER, list); curl_easy_setopt(curl, CURLOPT_HTTPHEADER, list);
} }
curl_easy_setopt(curl, CURLOPT_POSTFIELDS, content.c_str()); curl_easy_setopt(curl, CURLOPT_POSTFIELDS, content.c_str());
curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, &_ReceiveResponse); curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, &_ReceiveResponse);
curl_easy_setopt(curl, CURLOPT_WRITEDATA, &response); curl_easy_setopt(curl, CURLOPT_WRITEDATA, &response);
bool ok = curl_easy_perform(curl) == CURLE_OK; bool ok = curl_easy_perform(curl) == CURLE_OK;
curl_easy_cleanup(curl);
if (list) { if (list) {
curl_slist_free_all(list); curl_slist_free_all(list);
} }
curl_easy_cleanup(curl);
return ok; return ok;
} }
bool Get(const std::string& url, std::string& response, int timeout=10) bool Get(const std::string& url, std::string& response, a8::XObject* headers, int timeout)
{ {
CURL *curl = curl_easy_init(); CURL *curl = curl_easy_init();
curl_easy_setopt(curl, CURLOPT_TIMEOUT, timeout); curl_easy_setopt(curl, CURLOPT_TIMEOUT, timeout);
curl_easy_setopt(curl, CURLOPT_URL, url.c_str()); curl_easy_setopt(curl, CURLOPT_URL, url.c_str());
curl_easy_setopt(curl, CURLOPT_HTTPGET, 1); curl_easy_setopt(curl, CURLOPT_HTTPGET, 1);
curl_slist* list = nullptr;
if (headers && headers->GetType() == a8::XOT_ARRAY) {
for (int i = 0; i < headers->Size(); ++i) {
list = curl_slist_append(list, headers->At(i)->AsXValue().GetString().c_str());
}
curl_easy_setopt(curl, CURLOPT_HTTPHEADER, list);
}
curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, &_ReceiveResponse); curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, &_ReceiveResponse);
curl_easy_setopt(curl, CURLOPT_WRITEDATA, &response); curl_easy_setopt(curl, CURLOPT_WRITEDATA, &response);
bool ok = curl_easy_perform(curl) == CURLE_OK; bool ok = curl_easy_perform(curl) == CURLE_OK;
if (list) {
curl_slist_free_all(list);
}
curl_easy_cleanup(curl); curl_easy_cleanup(curl);
return ok; return ok;
} }

4
a8/curl.h
View File

@ -6,8 +6,8 @@ namespace a8
namespace http namespace http
{ {
bool Post(const char* url, const std::string& content, std::string& response, bool Post(const char* url, const std::string& content, std::string& response,
const char* headers = nullptr); a8::XObject* headers = nullptr, int timeout = 10);
bool Get(const std::string& url, std::string& response, int timeout=10); bool Get(const std::string& url, std::string& response, a8::XObject* headers = nullptr, int timeout=10);
} }
} }