libhv

✨ Features

⌛️ Build

./configuremakesudo make install

mkdir buildcd buildcmake ..cmake --build.

bazel build libhv

vcpkg install libhv

xrepo install libhv

⚡️ Getting Started

git clone https://github.com/ithewei/libhv.gitcd libhv./configuremakebin/httpd -hbin/httpd -d#bin/httpd -c etc/httpd.conf -s restart -dps aux| grep httpd# http file servicebin/curl -v localhost:8080# http indexof servicebin/curl -v localhost:8080/downloads/# http api servicebin/curl -v localhost:8080/pingbin/curl -v localhost:8080/echo -d"hello,world!"bin/curl -v localhost:8080/query?page_no=1\&page_size=10bin/curl -v localhost:8080/kv   -H"Content-Type:application/x-www-form-urlencoded" -d'user=admin&pswd=123456'bin/curl -v localhost:8080/json -H"Content-Type:application/json" -d'{"user":"admin","pswd":"123456"}'bin/curl -v localhost:8080/form -F'user=admin' -F'pswd=123456'bin/curl -v localhost:8080/upload -d"@LICENSE"bin/curl -v localhost:8080/upload -F"file=@LICENSE"bin/curl -v localhost:8080/test -H"Content-Type:application/x-www-form-urlencoded" -d'bool=1&int=123&float=3.14&string=hello'bin/curl -v localhost:8080/test -H"Content-Type:application/json" -d'{"bool":true,"int":123,"float":3.14,"string":"hello"}'bin/curl -v localhost:8080/test -F'bool=1' -F'int=123' -F'float=3.14' -F'string=hello'# RESTful API: /group/:group_name/user/:user_idbin/curl -v -X DELETE localhost:8080/group/test/user/123# benchmarkbin/wrk -c 1000 -d 10 -t 4 http://127.0.0.1:8080/

TCP

tcp server

#include"TcpServer.h"usingnamespacehv;intmain() {int port =1234;    TcpServer srv;int listenfd = srv.createsocket(port);if (listenfd <0) {return -1;    }printf("server listen on port %d, listenfd=%d ...\n", port, listenfd);    srv.onConnection = [](const SocketChannelPtr& channel) {        std::string peeraddr = channel->peeraddr();if (channel->isConnected()) {printf("%s connected! connfd=%d\n", peeraddr.c_str(), channel->fd());        }else {printf("%s disconnected! connfd=%d\n", peeraddr.c_str(), channel->fd());        }    };    srv.onMessage = [](const SocketChannelPtr& channel, Buffer* buf) {// echo        channel->write(buf);    };    srv.setThreadNum(4);    srv.start();// press Enter to stopwhile (getchar() !='\n');return0;}

tcp client

#include<iostream>#include"TcpClient.h"usingnamespacehv;intmain() {int port =1234;    TcpClient cli;int connfd = cli.createsocket(port);if (connfd <0) {return -1;    }    cli.onConnection = [](const SocketChannelPtr& channel) {        std::string peeraddr = channel->peeraddr();if (channel->isConnected()) {printf("connected to %s! connfd=%d\n", peeraddr.c_str(), channel->fd());        }else {printf("disconnected to %s! connfd=%d\n", peeraddr.c_str(), channel->fd());        }    };    cli.onMessage = [](const SocketChannelPtr& channel, Buffer* buf) {printf("< %.*s\n", (int)buf->size(), (char*)buf->data());    };    cli.start();    std::string str;while (std::getline(std::cin, str)) {if (str =="close") {            cli.closesocket();        }elseif (str =="start") {            cli.start();        }elseif (str =="stop") {            cli.stop();break;        }else {if (!cli.isConnected())break;            cli.send(str);        }    }return0;}

HTTP

http server

#include"HttpServer.h"usingnamespacehv;intmain() {    HttpService router;    router.GET("/ping", [](HttpRequest* req, HttpResponse* resp) {return resp->String("pong");    });    router.GET("/data", [](HttpRequest* req, HttpResponse* resp) {staticchar data[] ="0123456789";return resp->Data(data,10);    });    router.GET("/paths", [&router](HttpRequest* req, HttpResponse* resp) {return resp->Json(router.Paths());    });    router.GET("/get", [](HttpRequest* req, HttpResponse* resp) {        resp->json["origin"] = req->client_addr.ip;        resp->json["url"] = req->url;        resp->json["args"] = req->query_params;        resp->json["headers"] = req->headers;return200;    });    router.POST("/echo", [](const HttpContextPtr& ctx) {return ctx->send(ctx->body(), ctx->type());    });    HttpServerserver(&router);    server.setPort(8080);    server.setThreadNum(4);    server.run();return0;}

http client

#include"requests.h"intmain() {auto resp =requests::get("http://www.example.com");if (resp ==NULL) {printf("request failed!\n");    }else {printf("%s\n", resp->body.c_str());    }    resp =requests::post("127.0.0.1:8080/echo","hello,world!");if (resp ==NULL) {printf("request failed!\n");    }else {printf("%s\n", resp->body.c_str());    }return0;}

WebSocket

WebSocket server

#include"WebSocketServer.h"usingnamespacehv;intmain(int argc,char** argv) {    WebSocketService ws;    ws.onopen = [](const WebSocketChannelPtr& channel,const HttpRequestPtr& req) {printf("onopen: GET %s\n", req->Path().c_str());    };    ws.onmessage = [](const WebSocketChannelPtr& channel,const std::string& msg) {printf("onmessage: %.*s\n", (int)msg.size(), msg.data());    };    ws.onclose = [](const WebSocketChannelPtr& channel) {printf("onclose\n");    };    WebSocketServerserver(&ws);    server.setPort(9999);    server.setThreadNum(4);    server.run();return0;}

WebSocket client

#include"WebSocketClient.h"usingnamespacehv;intmain(int argc,char** argv) {    WebSocketClient ws;    ws.onopen = []() {printf("onopen\n");    };    ws.onmessage = [](const std::string& msg) {printf("onmessage: %.*s\n", (int)msg.size(), msg.data());    };    ws.onclose = []() {printf("onclose\n");    };// reconnect: 1,2,4,8,10,10,10...reconn_setting_t reconn;reconn_setting_init(&reconn);    reconn.min_delay =1000;    reconn.max_delay =10000;    reconn.delay_policy =2;    ws.setReconnect(&reconn);    ws.open("ws://127.0.0.1:9999/test");    std::string str;while (std::getline(std::cin, str)) {if (!ws.isConnected())break;if (str =="quit") {            ws.close();break;        }        ws.send(str);    }return0;}

🍭 More examples

c version

c++ version

simulate well-known command line tools

🥇 Benchmark

pingpong echo-servers

cd echo-servers./build.sh./benchmark.sh

libevent running on port 2001libev running on port 2002libuv running on port 2003libhv running on port 2004asio running on port 2005poco running on port 2006==============2001=====================================[127.0.0.1:2001] 4 threads 1000 connections run 10stotal readcount=1616761 readbytes=1655563264throughput = 157 MB/s==============2002=====================================[127.0.0.1:2002] 4 threads 1000 connections run 10stotal readcount=2153171 readbytes=2204847104throughput = 210 MB/s==============2003=====================================[127.0.0.1:2003] 4 threads 1000 connections run 10stotal readcount=1599727 readbytes=1638120448throughput = 156 MB/s==============2004=====================================[127.0.0.1:2004] 4 threads 1000 connections run 10stotal readcount=2202271 readbytes=2255125504throughput = 215 MB/s==============2005=====================================[127.0.0.1:2005] 4 threads 1000 connections run 10stotal readcount=1354230 readbytes=1386731520throughput = 132 MB/s==============2006=====================================[127.0.0.1:2006] 4 threads 1000 connections run 10stotal readcount=1699652 readbytes=1740443648throughput = 165 MB/s

iperf tcp_proxy_server

# sudo apt install iperfiperf -s -p 5001> /dev/null&bin/tcp_proxy_server 1212 127.0.0.1:5001&iperf -c 127.0.0.1 -p 5001 -l 8Kiperf -c 127.0.0.1 -p 1212 -l 8K

------------------------------------------------------------[  3]local 127.0.0.1 port 52560 connected with 127.0.0.1 port 5001[ ID] Interval       Transfer     Bandwidth[  3]  0.0-10.0 sec  20.8 GBytes  17.9 Gbits/sec------------------------------------------------------------[  3]local 127.0.0.1 port 48142 connected with 127.0.0.1 port 1212[ ID] Interval       Transfer     Bandwidth[  3]  0.0-10.0 sec  11.9 GBytes  10.2 Gbits/sec

webbench

# sudo apt install wrkwrk -c 100 -t 4 -d 10s http://127.0.0.1:8080/# sudo apt install apache2-utilsab -c 100 -n 100000 http://127.0.0.1:8080/