{"id":1643,"date":"2018-09-06T20:44:09","date_gmt":"2018-09-06T12:44:09","guid":{"rendered":"https:\/\/damogame.cn:15443\/wordpress\/?p=1643"},"modified":"2018-09-06T20:44:09","modified_gmt":"2018-09-06T12:44:09","slug":"%e5%a5%bd%e7%94%a8%e7%9a%84http-client%e5%ba%93cpp-rest-sdk","status":"publish","type":"post","link":"https:\/\/i007.cc\/wordpress\/archives\/1643","title":{"rendered":"\u597d\u7528\u7684http client\u5e93CPP REST SDK"},"content":{"rendered":"

\u597d\u7528\u7684http client\u5e93CPP REST SDK<\/a><\/h1>\n
<\/div>\n
\n
\n

\"\u6b64\u5904\u8f93\u5165\u56fe\u7247\u7684\u63cf\u8ff0\"<\/p>\n

\u524d\u8a00<\/h2>\n

C++\u4e2dhttp client\u5e93\u672c\u8eab\u5c31\u5c11\uff0c\u597d\u7528\u7684\u5c31\u66f4\u5c11\u4e86\uff0c\u5728\u4e86\u89e3\u5fae\u8f6f\u5f00\u6e90\u7684CPP REST SDK<\/a>\u5e93\u4e4b\u524d\uff0c\u6211\u77e5\u9053\u7684C++ http client\u5e93\u6709libcurl<\/a>\uff08\u8fd9\u4e2a\u662fC\u8bed\u8a00\u7684\uff09\uff0cQt\u7684QNetworkAccessManager<\/a>\uff0c\u8fd8\u6709VC++ http client\uff0cQt\u7684QNetworkAccessManager\u5e93\u6211\u5728\u5f00\u53d1CZPlayer<\/a>\u7684\u65f6\u5019\u7528\u6765\u4e0b\u8f7d\u8fc7\u97f3\u4e50\u3001\u4e13\u8f91\u56fe\u7247\u548c\u6b4c\u8bcd\uff0c\u4e0d\u5f97\u4e0d\u8bf4Qt\u63d0\u4f9b\u7684API\u8fd8\u662f\u6bd4\u8f83\u597d\u7528\u7684\uff0c\u5982\u679c\u4e0d\u6d89\u53ca\u754c\u9762\u5f00\u53d1\uff0c\u96be\u9053\u6211\u4eec\u5728linux\u4e0a\u5c31\u53ea\u80fd\u7528libcurl\uff0c\u5728windows\u4e0a\u5c31\u7528VC++\u7684http client\uff1f\u7b54\u6848\u662f\u5426\u5b9a\u7684\uff0c\u5728\u7edd\u671b\u4e4b\u9645CPP REST SDK\u51fa\u73b0\u5728\u6211\u7684\u773c\u524d\uff0cCPP REST SDK\u662f\u5fae\u8f6f\u5f00\u6e90\u7684\u57fa\u4e8ePPL\u7684\u5f02\u6b65http client\uff0c\u7f51\u7edc\u5c42\u4f7f\u7528\u7684\u662fBoost.Asio\uff0c\u8de8\u5e73\u53f0\uff0c\u5e76\u4e14\u652f\u6301json\u89e3\u6790\uff0c\u5728\u4f7f\u7528CPP REST SDK\u4e4b\u524d\u8981\u786e\u4fdd\u4f60\u5df2\u7ecf\u5b89\u88c5\u4e86boost\u548copenssl\uff0c\u4e0b\u9762\u662f\u5fae\u8f6f\u5b98\u65b9\u63d0\u4f9b\u7684\u4f8b\u5b50\u3002<\/p>\n

\u5fae\u8f6f\u5b98\u65b9\u4f8b\u5b50<\/h2>\n
#include<\/span> <cpprest\/http_client.h><\/span><\/span>\r\n#include<\/span> <cpprest\/filestream.h><\/span><\/span>\r\n\r\nusing<\/span> namespace<\/span> utility;                    \/\/ Common utilities like string conversions<\/span>\r\nusing<\/span> namespace<\/span> web;                        \/\/ Common features like URIs.<\/span>\r\nusing<\/span> namespace<\/span> web::http;                  \/\/ Common HTTP functionality<\/span>\r\nusing<\/span> namespace<\/span> web::http::client;          \/\/ HTTP client features<\/span>\r\nusing<\/span> namespace<\/span> concurrency::streams;       \/\/ Asynchronous streams<\/span>\r\n\r\nint<\/span> main<\/span>(int<\/span> argc, char<\/span>* argv[])<\/span>\r\n<\/span>{\r\n    auto<\/span> fileStream = std<\/span>::make_shared<ostream>();\r\n\r\n    \/\/ Open stream to output file.<\/span>\r\n    pplx::task<void<\/span>> requestTask = fstream::open_ostream(U(\"results.html\"<\/span>)).then([=](ostream outFile)\r\n    {\r\n        *fileStream = outFile;\r\n\r\n        \/\/ Create http_client to send the request.<\/span>\r\n        http_client client<\/span>(U(\"http:\/\/www.bing.com\/\"<\/span>)<\/span>)<\/span>;\r\n\r\n        \/\/ Build request URI and start the request.<\/span>\r\n        uri_builder builder<\/span>(U(\"\/search\"<\/span>)<\/span>)<\/span>;\r\n        builder.append_query(U(\"q\"<\/span>), U(\"cpprestsdk github\"<\/span>));\r\n        return<\/span> client.request(methods::GET, builder.to_string());\r\n    })\r\n\r\n    \/\/ Handle response headers arriving.<\/span>\r\n    .then([=](http_response response)\r\n    {\r\n        printf<\/span>(\"Received response status code:%u\\n\"<\/span>, response.status_code());\r\n\r\n        \/\/ Write response body into the file.<\/span>\r\n        return<\/span> response.body().read_to_end(fileStream->streambuf());\r\n    })\r\n\r\n    \/\/ Close the file stream.<\/span>\r\n    .then([=](size_t<\/span>)\r\n    {\r\n        return<\/span> fileStream->close();\r\n    });\r\n\r\n    \/\/ Wait for all the outstanding I\/O to complete and handle any exceptions<\/span>\r\n    try<\/span>\r\n    {\r\n        requestTask.wait();\r\n    }\r\n    catch<\/span> (const<\/span> std<\/span>::exception &e)\r\n    {\r\n        printf<\/span>(\"Error exception:%s\\n\"<\/span>, e.what());\r\n    }\r\n\r\n    return<\/span> 0<\/span>;\r\n}<\/code><\/pre>\n
\u4e0a\u9762\u7684\u4f8b\u5b50\u4e3b\u8981\u5185\u5bb9\u662f\u8bbf\u95ee\u4e00\u4e2a\u7f51\u7ad9\u5e76\u5c06\u8be5\u5185\u5bb9\u4fdd\u5b58\u5728results.html\u91cc\u9762\uff0c\u8fd9\u91cc\u7528\u5230\u4e86\u5fae\u8f6f\u81ea\u5bb6\u7684PPL\u5e76\u884c\u8ba1\u7b97\u5e93\uff08\u8fd8\u6709\u4e00\u4e2a\u662f\u82f1\u7279\u5c14\u7684TBB\uff09\uff0c\u8be5\u4f8b\u5b50\u4f7f\u7528lambda\u8868\u8fbe\u5f0f\u4f5c\u4e3a\u5f02\u6b65\u56de\u8c03\u7684handler\uff0c\u6253\u5f00\u6587\u4ef6\u6d41\u3001\u8bf7\u6c42\u3001\u56de\u5e94\u548c\u5173\u95ed\u6587\u4ef6\u6d41\u90fd\u662f\u5f02\u6b65\u7684\uff0c\u4e3a\u4e86\u65b9\u4fbf\u8d77\u89c1\uff0c\u6211\u4eec\u5c06\u8be5\u4f8b\u5b50\u6539\u4e3a\u540c\u6b65\u65b9\u5f0f\u3002<\/p>\n
\u4f7f\u7528\u540c\u6b65\u65b9\u5f0f<\/h2>\n
auto<\/span> fileStream = std<\/span>::make_shared<ostream>();\r\nostream outFile = fstream::open_ostream(U(\"results.html\"<\/span>)).get();\r\n*fileStream = outFile;\r\n\r\n\/\/ Create http_client to send the request.<\/span>\r\nhttp_client client<\/span>(U(\"http:\/\/www.bing.com\/\"<\/span>)<\/span>)<\/span>;\r\n\r\n\/\/ Build request URI and start the request.<\/span>\r\nuri_builder builder<\/span>(U(\"\/search\"<\/span>)<\/span>)<\/span>;\r\nbuilder.append_query(U(\"q\"<\/span>), U(\"cpprestsdk github\"<\/span>));\r\nhttp_response response = client.request(methods::GET, builder.to_string()).get();\r\n\/\/ Write response body into the file.<\/span>\r\nresponse.body().read_to_end(fileStream->streambuf()).get();\r\nfileStream->close().get();<\/code><\/pre>\n
\u4f7f\u7528\u540c\u6b65\u65b9\u5f0f\u7684\u4ee3\u7801\u6bd4\u8f83\u6e05\u6670\uff0c\u53ef\u4ee5\u770b\u5230\u6bcf\u4e00\u4e2a\u51fd\u6570\u8c03\u7528\u540e\u9762\u90fd\u4f1a\u8c03\u7528get\u51fd\u6570\uff0c\u56e0\u4e3aCPP REST SDK\u662f\u57fa\u4e8ePPL\u7684\uff0c\u6240\u4ee5\u5728request\u3001read_to_end\u3001close\u7b49\u51fd\u6570\u8c03\u7528\u540e\u90fd\u4f1a\u8fd4\u56de\u4e00\u4e2aTask\u5bf9\u8c61\uff0c\u800cTask\u91cc\u9762\u7684get\u548cwait\u51fd\u6570\u662f\u7b49\u5f85\u4efb\u52a1\u6267\u884c\u5b8c\u6210\u3002<\/p>\n
\u5b9e\u6218<\/h2>\n
\u6211\u4e4b\u524d\u5728\u770b\u522b\u4eba\u535a\u5ba2\u7684\u65f6\u5019\u770b\u5230\u6bcf\u4e00\u7bc7\u535a\u5ba2\u524d\u90fd\u6709\u4e00\u526f\u56fe\uff0c\u770b\u8d77\u6765\u6bd4\u8f83\u597d\u770b\uff0c\u542c\u535a\u4e3b\u8bb2\u4ed6\u662f\u4f7f\u7528bing\u7684\u6bcf\u65e5\u4e00\u56fe\uff0c\u540e\u6765\u6211\u4e5f\u6548\u4eff\uff0c\u6211\u5728\u4e3b\u9898\u4e4b\u5bb6\u627e\u5230\u4e86\u81ea\u5df1\u6bd4\u8f83\u559c\u6b22\u7684\u56fe\u7247\uff0c\u6700\u5f00\u59cb\u81ea\u5df1\u5199\u535a\u5ba2\u7684\u65f6\u5019\u90fd\u662f\u76f4\u63a5\u53bb\u4e3b\u9898\u4e4b\u5bb6\u4e00\u9875\u4e00\u9875\u7684\u627e\u770b\uff0c\u7136\u540e\u518d\u4e0b\u8f7d\u56fe\u7247\uff0c\u5199\u4e86\u51e0\u7bc7\u535a\u5ba2\u4e4b\u540e\u611f\u89c9\u6bcf\u6b21\u90fd\u8981\u53bb\u4e0b\u8f7d\u56fe\u7247\u611f\u89c9\u6709\u70b9low\uff0c\u6240\u4ee5\u6211\u51b3\u5b9a\u76f4\u63a5\u5c06\u4e3b\u9898\u4e4b\u5bb6\u7684\u67d0\u7c7b\u578b\u7684\u56fe\u7247\u90fd\u4e0b\u8f7d\u4e0b\u6765\uff0c\u8fd9\u6837\u9009\u56fe\u7247\u5c31\u65b9\u4fbf\u591a\u4e86\uff0c\u4e0b\u9762\u662f\u6211\u5728\u4e3b\u9898\u4e4b\u5bb6\u6293\u56fe\u7684\u4ee3\u7801\u3002<\/p>\n
#include<\/span> <iostream><\/span><\/span>\r\n#include<\/span> <string><\/span><\/span>\r\n#include<\/span> <vector><\/span><\/span>\r\n#include<\/span> <fstream><\/span><\/span>\r\n#include<\/span> <memory><\/span><\/span>\r\n#include<\/span> <regex><\/span><\/span>\r\n#include<\/span> <cpprest\/http_client.h><\/span><\/span>\r\n#include<\/span> <cpprest\/filestream.h><\/span><\/span>\r\n#include<\/span> <cpprest\/containerstream.h><\/span><\/span>\r\n\r\n\/\/ \u8bf7\u6c42\u5e76\u89e3\u6790url<\/span>\r\nbool<\/span> get_result<\/span>(const<\/span> std<\/span>::string<\/span>& url, const<\/span> std<\/span>::string<\/span>& pattern, std<\/span>::vector<\/span><std<\/span>::string<\/span>>& vec)<\/span>\r\n<\/span>{\r\n    try<\/span>\r\n    {\r\n        web::http::client::http_client client<\/span>(web::uri(utility::conversions::to_string_t(url)<\/span>))<\/span>;\r\n        web::http::http_response response = client.request(web::http::methods::GET).get();\r\n\r\n        concurrency::streams::stringstreambuf buffer;\r\n        response.body().read_to_end(buffer).get();\r\n        std<\/span>::string<\/span>& str = buffer.collection();\r\n        \r\n            \/\/ \u4f7f\u7528C++11\u63d0\u4f9b\u7684\u6b63\u5219\u8868\u8fbe\u5f0f\u5e93<\/span>\r\n        std<\/span>::regex r<\/span>(pattern)<\/span><\/span>;\r\n        for<\/span> (std<\/span>::sregex_iterator iter<\/span>(str.begin()<\/span>, str.end<\/span>()<\/span>, r), end<\/span>; iter != end; ++iter)\r\n        {\r\n            std<\/span>::cout<\/span> << iter->str() << std<\/span>::endl<\/span>;\r\n            vec.emplace_back(iter->str());\r\n        }\r\n    }\r\n    catch<\/span> (std<\/span>::exception& e)\r\n    {\r\n        std<\/span>::cout<\/span> << \"Exception: \"<\/span> << e.what() << std<\/span>::endl<\/span>;\r\n        return<\/span> false<\/span>;\r\n    }\r\n\r\n    return<\/span> true<\/span>;\r\n}\r\n\r\n\/\/ \u83b7\u53d6\u56fe\u7247<\/span>\r\nbool<\/span> get_result<\/span>(const<\/span> std<\/span>::string<\/span>& url, std<\/span>::string<\/span>& picture)<\/span>\r\n<\/span>{\r\n    try<\/span>\r\n    {\r\n        web::http::client::http_client client<\/span>(web::uri(utility::conversions::to_string_t(url)<\/span>))<\/span>;\r\n        web::http::http_response response = client.request(web::http::methods::GET).get();\r\n\r\n        concurrency::streams::stringstreambuf buffer;\r\n        response.body().read_to_end(buffer).get();\r\n        picture = buffer.collection();\r\n    }\r\n    catch<\/span> (std<\/span>::exception& e)\r\n    {\r\n        std<\/span>::cout<\/span> << \"Exception: \"<\/span> << e.what() << std<\/span>::endl<\/span>;\r\n        return<\/span> false<\/span>;\r\n    }\r\n\r\n    return<\/span> true<\/span>;\r\n}\r\n\r\n\/\/ \u4fdd\u5b58\u56fe\u7247<\/span>\r\nbool<\/span> write_to_file<\/span>(const<\/span> std<\/span>::string<\/span>& file_path, const<\/span> std<\/span>::string<\/span>& data)<\/span>\r\n<\/span>{\r\n    try<\/span>\r\n    {\r\n        std<\/span>::ofstream file;\r\n        file.open(file_path, std<\/span>::ios::out | std<\/span>::ios::binary);\r\n        if<\/span> (!file.good())\r\n        {\r\n            return<\/span> false<\/span>;\r\n        }\r\n        file.write(data.c_str(), data.size());\r\n        file.close();\r\n    }\r\n    catch<\/span> (std<\/span>::exception& e)\r\n    {\r\n        std<\/span>::cout<\/span> << \"Exception: \"<\/span> << e.what() << std<\/span>::endl<\/span>;\r\n        return<\/span> false<\/span>;\r\n    }\r\n\r\n    return<\/span> true<\/span>;\r\n}\r\n\r\nint<\/span> main<\/span>()<\/span>\r\n<\/span>{\r\n    \/\/ [1] \u8bf7\u6c42\u6bcf\u4e00\u9875\uff0c\u5c06\u5b50\u9875\u9762\u7684url\u4fdd\u5b58\u5728sub_url_vec\u91cc\u9762<\/span>\r\n    std<\/span>::vector<\/span><std<\/span>::string<\/span>> sub_url_vec;\r\n    std<\/span>::string<\/span> pattern = \"\/desk\/[0-9]+.htm\"<\/span>;\r\n    for<\/span> (int<\/span> i = 1<\/span>; i <= 32<\/span>; ++i)\r\n    {\r\n        \/\/ \u521b\u610f\u4e3b\u9898<\/span>\r\n        std<\/span>::string<\/span> url = \"http:\/\/www.51ztzj.com\/dbizhi\/category_27_\"<\/span> + std<\/span>::to_string(i) + \".htm#content_anchor\"<\/span>;\r\n        std<\/span>::cout<\/span> << \"Start get \"<\/span> << i << \" page, url: \"<\/span> << url << std<\/span>::endl<\/span>;\r\n        \/\/ \u8bf7\u6c42\u5e76\u89e3\u6790url<\/span>\r\n        if<\/span> (!get_result(url, pattern, sub_url_vec))\r\n        {\r\n            std<\/span>::cout<\/span> << \"Get \"<\/span> << i << \" page failed\"<\/span> << std<\/span>::endl<\/span>;\r\n        }\r\n    }\r\n\r\n    \/\/ \u6700\u7ec8\u7684\u56fe\u7247url\uff1ahttp:\/\/img.51ztzj.com\/\/upload\/image\/20130220\/2013022014_670x419.jpg<\/span>\r\n    \/\/ [2] \u5c06\u5b50\u9875\u9762\u7684\u56fe\u7247url\u89e3\u6790\u51fa\u6765\u653e\u5165picture_url_vec<\/span>\r\n    std<\/span>::vector<\/span><std<\/span>::string<\/span>> picture_url_vec;\r\n    pattern = \"http:\/\/img.51ztzj.com\/\/upload\/image\/.+\/.+_670x419.jpg\"<\/span>;\r\n    for<\/span> (std<\/span>::size_t<\/span> i = 0<\/span>; i < sub_url_vec.size(); ++i)\r\n    {\r\n        std<\/span>::string<\/span> url = \"http:\/\/www.51ztzj.com\"<\/span> + sub_url_vec[i];\r\n        std<\/span>::cout<\/span> << \"Start get \"<\/span> << i + 1<\/span> << \" sub page, url: \"<\/span> << url << std<\/span>::endl<\/span>;\r\n        \/\/ \u8bf7\u6c42\u5e76\u89e3\u6790url<\/span>\r\n        if<\/span> (!get_result(url, pattern, picture_url_vec))\r\n        {\r\n            std<\/span>::cout<\/span> << \"Get \"<\/span> << i + 1<\/span> << \" sub page failed\"<\/span> << std<\/span>::endl<\/span>;\r\n        }\r\n    }\r\n\r\n    \/\/ [3] \u6700\u540e\u904d\u5386picture_url_vec\uff0c\u7136\u540e\u4e00\u4e2a\u4e00\u4e2a\u7684\u4e0b\u8f7d\u56fe\u7247<\/span>\r\n    for<\/span> (std<\/span>::size_t<\/span> i = 0<\/span>; i < picture_url_vec.size(); ++i)\r\n    {\r\n        std<\/span>::cout<\/span> << \"Start download \"<\/span> << i + 1<\/span> << \" picture, url: \"<\/span> << picture_url_vec[i] << std<\/span>::endl<\/span>;\r\n        std<\/span>::string<\/span> picture;\r\n        \/\/ \u83b7\u53d6\u56fe\u7247<\/span>\r\n        if<\/span> (!get_result(picture_url_vec[i], picture))\r\n        {\r\n            std<\/span>::cout<\/span> << \"Download \"<\/span> << i + 1<\/span> << \" picture failed\"<\/span> << std<\/span>::endl<\/span>;\r\n        }\r\n\r\n        std<\/span>::string<\/span> file_path = \".\/download\/\"<\/span> + std<\/span>::to_string(i) + \".jpg\"<\/span>;\r\n        \/\/ \u4fdd\u5b58\u56fe\u7247<\/span>\r\n        if<\/span> (!write_to_file(file_path, picture))\r\n        {\r\n            std<\/span>::cout<\/span> << \"Write to file failed: \"<\/span> << i + 1<\/span> << std<\/span>::endl<\/span>;\r\n        }\r\n    }\r\n\r\n    return<\/span> 0<\/span>;\r\n}<\/code><\/pre>\n<\/div>\n
\u5174\u8da3\u662f\u6700\u597d\u7684\u8001\u5e08\uff0c\u6211\u7684github\u5730\u5740\uff1ahttps:\/\/github.com\/chxuan<\/div>\n
<\/div>\n
\n
\u5206\u7c7b:\u00a0C++11<\/a><\/div>\n<\/div>\n<\/div>\n","protected":false},"excerpt":{"rendered":"
\u597d\u7528\u7684http client\u5e93CPP R<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"colormag_page_container_layout":"default_layout","colormag_page_sidebar_layout":"default_layout","footnotes":""},"categories":[],"tags":[118],"class_list":["post-1643","post","type-post","status-publish","format-standard","hentry","tag-02-"],"_links":{"self":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/posts\/1643","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/comments?post=1643"}],"version-history":[{"count":0,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/posts\/1643\/revisions"}],"wp:attachment":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/media?parent=1643"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/categories?post=1643"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/tags?post=1643"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}