python socket之SocketServer
首先感谢alex分享的博客《一小时学会用Python Socket 开发可并发的FTP服务器！！》，其中详细讲解到socket的用法，而因为需要实现多线程的接口，从而使server端使用SocketServer模块，但是这部分没有详细讲解，于是菜鸟某查找相关资料，以做补全： 首先请出alex大神的代码：1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
import SocketServer
class MyTCPHandler(SocketServer.BaseRequestHandler):
#继承BaseRequestHandler基类，然后必须重写handle方法，并且在handle方法里实现与客户端的所有交互
def handle(self):
whileTrue:
data = self.request.recv(1024) #接收1024字节数据
if not data: break
self.request.sendall(data.upper())
if __name__ == "__main__":
HOST, PORT = "localhost", 50007
# 把刚才写的类当作一个参数传给ThreadingTCPServer这个类，下面的代码就创建了一个多线程socket server
server = SocketServer.ThreadingTCPServer((HOST, PORT), MyTCPHandler)
# 启动这个server,这个server会一直运行，除非按ctrl-C停止
server.serve_forever()
需要详细解释的就是：
1
server = SocketServer.ThreadingTCPServer((HOST, PORT), MyTCPHandler)
先要说明的是使用SocketServer模块中ThreadingTCPServer(address,handler)的规则：
要使用本模块，必须定义一个继承于基类BaseRequestHandler的处理程序类。BaseRequestHandler类的实例h可以实现以下方法：1、h.handle()调用该方法执行实际的请求操作。调用该函数可以不带任何参数，但是几个实例变量包含有用的值。h.request包含请求，h.client_address包含客户端地址，h.server包含调用处理程序的实例。对于TCP之类的数据流服务，h.request属性是套接字对象。对于数据报服务，它是包含收到数据的字节字符串。2、h.setup() 该方法在handle()之前调用。默认情况下，它不执行任何操作。如果希望服务器实现更多连接设置（如建立SSL连接），可以在这里实现。3、h.finish() 调用本方法可以在执行完handle()之后执行清除操作。默认情况下，它不执行任何操作。如果setup()和handle()方法都不生成异常，则无需调用该方法。 如果知道应用程序只能操纵面向数据流的连接（如TCP），那么应从StreamRequestHandler继承，而不是BaseRequestHandler。StreamRequestHandler类设置了两个属性，h.wfile是将数据写入客户端的类文件对象，h.rfile是从客户端读取数据的类文件对象。如果要编写针对数据包操作的处理程序并将响应持续返回发送方，那么它应当从DatagramRequestHandler继承。它提供的类接口与StramRequestHandler相同。
重点在于：1.handler需要这样出来，先定义一个类，这个类就是ThreadingTCPServer(address,handler)中的hander。2.这个类必须继承BaseRequestHandler类。3.方法有3个，我们使用h.handle()方法。
哦哦~~这下就清楚了
import SocketServer
class MyTCPHandler(SocketServer.BaseRequestHandler): #1.定义了一个类MyTCPHandler#继承BaseRequestHandler基类，然后必须重写handle方法，并且在handle方法里实现与客户端的所有交互
def handle(self): #使用了handle方法，执行实际的请求操作
whileTrue: data = self.request.recv(1024) #接收1024字节数据 if not data: break self.request.sendall(data.upper())
if __name__ == "__main__": HOST, PORT = "localhost", 50007
# 把刚才写的类当作一个参数传给ThreadingTCPServer这个类，下面的代码就创建了一个多线程socket server server = SocketServer.ThreadingTCPServer((HOST, PORT), MyTCPHandler)
# 启动这个server,这个server会一直运行，除非按ctrl-C停止 server.serve_forever()
页:
[1]