0

我用 pyftpdlib 建立了一个简单的 FTP 服务器，用 ftplib 建立了一个客户端。当我让客户端脚本运行时，它会按预期正确上传文件。

pyftpdlib 服务器代码：

import logging
from pyftpdlib.handlers import FTPHandler
from pyftpdlib.servers import FTPServer
from pyftpdlib.authorizers import DummyAuthorizer

authorizer = DummyAuthorizer()
authorizer.add_user("test","123","C:\\Users\\Usr\\Desktop\\server_data","elradfmwM")
handler = FTPHandler
handler.authorizer = authorizer
logging.basicConfig(level=logging.DEBUG)
connection = ("localhost", 8080)
ftpd = FTPServer(connection, handler)
ftpd.serve_forever()

ftplib 客户端代码#1：

import ftplib

ftp = ftplib.FTP()
ftp.connect("localhost",8080)
ftp.login("test","123")

block_size = 128
c_dir = "C:\\Users\\Usr\\Desktop\\client_data"
filename = "test.pdf" # ~ 30Mb

ftp.dir()
myfile = open(c_dir + "\\" + filename , "rb")

ftp.storbinary("STOR " + filename, myfile, blocksize=block_size)

ftp.dir()
ftp.close()

现在我想测试REST（从特定位置重新启动上传/下载）功能。所以我在上传时中断了客户端代码（只需在上传时关闭我的命令提示符）。接下来，当服务器仍在运行时，我运行以下客户端代码以尝试从中断位置恢复上传：

ftplib 客户端代码#2：

import ftplib

ftp = ftplib.FTP()
ftp.connect("localhost",8080)
ftp.login("test","123")

block_size = 128
c_dir = "C:\\Users\\Usr\\Desktop\\client_data"
filename = "test.pdf" # ~ 30Mb

ftp.dir()
myfile = open(c_dir + "\\" + filename , "rb")

ftp.voidcmd('TYPE I')
rest_pos = ftp.size(filename)
print(rest_pos)
ftp.storbinary("STOR " + filename, myfile, blocksize=block_size, rest=rest_pos)

ftp.dir()
ftp.close()

当我运行客户端代码 #2 时，它会上传，但它似乎没有从正确的位置开始。

文件大小约为。30 MB

客户端代码 #1 正确上传（约 30Mb）

客户端代码 #2 上传，但文件较大且已损坏（约 35Mb）

我rest_pos在中断后将输出与 Windows 下的文件大小进行了比较，它们确实匹配。所以rest我要传递的位置ftp.storbinary与 Windows 下的位置相同。

我对 python 和 ftp 还很陌生，无法弄清楚问题是什么。谷歌搜索，但找不到类似的东西。

任何提示/提示将不胜感激:)

4

1 回答 1

2

我想我犯了一个愚蠢的错误。万一其他人遇到同样的情况，我必须添加myfile.seek(rest_pos,0)客户端代码# 2 以开始读取要在特定位置发送的文件。所以它应该是这样的：

import ftplib

ftp = ftplib.FTP()
ftp.connect("localhost",8080)
ftp.login("test","123")

block_size = 128
c_dir = "C:\\Users\\Usr\\Desktop\\client_data"
filename = "test.pdf" # ~ 30Mb

ftp.dir()
myfile = open(c_dir + "\\" + filename , "rb")

ftp.voidcmd('TYPE I')
rest_pos = ftp.size(filename)
print(rest_pos)

myfile.seek(rest_pos,0)

ftp.storbinary("STOR " + filename, myfile, blocksize=block_size, rest=rest_pos)

ftp.dir()
ftp.close()
于 2017-03-05T12:26:40.380 回答