实例讲解Python中SocketServer模块处理网络请求的用法
|
SocketServer创建一个网络服务框架。它定义了类来处理TCP,UDP,UNIX streams 和UNIX datagrams上的同步网络请求。 一、Server Types 有五个不同的服务器类在SocketServer中。 1.BaseServer定义了API,而且他不是用来实例化和直接使用的。 二、Server Objects 构建一个服务器,通过它来监听请求的地址和请求的处理类(not instance)。 1.class SocketServer.BaseServer 2.BaseServer.fileno 返回一个整数文件描述符来表示哪个服务器正在监听。这个函数最常见的传递给select.select()，允许监控多个相同处理过程的服务。 3.BaseServer.handle_request 处理单一的请求,这个函数会顺序调用接下来的方法。get_request(),verify_request和proccess_request。 4.BaseServer.serve_forever BaseServer.serve_forever(poll_interval=0.5)，处理请求一直到明确的shutdown()请求。轮训每隔poll_interval时间内关闭。忽略self.timeout,如果需要使用定时任务，需要使用其他线程。 5.BaseServer.shutdown 告诉serve_forever()循环停止。 6.BaseServer.RequestHandlerClass 用户请求处理程序类，为每个请求创建这个类的一个实例。 三、Implementing a Server 如果你创建一个服务器，它通常可以重复使用现有的类和简单的提供一个自定义请求处理的类。如果不符合需求，有几种BaseServer方法覆盖一个子类。 1.verify_request(reqeust,client_address): 必须返回一个布尔值，如果返回True,请求将被处理，如果返回False，请求将被拒绝。这个函数可以覆盖来实现访问控制服务。 四、Request Handlers 请求处理程序做的大部分工作接收传入的请求,并决定采取何种行动。处理程序负责实现“协议”上的套接字层(例如,HTTP或xml - rpc)。从传入的请求处理程序读取请求数据通道,流程,和写一个响应。有三个方法可以重写。 1.setup(): 准备请求的请求处理程序,就是初始化运行在handle之前。 五、例子 下面例子展示了tcp,udp和异步 1.TCPServer 例子
import SocketServer
class MyHandler(SocketServer.BaseRequestHandler):
def handle(self):
self.data = self.request.recv(1024).strip()
print '{} wrote:'.format(self.client_address[0])
print self.data
self.request.sendall(self.data.upper())
if __name__ == '__main__':
HOST,PORT = 'localhost',9999
server = SocketServer.TCPServer((HOST,PORT),MyHandler)
server.serve_forever()
2.UDPServr 例子
import SocketServer
class MyHandler(SocketServer.BaseRequestHandler):
def handle(self):
data = self.request[0].strip()
socket = self.request[1]
print '{} wrote:'.format(self.client_address[0])
print data
socket.sendto(data.upper(),self.client_address)
if __name__ == '__main__':
HOST,9999
server = SocketServer.UDPServer((HOST,MyHandler)
server.serve_forever()
3.异步例子 可以通过ThreadingMixIn和ForkingMixIn类来构造异步处理程序。
import socket
import threading
import SocketServer
class MyHandler(SocketServer.BaseRequestHandler):
def handle(self):
data = self.request.recv(1024)
curr_thread = threading.current_thread()
response = '{}: {}'.format(curr_thread.name,data)
self.request.sendall(response)
class Server(SocketServer.ThreadingMixIn,SocketServer.TCPServer):
pass
def client(ip,port,message):
sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
sock.connect((ip,port))
try:
sock.sendall(message)
response = sock.recv(1024)
print 'Received: {}'.format(response)
finally:
sock.close()
if __name__ == '__main__':
HOST,0
server = Server((HOST,MyHandler)
ip,port = server.server_address
serer_thread = threading.Thread(target=server.serve_forever)
server_thread.daemon = True
server_thread.start()
print 'Server loop running in thread:',server_thread.name
client(ip,'Hello World 1')
client(ip,'Hello World 2')
client(ip,'Hello World 3')
server.shutdown()
server.server_close()
4.SocketServer 实现客户端与服务器间非阻塞通信
#创建SocketServerTCP服务器：
import SocketServer
from SocketServer import StreamRequestHandler as SRH
from time import ctime
host = 'xxx.xxx.xxx.xxx'
port = 9999
addr = (host,port)
class Servers(SRH):
def handle(self):
print 'got connection from ',self.client_address
self.wfile.write('connection %s:%s at %s succeed!' % (host,ctime()))
while True:
data = self.request.recv(1024)
if not data:
break
print data
print "RECV from ",self.client_address[0]
self.request.send(data)
print 'server is running....'
server = SocketServer.ThreadingTCPServer(addr,Servers)
server.serve_forever()
（2）创建SocketServerTCP客户端
from socket import *
host = 'xxx.xxx.xxx.xxx'
port = 9999
bufsize = 1024
addr = (host,port)
client = socket(AF_INET,SOCK_STREAM)
client.connect(addr)
while True:
data = raw_input()
if not data or data=='exit':
break
client.send('%srn' % data)
data = client.recv(bufsize)
if not data:
break
print data.strip()
client.close()
（编辑：安卓应用网） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |