devbox
繁依Fanyi0
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

十八.Python模拟FTP文件上传_python 模拟 filezilla上传文件

作者：繁依Fanyi0 | 2024-04-09 02:35:05

赞

踩

python 模拟 filezilla上传文件

Python 模拟FTP断点续传并发服务器

 

#配置文件

#服务器配置文件

  1. [server_config]
  2. ip=127.0.0.1
  3. port=8006
  4. buffersize=1024
  5. encoding=utf-8

#服务器用户数据 

  1. [tom]
  2. username=tom
  3. password=123456
  4. [alex]
  5. username=alex
  6. password=123456

 

#FTP服务器代码

  1. #程序入口
  2. import optparse
  3. import sys,os
  4. #os.path.dirname 获取文件的文件夹路径
  5. path=os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
  6. sys.path.append(path)
  7. from core import main
  8. class ftt_server:
  9.    def __init__(self):
  10.       self.option = optparse.OptionParser()
  11.       self.option.add_option("-i", "--ip", dest="ip")
  12.       self.option.add_option("-p", "--port", dest="port")
  13.       self.opt, self.args = self.option.parse_args()
  14.       self.one()
  15.    def one(self):
  16.       main.main(self.opt, self.args)
  17.  
  18. if __name__=="__main__":
  19.    ftt_server()
  20.  
  1. #服务器监听程序
  2. import socketserver
  3. import optparse
  4. import configparser
  5. import os
  6. from core import server
  7. class main():
  8.     def __init__(self,opt,args):
  9.         args=args
  10.         self.option=opt
  11.         self.config=configparser.ConfigParser()
  12.         self.config.read(os.path.dirname(os.path.dirname(__file__))+"/conf/config.ini")
  13.         self.server=server
  14.         self.BaseDir=os.path.dirname(os.path.dirname(__file__))
  15.         self.validate(opt, args)
  16.     def validate(self, options, args):
  17.         cmd=args[0]
  18.         if hasattr(self,cmd):
  19.             fun=getattr(self,cmd)
  20.             fun()
  21.     def start(self):
  22.         ip=self.option.ip
  23.         port=self.option.port
  24.         if ip=="":
  25.             ip=self.getConfig("server_config","ip")
  26.         if port=="":
  27.             port=self.getConfig("server_config","port")
  28.         print("server start Successful!")
  29.         self.sock_ser=socketserver.ThreadingTCPServer((ip,int(port)),self.server.server_handler)
  30.         self.sock_ser.serve_forever()
  31.  
  32.     def help(self):
  33.         pass
  34.  
  35.     def getConfig(self,section,attribute):
  36.         return self.config.read(section,attribute)
  37.  
  38.  
  1. #服务器主程序
  2. import socketserver
  3. import configparser
  4. import os
  5. import json
  6. import sys
  7. class server_handler(socketserver.BaseRequestHandler):
  8.     def handle(self):
  9.         self.config_name="server_config"
  10.         self.BaseDir=os.path.dirname(os.path.abspath(os.path.dirname(__file__)))
  11.         self.config_Path=os.path.join(self.BaseDir,"conf","config.ini")
  12.         self.user_config=os.path.join(self.BaseDir,"conf","user.ini")
  13.         self.buffersize=int(self.getIni(self.config_Path,self.config_name,"buffersize"))
  14.         self.encoding=self.getIni(self.config_Path,self.config_name,"encoding")
  15.         self.currenSize=0
  16.         data = self.request.recv(self.buffersize).decode(self.encoding)
  17.         data = json.loads(data)
  18.         print(data)
  19.         fun = data["action"]
  20.         if fun=="login":
  21.             con=configparser.ConfigParser()
  22.             con.read(self.user_config)
  23.             if con.has_section(data["user"]):
  24.                 if con.get(data["user"],"password")==data["password"]:
  25.                     self.currenDir=data["user"]
  26.                     self.request.sendall("504".encode("utf-8"))
  27.                     self.name=data["user"]
  28.                     self.home=os.path.join(self.BaseDir, "home",data["user"])
  29.                     self.currenDir=self.home
  30.                     self.interception()
  31.                 else:
  32.                     self.request.sendall("404".encode("utf-8"))
  33.     
  34.  
  35.     def getIni(self,path,section,attribute):
  36.         conf = configparser.ConfigParser()
  37.         conf.read(path)
  38.         return conf.get(section, attribute)
  39.     #交互
  40.     def interception(self):
  41.         while 1:
  42.             print("wait recv....")
  43.             data=self.request.recv(self.buffersize)
  44.             data=json.loads(data)
  45.             print(data)
  46.             fun=data["action"]
  47.             if hasattr(self,fun):
  48.                 func=getattr(self,fun)
  49.                 func(**data)
  50.             else:
  51.                 self.request.sendall("400".encode("utf-8"))
  52.     #cd文件夹切换功能
  53.     def cd(self,**kwargs):
  54.         position=kwargs["position"]
  55.         if position=="../":
  56.             self.currenDir =os.path.dirname(self.currenDir)
  57.         else:
  58.             self.currenDir=os.path.join(self.currenDir,position)
  59.         self.request.sendall(os.path.basename(self.currenDir).encode(self.encoding))
  60.     #创建文件夹功能
  61.     def mkdir(self,**kwargs):
  62.         print(kwargs)
  63.         position=kwargs["position"]
  64.         mkfile=os.path.join(self.currenDir,position)
  65.         try:
  66.             if "/" in position or "\\" in position:
  67.                 os.makedirs(mkfile)
  68.             else:
  69.                 os.mkdir(mkfile)
  70.         except Exception as e:
  71.             self.request.sendall("605".encode(self.encoding))
  72.         self.request.sendall("606".encode(self.encoding))
  73.     #显示当前文件夹内容
  74.     def ls(self,**kwargs):
  75.         dir_con=os.listdir(self.currenDir)
  76.         self.request.sendall(str(dir_con).encode("utf-8"))
  77.     #文件断点续传功能
  78.     def put(self,**kwargs):
  79.         file_name=kwargs["file_name"]
  80.         file_size=kwargs["file_size"]
  81.         target=kwargs["target"]
  82.         self.target_file=os.path.join(self.currenDir,target,file_name)
  83.         if os.path.exists(self.target_file):
  84.             self.currenSize=os.stat(self.target_file).st_size
  85.             if self.currenSize>=file_size:
  86.                 self.request.sendall("801".encode(self.encoding))
  87.                 return
  88.             else:
  89.                 self.request.sendall("802".encode(self.encoding))
  90.                 data=self.request.recv(self.buffersize).decode(self.encoding)
  91.                 if data=="Y":
  92.                     f = open(self.target_file, "ab")
  93.                     self.request.sendall(str(self.currenSize).encode(self.encoding))
  94.                 else:
  95.                     f = open(self.target_file, "wb")
  96.         else:
  97.             f = open(self.target_file, "wb")
  98.             self.request.sendall("803".encode("utf-8"))
  99.  
  100.         while self.currenSize<file_size:
  101.             data=self.request.recv(self.buffersize)
  102.             f.write(data)
  103.             self.currenSize+=len(data)
  104.             self.progess(self.currenSize, file_size)
  105.     #文件上传进度
  106.     def progess(self,curren,total):
  107.         rate = int(curren / total * 100)
  108.         if rate > 0:
  109.             st=sys.stdout
  110.             st.write("%s%% %s \r\n"%(rate,"*"*rate))
  111.             st.flush()
  112.             if rate==100:
  113.                 print("upload finish!")
  114.  
  115.

#FTP客户端

#配置文件

  1. [client_config]
  2. buffer_size=1024

#客户端代码

  1. #FTP客户端程序
  2. from socket import *
  3. import sys,os
  4. import optparse
  5. import json
  6. import configparser
  7. path=os.path.dirname(os.path.dirname(__file__))
  8. sys.path.append(path)
  9.  
  10. #状态字典
  11. dicts={"504":"登陆成功！",
  12.       "404":"用户或者密码有误！登陆失败！",
  13.       "400":"Input Error",
  14.        "606":"create success",
  15.        "605":"create fail",
  16.        "801":"the file is existing",
  17.        "802":"the file is existing,but not enough",
  18.        "803":"the file start upload..."
  19.       }
  20.  
  21. class client_handler:
  22.     def __init__(self):
  23.         self.option=optparse.OptionParser()
  24.         self.option.add_option("-i", "--ip", dest="ip")
  25.         self.option.add_option("-p", "--port", dest="port")
  26.         self.option.add_option("-u", "--user", dest="username")
  27.         self.option.add_option("-P", "--password", dest="password")
  28.         self.conf = configparser.ConfigParser()
  29.         self.Base_Dir=os.path.dirname(os.path.abspath(os.path.dirname(__file__)))
  30.         self.buffersize= int(self.bufferSize())
  31.         self.size_file=0
  32.         options, args = self.option.parse_args()
  33.         self.task(options,args)
  34.     def task(self, options, args):
  35.         port=options.port
  36.         if int(port)>0 and int(port)<65535:
  37.             self.make_connection(options,args)
  38.         else:
  39.             exit("the port is in 0 and 65535!")
  40.     def make_connection(self, options, args):
  41.         self.sclient = socket(AF_INET, SOCK_STREAM)
  42.         self.sclient.connect((options.ip, int(options.port)))
  43.         self.login()
  44.     def login(self):
  45.         name=input("请输入用户名>>")
  46.         password=input("请输入密码>>")
  47.         self.json = {"action": "login", "user": name, "password": password}
  48.         self.sclient.send(json.dumps(self.json).encode("utf-8"))
  49.         data=self.sclient.recv(self.buffersize).decode("utf-8")
  50.         # print(data)
  51.         if data=="504":
  52.             self.name=name
  53.             print(dicts[data])
  54.             while 1:
  55.                 code=input("[%s]"%self.name)
  56.                 cmd_list=code.split()
  57.                 if hasattr(self,cmd_list[0]):
  58.                     fun=getattr(self,cmd_list[0])
  59.                     fun(*cmd_list)
  60.         else:
  61.             print(dicts[data])
  62.     def bufferSize(self):
  63.         self.conf_path=os.path.join(self.Base_Dir,"conf","config.ini")
  64.         self.conf.read(self.conf_path)
  65.         return self.conf.get("client_config", "buffer_size")
  66.  
  67.     def put(self,*cmd_list):
  68.         # print("put...")
  69.         action,location,target=cmd_list
  70.         file_name=os.path.basename(location)
  71.         file_size=os.stat(location).st_size
  72.         data={"action":action,
  73.               "file_name":file_name,
  74.               "file_size":file_size,
  75.               "target":target}
  76.         self.sclient.sendall(json.dumps(data).encode("utf-8"))
  77.         data=self.sclient.recv(self.buffersize).decode("utf-8")
  78.         self.parseNum(data)
  79.         if data=="801":
  80.             return
  81.         elif data=="802":
  82.             choice=input("the file is existing,but not enough,is continue?<Y/N>")
  83.             if choice.upper()=="Y":
  84.                 self.sclient.sendall(choice.upper().encode("utf-8"))
  85.                 self.size_file =int(self.sclient.recv(self.buffersize).decode("utf-8"))
  86.             else:
  87.                 self.sclient.sendall(choice.upper().encode("utf-8"))
  88.         elif data=="803":
  89.             pass
  90.         f=open(location,"rb")
  91.         f.seek(self.size_file)
  92.         while self.size_file<file_size:
  93.             fdata=f.read(self.buffersize)
  94.             self.sclient.sendall(fdata)
  95.             self.size_file+=len(fdata)
  96.             self.progess(self.size_file, file_size)
  97.     def cd(self,*cmd_list):
  98.         # print("cd...")
  99.         action,position=cmd_list
  100.         data={"action":action,
  101.               "position":position}
  102.         data=json.dumps(data)
  103.         self.sclient.sendall(data.encode("utf-8"))
  104.         data=self.sclient.recv(self.buffersize).decode("utf-8")
  105.         self.name=data
  106.     def ls(self,*cmd_list):
  107.         action=cmd_list[0]
  108.         data={"action":action}
  109.         data=json.dumps(data)
  110.         self.sclient.sendall(data.encode("utf-8"))
  111.         con=self.sclient.recv(self.buffersize).decode("utf-8")
  112.         con=list(con)
  113.         for i in con:
  114.             print(i,end="\r")
  115.     def mkdir(self,*cmd_list):
  116.         print("mkdir...")
  117.         action,position=cmd_list
  118.         data={"action":action,
  119.               "position":position
  120.               }
  121.         data=json.dumps(data)
  122.         self.sclient.sendall(data.encode("utf-8"))
  123.         con=self.sclient.recv(self.buffersize).decode("utf-8")
  124.         print(dicts[con])
  125.     def parseNum(self,st):
  126.         print(dicts[st])
  127.     def progess(self,curren,total):
  128.         rate=int(curren/total*100)
  129.         if rate > 0:
  130.             st=sys.stdout
  131.             st.write("%s%% %s\r\n"%(rate,"*"*rate))
  132.             st.flush()
  133.             if rate==100:
  134.                 print("upload finish!")
  135.  
  136. #程序入口
  137. if __name__=="__main__":
  138.     client_handler()
  139.  
  140.  
  141.  
  142.  
  143.  
  144.  
  145.  
  146.

启动

  1. #服务器启动
  2. python ftp_server start -i 127.0.0.1 -p 8006
  3.  
  4. #客户端启动
  5. python ftp_client -i 127.0.0.1 -p 8006

 

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/繁依Fanyi0/article/detail/389748?site
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号