python WSGI
WSGI是作为Web服务器与Web应用程序或应用框架之间的一种低级别的接口 。WSGI is the Web Server Gateway Interface. It is a specification for webservers and application servers to communicate with web applications
(though it can also be used for more than that
WSGI有两方：“服务器
”或“网关”一方，以及“应用程序”或“应用框架”一方。WSIG架构：
WSGI
中间件
同时实现了API的两方，因此可以在WSGI服务和WSGI应用之间起调解作用，“中间件”组件可以执行以下功能：
[*]重写环境变量
后，根据目标URL
，将请求消息路由到不同的应用对象。
[*]允许在一个进程
中同时运行多个应用程序或应用框架。
[*]
负载均衡
和远程处理，通过在网络
上转发请求和响应消息。
[*]进行内容后处理，例如应用XSLT
样式表。
用Python
语言写的一个符合WSGI的“Hello World
”应用程序如下所示：
def hello_world_app(environ, start_response):
start_response('200 OK', [('Content-Type', 'text/plain')])
return "Hello world!\n"
[*]第一行定义了一个名为app的callable，
接受两个参数，environ和start_response，environ是一个字典包含了CGI中的环境变量，start_response也是一
个callable，接受两个必须的参数，status（HTTP状态）和response_headers（响应消息的头）。
[*]第二行调用了start_response，状态指定为“200 OK”，消息头指定为内容类型是“text/plain”
[*]第三行将响应消息的消息体返回。
调用这个程序
from wsgiref.simple_server import make_server
httpd = make_server('', 8080, hello_world_app)
print "Serving on port 8080..."
# Serve until process is killed
httpd.serve_forever()
完整的代码：
#/bin/py
from wsgiref.simple_server import make_server
def hello_world_app(environ, start_response):
status = '200 OK' # HTTP Status
headers = [('Content-type', 'text/plain')] # HTTP Headers
start_response(status, headers)
# The returned object is going to be printed
return ["Hello World"]
httpd = make_server('', 8080, hello_world_app)
print "Serving on port 8080..."
# Serve until process is killed
httpd.serve_forever()
访问地址： http://localhost:8080/
参考
http://smartzxy.iteye.com/blog/734050
http://zh.wikipedia.org/wiki/Web%E6%9C%8D%E5%8A%A1%E5%99%A8%E7%BD%91%E5%85%B3%E6%8E%A5%E5%8F%A3
更多关于BaseServer的解释：
BaseServer: 定义基础服务器接口，这些功能接口提供给子类继承。同时提供服务处理的骨架
serve_forever()循环调用 handle_request()
handle_request()调用子类的get_request() ，在tcpServer时实则进行accept()应答; 验证处理 verify_request();
最终处理请求 process_request()，
verify_request() 虚函数
process_request()虚函数，这个函数并没有直接在BaseServer的子类TcpServer中被重载，而是在TcpServer的派生类中通过另一个父类来实
现，比如 ThreadingTCPServer的基类ThreadingMixIn.process_request()实现了此功能函数
finish_request(request, client_address)
执行一次完整的socket数据读入处理，如果是ThreadMixInTcpServer产生的request，这个方法内必须实行循环读取
socket数据,直到socket关闭。(此处 request 就是 socket对象)
def finish_request(self, request, client_address):
“”"Finish one request by instantiating RequestHandlerClass.”"”
self.RequestHandlerClass(request, client_address, self)在finish_request里面便将读取socket数据的任务扔给了RequestHandler去处理了，代码可以跳过去看了
##———————————————
TcpServer:tcp服务器
__init__(self, server_address, RequestHandlerClass) 需要提供服务侦听地址和请求处理类对象
server_bind() 绑定服务器地址
server_activate() 激活服务器
server_close()关闭服务器
fileno()返回服务器socket的句柄fd编号
get_request() 接收应答accept()
close_request(request) 关闭socket,request即为socket对象
三种输出处理方式: 阻塞方式、线程处理(ThreadingMixIn)、进程处理(ForkingMixIn)
ThreadingMixIn: 线程模型
process_request( request, client_address) 为请求的链接创建新的线程,在创建线程时直接指定线程入口和参数:
import threading
t = threading.Thread(target = self.process_request_thread,
args = (request, client_address))
if self.daemon_threads:
t.setDaemon (1)process_request_thread() 线程处理socket入口，负责接收数据，代码实现有点绕，看看代码
def process_request_thread(self, request, client_address):
try:
self.finish_request(request, client_address)
self.close_request(request)
except:
self.handle_error(request, client_address)
self.close_request(request)ThreadingMixIn其实就是线程代理，
还是调用finish_request()进入处理tcp数据的循环，处理完成便close_request()。但是finish_request和
close_request并未在ThreadingMinxIn内定义，在哪里呢？
通过研读ThreadingTcpServer,原来通过ThreadingTcpServer这个finish_request又跑回了
BaseServer.finish_request()
ThreadingTCPServer(ThreadingMixIn, TCPServer) 装配成线程池处理的tcp服务器
BaseRequestHandler:请求处理基础对象，提供统一的行为接口实现处理socket数据。
BaseRequestHandler比较好玩，在构造函数内完成了所有的操作，见代码： def __init__(self, request,
client_address, server):
self.request = request
self.client_address = client_address
self.server = server
try:
self.setup()
self.handle()
self.finish()
finally:
sys.exc_traceback = None # Help garbage collectionsetup()对应的子类会进行初始化处理
self.handle()直接调用子类的处理函数，可以参考 BaseHTTPRequestHandler(SocketServer.StreamRequestHandler)::handle()
StreamRequestHandler(BaseRequestHandler) 流式socket处理类
setup() 设置好socket对象和读写文件句柄 rfile/wfile
HTTPServer(SocketServer.TCPServer) http服务器
BaseHTTPRequestHandler(SocketServer.StreamRequestHandler) 流式的请求处理类
handle() 处理入口，在基类BaseRequestHandle()的构造函数中直接调用
handle_one_request() 如果不是处理一次则返回false。接收一次socket数据，解析parse_request(),调用对应的do_xxx事件
python 的daemon线程：
如果一个进程的主线程运行完毕而子线程还在执行的话，那么进程就不会退出，直到所有子线程结束为止，如何让主线程结束的时候其他子线程也乖乖的跟老
大撤退呢？那就要把那些不听话的人设置为听话的小弟，使用线程对象的setDaemon()方法，参数为bool型。True的话就代表你要听话，我老大
（主线程）扯呼，你也要跟着撤，不能拖后腿。如果是False的话就不用那么听话了，老大允许你们将在外军命有所不受的。需要注意的是
setDaemon()方法必须在线程对象没有调用start()方法之前调用，否则没效果。
转载过来以后用
页:
[1]