python socket之SocketServer

jhyji

  首先感谢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):         while  True:             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方法，执行实际的请求操作

        while  True:

            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()