python ftp上传下载文件，支持断点续传

1xg93976uq

功能：ftp断点上传下载
仅供参考:

#encoding=utf-8
'''
Created on 2012-3-14
@author: cooler
'''
from ftplib import FTP  
import sys  
import os.path  
class MyFTP(FTP):  
'''''
conncet to FTP Server
'''  
def __init__(self):
print 'make a object'
def ConnectFTP(self,remoteip,remoteport,loginname,loginpassword):  
ftp=MyFTP()
try:
ftp.connect(remoteip,remoteport,600)
print 'success'
except:
print "conncet failed1"
return (0,'conncet failed')  
else:  
try:  
ftp.login(loginname,loginpassword)  
print 'login success'
except:  
print 'login failed'
return (0,'login failed')  
else:  
print 'return 1'
return (1,ftp)  
def download(self,remoteHost,remotePort,loginname,loginpassword,remotePath,localPath):  
#connect to the FTP Server and check the return  
res = self.ConnectFTP(remoteHost,remotePort,loginname,loginpassword)  
if(res[0]!=1):  
print res[1]  
sys.exit()  
#change the remote directory and get the remote file size  
ftp=res[1]  
ftp.set_pasv(0)  
dires = self.splitpath(remotePath)  
if dires[0]:  
ftp.cwd(dires[0])  
remotefile=dires[1]  
print dires[0]+' '+ dires[1]  
fsize=ftp.size(remotefile)  
if fsize==0 :  
return  
#check local file isn't exists and get the local file size  
lsize=0L  
if os.path.exists(localPath):  
lsize=os.stat(localPath).st_size  
if lsize >= fsize:  
print 'local file is bigger or equal remote file'  
return  
blocksize=1024  
cmpsize=lsize  
ftp.voidcmd('TYPE I')  
conn = ftp.transfercmd('RETR '+remotefile,lsize)  
lwrite=open(localPath,'ab')
while True:  
data=conn.recv(blocksize)  
if not data:  
break  
lwrite.write(data)  
cmpsize+=len(data)  
print '\b'*30,'download process:%.2f%%'%(float(cmpsize)/fsize*100),  
lwrite.close()  
ftp.voidcmd('NOOP')  
ftp.voidresp()  
conn.close()  
ftp.quit()  
def upload(self,remotehost,remoteport,loginname,loginpassword,remotepath,localpath,callback=None):  
if not os.path.exists(localpath):  
print "Local file doesn't exists"  
return  
self.set_debuglevel(2)  
res=self.ConnectFTP(remotehost,remoteport,loginname,loginpassword)  
if res[0]!=1:  
print res[1]  
sys.exit()  
ftp=res[1]  
remote=self.splitpath(remotepath)  
ftp.cwd(remote[0])  
rsize=0L  
try:  
rsize=ftp.size(remote[1])  
except:  
pass  
if (rsize==None):  
rsize=0L  
lsize=os.stat(localpath).st_size  
if (rsize==lsize):  
print 'remote filesize is equal with local'  
return  
if (rsize<lsize):  
localf=open(localpath,'rb')  
localf.seek(rsize)  
ftp.voidcmd('TYPE I')  
datasock,esize=ftp.ntransfercmd("STOR "+remote[1],rsize)  
cmpsize=rsize  
while True:  
buf=localf.read(1024)  
if not len(buf):  
print '\rno data break'  
break  
datasock.sendall(buf)  
if callback:  
callback(buf)  
cmpsize+=len(buf)  
print '\b'*30,'uploading %.2f%%'%(float(cmpsize)/lsize*100),  
if cmpsize==lsize:  
print '\rfile size equal break'  
break  
datasock.close()  
print 'close data handle'  
localf.close()  
print 'close local file handle'  
ftp.voidcmd('NOOP')  
print 'keep alive cmd success'  
ftp.voidresp()  
print 'No loop cmd'  
ftp.quit()  

def splitpath(self,remotepath):  
position=remotepath.rfind('/')  
return (remotepath[:position+1],remotepath[position+1:])  

if __name__=='__main__':  
lf = MyFTP()
lf.ConnectFTP("192.168.100.237","21","cooler","123123")
lf.download("192.168.100.237","21","cooler","123123","/tmp/cooler/boke.rar","C:/cooler/boke.rar")
lf.upload("192.168.100.237","21","cooler","123123","/tmp/cooler/boke1.rar","C:/cooler/boke.rar")