Home | Trees | Indices | Help |
|
---|
|
A high-speed, production ready, thread pooled, generic HTTP server.
Simplest example on how to use this module directly (without using CherryPy's application machinery):
from cherrypy import wsgiserver def my_crazy_app(environ, start_response): status = '200 OK' response_headers = [('Content-type','text/plain')] start_response(status, response_headers) return ['Hello world!'] server = wsgiserver.CherryPyWSGIServer( ('0.0.0.0', 8070), my_crazy_app, server_name='www.cherrypy.example') server.start()
The CherryPy WSGI server can serve as many WSGI applications as you want in one instance by using a WSGIPathInfoDispatcher:
d = WSGIPathInfoDispatcher({'/': my_crazy_app, '/blog': my_blog_app}) server = wsgiserver.CherryPyWSGIServer(('0.0.0.0', 80), d)
Want SSL support? Just set server.ssl_adapter to an SSLAdapter instance.
This won't call the CherryPy engine (application side) at all, only the HTTP server, which is independent from the rest of CherryPy. Don't let the name "CherryPyWSGIServer" throw you; the name merely reflects its origin, not its coupling.
For those of you wanting to understand internals of this module, here's the basic call flow. The server's listening thread runs a very tight loop, sticking incoming connections onto a Queue:
server = CherryPyWSGIServer(...) server.start() while True: tick() # This blocks until a request comes in: child = socket.accept() conn = HTTPConnection(child, ...) server.requests.put(conn)
Worker threads are kept in a pool and poll the Queue, popping off and then handling each connection in turn. Each connection can consist of an arbitrary number of requests and their responses, so we run a nested loop:
while True: conn = server.requests.get() conn.communicate() -> while True: req = HTTPRequest(...) req.parse_request() -> # Read the Request-Line, e.g. "GET /page HTTP/1.1" req.rfile.readline() read_headers(req.rfile, req.inheaders) req.respond() -> response = app(...) try: for chunk in response: if chunk: req.write(chunk) finally: if hasattr(response, "close"): response.close() if req.close_connection: return
|
|||
MaxSizeExceeded | |||
SizeCheckWrapper Wraps a file-like object, raising MaxSizeExceeded if too large. |
|||
KnownLengthRFile Wraps a file-like object, returning an empty string when exhausted. |
|||
ChunkedRFile Wraps a file-like object, returning an empty string when exhausted. |
|||
HTTPRequest An HTTP Request (and response). |
|||
NoSSLError Exception raised when a client speaks HTTP to an HTTPS socket. |
|||
FatalSSLAlert Exception raised when the SSL implementation signals a fatal alert. |
|||
CP_fileobject Faux file object attached to a socket object. |
|||
HTTPConnection An HTTP connection (active socket). |
|||
TrueyZero An object which equals and does math like the integer 0 but evals True. |
|||
WorkerThread Thread which continuously polls a Queue for Connection objects. |
|||
ThreadPool A Request Queue for an HTTPServer which pools threads. |
|||
SSLAdapter Base class for SSL driver library adapters. |
|||
HTTPServer An HTTP server. |
|||
Gateway A base class to interface HTTPServer with other systems, such as WSGI. |
|||
CherryPyWSGIServer A subclass of HTTPServer which calls a WSGI application. |
|||
WSGIGateway A base class to interface HTTPServer with WSGI. |
|||
WSGIGateway_10 A Gateway class to interface HTTPServer with WSGI 1.0.x. |
|||
WSGIGateway_u0 A Gateway class to interface HTTPServer with WSGI u.0. |
|||
WSGIPathInfoDispatcher A WSGI dispatcher for dispatch based on the PATH_INFO. |
|
|||
|
|||
|
|||
|
|||
|
|||
|
|||
|
|
|||
DEFAULT_BUFFER_SIZE = -1
|
|||
_fileobject_uses_str_type = False
|
|||
LF =
|
|||
CRLF =
|
|||
TAB =
|
|||
SPACE =
|
|||
COLON =
|
|||
SEMICOLON =
|
|||
EMPTY =
|
|||
NUMBER_SIGN =
|
|||
QUESTION_MARK =
|
|||
ASTERISK =
|
|||
FORWARD_SLASH =
|
|||
quoted_slash = re.compile(r'
|
|||
socket_error_eintr =
|
|||
socket_errors_to_ignore =
|
|||
socket_errors_nonblocking =
|
|||
comma_separated_headers =
|
|||
trueyzero = <cherrypy.wsgiserver.wsgiserver2.TrueyZero object>
|
|||
_SHUTDOWNREQUEST = None hash(x) |
|||
_SetHandleInformation = windll.kernel32.SetHandleInformation
|
|||
ssl_adapters =
|
|||
wsgi_gateways =
|
|||
__package__ =
|
|||
h =
|
|
Like print_exc() but return a string. Backport for Python 2.3. |
Return error numbers for all errors in errnames on this platform. The 'errno' module contains different global constants depending on the specific platform (OS). This function will return the list of numeric values for a given list of potential names. |
Read headers from the given stream into the given header dict. If hdict is None, a new header dict is created. Returns the populated header dict. Headers which are repeated are folded together using a comma if their specification so dictates. This function raises ValueError when the read bytes violate the HTTP spec. You should probably return "400 Bad Request" if this happens. |
|
socket_errors_to_ignore
|
comma_separated_headers
|
ssl_adapters
|
wsgi_gateways
|
Home | Trees | Indices | Help |
|
---|
Generated by Epydoc 3.0.1 on Mon Dec 1 16:24:00 2014 | http://epydoc.sourceforge.net |