我试图做多线程上传,但得到错误.我猜测,也许它是不可能使用多线程与ftplib?
下面是我的代码。
class myThread (threading.Thread):
def __init__(self, threadID, src, counter, image_name):
self.threadID = threadID
self.src = src
self.counter = counter
self.image_name = image_name
threading.Thread.__init__(self)
def run(self):
uploadFile(self.src, self.image_name)
def uploadFile(src, image_name):
f = open(src, "rb")
ftp.storbinary('STOR ' + image_name, f)
f.close()
ftp = FTP('host') # connect to host, default port
ftp.login() # user anonymous, passwd anonymous@
dirname = "/home/folder/"
i = 1
threads = []
for image in os.listdir(dirname):
if os.path.isfile(dirname + image):
thread = myThread(i , dirname + image, i, image )
thread.start()
threads.append( thread )
i += 1
for t in threads:
t.join()
得到一堆ftplib错误,比如
raise error_reply, resperror_reply: 200类型设置为I
如果我试着一个个上传,一切都很正常。
你有没有试过把连接代码放在线程里面?
换句话说,让每个线程用FTP.host()和FTP.login()做自己独立的连接。 服务器可能不喜欢在一个连接上同时进行多个上传,因为它可能一次只解析一个命令,无法处理第二个上传或 "STOR "命令。 但如果你可以从同一个IP地址进行多个连接,你就会有单独的会话在上面发出 "STOR "命令。
下面是一个例子。
class myThread (threading.Thread):
def __init__(self, threadID, src, counter, image_name):
###############
#Add ftp connection here!
self.ftp = FTP('host') # connect to host, default port
self.ftp.login() # user anonymous, passwd anonymous@
################
self.threadID = threadID
self.src = src
self.counter = counter
self.image_name = image_name
threading.Thread.__init__(self)
def run(self):
uploadFile(self.src, self.image_name)
def uploadFile(src, image_name):
f = open(src, "rb")
self.ftp.storbinary('STOR ' + image_name, f)
f.close()
dirname = "/home/folder/"
i = 1
threads = []
for image in os.listdir(dirname):
if os.path.isfile(dirname + image):
thread = myThread(i , dirname + image, i, image )
thread.start()
threads.append( thread )
i += 1
for t in threads:
t.join()
看看是否会有更好的效果
P.S.不知道我所有的标签是否都对齐了。