java基于Apache FTP點(diǎn)斷續(xù)傳的文件上傳和下載

更新時(shí)間：2016年11月01日 15:41:35 作者：boonya

本篇文章主要介紹了java基于Apache FTP點(diǎn)斷續(xù)傳的文件上傳和下載，利用FTP實(shí)現(xiàn)文件的上傳和下載，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下。

基于Apache FTP實(shí)現(xiàn)文件上傳下載工具，上傳文件時(shí)需要考慮以下問(wèn)題（實(shí)例是續(xù)傳功能）：

（1）、 FTP服務(wù)器是否存在改目錄，如果不存在目錄則需要?jiǎng)?chuàng)建目錄。

（2）、判斷上傳文件是否已經(jīng)存在，如果存在是需要?jiǎng)h除后再上傳還是續(xù)傳。

1、上傳或下載狀態(tài)的枚舉類：

package com.scengine.wtms.utils.ftp; 
 
public enum UploadStatus 
{ 
  File_Exits(0), Create_Directory_Success(1), Create_Directory_Fail(2), Upload_From_Break_Success(3), Upload_From_Break_Faild(4), Download_From_Break_Success(5), Download_From_Break_Faild(6), Upload_New_File_Success(7), Upload_New_File_Failed(8), Delete_Remote_Success(9), Delete_Remote_Faild(10),Remote_Bigger_Local(11),Remote_smaller_locall(12); 
 
  private int status; 
 
  public int getStatus() 
  { 
    return status; 
  } 
 
  public void setStatus(int status) 
  { 
    this.status = status; 
  } 
 
  UploadStatus(int status) 
  { 
    this.status = status; 
  } 
}

2、工具類代碼：

package com.scengine.wtms.utils.ftp; 
 
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(); 
 
  /** 
   * 對(duì)象構(gòu)造 設(shè)置將過(guò)程中使用到的命令輸出到控制臺(tái) 
   */ 
  public ContinueFTP() 
  { 
    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 
   */ 
 
  @SuppressWarnings("resource") 
  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 
   */ 
 
  @SuppressWarnings("resource") 
  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ù)傳沒(méi)有成功，則刪除服務(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; 
 
  } 
 
  /** 
   * 
   * 斷開(kāi)與遠(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.1.200", 21, "duser", "HTPDuserXP32"); 
 
      System.out.println(myFtp.upload("C:\\Users\\Administrator\\Desktop\\swing.drawer.jar", "/jars/swing.drawer.jar")); 
 
      myFtp.disconnect(); 
 
    } catch (IOException e) 
    { 
 
      System.out.println("連接FTP出錯(cuò)：" + e.getMessage()); 
 
    } 
 
  } 
 
}

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: