/* * Copyright 2008 Stephen Liu * For license terms, see the file COPYING along with this library. */ #include #include #include #include #define _CRTDBG_MAP_ALLOC #include #include #include "spporting.hpp" #include "spwin32iocp.hpp" #include "spiocpserver.hpp" #include "sphttp.hpp" #include "sphttpmsg.hpp" #include "spserver.hpp" #pragma comment(lib,"ws2_32") #pragma comment(lib,"mswsock") class SP_HttpEchoHandler : public SP_HttpHandler { public: SP_HttpEchoHandler(){} virtual ~SP_HttpEchoHandler(){} virtual void handle( SP_HttpRequest * request, SP_HttpResponse * response ) { response->setStatusCode( 200 ); response->appendContent( "" "Welcome to simple http" "" ); char buffer[ 512 ] = { 0 }; snprintf( buffer, sizeof( buffer ), "

The requested URI is : %s.

", request->getURI() ); response->appendContent( buffer ); snprintf( buffer, sizeof( buffer ), "

Client IP is : %s.

", request->getClientIP() ); response->appendContent( buffer ); int i = 0; for( i = 0; i < request->getParamCount(); i++ ) { snprintf( buffer, sizeof( buffer ), "

Param - %s = %s

", request->getParamName( i ), request->getParamValue( i ) ); response->appendContent( buffer ); } for( i = 0; i < request->getHeaderCount(); i++ ) { snprintf( buffer, sizeof( buffer ), "

Header - %s: %s

", request->getHeaderName( i ), request->getHeaderValue( i ) ); response->appendContent( buffer ); } if( NULL != request->getContent() ) { response->appendContent( "

" ); response->appendContent( request->getContent(), request->getContentLength() ); response->appendContent( "

" ); } response->appendContent( "\n" ); } }; class SP_HttpEchoHandlerFactory : public SP_HttpHandlerFactory { public: SP_HttpEchoHandlerFactory(){} virtual ~SP_HttpEchoHandlerFactory(){} virtual SP_HttpHandler * create() const { return new SP_HttpEchoHandler(); } }; int main( int argc, char * argv[] ) { int port = 8080, maxThreads = 10; const char * serverType = "hahs"; if( 0 != sp_initsock() ) assert( 0 ); SP_IocpServer server( "", port, new SP_HttpHandlerAdapterFactory( new SP_HttpEchoHandlerFactory() ) ); server.setTimeout( 60 ); server.setMaxThreads( maxThreads ); server.setReqQueueSize( 100, "HTTP/1.1 500 Sorry, server is busy now!\r\n" ); server.runForever(); sp_closelog(); return 0; }