python WSGI

WSGI是作为Web服务器与Web应用程序或应用框架之间的一种低级别的接口 。WSGI is the Web Server Gateway Interface. It is a specification for web servers 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()方法之前调用，否则没效果。
转载过来以后用