FTP上传大文件程序卡死

在使用ftp上传文件的过程中发现程序很久不结束，起初以为是缓冲区设置过小导致传输速度变慢，但是几个小时都不见结束，通过查看ftp盘的文件发现文件上传其实已经结束，可是程序却没有结束

其实通过ftp上传文件会建立两个tcp连接，一条控制连接用来提交指令和接受回复，另一条数据连接是用来传输数据的，当指令发布完成后，控制连接会进入空闲状态，tcp不会对空闲状态的连接有时间限制，但是防火墙会提前杀掉空闲连接,并且数据连接是不感知的，所以文件传输完成的通知就不会被感知从而导致程序卡死

分享一下python的ftplib传输文件以及查看ftp盘文件信息的代码

# 上传文件
import ftplib
import sys
import datetime

today = datetime.datetime.combine(datetime.date.today(), datetime.time.min)
yesterday = today - datetime.timedelta(days=1)

f=ftplib.FTP("ip")  # 实例化FTP对象
f.login("user", "password")  # 登录


def ftp_upload():
    file_remote="filename" # 指定上传文件名
    file_local="" # 要上传的文件路径
    bufsize=2048  # 设置缓冲器大小
    fp=open(file_local, 'rb') 
    result=f.storbinary("STOR " + file_remote, fp, bufsize)
    print(result)
    fp.close()
    

ftp_upload()
f.quit()

# 查看ftp盘文件信息
from ftplib import FTP, error_perm
import os
import re


class MyFTP(FTP):
    encoding = "utf-8"

    def getdirs(self, dirpath=None):
        """
        获取当前路径或者指定路径下的文件、目录
        """
        if dirpath != None:
            self.cwd(dirpath)
        dir_list = []
        self.dir('.', dir_list.append)
        dir_name_list = [dir_detail_str.split(' ')[-1] for dir_detail_str in dir_list]
        return [file for file in dir_name_list if file != "." and file !=".."]

    def checkFileDir(self, dirpath):
        """
        检查指定路径是目录还是文件
        """
        rec = ""
        try:
            rec = self.cwd(dirpath)  # 需要判断的元素
            self.cwd("..")  # 如果能通过路劲打开必为文件夹，在此返回上一级
        except error_perm as fe:
            rec = fe  # 不能通过路劲打开必为文件，抓取其错误信息
        finally:
            if "Not a directory" in str(rec):
                return "File"
            elif "Current directory is" in str(rec):
                return "Dir"
            else:
                return "Unknow"

    def get_modify_time(self, dirpath=None):
        """
        得到指定目录、文件或者当前目录、文件的修改时间
        """
        if dirpath != None:
            if dirpath[-1] == '/':
                dir_path = os.path.split(dirpath[0: -1])[0]
                current_name = os.path.split(dirpath[0: -1])[1]
            else:
                dir_path = os.path.split(dirpath)[0]
                # .strip()是为了避免出现”/ 2095-8757“这种情况，下面匹配不到
                current_name = os.path.split(dirpath)[1].strip()
            self.cwd(dir_path)
        else:
            dirpath = self.pwd()
            dir_path = os.path.split(dirpath)[0]
            current_name = os.path.split(dirpath)[1]
            self.cwd(dir_path)

        detail_list = []
        self.retrlines('MLSD', detail_list.append)

        current_info = ''
        for detail_info in detail_list:
            # 文件和目录不一样
            # 文件从字符串获取名称
            if detail_info.split(';')[3].strip() == current_name:
                current_info = detail_info
                break
        if not current_info:
            for detail_info in detail_list:
                # 目录从字符串获取名称
                if detail_info.split(';')[2].strip() == current_name:
                    current_info = detail_info
        modify_time = re.search(r'modify=(.*);', current_info)

        return modify_time

from test import MyFTP
import os

def connect_ftp(host, user, passwd):
    ftpServer = MyFTP()
    ftpServer.encoding = "utf-8"
    ftpServer.connect(host=host)
    ftpServer.login(user=user, passwd=passwd)
    return ftpServer

# 连接服务器（参数是你的ftp服务器东西）
ftpServer = connect_ftp("ip", "user", "password")
print(ftpServer.getdirs())
print(ftpServer.size(filename=""))
)