高性能C++网络库libtnet实现：http

HTTP

libtnet提供了简单的http支持，使用也很简单。

一个简单的http server：

void onHandler(const HttpConnectionPtr_t& conn, const HttpRequest& request)
{
    HttpResponse resp;
    resp.statusCode = 200;
    resp.setContentType("text/html");
    resp.body.append("Hello World");    
    conn->send(resp);
}

TcpServer s;
HttpServer httpd(&s);
httpd.setHttpCallback("/test", std::bind(&onHandler, _1, _2));
httpd.listen(Address(80));
s.start(4);

我们对http server的"/test"注册了一个handler，当用户访问该url的时候，就会显示"Hello World"。

同样，http client的使用也很简单：

void onResponse(IOLoop* loop, const HttpResponse& resp)
{
    cout << resp.body << endl;
    loop->stop();
}

IOLoop loop;
HttpClientPtr_t client = std::make_shared<HttpClient>(&loop);
client->request("http://127.0.0.1:80/test", std::bind(&onResponse, &loop, _1));
loop.start();

这里，我们使用了一个http client，向server请求"/test"的内容，当服务器有响应之后，会调用响应的回调函数。

HTTP Parser

对于http的解析，我采用的是http parser，因为它采用的是流式解析，同时非常容易集成进libtnet。

使用http parser只需要设置相应的回调函数即可。http parser有如下几种回调：

message begin，解析开始的时候调用
url，解析url的时候调用
status complete，http response解析status的时候调用
header field，解析http header的field调用
header value，解析http header的value调用
headers complete，解析完成http header调用
body，解析http body调用
message complete，解析完成调用

这里特别需要注意的是http header的解析，因为http parser将其拆分成了两种回调，所以我们在处理的时候需要记录上一次header callback是field的还是value的。在解析field的时候，如果上一次是value callback，那我们就需要将上一次解析的field和value保存下来，而该次的解析则是一个新的field了。

另外，http parser还提供了upgrade的支持，所以我们很方便的就能区分该次请求是否为websocket。

Websocket

libtnet也提供了websocket的支持，现阶段，只支持RFC6455。

当libtnet通过http parser发现该次请求为websocket的时候，就进入了websocket的流程。websocket的使用也很简单，当握手成功之后，后续的所有通讯就是纯粹的tcp通信了。

一个简单的websocket server：

void onWsCallback(const WsConnectionPtr_t& conn, WsEvent event, const void* context)
{
    switch(event)
    {
        case Ws_CloseEvent:
            break;
        case Ws_MessageEvent:
            {
                const string& str = *(const string*)context;
                conn->send(str);
            }
            break;
        case Ws_PongEvent:
            break;
        default:
            break;
    }
}

TcpServer s;
HttpServer httpd(&s);
httpd.setWsCallback("/push/ws", std::bind(&onWsCallback, _1, _2, _3));    
httpd.listen(Address(80));
s.start();

可以看到，websocket的callback机制也类似于libtnet connection的callback机制，用户需通过event + context的方式来处理该次回调的数据。

libtnet对websocket的frame的处理参照的是tornado的websocket模块。也能够组合多frame的数据，外部只需要关注Ws_MessageEvent即可。

websocket client的实现也很简单：

void onWsConnEvent(const WsConnectionPtr_t& conn, WsEvent event, const void* context)
{
    switch(event)
    {
        case Ws_OpenEvent:
            conn->send("Hello world");
            break;    
        case Ws_MessageEvent:
            {
                const string& msg = *(const string*)context;

                LOG_INFO("message %s", msg.c_str());
                conn->close();                        
            }
            break;
        default:
            break;
    }    
}

IOLoop loop;
WsClientPtr_t client = std::make_shared<WsClient>(&loop);    
client->connect("ws://127.0.0.1:80/push/ws", std::bind(&onWsConnEvent, _1, _2, _3));
loop.start();

libtnet的地址https://github.com/siddontang/libtnet，欢迎围观。