Python使用pyftpdlib搭建FTP服务器及文件传输实战

陆景行

发布时间：2026-10-13 | 2人浏览过

原创

本文介绍如何利用Python的pyftpdlib库搭建FTP服务器，实现高效的大文件传输与断点续传功能。内容涵盖服务器核心代码编写、防火墙端口（21/20）及被动模式设置、Windows客户端登录配置，以及通过ftplib库从服务器下载文件的具体示例，并解析关键事件回调函数的用法。

本文基于Python 3.6.2版本进行演示。

项目中使用的FTP相关库为pyftpdlib，可通过执行pip install pyftpdlib命令进行下载和安装。

在处理大文件传输时，FTP协议相比HTTP更具优势，能够更便捷地实现断点上传及进度监控。具体实现细节可参考官方文档。

以下是搭建FTP服务器的基本方法。

import os 
from pyftpdlib.authorizers import DummyAuthorizer 
from pyftpdlib.handlers import FTPHandler 
from pyftpdlib.servers import FTPServer 
 
def main(): 
  # 实例化用户授权管理 
  authorizer = DummyAuthorizer() 
  authorizer.add_user('user', '12345', 'path', perm='elradfmwMT')#添加用户 参数:username,password,允许的路径,权限 
  authorizer.add_anonymous(os.getcwd())#这里是允许匿名用户,如果不允许删掉此行即可 
 
  # 实例化FTPHandler 
  handler = FTPHandler 
  handler.authorizer = authorizer 
 
  # 设定一个客户端链接时的标语 
  handler.banner = "pyftpdlib based ftpd ready." 
 
  #handler.masquerade_address = '151.25.42.11'#指定伪装ip地址 
  #handler.passive_ports = range(60000, 65535)#指定允许的端口范围 
 
  address = (ipaddr, 21)#FTP一般使用21,20端口 
  server = FTPServer(address, handler)#FTP服务器实例 
 
  # set a limit for connections 
  server.max_cons = 256 
  server.max_cons_per_ip = 5 
 
  # 开启服务器 
  server.serve_forever() 
 
if __name__ == '__main__': 
  main()

启动FTP服务器后，需确保防火墙已开放21和20端口。此外，在客户端浏览器登录服务器前，需在Internet选项的高级选项卡中取消勾选“被动FTP”，否则可能无法成功连接。

以下是从Windows客户端登录到该FTP服务器的操作步骤。

接下来展示如何利用Python代码从已搭建的FTP服务器上下载文件。

from ftplib import FTP 
ftp=FTP() 
ftp.connect('localhost',21)#localhost改成服务器ip地址 
ftp.login(user='user',passwd='12345') 
 
file=open('f://ftpdownload/test.txt','wb') 
ftp.retrbinary("RETR test.txt",file.write,1024)#从服务器上下载文件 1024字节一个块 
ftp.set_debuglevel(0) 
ftp.close()

此外，还可以为FTP服务器配置事件回调函数，以处理连接、登录、文件传输等状态变化。

class MyHandler(FTPHandler):  
  def on_connect(self):#链接时调用 
    print "%s:%s connected" % (self.remote_ip, self.remote_port) 
 
  def on_disconnect(self):#关闭连接是调用 
    # do something when client disconnects 
    pass 
 
  def on_login(self, username):#登录时调用 
    # do something when user login 
    pass 
 
  def on_logout(self, username):#登出时调用 
    # do something when user logs out 
    pass 
 
  def on_file_sent(self, file):#文件下载后调用 
    # do something when a file has been sent 
    pass 
 
  def on_file_received(self, file):#文件上传后调用 
    # do something when a file has been received 
    pass 
 
  def on_incomplete_file_sent(self, file):#下载文件时调用 
    # do something when a file is partially sent 
    pass 
 
  def on_incomplete_file_received(self, file):#上传文件时调用 
    # remove partially uploaded files 
    import os 
    os.remove(file)

以上即为本文的全部内容，希望能为读者的学习提供有益帮助，同时也欢迎大家继续支持本站。