我目前正在尝试使用Boost.Asio创建一个http服务器,我这样做了这个HTTP Server 3。Boost :: Asio HTTP Server极其缓慢
目前我只是阅读请求,并总是返回一个OK消息。所以没有什么特别的或耗时的。
我遇到的问题是,使用12个线程(16个核心@ 2.53GHz)运行服务器,服务器每秒处理200-300个请求。
我在C#中使用HttpListener进行了相同的处理,它使用12个线程运行,它处理了5000-7000个请求。
Boost.Asio在干什么?
使用仪器探查与Visual Studio取得以下 “功能使用的大多数个人工作”:
Name Exclusive Time %
GetQueuedCompletionStatus 44,46
std::_Lockit::_Lockit 14,54
std::_Container_base12::_Orphan_all 3,46
std::_Iterator_base12::~_Iterator_base12 2,06
编辑1:
if (!err) { //Add data to client request if(client_request_.empty()) client_request_ = std::string(client_buffer_.data(), bytes_transferred); else client_request_ += std::string(client_buffer_.data(), bytes_transferred); //Check if headers complete client_headerEnd_ = client_request_.find("\r\n\r\n"); if(client_headerEnd_ == std::string::npos) { //Headers not yet complete, read again client_socket_.async_read_some(boost::asio::buffer(client_buffer_), boost::bind(&session::handle_client_read_headers, shared_from_this(), boost::asio::placeholders::error, boost::asio::placeholders::bytes_transferred)); } else { //Search Cookie std::string::size_type loc=client_request_.find("Cookie"); if(loc != std::string::npos) { //Found Cookie std::string::size_type locend=client_request_.find_first_of("\r\n", loc); if(locend != std::string::npos) { std::string lCookie = client_request_.substr(loc, (locend-loc)); loc = lCookie.find(": "); if(loc != std::string::npos) { std::string sCookies = lCookie.substr(loc+2); std::vector<std::string> vCookies; boost::split(vCookies, sCookies, boost::is_any_of(";")); for (std::size_t i = 0; i < vCookies.size(); ++i) { std::vector<std::string> vCookie; boost::split(vCookie, vCookies[i], boost::is_any_of("=")); if(vCookie[0].compare("sessionid") == 0) { if(vCookie.size() > 1) { client_sessionid_ = vCookie[1]; break; } } } } } } //Search Content-Length loc=client_request_.find("Content-Length"); if(loc == std::string::npos) { //No Content-Length, no Content? -> stop further reading send_bad_request(); return; } else { //Parse Content-Length, for further body reading std::string::size_type locend=client_request_.find_first_of("\r\n", loc); if(locend == std::string::npos) { //Couldn't find header end, can't parse Content-Length -> stop further reading send_bad_request(); return; } std::string lHeader = client_request_.substr(loc, (locend-loc)); loc = lHeader.find(": "); if(loc == std::string::npos) { //Couldn't find colon, can't parse Content-Length -> stop further reading send_bad_request(); return; } //Save Content-Length client_request_content_length_ = boost::lexical_cast<std::string::size_type>(lHeader.substr(loc+2)); //Check if already read complete body if((client_request_.size()-(client_headerEnd_)) < client_request_content_length_) { //Content-Length greater than current body, start reading. client_socket_.async_read_some(boost::asio::buffer(client_buffer_), boost::bind(&session::handle_client_read_body, shared_from_this(), boost::asio::placeholders::error, boost::asio::placeholders::bytes_transferred)); } else { //Body is complete, start handling handle_request(); } } } }
编辑2:
用于测试的客户端是一个简单的C#应用程序,它启动128个线程,每次迭代1000次而没有任何睡眠。
System.Net.HttpWebRequest req = (System.Net.HttpWebRequest)System.Net.WebRequest.Create(BaseUrl);
req.Method = "POST";
byte[] buffer = Encoding.ASCII.GetBytes("{\"method\":\"User.Login\",\"params\":[]}");
req.GetRequestStream().Write(buffer, 0, buffer.Length);
req.GetRequestStream().Close();
简单地重写代码。这不是最佳的。 request_parser以每个字节为例进行解析,并将其push_back为字符串,不作任何保留。 asio :: strand也有一些未公开的问题。 – ForEveR
很难说没有看到一些真实的代码..你有没有尝试分析它?此外,你有没有编译过任何优化? – Nim
这通常是让Nagle开启的问题。 请参阅:http://stackoverflow.com/questions/2039224/poor-boost-asio-performance/2039378#2039378 – janm