/* * Copyright 2007 Stephen Liu * For license terms, see the file COPYING along with this library. */ #include #include #include #include #include #include #include #include "sphttp.hpp" #include "sphttpmsg.hpp" #include "spserver.hpp" #include "splfserver.hpp" #include "spopenssl.hpp" 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 ); for( int i = 0; i < request->getParamCount(); i++ ) { snprintf( buffer, sizeof( buffer ), "

Param - %s = %s

", request->getParamName( i ), request->getParamValue( i ) ); response->appendContent( buffer ); } for( int 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"; extern char *optarg ; int c ; while( ( c = getopt ( argc, argv, "p:t:s:v" )) != EOF ) { switch ( c ) { case 'p' : port = atoi( optarg ); break; case 't': maxThreads = atoi( optarg ); break; case 's': serverType = optarg; break; case '?' : case 'v' : printf( "Usage: %s [-p ] [-t ] [-s ]\n", argv[0] ); exit( 0 ); } } #ifdef LOG_PERROR openlog( "testhttps", LOG_CONS | LOG_PID | LOG_PERROR, LOG_USER ); #else openlog( "testhttps", LOG_CONS | LOG_PID, LOG_USER ); #endif SP_OpensslChannelFactory * opensslFactory = new SP_OpensslChannelFactory(); opensslFactory->init( "demo.crt", "demo.key" ); if( 0 == strcasecmp( serverType, "hahs" ) ) { SP_Server 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.setIOChannelFactory( opensslFactory ); server.runForever(); } else { SP_LFServer 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.setIOChannelFactory( opensslFactory ); server.runForever(); } closelog(); return 0; }