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

客户端 main代码：

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

&＃39;&＃39;&＃39;
import socket,os,json,time,hashlib,sys
class Ftp_client(object):
 def init(self):
  self.client = socket.socket()
 def help(self):
  msg = &＃39;&＃39;&＃39;useage:
  ls
  pwd
  cd dir(example: / .. . /var)
  put filename
  rm filename
  get filename
  mkdir directory name
  &＃39;&＃39;&＃39;
  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 = {
   &＃39;action&＃39;:&＃39;auth&＃39;,
   &＃39;username&＃39;:username,
   &＃39;password&＃39;:password}
  self.client.send(json.dumps(user_info).encode(&＃39;utf-8&＃39;))
  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":&＃39;True&＃39;
    }
    self.client.send( json.dumps(file_info).encode(&＃39;utf-8&＃39;) )
    #防止粘包，等待服务器确认。
    request_code = {
     &＃39;200&＃39;: &＃39;Ready to recceive data!&＃39;,
     &＃39;210&＃39;: &＃39;Not ready to received data!&＃39;
    }
    server_respOnse= self.client.recv(1024).decode()
    if server_respOnse== &＃39;200&＃39;:
     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 = (&＃39;\r已上传%sMB(%s%%)&＃39; % (round(send_size / 102400, 2), send_percentage)).encode(
        &＃39;utf-8&＃39;)
       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(&＃39;\n平均下载速度%s MB/s&＃39; % (round(round(send_size / 102400, 2) / time_use, 2)))
      f.close()
    else:
     print("Sever isn&＃39;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 = (&＃39;\r已上传%sMB(%s%%)&＃39; % (round(send_size / 102400, 2), send_percentage)).encode(
         &＃39;utf-8&＃39;)
        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(&＃39;\n平均下载速度%s MB/s&＃39; % (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 = &＃39;.&＃39;
  request_info = {
   &＃39;action&＃39;: &＃39;ls&＃39;,
   &＃39;path&＃39;: path
  }
  self.client.send(json.dumps(request_info).encode(&＃39;utf-8&＃39;))
  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 = {
    &＃39;action&＃39;: &＃39;pwd&＃39;,
   }
   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": &＃39;True&＃39;
    }
   self.client.send(json.dumps(file_info).encode(&＃39;utf-8&＃39;))
   server_respOnse= self.client.recv(1024).decode() #服务器反馈文件是否存在
   self.client.send(&＃39;0&＃39;.encode(&＃39;utf-8&＃39;))
   if server_respOnse== &＃39;0&＃39;:
    file_size = int(self.client.recv(1024).decode())
    # print(file_size)
    self.client.send(&＃39;0&＃39;.encode(&＃39;utf-8&＃39;)) #确认开始传输数据
    if os.path.isfile(filename):
     filename = filename+&＃39;.new&＃39;
    f = open(filename,&＃39;wb&＃39;)
    receive_size = 0
    m = hashlib.md5()
    start_time = time.time()
    while 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 = (&＃39;\r已下载%sMB(%s%%)&＃39; %(round(receive_size/102400,2),data_percent)).encode(&＃39;utf-8&＃39;)
     os.write(1,progress)
     sys.stdout.flush()
     time.sleep(0.0001)

    else:
     end_time = time.time()
     time_use = int(end_time - start_time)
     print(&＃39;\n平均下载速度%s MB/s&＃39;%(round(round(receive_size/102400,2)/time_use,2)))
     Md5_server = self.client.recv(1024).decode()
     Md5_client = m.hexdigest()
     print(&＃39;文件校验中，请稍候...&＃39;)
     time.sleep(0.3)
     if Md5_server == Md5_client:
      print(&＃39;文件正常。&＃39;)
     else:
      print(&＃39;文件与服务器MD5值不符，请确认！&＃39;)
   else:
    print(&＃39;File not found!&＃39;)
    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 = {
    &＃39;action&＃39;:&＃39;rm&＃39;,
    &＃39;filename&＃39;: filename,
    &＃39;prompt&＃39;:&＃39;Y&＃39;
   }
   self.client.send(json.dumps(request_info).encode("utf-8"))
   server_respOnse= self.client.recv(10240).decode()
   request_code = {
    &＃39;0&＃39;:&＃39;confirm to deleted&＃39;,
    &＃39;1&＃39;:&＃39;cancel to deleted&＃39;
   }

   if server_respOnse== &＃39;0&＃39;:
    cOnfirm= input("请确认是否真的删除该文件：")
    if cOnfirm== &＃39;Y&＃39; or cOnfirm== &＃39;y&＃39;:
     self.client.send(&＃39;0&＃39;.encode("utf-8"))
     print(self.client.recv(1024).decode())
    else:
     self.client.send(&＃39;1&＃39;.encode("utf-8"))
     print(self.client.recv(1024).decode())
   else:
    print(&＃39;File not found!&＃39;)
    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 = &＃39;.&＃39;
  request_info = {
   &＃39;action&＃39;:&＃39;cd&＃39;,
   &＃39;path&＃39;: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 = {
   &＃39;0&＃39;: &＃39;Directory has been made!&＃39;,
   &＃39;1&＃39;: &＃39;Directory is aleady exist!&＃39;
  }
  cmd_split = args[0].split()
  if len(cmd_split) > 1:
   dir_name = cmd_split[1]
   request_info = {
    &＃39;action&＃39;:&＃39;mkdir&＃39;,
    &＃39;dir_name&＃39;: dir_name
   }
   self.client.send(json.dumps(request_info).encode("utf-8"))
   server_respOnse= self.client.recv(1024).decode()
   if server_respOnse== &＃39;0&＃39;:
    print(&＃39;Directory has been made!&＃39;)
   else:
    print(&＃39;Directory is aleady exist!&＃39;)
  else:
   self.help()
 # def touch(self,*args):
def run():
 client = Ftp_client()
 # client.connect(&＃39;10.1.2.3&＃39;,6969)
 Addr = input("请输入服务器IP：").strip()
 Port = int(input("请输入端口号：").strip())
 client.connect(Addr,Port)
 while True:
  if client.auth() == &＃39;0&＃39;:
   print("Welcome.....")
   client.interactive()
   break
  else:
   print("用户名或密码错误！")
   continue

目录结构：

以上就是使用python3实现ftp服务功能实例（客户端）的详细内容，更多请关注 第一PHP社区 其它相关文章！