// Copyright 2019, Chen Shuaihao.
//
//Author: Chen Shuaihao
//
//
#include "HttpServer.h"
#include
#include
#include
#include "TimerManager.h"
HttpServer::HttpServer(EventLoop *loop, const int port, const int iothreadnum, const int workerthreadnum)
: tcpserver_(loop, port, iothreadnum),
threadpool_(workerthreadnum)
{
tcpserver_.SetNewConnCallback(std::bind(&HttpServer::HandleNewConnection, this, std::placeholders::_1));
tcpserver_.SetMessageCallback(std::bind(&HttpServer::HandleMessage, this, std::placeholders::_1, std::placeholders::_2));
tcpserver_.SetSendCompleteCallback(std::bind(&HttpServer::HandleSendComplete, this, std::placeholders::_1));
tcpserver_.SetCloseCallback(std::bind(&HttpServer::HandleClose, this, std::placeholders::_1));
tcpserver_.SetErrorCallback(std::bind(&HttpServer::HandleError, this, std::placeholders::_1));
threadpool_.Start(); //å·¥ä½œçº¿ç¨‹æ± å¯åŠ¨
TimerManager::GetTimerManagerInstance()->Start(); //HttpServer定时器管ç†å™¨å¯åŠ¨
}
HttpServer::~HttpServer()
{
}
void HttpServer::HandleNewConnection(const spTcpConnection& sptcpconn)
{
//std::string msg(s);
std::shared_ptr sphttpsession = std::make_shared(); //创建应用层会è¯
spTimer sptimer = std::make_shared(5000, Timer::TimerType::TIMER_ONCE, std::bind(&TcpConnection::Shutdown, sptcpconn));
sptimer->Start();
//å¯ä»¥ä¼˜åŒ–æˆæ— é”，放入conn里é¢å°±è¡Œ
{
std::lock_guard <:mutex> lock(mutex_);
httpsessionnlist_[sptcpconn] = sphttpsession;
timerlist_[sptcpconn] = sptimer;
}
}
void HttpServer::HandleMessage(const spTcpConnection& sptcpconn, std::string &msg)
{
std::shared_ptr sphttpsession;
spTimer sptimer;
{
std::lock_guard <:mutex> lock(mutex_);
sphttpsession = httpsessionnlist_[sptcpconn];
sptimer = timerlist_[sptcpconn];
}
sptimer->Adjust(5000, Timer::TimerType::TIMER_ONCE, std::bind(&TcpConnection::Shutdown, sptcpconn));
if(threadpool_.GetThreadNum() > 0)
{
//Bug20190320：多线程下，对象的声明周期管ç†é—®é¢˜ï¼Œå°±åƒåœ¨è¿™é‡Œï¼Œå‘çº¿ç¨‹æ± ä¼ å…¥äº†phttpsessionå’Œptcpconn，怎么知é“其指å‘对象是å¦å·²ç»æžæž„了呢？
//所以，需è¦é‡‡ç”¨æ™ºèƒ½æŒ‡é’ˆæ¥ç®¡ç†å¯¹è±¡,替æ¢åŽŸå§‹æŒ‡é’ˆ
//çº¿ç¨‹æ± å¤„ç†ä¸šåŠ¡ï¼Œå¤„ç†å®ŒåŽæŠ•é€’回本IO线程执行send
//std::cout << "threadpool_.AddTask" << std::endl;
HttpRequestContext httprequestcontext;
std::string responsecontext;
bool result = sphttpsession->PraseHttpRequest(msg, httprequestcontext);
if(result == false)
{
sphttpsession->HttpError(400, "Bad request", httprequestcontext, responsecontext); //请求报文解æžé”™è¯¯ï¼ŒæŠ¥400
sptcpconn->Send(responsecontext);
return;
}
sptcpconn->SetAsyncProcessing(true);
threadpool_.AddTask([=]() {
//HttpRequestContext req = httprequestcontext;
std::string responsemsg;
sphttpsession->HttpProcess(httprequestcontext, responsemsg);
sptcpconn->Send(responsemsg); //任务已ç»å¤„ç†å®Œæˆï¼Œæ‰§è¡Œè·¨çº¿ç¨‹è°ƒåº¦ï¼Œå³å›žè°ƒ
if(!sphttpsession->KeepAlive())
{
//çŸè¿žæŽ¥ï¼Œå¯ä»¥å‘Šè¯‰æ¡†æž¶å±‚æ•°æ®å‘完就å¯ä»¥å…³æŽ‰TCP连接，ä¸è¿‡è¿™é‡Œæ³¨é‡ŠæŽ‰ï¼Œè¿˜æ˜¯äº¤ç»™å®¢æˆ·ç«¯ä¸»åŠ¨å…³é—å§
//sptcpconn->HandleClose();
}
});
}
else
{
//没有开å¯ä¸šåŠ¡çº¿ç¨‹æ± ，业务计算直接在IO线程执行
HttpRequestContext httprequestcontext;
std::string responsecontext;
bool result = sphttpsession->PraseHttpRequest(msg, httprequestcontext);
if(result == false)
{
sphttpsession->HttpError(400, "Bad request", httprequestcontext, responsecontext); //请求报文解æžé”™è¯¯ï¼ŒæŠ¥400
sptcpconn->Send(responsecontext);
return;
}
sphttpsession->HttpProcess(httprequestcontext, responsecontext);
sptcpconn->Send(responsecontext);
if(!sphttpsession->KeepAlive())
{
//çŸè¿žæŽ¥ï¼Œå¯ä»¥å‘Šè¯‰æ¡†æž¶å±‚æ•°æ®å‘完就å¯ä»¥å…³æŽ‰TCP连接，ä¸è¿‡è¿™é‡Œæ³¨é‡ŠæŽ‰ï¼Œè¿˜æ˜¯äº¤ç»™å®¢æˆ·ç«¯ä¸»åŠ¨å…³é—å§
//sptcpconn->HandleClose();
}
}
}
void HttpServer::HandleSendComplete(const spTcpConnection& sptcpconn)
{
}
void HttpServer::HandleClose(const spTcpConnection& sptcpconn)
{
{
std::lock_guard <:mutex> lock(mutex_);
httpsessionnlist_.erase(sptcpconn);
timerlist_.erase(sptcpconn);
}
}
void HttpServer::HandleError(const spTcpConnection& sptcpconn)
{
{
std::lock_guard <:mutex> lock(mutex_);
httpsessionnlist_.erase(sptcpconn);
timerlist_.erase(sptcpconn);
}
}
void HttpServer::Start()
{
tcpserver_.Start();
}