python3实现ftp服务功能（客户端）

Python  /  管理员 发布于 7年前   253

本文实例为大家分享了python3实现ftp服务功能的具体代码，供大家参考，具体内容如下

客户端 main代码：

#Author by Andy#_*_ coding:utf-8 _*_'''This program is used to create a ftp client'''import socket,os,json,time,hashlib,sysclass Ftp_client(object): def __init__(self):  self.client = socket.socket() def help(self):  msg = '''useage:  ls  pwd  cd dir(example: / .. . /var)  put filename  rm filename  get filename  mkdir directory name  '''  print(msg) def connect(self,addr,port):  self.client.connect((addr,port)) def auth(self):  m = hashlib.md5()  username = input("请输入用户名：").strip()  m.update(input("请输入密码：").strip().encode())  password = m.hexdigest()  user_info = {   'action':'auth',   'username':username,   'password':password}  self.client.send(json.dumps(user_info).encode('utf-8'))  server_response = self.client.recv(1024).decode()  # print(server_response)  return server_response def interactive(self):  while True:   msg = input(">>>:").strip()   if not msg:    print("不能发送空内容！")    continue   cmd = msg.split()[0]   if hasattr(self,cmd):    func = getattr(self,cmd)    func(msg)   else:    self.help()    continue def 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    file_info = {     "action":"put",     "filename":filename,     "size":filesize,     "overriding":'True'    }    self.client.send( json.dumps(file_info).encode('utf-8') )    #防止粘包，等待服务器确认。    request_code = {     '200': 'Ready to recceive data!',     '210': 'Not ready to received data!'    }    server_response = self.client.recv(1024).decode()    if server_response == '200':     f = open(filename,"rb")     send_size = 0     start_time = time.time()     for line in f:      self.client.send(line)      send_size += len(line)      send_percentage = int((send_size / filesize) * 100)      while True:       progress = ('\r已上传%sMB(%s%%)' % (round(send_size / 102400, 2), send_percentage)).encode(        'utf-8')       os.write(1, progress)       sys.stdout.flush()       time.sleep(0.0001)       break     else:      end_time = time.time()      time_use = int(end_time - start_time)      print("\nFile %s has been sent successfully!" % filename)      print('\n平均下载速度%s MB/s' % (round(round(send_size / 102400, 2) / time_use, 2)))      f.close()    else:     print("Sever isn't ready to receive data!")     time.sleep(10)     start_time = time.time()     f = open(filename, "rb")     send_size = 0     for line in f:       self.client.send(line)       send_size += len(line)       # print(send_size)       while True:        send_percentage = int((send_size / filesize) * 100)        progress = ('\r已上传%sMB(%s%%)' % (round(send_size / 102400, 2), send_percentage)).encode(         'utf-8')        os.write(1, progress)        sys.stdout.flush()        # time.sleep(0.0001)        break     else:      end_time = time.time()      time_use = int(end_time - start_time)      print("File %s has been sent successfully!" % filename)      print('\n平均下载速度%s MB/s' % (round(round(send_size / 102400, 2) / time_use, 2)))      f.close()   else:    print("File %s is not exit!" %filename)  else:   self.help() def ls(self,*args):  cmd_split = args[0].split()  # print(cmd_split)  if len(cmd_split) > 1:   path = cmd_split[1]  elif len(cmd_split) == 1:   path = '.'  request_info = {   'action': 'ls',   'path': path  }  self.client.send(json.dumps(request_info).encode('utf-8'))  sever_response = self.client.recv(1024).decode()  print(sever_response) def pwd(self,*args):  cmd_split = args[0].split()  if len(cmd_split) == 1:   request_info = {    'action': 'pwd',   }   self.client.send(json.dumps(request_info).encode("utf-8"))   server_response = self.client.recv(1024).decode()   print(server_response)  else:   self.help() def get(self,*args):  cmd_split = args[0].split()  if len(cmd_split) > 1:   filename = cmd_split[1]   file_info = {     "action": "get",     "filename": filename,     "overriding": 'True'    }   self.client.send(json.dumps(file_info).encode('utf-8'))   server_response = self.client.recv(1024).decode() #服务器反馈文件是否存在   self.client.send('0'.encode('utf-8'))   if server_response == '0':    file_size = int(self.client.recv(1024).decode())    # print(file_size)    self.client.send('0'.encode('utf-8')) #确认开始传输数据    if os.path.isfile(filename):     filename = filename+'.new'    f = open(filename,'wb')    receive_size = 0    m = hashlib.md5()    start_time = time.time()    while receive_size < file_size:     if file_size - receive_size > 1024: # 还需接收不止1次      size = 1024     else:      size = file_size - receive_size     data = self.client.recv(size)     m.update(data)     receive_size += len(data)     data_percent=int((receive_size / file_size) * 100)     f.write(data)     progress = ('\r已下载%sMB(%s%%)' %(round(receive_size/102400,2),data_percent)).encode('utf-8')     os.write(1,progress)     sys.stdout.flush()     time.sleep(0.0001)    else:     end_time = time.time()     time_use = int(end_time - start_time)     print('\n平均下载速度%s MB/s'%(round(round(receive_size/102400,2)/time_use,2)))     Md5_server = self.client.recv(1024).decode()     Md5_client = m.hexdigest()     print('文件校验中，请稍候...')     time.sleep(0.3)     if Md5_server == Md5_client:      print('文件正常。')     else:      print('文件与服务器MD5值不符，请确认！')   else:    print('File not found!')    client.interactive()  else:   self.help() def rm(self,*args):  cmd_split = args[0].split()  if len(cmd_split) > 1:   filename = cmd_split[1]   request_info = {    'action':'rm',    'filename': filename,    'prompt':'Y'   }   self.client.send(json.dumps(request_info).encode("utf-8"))   server_response = self.client.recv(10240).decode()   request_code = {    '0':'confirm to deleted',    '1':'cancel to deleted'   }   if server_response == '0':    confirm = input("请确认是否真的删除该文件：")    if confirm == 'Y' or confirm == 'y':     self.client.send('0'.encode("utf-8"))     print(self.client.recv(1024).decode())    else:     self.client.send('1'.encode("utf-8"))     print(self.client.recv(1024).decode())   else:    print('File not found!')    client.interactive()  else:   self.help() def cd(self,*args):  cmd_split = args[0].split()  if len(cmd_split) > 1:   path = cmd_split[1]  elif len(cmd_split) == 1:   path = '.'  request_info = {   'action':'cd',   'path':path  }  self.client.send(json.dumps(request_info).encode("utf-8"))  server_response = self.client.recv(10240).decode()  print(server_response) def mkdir(self,*args):  request_code = {   '0': 'Directory has been made!',   '1': 'Directory is aleady exist!'  }  cmd_split = args[0].split()  if len(cmd_split) > 1:   dir_name = cmd_split[1]   request_info = {    'action':'mkdir',    'dir_name': dir_name   }   self.client.send(json.dumps(request_info).encode("utf-8"))   server_response = self.client.recv(1024).decode()   if server_response == '0':    print('Directory has been made!')   else:    print('Directory is aleady exist!')  else:   self.help() # def touch(self,*args):def run(): client = Ftp_client() # client.connect('10.1.2.3',6969) Addr = input("请输入服务器IP：").strip() Port = int(input("请输入端口号：").strip()) client.connect(Addr,Port) while True:  if client.auth() == '0':   print("Welcome.....")   client.interactive()   break  else:   print("用户名或密码错误！")   continue

目录结构：

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。