高性能 C HTTP客户端的原理
Workflow是个异步调度框架,因此这个任务发出之后,不会阻塞当前线程,外加内部自带的连接复用,从根本上保证了我们的Http Client的高性能。
1、创建Http任务
上述demo可以看到,请求是通过发起一个Workflow的Http异步任务来实现的,创建任务的接口如下:
WFHttpTask *create_http_task(const std::string& url,
int redirect_max, int retry_max,
http_callback_t callback);
第一个参数就是我们要请求的URL。对应的,在一开始的示例中,我们的重定向次数redirect_max是2次,而重试次数retry_max是3次。第四个参数是一个回调函数,示例中我们用了一个lambda,由于Workflow的任务都是异步的,因此我们处理结果这件事情是被动通知我们的,结果回来就会调起这个回调函数,格式如下:
代码语言:javascript复制using http_callback_t = std::function<void (WFHttpTask *)>;
2、填写header并发出
我们的网络交互无非是请求-回复,对应到Http Client上,在我们创建好了task之后,我们有一些时机是处理请求的,在Http协议里,就是在header里填好协议相关的事情,比如我们可以通过Connection来指定希望得到建立Http的长连接,以节省下次建立连接的耗时,那么我们可以把Connection设置为Keep-Alive。示例如下:
代码语言:javascript复制protocol::HttpRequest *req = task->get_req();
req->add_header_pair("Connection", "Keep-Alive");
task->start();
最后我们会把设置好请求的任务,通过 task->start(); 发出。最开始的 http_client.cc 示例中,有一个 getchar(); 语句,是因为我们的异步任务发出后是非阻塞的,当前线程不暂时停住就会退出,而我们希望等到回调函数回来,因此我们可以用多种暂停的方式。
3、处理返回结果
一个返回结果,根据Http协议,会包含三部分:消息行、消息头header、消息正文body。如果我们想要获取body,可以这样:
代码语言:javascript复制const void *body;
size_t body_len;
task->get_resp()->get_parsed_body(&body, &body_len);
高性能的基本保证
我们使用C 来写Http Client,最香的就是可以利用其高性能。Workflow对高并发是如何保证的呢?其实就两点:
- 纯异步;
- 连接复用;
前者是对线程资源的重复利用、后者是对连接资源的重复利用,这些框架层级都为用户管理好了,充分减少开发者的心智负担。
以上就是高性能 C HTTP客户端的原理,希望对大家有所帮助。更多精彩内容分享:头条