#include#include#include#include#include#include#includestructdownload_context{structevhttp_uri*uri;structevent_b" />

日韩久久久精品,亚洲精品久久久久久久久久久,亚洲欧美一区二区三区国产精品 ,一区二区福利

libevent http client

系統 1977 0

#include <errno.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>

#include <event2/event.h>
#include <event2/buffer.h>
#include <event2/http.h>
#include <event2/http_struct.h>

struct download_context
{
??? struct evhttp_uri *uri;
??? struct event_base *base;
??? struct evhttp_connection *cn;
??? struct evhttp_request *req;
??? struct evbuffer *buffer;
??? int ok;
};

static void download_callback(struct evhttp_request *req, void *arg);

static int download_renew_request(struct download_context *ctx);

static void download_callback(struct evhttp_request *req, void *arg)
{
??? struct download_context *ctx = (struct download_context *)arg;
??? struct evhttp_uri *new_uri = NULL;
??? const char *new_location = NULL;

??? /*? response is ready */

??? switch(req->response_code)
??? {
??????? case HTTP_OK:
??????????? /*?
???????????? *?????????? * Response is received. No futher handling is required.
???????????? *?????????????????? * Finish
???????????? *?????????????????????????? */
??????????? event_base_loopexit(ctx->base, 0);
??????????? break;

??????? case HTTP_MOVEPERM:
??????? case HTTP_MOVETEMP:
??????????? new_location = evhttp_find_header(req->input_headers, "Location");
??????????? if (!new_location)
??????????????? return;

??????????? new_uri = evhttp_uri_parse(new_location);
??????????? if (!new_uri)
??????????????? return;

??????????? evhttp_uri_free(ctx->uri);
??????????? ctx->uri = new_uri;

??????????? download_renew_request(ctx);
??????????? return;

??????? default:
??????????? /*? FAILURE */
??????????? event_base_loopexit(ctx->base, 0);
??????????? return;
??? }

??? evbuffer_add_buffer(ctx->buffer, req->input_buffer);

??? /*? SUCCESS */
??? ctx->ok = 1;
}

struct download_context *context_new(const char *url)
{
??? struct download_context *ctx = 0;
??? ctx = new (struct download_context);//(struct download_context*)calloc(0, sizeof(*ctx));
??? if (!ctx)
??????? return 0;

??? ctx->uri = evhttp_uri_parse(url);
??? if (!ctx->uri)
??????? return 0;

??? ctx->base = event_base_new();
??? if (!ctx->base)
??????? return 0;

??? ctx->buffer = evbuffer_new();

??? download_renew_request(ctx);

??? return ctx;
}

void context_free(struct download_context *ctx)
{
??? evhttp_connection_free(ctx->cn);
??? event_base_free(ctx->base);

??? if (ctx->buffer)
??????? evbuffer_free(ctx->buffer);

??? evhttp_uri_free(ctx->uri);
??? free(ctx);
}

static int download_renew_request(struct download_context *ctx)
{
??? /*? free connections & request */
??? if (ctx->cn)
??????? evhttp_connection_free(ctx->cn);

??? ctx->cn = evhttp_connection_base_new(ctx->base, NULL, "127.0.0.1", 56777);

??? ctx->req = evhttp_request_new(download_callback, ctx);

??? evhttp_make_request(ctx->cn, ctx->req, EVHTTP_REQ_GET, "/Hello");

??? evhttp_add_header(ctx->req->output_headers, "Host", "127.0.0.1");
??? return 0;
}

struct evbuffer *download_url(const char *url)
{
??? /*? setup request, connection etc */

??? struct download_context *ctx = context_new(url);
??? if (!ctx)
??????? return 0;

??? /*? do all of the job */
??? event_base_dispatch(ctx->base);

??? struct evbuffer *retval = 0;
??? if (ctx->ok)
??? {
??????? retval = ctx->buffer;
??????? ctx->buffer = 0;
??? }

??? context_free(ctx);

??? return retval;
}

int main(int argc, char *argv[])
{
??? if (argc < 2)
??? {
??????? printf("usage: %s example.com/\n", argv[0]);
??????? return 1;
??? }

??? struct evbuffer *data = download_url(argv[1]);

??? printf("got %d bytes\n", data ? evbuffer_get_length(data) : -1);

??? if (data)
??? {
??????? const unsigned char *joined = evbuffer_pullup(data, -1);
??????? printf("data itself:\n====================\n");
??????? ::write(1, joined, evbuffer_get_length(data));
??????? printf("\n====================\n");

??????? evbuffer_free(data);
??? }

??? return 0;
}

libevent http client


更多文章、技術交流、商務合作、聯系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯系: 360901061

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦!!!

發表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 磴口县| 织金县| 涞源县| 鄂伦春自治旗| 丘北县| 吉木乃县| 竹山县| 望都县| 天柱县| 津市市| 安庆市| 从化市| 清原| 白玉县| 监利县| 麟游县| 巨野县| 北川| 乾安县| 白玉县| 额敏县| 辽阳县| 安多县| 苍溪县| 汉沽区| 阿拉善左旗| 江川县| 西乌| 都江堰市| 嵩明县| 荣昌县| 崇左市| 东城区| 措勤县| 青岛市| 缙云县| 和林格尔县| 樟树市| 深州市| 阿坝| 宁波市|