import java.io.File; 
import java.io.FileInputStream; 
import java.io.FileOutputStream; 
import java.io.IOException; 
import java.io.InputStream; 
import java.io.OutputStream; 
import java.io.PrintWriter; 
import org.apache.commons.net.PrintCommandListener; 
import org.apache.commons.net.ftp.FTP; 
import org.apache.commons.net.ftp.FTPClient; 
import org.apache.commons.net.ftp.FTPFile; 
import org.apache.commons.net.ftp.FTPReply; 
public class ContinueFTP { 
   private FTPClient ftpClient = new FTPClient(); 
   public ContinueFTP(){ 
     //設(shè)置將過程中使用到的命令輸出到控制臺(tái) 
     this.ftpClient.addProtocolCommandListener(new PrintCommandListener(new PrintWriter(System.out))); 
   } 
   /** 
   * java編程中用于連接到FTP服務(wù)器 
   * @param hostname 主機(jī)名 
   * @param port 端口 
   * @param username 用戶名 
   * @param password 密碼 
   * @return 是否連接成功 
   * @throws IOException 
   */ 
   public boolean connect(String hostname,int port,String username,String password) throws IOException{ 
     ftpClient.connect(hostname, port); 
     if(FTPReply.isPositiveCompletion(ftpClient.getReplyCode())){ 
       if(ftpClient.login(username, password)){ 
         return true; 
       } 
     } 
     disconnect(); 
     return false; 
   } 
   /** 
   * 從FTP服務(wù)器上下載文件 
   * @param remote 遠(yuǎn)程文件路徑 
   * @param local 本地文件路徑 
   * @return 是否成功 
   * @throws IOException 
   */ 
   public boolean download(String remote,String local) throws IOException{ 
     ftpClient.enterLocalPassiveMode(); 
     ftpClient.setFileType(FTP.BINARY_FILE_TYPE); 
     boolean result; 
     File f = new File(local); 
     FTPFile[] files = ftpClient.listFiles(remote); 
     if(files.length != 1){ 
       System.out.println("遠(yuǎn)程文件不唯一"); 
       return false; 
     } 
     long lRemoteSize = files[0].getSize(); 
     if(f.exists()){ 
       OutputStream out = new FileOutputStream(f,true); 
       System.out.println("本地文件大小為:"+f.length()); 
       if(f.length() >= lRemoteSize){ 
         System.out.println("本地文件大小大于遠(yuǎn)程文件大小，下載中止"); 
         return false; 
       } 
       ftpClient.setRestartOffset(f.length()); 
       result = ftpClient.retrieveFile(remote, out); 
       out.close(); 
     }else { 
       OutputStream out = new FileOutputStream(f); 
       result = ftpClient.retrieveFile(remote, out); 
       out.close(); 
     } 
     return result; 
   } 
   /** 
   * 上傳文件到FTP服務(wù)器，支持?jǐn)帱c(diǎn)續(xù)傳 
   * @param local 本地文件名稱，絕對(duì)路徑 
   * @param remote 遠(yuǎn)程文件路徑，使用/home/directory1/subdirectory/file.ext 按照Linux上的路徑指定方式，支持多級(jí)目錄嵌套，支持遞歸創(chuàng)建不存在的目錄結(jié)構(gòu) 
   * @return 上傳結(jié)果 
   * @throws IOException 
   */ 
   public UploadStatus upload(String local,String remote) throws IOException{ 
     //設(shè)置PassiveMode傳輸 
     ftpClient.enterLocalPassiveMode(); 
     //設(shè)置以二進(jìn)制流的方式傳輸 
     ftpClient.setFileType(FTP.BINARY_FILE_TYPE); 
     UploadStatus result; 
     //對(duì)遠(yuǎn)程目錄的處理 
     String remoteFileName = remote; 
     if(remote.contains("/")){ 
       remoteFileName = remote.substring(remote.lastIndexOf("/")+1); 
       String directory = remote.substring(0,remote.lastIndexOf("/")+1); 
       if(!directory.equalsIgnoreCase("/")&&!ftpClient.changeWorkingDirectory(directory)){ 
         //如果遠(yuǎn)程目錄不存在，則遞歸創(chuàng)建遠(yuǎn)程服務(wù)器目錄 
         int start=0; 
         int end = 0; 
         if(directory.startsWith("/")){ 
           start = 1; 
         }else{ 
           start = 0; 
         } 
         end = directory.indexOf("/",start); 
         while(true){ 
           String subDirectory = remote.substring(start,end);
           if(!ftpClient.changeWorkingDirectory(subDirectory)){ 
             if(ftpClient.makeDirectory(subDirectory)){ 
               ftpClient.changeWorkingDirectory(subDirectory); 
             }else { 
               System.out.println("創(chuàng)建目錄失敗"); 
               return UploadStatus.Create_Directory_Fail;
             } 
           } 
           start = end + 1; 
           end = directory.indexOf("/",start); 
           //檢查所有目錄是否創(chuàng)建完畢 
           if(end <= start){ 
             break; 
           } 
         } 
       } 
     } 
     //檢查遠(yuǎn)程是否存在文件 
     FTPFile[] files = ftpClient.listFiles(remoteFileName); 
     if(files.length == 1){ 
       long remoteSize = files[0].getSize(); 
       File f = new File(local); 
       long localSize = f.length(); 
       if(remoteSize==localSize){ 
         return UploadStatus.File_Exits; 
       }else if(remoteSize > localSize){ 
         return UploadStatus.Remote_Bigger_Local; 
       } 
       //嘗試移動(dòng)文件內(nèi)讀取指針,實(shí)現(xiàn)斷點(diǎn)續(xù)傳 
       InputStream is = new FileInputStream(f); 
       if(is.skip(remoteSize)==remoteSize){ 
         ftpClient.setRestartOffset(remoteSize); 
         if(ftpClient.storeFile(remote, is)){ 
           return UploadStatus.Upload_From_Break_Success; 
         } 
       } 
       //如果斷點(diǎn)續(xù)傳沒有成功，則刪除服務(wù)器上文件，重新上傳 
       if(!ftpClient.deleteFile(remoteFileName)){ 
         return UploadStatus.Delete_Remote_Faild; 
       } 
       is = new FileInputStream(f); 
       if(ftpClient.storeFile(remote, is)){   
         result = UploadStatus.Upload_New_File_Success; 
       }else{ 
         result = UploadStatus.Upload_New_File_Failed; 
       } 
       is.close(); 
     }else { 
       InputStream is = new FileInputStream(local); 
       if(ftpClient.storeFile(remoteFileName, is)){ 
         result = UploadStatus.Upload_New_File_Success; 
       }else{ 
         result = UploadStatus.Upload_New_File_Failed; 
       } 
       is.close(); 
     } 
     return result; 
   } 
   /** 
   * 斷開與遠(yuǎn)程服務(wù)器的連接 
   * @throws IOException 
   */ 
   public void disconnect() throws IOException{ 
     if(ftpClient.isConnected()){ 
       ftpClient.disconnect(); 
     } 
   } 
   public static void main(String[] args) { 
     ContinueFTP myFtp = new ContinueFTP(); 
     try { 
       myFtp.connect("192.168.21.171", 21, "test", "test"); 
       System.out.println(myFtp.upload("E:\\VP6.flv", "/MIS/video/VP6.flv")); 
       myFtp.disconnect(); 
     } catch (IOException e) { 
       System.out.println("連接FTP出錯(cuò)："+e.getMessage()); 
     } 
   } 
}