自己寫的單任務FTP斷點續傳程式，新建立的任務會存到日誌檔案中(可儲存多個任務的日誌)，異常中斷重啟時可以選擇指定任務繼續下載。程式比較簡單，也可以說比較簡陋，有些問題並未細緻的考慮，比如磁碟空間不足的情況。SO，僅是作為一個簡單的學習例程（給自己，也給那些認為可以學習學習的朋友們，或許想偷懶的人還可以拿去簡單的應用）！

myctrl.py #-*-encoding:gbk-*- #Author:沒車步行 #Email:lu_zhouyu@hotmail.com #Edit:2009-4-7 #Copyright:轉載請註明出處 import sys import base64 import shelve import myftplib import os shlfp='task.dat' class mytask: """ shlf:任務佇列 remoteip:遠端伺服器IP,預設localhost remoteport:遠端伺服器埠,預設21 remotepath:遠端伺服器路徑,預設根目錄 remotefilename:遠端伺服器檔案,必填項 localpath:本地路徑,預設程式目錄 localfilename:本地檔案,默認同遠端伺服器檔案 taskcode:任務程式碼,用於判斷任務是否已存在,假設性條件無限制 loginname:遠端伺服器登入名 loginpassword:遠端伺服器登入密碼 """ shlf=shelve.open(shlfp) remoteip='localhost' remoteport='21' remotepath=localpath='' localfilename=remotefilename='' taskcode='' loginname='' loginpassword='' def __init__(self): self.printtask() def maketask(self,remotefilename,localfilename,**kwargs): self.remotefilename=remotefilename if localfilename: self.localfilename=localfilename else: self.localfilename=remotefilename for k in kwargs.keys(): v=kwargs[k] if k=='remoteip' and v!='': self.remoteip=v elif k=='remoteport' and v!='': self.remoteport=v elif k=='remotepath' and v!='': self.remotepath=v elif k=='localpath' and v!='': self.localpath=v elif k=='loginname' and v!='': self.loginname=v elif k=='loginpassword' and v!='': self.loginpassword=v self.starttask() def removetask(self,taskid): del self.shlf[taskid] def starttask(self): taskid='1' if len(self.shlf): taskid=str(int(max(self.shlf.keys()))+1) taskval={} taskval['remoteip']=self.remoteip taskval['remoteport']=self.remoteport taskval['remotepath']=self.remotepath taskval['remotefilename']=self.remotefilename taskval['localpath']=self.localpath taskval['localfilename']=self.localfilename taskval['taskcode']=self.taskcode taskval['loginname']=self.loginname taskval['loginpassword']=self.loginpassword self.shlf[taskid]=taskval myftplib.mywork(self.remoteip,self.remoteport,self.remotepath,self.remotefilename,self.localpath,self.localfilename,self.loginname,self.loginpassword,0) del self.shlf[taskid] self.shlf.close() def restarttask(self,taskid): taskval=self.shlf[taskid] remoteip=taskval['remoteip'] remoteport=taskval['remoteport'] remotepath=taskval['remotepath'] remotefilename=taskval['remotefilename'] localpath=taskval['localpath'] localfilename=taskval['localfilename'] loginname=taskval['loginname'] loginpassword=taskval['loginpassword'] myftplib.mywork(remoteip,remoteport,remotepath,remotefilename,localpath,localfilename,loginname,loginpassword,1) del self.shlf[taskid] self.shlf.close() def printtask(self): print '%-6s|%-15s|%s'%('任務ID','伺服器地址','下載檔名') print '%s'%('-'*38) for t in self.shlf.keys(): v=self.shlf[t] print '%-6s|%-15s|%s'%(t,v['remoteip'],v['remotefilename']) print '' if __name__=='__main__': mytask=mytask() if len(mytask.shlf): chk=raw_input('重新啟動已存在的下載任務(Y-是/N-否):') if chk.strip().upper()=='Y': while 1: tid=raw_input('輸入任務ID:') tid=tid.strip() if mytask.shlf.has_key(tid): mytask.restarttask(tid) break print '輸入有誤!', sys.exit() remoteip=raw_input("遠端地址(localhost):") remoteip=remoteip.strip() remoteport=raw_input("遠端埠(21):") remoteport=remoteport.strip() remotepath=raw_input("遠端路徑(預設為根目錄):") remotepath=remotepath.strip() remotefilename=raw_input("遠端檔名:") remotefilename=remotefilename.strip() loginname=raw_input("登入名:") loginname=loginname.strip() loginpassword=raw_input("登入密碼:") loginpassword=loginpassword.strip() localfilename=raw_input("本地重新命名(預設與遠端檔案同名):") localfilename=localfilename.strip() localpath=raw_input("本地路徑(不存在自動建立):") localpath=localpath.strip() mytask.maketask(remotefilename,/ localfilename,/ remoteip=remoteip,/ remoteport=remoteport,/ remotepath=remotepath,/ localpath=localpath,/ loginname=loginname,/ loginpassword=loginpassword)

myftplib.py #-*-encoding:gbk-*- #Author:沒車步行 #Email:lu_zhouyu@hotmail.com #Edit:2009-4-7 #Copyright:轉載請註明出處 from ftplib import FTP import os import sys class MyFTP(FTP):#對FTP的繼承 #繼承父類中的方法,在子類中可以直接呼叫 #過載父類中retrbinary的方法 def retrbinary(self, cmd, callback, fsize=0,rest=0): blocksize=1024 cmpsize=rest self.voidcmd('TYPE I') conn = self.transfercmd(cmd, rest)#此命令實現從指定位置開始下載,以達到續傳的目的 while 1: if fsize: print '/b'*30,'下載進度:%.2f%%'%(float(cmpsize)/fsize*100), data = conn.recv(blocksize) if not data: break callback(data) cmpsize+=blocksize conn.close() return self.voidresp() def ConnectFTP(remoteip,remoteport,loginname,loginpassword): ftp=MyFTP() try: ftp.connect(remoteip,remoteport) except: return (0,'connect failed!') else: try: ftp.login(loginname,loginpassword) except: return (0,'login failed!') else: return (1,ftp) def mywork(remoteip,remoteport,remotepath,remotefilename,localpath,localfilename,loginname,loginpassword,reloadflag): res=ConnectFTP(remoteip,remoteport,loginname,loginpassword) if res[0]!=1: print res[1] sys.exit() ftp=res[1] ftp.set_pasv(0) #到這一部出現連線超時請償試設定非0值 if remotepath:#如果檔案不在FTP根目錄,則需要指定下一級目錄 ftp.cwd(remotepath) fsize=ftp.size(remotefilename)#獲取遠端檔案大小 print '目標檔案大小:',fsize if fsize==0: return localfullpath=localfilename if localpath: localfullpath=localpath+'/'+localfilename if not os.path.exists(localpath): os.makedirs(localpath) if reloadflag and os.path.isfile(localfullpath): rest=os.stat(localfullpath).st_size#獲取本地檔案的大小 if rest: if rest==fsize: print '遠端檔案大小與本地檔案大小相同,刪除任務!' return print '/b'*30,'已經下載:%.2f%%'%(float(rest)/fsize*100), raw_input('回車繼續....') ftp.retrbinary('RETR '+remotefilename,open(localfullpath,'ab').write,fsize,rest) else: ftp.retrbinary('RETR '+remotefilename,open(localfullpath,'wb').write,fsize) print '完成檔案大小:',os.stat(localfullpath).st_size

轉載請註明出處