进阶版socket套接字ftp文件传输可并发

server

import socketserver
import json
import struct
class Mytcp(socketserver.BaseRequestHandler):
    def handle(self):
        try:
            while True:
                data_path = self.request.recv(1024)
                data = str(data_path,encoding="utf8")
                print(data_path)
                with open(data,"rb") as f:
                    data = f.read()
                dic = {"size":len(data)}
                dic_b = bytes(json.dumps(dic).encode("utf-8"))
                obj = struct.pack("i",len(dic_b))
                self.request.send(obj)
                self.request.send(dic_b)
                self.request.send(data)
                if len(data) == 0:
                    return
        except Exception:
            pass
if __name__ == "__main__":
    server = socketserver.ThreadingTCPServer(("127.0.0.1",8009),Mytcp)
    server.serve_forever()import socketserver
import json
import str