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

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

客户端 main代码：

    #Author by Andy
    #_*_ coding:utf-8 _*_
    '''
    This program is used to create a ftp client

    '''
    import socket,os,json,time,hashlib,sys
    class 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

目录结构：

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