服务端： import socketserver import json,os import hashlib class MyTCPHandler(socketserver.BaseRequestHandler):     def put(self,*args):         server_md5=hashlib.md5()         '''接收客户端文件'''         cmd_dic = args[0]         filename = cmd_dic["filename"]         filesize = cmd_dic["size"]         if os.path.isfile(filename):             f = open(filename + ".new","wb")         else:             f = open(filename , "wb")         self.request.send(b"200 ok")         received_size = 0         while received_size < filesize:             data = self.request.recv(1024)             server_md5.update(data)             f.write(data)             received_size += len(data)         else:             print("file [%s] has uploaded..." % filename)         self.request.send(server_md5.hexdigest().encode())     def get(self,*args):         md5_server=hashlib.md5()         #接收客户端的信息         cmd_dic=args[0]         #得到文件名称         filename=cmd_dic["filename"]         #判断是不是个文件         if os.path.isfile(filename):             #得到文件大小             file_size=os.stat(filename).st_size             #j将文件大小发送给客户端             self.request.send(str(file_size).encode())             #对应客户端的胡写，防止粘包             self.request.recv(1024)             #开始发送文件了             f=open(filename,"rb")             for line in f :                 self.request.send(line)                 md5_server.update(line)             #将MD5后的值 发送给客户端             print(md5_server.hexdigest())             self.request.send((md5_server.hexdigest()).encode())         else:             print("服务端没有此文件")     def handle(self):         while True:             try:                 self.data = self.request.recv(1024).strip()                 print("{} wrote:".format(self.client_address[0]))                 print(self.data)                 cmd_dic = json.loads(self.data.decode())                 action = cmd_dic["action"]                 if hasattr(self,action):                     func = getattr(self,action)                     func(cmd_dic)             except ConnectionResetError as e:                 print("err",e)                 break if __name__ == "__main__":     HOST, PORT = "localhost", 9997     # Create the server, binding to localhost on port 9999     server = socketserver.ThreadingTCPServer((HOST, PORT), MyTCPHandler)     server.serve_forever() 客户端

_author__ = "Alex Li" import socket import json import os import hashlib #用于打印进度条 import sys,time # client.connect(('192.168.16.200',9999)) class FtpClient(object):     def __init__(self):         self.client = socket.socket()     def help(self):         msg = '''         ls         pwd         cd ../..         get filename         put filename         '''         print(msg)     def connect(self, ip, port):         self.client.connect((ip, port))     #利用反射，通过输入的字符串 来调用不同的方法     def interactive(self):         md5_client=hashlib.md5()         # self.authenticate()         #执行操作的代码         while True:             cmd = input(">>").strip()             if len(cmd) == 0: continue             cmd_str = cmd.split()[0]             if hasattr(self, "cmd_%s" % cmd_str):                 func = getattr(self, "cmd_%s" % cmd_str)                 func(cmd)             else:                 self.help()     def cmd_put(self, *args):         cmd_split = args[0].split()         if len(cmd_split) > 1:             filename = cmd_split[1]             if os.path.isfile(filename):                 filesize = os.stat(filename).st_size                 msg_dic = {
                      "action": "put",                     "filename": filename,                     "size": filesize,                     "overridden": True                 }                 self.client.send(json.dumps(msg_dic).encode("utf-8"))                 print("send", json.dumps(msg_dic).encode("utf-8"))                 # 防止粘包，等服务器确认                 server_response = self.client.recv(1024)                 f = open(filename, "rb")                 #用于MD5校验                 client_md5=hashlib.md5()                 #用于计算发送了多少数据                 clien_size=0                 b=0                 for line in f:                     self.client.send(line)                     client_md5.update(line)                     clien_size +=len(line)                     # 计算接收的数据 占 总文件的百分比                     a = int(clien_size / filesize * 100)                     if b != a and a % 2 == 0:                         # print("%d" % a + "%")                         sys.stdout.write("#")                         sys.stdout.flush()                     else:                         pass                     b = a                 else:                     print("100%")                     f.close()                  #客户端发送数据的md5值                 client_md5=client_md5.hexdigest()             else:                 print(filename, "is not exist")             server_ma5=self.client.recv(1024)             server_ma5=server_ma5.decode()             #判断 两边的md5值是否是一致的             if server_ma5==client_md5:                 print("文件成功上传至服务器")             else:                 print("上传出错")     def cmd_get(self, *args):         # 用md5对比文件是否一致         md5_clent = hashlib.md5()         '''此方法用于下载操作'''         # 把输入的命令 按空格分隔 切分成列表         cmd_split = args[0].split()         # 如果命令的长度大于0         if len(cmd_split) > 1:             # 得到文件名             filename = cmd_split[1]             # 服务端那边解析的是一个字典，所以我也写个字典             msg_dic = {
                  "action": "get",                 "filename": filename             }             print(msg_dic)             # 将动作和文件名发给服务端             self.client.send(json.dumps(msg_dic).encode("utf-8"))             print("发送完毕")             # 获得服务端文件的大小             size = self.client.recv(1024).decode()             print(type(size))             print(size)             server_size = int(size)             print("获得服务器文件的大小是%s" % server_size)             # 胡写一个，防止粘包             self.client.send(b"jiehsou wenjian")             # 准备接受 服务端发来的数据             # 已经获取文件的大小             clien_size = 0             if os.path.isfile(filename):                 f = open(filename + "new", "wb")             else:                 f = open(filename, "wb")             #防止重复出现相同的百分比 而设置的变量             b=0             while clien_size < server_size:                 if server_size - clien_size > 1024:                     data_size = 1024                 else:                     data_size = server_size - clien_size                 data=self.client.recv(data_size)                 md5_clent.update(data)                 f.write(data)                 #计算接收过来的数据长度                 clien_size += len(data)                 #计算接收的数据 占 总文件的百分比                 a=int(clien_size/server_size*100)                 if b!=a  and a%2==0:                     # print("%d" % a + "%")                     sys.stdout.write("#")                     sys.stdout.flush()                 else:                     pass                 b=a         # 接收server过来的md5值         server_md51 = self.client.recv(1024)         server_md52 = server_md51.decode()         clien_md5= md5_clent.hexdigest()         # print("md5_server1--%s" % server_md51)         # print("md5_server2--%s" % server_md52)         #         # print("md5_client--%s" % clien_md5)         # print(server_md51==clien_md5)         # print(server_md52==clien_md5)         if server_md52==clien_md5 :             print("100%")         else:             print("文件可能被篡改，请重新下载") ftp = FtpClient() ftp.connect("localhost", 9997) ftp.interactive()