http_HttpServer.hpp

浏览该文件的文档.

#pragma once

namespace http
{
class HTTPWRAPPER_DLL HttpServer : public eiennet::Server, public UrlRouter
{
public:
    using CrossRouteHandlerFunction = CrossRouteHandlerFunctionT<HttpRequestCtx, Response>;

    using RouteHandlerFunction = RouteHandlerFunctionT<HttpRequestCtx, Response>;

    HttpServer();

    HttpServer( winux::ConfigureSettings const & settings );

    HttpServer(
        winux::ConfigureSettings const & settings,
        eiennet::ip::EndPoint const & ep,
        int threadCount = 4,
        int backlog = 0,
        double serverWait = 0.002,
        double verboseInterval = 0.01,
        eiennet::VerboseOutputType verbose = eiennet::votConsole,
        int cacheLifeTime = 86400
    );

    bool init( winux::ConfigureSettings const & settings );

    bool init(
        winux::ConfigureSettings const & settings,
        eiennet::ip::EndPoint const & ep,
        int threadCount = 4,
        int backlog = 0,
        double serverWait = 0.002,
        double verboseInterval = 0.01,
        eiennet::VerboseOutputType verbose = eiennet::votConsole,
        int cacheLifeTime = 86400
    );

    void crossRoute( winux::String const & method, winux::String const & path, CrossRouteHandlerFunction handler );

    void route( winux::String const & method, winux::String const & path, RouteHandlerFunction handler );

    virtual int run( void * runParam ) override;

    HttpServerConfig httpConfig;

protected:
    // 当创建客户连接
    virtual eiennet::ClientCtx * onCreateClient( winux::uint64 clientId, winux::String const & clientEpStr, winux::SharedPointer<eiennet::ip::tcp::Socket> clientSockPtr ) override;
    // 当客户数据到达
    virtual void onClientDataArrived( winux::SharedPointer<eiennet::ClientCtx> clientCtxPtr, winux::Buffer & data ) override;
    void _onHttpRequestInternal( winux::SharedPointer<HttpRequestCtx> requestCtxPtr );
    virtual bool _beginHttpRequest( winux::SharedPointer<http::HttpRequestCtx> requestCtxPtr, http::UrlPathPartData * urlData );
    virtual void _endHttpRequest( winux::SharedPointer<http::HttpRequestCtx> requestCtxPtr );
    virtual bool _beginRouting( winux::SharedPointer<http::HttpRequestCtx> requestCtxPtr, http::UrlPathPartData const & urlData, http::Response & rsp ) { return true; }
    virtual void _endRouting( winux::SharedPointer<http::HttpRequestCtx> requestCtxPtr, http::UrlPathPartData const & urlData, http::Response & rsp ) { }

    virtual void _whatNextTask( winux::SharedPointer<HttpRequestCtx> requestCtxPtr );

    virtual void _doTask( winux::SharedPointer<http::HttpRequestCtx> requestCtxPtr );

    void _doRecvRequestHeaderTask( winux::SharedPointer<HttpRequestCtx> requestCtxPtr );

    void _doRecvRequestBodyTask( winux::SharedPointer<HttpRequestCtx> requestCtxPtr );

    // 创建响应
    DEFINE_CUSTOM_EVENT_RETURN_EX(
        Response *,
        CreateResponse,
        ( Request & req, winux::SimplePointer<RspOutputMgr> outputMgr )
    );

    friend class HttpRequestCtx;
};


} // namespace http