python 实现ftp服务简介

刺骨的言语ヽ痛彻心扉 2021-09-02 08:00 357阅读 0赞

**目录**

一. Python搭建FTP服务器

二. FTP函数释义

三. 查看目录结构

四. 上传下载程序

--------------------

### 一. Python搭建FTP服务器 ###

1. 搭建FTP服务器的Server端

# -*- coding:utf-8 -*-
    from pyftpdlib.authorizers import DummyAuthorizer
    from  pyftpdlib.handlers  import FTPHandler
    from  pyftpdlib.servers import FTPServer
    # 实例化DummyAuthorizer来创建ftp用户
    authorizer = DummyAuthorizer()
    # 参数：用户名，密码，目录，权限
    authorizer.add_user('admin', '123456', r'C:\Users\Administrator\Desktop\ftp', perm='elradfmwMT')
    # 匿名登录
    # authorizer.add_anonymous('/home/nobody')
    handler = FTPHandler
    handler.authorizer = authorizer
    # 参数：IP，端口，handler
    server = FTPServer(('0.0.0.0', 2121), handler)           #设置为0.0.0.0为本机的IP地址
    server.serve_forever()

2. FTP服务器的客户端连接

# -*- coding: utf-8 -*-
    from ftplib import FTP
    import time,tarfile,os
    
    
    #连接ftp
    def ftpconnect(host,port, username, password):
        ftp = FTP()
        # 打开调试级别2，显示详细信息
        # ftp.set_debuglevel(2)
        ftp.connect(host, port)
        ftp.login(username, password)
        return ftp
    
    #从ftp下载文件
    def downloadfile(ftp, remotepath, localpath):
        # 设置的缓冲区大小
        bufsize = 1024
        fp = open(localpath, 'wb')
        ftp.retrbinary('RETR ' + remotepath, fp.write, bufsize)
        ftp.set_debuglevel(0)# 参数为0，关闭调试模式
        fp.close()
    
    #从本地上传文件到ftp
    def uploadfile(ftp, remotepath, localpath):
        bufsize = 1024
        fp = open(localpath, 'rb')
        ftp.storbinary('STOR ' + remotepath, fp, bufsize)
        ftp.set_debuglevel(0)
        fp.close()
    
    if __name__ == "__main__":
        #host,port, username, password
        ftp = ftpconnect("192.168.10.113", 2121,"admin", "123456")
        #下载文件，第一个是ftp服务器路径下的文件，第二个是要下载到本地的路径文件
        downloadfile(ftp, "/12.mp3", r"C:\Users\Administrator\Desktop\ftp\download\test.mp3")
        # 上传文件，第一个是要上传到ftp服务器路径下的文件，第二个是本地要上传的的路径文件
        uploadfile(ftp, '/upload/1.txt', "C:/Users/Administrator/Desktop/1.txt")
        # ftp.close() #关闭ftp
        # #调用本地播放器播放下载的视频
        # os.system('start D:\soft\kugou\KGMusic\KuGou.exe C:\Users\Administrator\Desktop\ftp\test.mp3')
    
        print(ftp.getwelcome())# 打印出欢迎信息
        # 获取当前路径
        pwd_path = ftp.pwd()
        print("FTP当前路径:", pwd_path)
        # 显示目录下所有目录信息
        # ftp.dir()
        # 设置FTP当前操作的路径
        ftp.cwd('/upload/')
        # 返回一个文件名列表
        filename_list = ftp.nlst()
        print(filename_list)
    
        ftp.mkd('目录名')# 新建远程目录
        ftp.rmd('目录名')  # 删除远程目录
        ftp.delete('文件名')  # 删除远程文件
        ftp.rename('fromname', 'toname')  # 将fromname修改名称为toname
    
        # 逐行读取ftp文本文件
        file = '/upload/1.txt'
        # ftp.retrlines('RETR %s' % file)
        #与 retrlines()类似，只是这个指令处理二进制文件。回调函数 cb 用于处理每一块（块大小默认为 8KB）下载的数据
        # ftp.retrbinary('RETR %s' % file)

### 二. FTP函数释义 ###

Python中默认安装的ftplib模块定义了FTP类，其中函数有限，可用来实现简单的ftp客户端，用于上传或下载文件，函数列举如下

ftp登陆连接
    from ftplib import FTP            #加载ftp模块
    ftp=FTP()                         #设置变量
    ftp.set_debuglevel(2)             #打开调试级别2，显示详细信息
    ftp.connect("IP","port")          #连接的ftp sever和端口
    ftp.login("user","password")      #连接的用户名，密码
    print ftp.getwelcome()            #打印出欢迎信息
    ftp.cmd("xxx/xxx")                #进入远程目录
    bufsize=1024                      #设置的缓冲区大小
    filename="filename.txt"           #需要下载的文件
    file_handle=open(filename,"wb").write #以写模式在本地打开文件
    ftp.retrbinaly("RETR filename.txt",file_handle,bufsize) #接收服务器上文件并写入本地文件
    ftp.set_debuglevel(0)             #关闭调试模式
    ftp.quit()                        #退出ftp
    
    ftp相关命令操作
    ftp.cwd(pathname)                 #设置FTP当前操作的路径
    ftp.dir()                         #显示目录下所有目录信息
    ftp.nlst()                        #获取目录下的文件
    ftp.mkd(pathname)                 #新建远程目录
    ftp.pwd()                         #返回当前所在位置
    ftp.rmd(dirname)                  #删除远程目录
    ftp.delete(filename)              #删除远程文件
    ftp.rename(fromname, toname)#将fromname修改名称为toname。
    ftp.storbinaly("STOR filename.txt",file_handel,bufsize)  #上传目标文件
    ftp.retrbinary("RETR filename.txt",file_handel,bufsize)  #下载FTP文件

FTP.quit()与FTP.close()的区别

FTP.quit():发送QUIT命令给服务器并关闭掉连接。这是一个比较“缓和”的关闭连接方式，但是如果服务器对QUIT命令返回错误时，会抛出异常。

*FTP.close()：单方面的关闭掉连接，不应该用在已经关闭的连接之后，例如不应用在FTP.quit()之后。*

FTP对象方法说明
    
    login(user=’anonymous’,passwd=”, acct=”) 登录 FTP 服务器，所有参数都是可选的
    pwd() 获得当前工作目录
    cwd(path) 把当前工作目录设置为 path 所示的路径
    dir ([path[,…[,cb]]) 显示 path 目录里的内容，可选的参数 cb 是一个回调函数，会传递给 retrlines()方法
    nlst ([path[,…]) 与 dir()类似， 但返回一个文件名列表，而不是显示这些文件名
    retrlines(cmd [, cb]) 给定 FTP命令（如“ RETR filename”），用于下载文本文件。可选的回调函数 cb 用于处理文件的每一行
    retrbinary(cmd,cb[,bs=8192[, ra]]) 与 retrlines()类似，只是这个指令处理二进制文件。回调函数 cb 用于处理每一块（块大小默认为 8KB）下载的数据
    storlines(cmd, f) 给定 FTP 命令（如“ STOR filename”），用来上传文本文件。要给定一个文件对象 f
    storbinary(cmd, f,[,bs=8192]) 与 storlines()类似，只是这个指令处理二进制文件。要给定一个文件对象 f，上传块大小 bs 默认为 8KB
    rename(old, new) 把远程文件 old 重命名为 new
    delete(path) 删除位于 path 的远程文件
    mkd(directory) 创建远程目录
    rmd(directory) 删除远程目录
    quit() 关闭连接并退出

### 三. 查看目录结构 ###

ftp.dir() 能显示目录下的文件信息，考虑到要分别对文件夹个数和文件数目进行统计，文件夹下存在文件夹和文件嵌套；将dir()后的目录信息放入列表，对列表进行操作；进入子文件夹后进行递归调用操作。

# -*- coding: utf-8 -*-
     
    from ftplib import FTP
     
    ftp = FTP()
    ftp.connect('132.121.xx.xxx', 'xx909')
    ftp.login('crmyun_xxx', 'wyjjjjxJ')
    sum1 = 0
    sum2 = 0
    value = 0
     
    def search_file(start_dir):
     ftp.cwd(start_dir)
     print ftp.pwd()
     dir_res = []
     ftp.dir('.', dir_res.append) #对当前目录进行dir()，将结果放入列表
     for i in dir_res:
      if i.startswith("d"):
       global sum1 
       sum1 += 1
       search_file(ftp.pwd()+"/"+i.split(" ")[-1])
       ftp.cwd('..')
      else:
       global sum2, value
       sum2 += 1
       val = i.split(" ")[-1]
       value += ftp.size(val)
       if ftp.pwd().endswith('/'):    
    #    print ftp.pwd()+val+"  "+str(ftp.size(val))+" B" #打印出每个文件路径和大小
        pass
       else:    
    #    print ftp.pwd()+"/"+val+"  "+str(ftp.size(val))+" B"
        pass
    def sum_file(file_path):
     search_file(file_path)
     print "folder number is "+str(sum1)+", file number is "+str(sum2)+", Totle size is "+str(value)+" B"
      
     
    if __name__ == '__main__':
     sum_file("/apps/crmyun/crmyun_755")

展示结果：

[![e088c02bdc31a1385a4191ca115d1fb8.png][]][e088c02bdc31a1385a4191ca115d1fb8.png 1]

### 四. 上传下载程序 ###

完整上传程序

Python中默认安装的ftplib模块定义了FTP类，其中函数有限，可用来实现简单的ftp客户端，用于上传或下载文件

# coding: utf-8
    from ftplib import FTP
    import time
    import tarfile
    import os
    # !/usr/bin/python
    # -*- coding: utf-8 -*-
     
    from ftplib import FTP
     
    def ftpconnect(host, username, password):
     ftp = FTP()
     # ftp.set_debuglevel(2)
     ftp.connect(host, 21)
     ftp.login(username, password)
     return ftp
     
    #从ftp下载文件
    def downloadfile(ftp, remotepath, localpath):
     bufsize = 1024
     fp = open(localpath, 'wb')
     ftp.retrbinary('RETR ' + remotepath, fp.write, bufsize)
     ftp.set_debuglevel(0)
     fp.close()
     
    #从本地上传文件到ftp
    def uploadfile(ftp, remotepath, localpath):
     bufsize = 1024
     fp = open(localpath, 'rb')
     ftp.storbinary('STOR ' + remotepath, fp, bufsize)
     ftp.set_debuglevel(0)
     fp.close()
     
    if __name__ == "__main__":
     ftp = ftpconnect("113.105.139.xxx", "ftp***", "Guest***")
     downloadfile(ftp, "Faint.mp4", "C:/Users/Administrator/Desktop/test.mp4")
     #调用本地播放器播放下载的视频
     os.system('start "C:\Program Files\Windows Media Player\wmplayer.exe" "C:/Users/Administrator/Desktop/test.mp4"')
     uploadfile(ftp, "C:/Users/Administrator/Desktop/test.mp4", "test.mp4")
     
     ftp.quit()

server main 代码：

# _*_ coding:utf-8 _*_
    import os, sys, json, hashlib, socketserver, time
     
    base_dir = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
    sys.path.append(base_dir)
    from conf import userdb_set
    class Ftp_server(socketserver.BaseRequestHandler):
     user_home_dir = ''
     def auth(self, *args):
      '''验证用户名及密码'''
      cmd_dic = args[0]
      username = cmd_dic["username"]
      password = cmd_dic["password"]
      f = open(userdb_set.userdb_set(), 'r')
      user_info = json.load(f)
      if username in user_info.keys():
       if password == user_info[username]:
        self.request.send('0'.encode())
        os.chdir('/home/%s' % username)
        self.user_home_dir = os.popen('pwd').read().strip()
        data = "%s login successed" % username
        self.loging(data)
       else:
        self.request.send('1'.encode())
        data = "%s login failed" % username
        self.loging(data)
        f.close
      else:
       self.request.send('1'.encode())
       data = "%s login failed" % username
       self.loging(data)
       f.close
       ##########################################
     
     def get(self, *args):
      '''给客户端传输文件'''
      request_code = {
       '0': 'file is ready to get',
       '1': 'file not found!'
      }
      cmd_dic = args[0]
      self.loging(json.dumps(cmd_dic))
      filename = cmd_dic["filename"]
      if os.path.isfile(filename):
       self.request.send('0'.encode('utf-8')) # 确认文件存在
       self.request.recv(1024)
       self.request.send(str(os.stat(filename).st_size).encode('utf-8'))
       self.request.recv(1024)
       m = hashlib.md5()
       f = open(filename, 'rb')
       for line in f:
        m.update(line)
        self.request.send(line)
       self.request.send(m.hexdigest().encode('utf-8'))
       print('From server:Md5 value has been sended!')
       f.close()
      else:
       self.request.send('1'.encode('utf-8'))
       ###########################################
     
     def cd(self, *args):
      '''执行cd命令'''
      user_current_dir = os.popen('pwd').read().strip()
      cmd_dic = args[0]
      self.loging(json.dumps(cmd_dic))
      path = cmd_dic['path']
      if path.startswith('/'):
       if self.user_home_dir in path:
        os.chdir(path)
        new_dir = os.popen('pwd').read()
        user_current_dir = new_dir
        self.request.send('Change dir successfully!'.encode("utf-8"))
        data = 'Change dir successfully!'
        self.loging(data)
       elif os.path.exists(path):
        self.request.send('Permission Denied!'.encode("utf-8"))
        data = 'Permission Denied!'
        self.loging(data)
       else:
        self.request.send('Directory not found!'.encode("utf-8"))
        data = 'Directory not found!'
        self.loging(data)
      elif os.path.exists(path):
       os.chdir(path)
       new_dir = os.popen('pwd').read().strip()
       if self.user_home_dir in new_dir:
        self.request.send('Change dir successfully!'.encode("utf-8"))
        user_current_dir = new_dir
        data = 'Change dir successfully!'
        self.loging(data)
       else:
        os.chdir(user_current_dir)
        self.request.send('Permission Denied!'.encode("utf-8"))
        data = 'Permission Denied!'
        self.loging(data)
      else:
       self.request.send('Directory not found!'.encode("utf-8"))
       data = 'Directory not found!'
       self.loging(data)
       ###########################################
     
     def rm(self, *args):
      request_code = {
       '0': 'file exist,and Please confirm whether to rm',
       '1': 'file not found!'
      }
      cmd_dic = args[0]
      self.loging(json.dumps(cmd_dic))
      filename = cmd_dic['filename']
      if os.path.exists(filename):
       self.request.send('0'.encode("utf-8")) # 确认文件存在
       client_response = self.request.recv(1024).decode()
       if client_response == '0':
        os.popen('rm -rf %s' % filename)
        self.request.send(('File %s has been deleted!' % filename).encode("utf-8"))
        self.loging('File %s has been deleted!' % filename)
       else:
        self.request.send(('File %s not deleted!' % filename).encode("utf-8"))
        self.loging('File %s not deleted!' % filename)
      else:
       self.request.send('1'.encode("utf-8"))
       ########################################
     
     def pwd(self, *args):
      '''执行pwd命令'''
      cmd_dic = args[0]
      self.loging(json.dumps(cmd_dic))
      server_response = os.popen('pwd').read().strip().encode("utf-8")
      self.request.send(server_response)
     
     #############################################
     def ls(self, *args):
      '''执行ls命名'''
      cmd_dic = args[0]
      self.loging(json.dumps(cmd_dic))
      path = cmd_dic['path']
      cmd = 'ls -l %s' % path
      server_response = os.popen(cmd).read().encode("utf-8")
      self.request.send(server_response)
     
     ############################################
     def put(self, *args):
      '''接收客户端文件'''
      cmd_dic = args[0]
      self.loging(json.dumps(cmd_dic))
      filename = cmd_dic["filename"]
      filesize = cmd_dic["size"]
      if os.path.isfile(filename):
       f = open(filename + '.new', 'wb')
      else:
       f = open(filename, 'wb')
      request_code = {
       '200': 'Ready to recceive data!',
       '210': 'Not ready to received data!'
      }
      self.request.send('200'.encode())
      receive_size = 0
      while True:
       if receive_size < filesize:
        data = self.request.recv(1024)
        f.write(data)
        receive_size += len(data)
       else:
        data = "File %s has been uploaded successfully!" % filename
        self.loging(data)
        print(data)
        break
     
        ################################################
     
     def mkdir(self, *args):
      request_code = {
       '0': 'Directory has been made!',
       '1': 'Directory is aleady exist!'
      }
      cmd_dic = args[0]
      self.loging(json.dumps(cmd_dic))
      dir_name = cmd_dic['dir_name']
      if os.path.exists(dir_name):
       self.request.send('1'.encode("utf-8"))
      else:
       os.popen('mkdir %s' % dir_name)
       self.request.send('0'.encode("utf-8"))
     
       #############################################
     
      def loging(self, data):
      '''日志记录'''
      localtime = time.asctime(time.localtime(time.time()))
      log_file = '/root/ftp/ftpserver/log/server.log'
      with open(log_file, 'a', encoding='utf-8') as f:
       f.write('%s-->' % localtime + data + '\n')
       ##############################################
     
     def handle(self):
      # print("您本次访问使用的IP为:%s" %self.client_address[0])
      # localtime = time.asctime( time.localtime(time.time()))
      # print(localtime)
     
      while True:
       try:
        self.data = self.request.recv(1024).decode() #
        # print(self.data)
        cmd_dic = json.loads(self.data)
        action = cmd_dic["action"]
        # print("用户请求%s"%action)
        if hasattr(self, action):
         func = getattr(self, action)
         func(cmd_dic)
       except Exception as e:
        self.loging(str(e))
        break
     
    def run():
     HOST, PORT = '0.0.0.0', 6969
     print("The server is started,and listenning at port 6969")
     server = socketserver.ThreadingTCPServer((HOST, PORT), Ftp_server)
     server.serve_forever()
    if __name__ == '__main__':
     run()

设置用户口令代码：

#_*_ coding:utf-8 _*_
    import os,json,hashlib,sys
     
    base_dir = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
    userdb_file = base_dir+"\data\\userdb"
    # print(userdb_file)
    def userdb_set():
     if os.path.isfile(userdb_file):
      # print(userdb_file)
      return userdb_file
     else:
      print('请先为您的服务器创建用户！')
      user_data = {}
      dict={}
      Exit_flags = True
      while Exit_flags:
       username = input("Please input username:")
       if username != 'exit':
        password = input("Please input passwod:")
        if password != 'exit':
          user_data.update({username:password})
          m = hashlib.md5()
          # m.update('hello')
          # print(m.hexdigest())
          for i in user_data:
           # print(i,user_data[i])
           m.update(user_data[i].encode())
           dict.update({i:m.hexdigest()})
        else:
         break
       else:
        break
      f = open(userdb_file,'w')
      json.dump(dict,f)
      f.close()
     return userdb_file

参考文章：

python的ftplib包介绍：https://docs.python.org/3/library/ftplib.html  
https://blog.csdn.net/xc\_zhou/article/details/81021414  
https://www.jb51.net/article/142388.htm  
https://www.jb51.net/article/109429.htm  
https://www.cnblogs.com/hltswd/p/6228992.html

[e088c02bdc31a1385a4191ca115d1fb8.png]: /images/20210728/0987bfdb8c4f4d779643f7c30232b048.png
[e088c02bdc31a1385a4191ca115d1fb8.png 1]: https://files.jb51.net/file_images/article/201806/201862115001.png