现在的位置: 首页 > 综合 > 正文

Python服务器开发(1)

2013年09月18日 ⁄ 综合 ⁄ 共 1478字 ⁄ 字号 评论关闭

Python的标准库里的服务器模块SocketServer可以很方便的开发简单的服务器程序

 

 

import SocketServer
class MyHandler(SocketServer.StreamRequestHandler):
	def handle():
		addr = self.request.getpeername()
		print 'connection from:", addr
		data = self.rfile.read(1024)
		print 'data:', data
		self.wfile.write('xxx')
server = SocketServer.ThreadingTCPServer((ip, host), MyHandler)
server.serve_forever()
对于UDP而言,StreamRequestHandler还可以用DatagramRequestHandler代替,ThreadingTCPServer可以用TCPServer, UDPServer代替


在 Python标准库里有如下定义:
class ThreadingTCPServer(ThreadingMixIn, TCPServer):
	pass
StreamRequestHandler是BaseRequestHandler的一个子类,我们需要创建一个自己的handler类,继承自StreamRequestHandler,
并重载StreamRequestHandler.handle()方法。
StreamRequestHandler.handle()方法的调用顺序为: 
StreamRequestHandler.setup()->StreamRequestHandler.handle()->StreamRequestHandler.finish(),setup和finish调用啥也不做,可以无视
该类中,self.client_address表示客户端地址,如果是StreamRequestHandler, self.request表示socket,如果是DatagramRequestHandler, 
self.request是(socket, data)的tuple。同时self.rfile, self.wfile可以用来读写


在标准库里,BaseServer通过handle_request来处理请求(serve_forever就是不停调用handle_request)。handle_request()中包含了
get_request, verify_request, process_request, finish_request。其中finish_request会调用StreamRequestHandler的handle方法。
而process_request会继承自ThreadingMixIn或者ForkingMixIn,对每个request新建线程,然后由线程调用finish_request


BaseServer的其他属性和方法请参考Python Library Reference:
BaseServer.socket: listen的socket
BaseServer.shutdown(): stop serve_forever() loop
BaseServer.allow_reuse_address
BaseServer.request_queue_size
BaseServer.handle_error: 如果RequestHandler的handle方法抛出异常,由handle_error处理

 

抱歉!评论已关闭.