eiennet_httpserv.hpp

浏览该文件的文档.

#ifndef __HTTPSERV_HPP__
#define __HTTPSERV_HPP__

#pragma once

namespace eiennet
{

struct EIENNET_DLL HttpServerConfig
{
    winux::String serverIp;
    winux::ushort serverPort;
    winux::String documentRoot;
    winux::String documentIndex;
    bool outputVerbose;
    int listenBacklog;
    int threadCount;
    double durationSec;
    int retryCount;

    std::map< winux::String, winux::String > mime; // MIME

    HttpServerConfig( winux::Configure const & confObj );
    HttpServerConfig( winux::String const & serverIp, winux::ushort port, int threadCount, int listenBacklog, double durationSec );

    winux::String getMime( winux::String const & extName ) const;
    void initMimeList();
};

class HttpClientCtx : public ClientCtx
{
public:
    HttpClientCtx( winux::uint64 clientId, winux::String clientEpStr, winux::SharedPointer<ip::tcp::Socket> clientSockPtr )
        : ClientCtx( clientId, clientEpStr, clientSockPtr ), url(http::Url::urlSimple), config(nullptr)
    {
    }
    virtual ~HttpClientCtx()
    {
        if ( !this->config || this->config->outputVerbose )
            ColorOutput( winux::fgPurple, "Client[", clientId, "]客户场景`", clientEpStr, "`析构" );
    }
    DataRecvSendCtx forClient; // 数据收发场景
    winux::AnsiString requestHeaderStr;   // 请求头字符串
    http::Header requestHeader;    // 请求头
    winux::GrowBuffer requestBody; // 请求体数据
    http::Url url; // URL
    HttpServerConfig const * config; // 引用配置对象
};

class EIENNET_DLL HttpServer : public Server<HttpClientCtx>
{
public:
    HttpServerConfig const config; 

    #define RESPONSE_HANDLER_PARAMS eiennet::HttpServer::ClientCtxSharedPointer & clientCtxPtr, http::Header const & reqHdr, http::Url const & url, http::Header & rspHdr, std::ostream & rspOut
    using ResponseHandlerFunction = std::function< void ( RESPONSE_HANDLER_PARAMS ) >;

    HttpServer( HttpServerConfig const & confObj );
    HttpServer( winux::String const & serverIp, winux::ushort port, int threadCount = 4, int listenBacklog = 10, double durationSec = 0.1 );

    void setHandler( winux::String const & urlPath, ResponseHandlerFunction handler ) { _handlers[urlPath] = handler; }

private:
    // 业务启动函数
    virtual void onStartup( ClientCtxSharedPointer clientCtxPtr ) override;

    // 尝试接收一个请求头的任务
    void _doRecvRequestHeaderTask( ClientCtxSharedPointer clientCtxPtr );

    // 尝试接收一个请求体的任务
    void _doRecvRequestBodyTask( ClientCtxSharedPointer clientCtxPtr );

    // 处理一个请求的任务
    void _doRequestTask( ClientCtxSharedPointer clientCtxPtr );

    // Web逻辑处理
    void _webProcess( ClientCtxSharedPointer & clientCtxPtr, http::Header const & reqHdr, http::Url const & url, http::Header & rspHdr, std::ostream & rspOut );

    std::map< winux::String, ResponseHandlerFunction > _handlers; // 响应处理函数

    friend class HttpClientCtx;
};



} // namespace eiennet

#endif // __HTTPSERV_HPP__