package com.scengine.wtms.utils.ftp;  public enum FTPStatus {   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_local(12),Not_Exist_File(13),Remote_Rename_Success(14),Remote_Rename_Faild(15),File_Not_Unique(16);    private int status;    public int getStatus()   {     return status;   }    public void setStatus(int status)   {     this.status = status;   }    FTPStatus(int status)   {     this.status = status;   } } 

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 javax.servlet.http.HttpServletResponse; 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; import com.scengine.wtms.utils.Log;  public class FTPUtils {   private FTPClient ftpClient = new FTPClient();    /**    * 對象構造 設置將過程中使用到的命令輸出到控制臺    */   public FTPUtils()   {     this.ftpClient.addProtocolCommandListener(new PrintCommandListener(new PrintWriter(System.out)));   }    /**    *    * java編程中用于連接到FTP服務器    *    * @param hostname    *      主機名    *    * @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文件    *    * @param remote    *      遠程文件路徑    * @return    * @throws IOException    */   public FTPStatus delete(String remote) throws IOException   {     ftpClient.enterLocalPassiveMode();      ftpClient.setFileType(FTP.BINARY_FILE_TYPE);      FTPStatus result = null;      FTPFile[] files = ftpClient.listFiles(remote);     if (files.length == 1)     {       boolean status = ftpClient.deleteFile(remote);       result = status ? FTPStatus.Delete_Remote_Success : FTPStatus.Delete_Remote_Faild;     }     else     {       result = FTPStatus.Not_Exist_File;     }     Log.getLogger(this.getClass()).info("FTP服務器文件刪除標識："+result);     return result;   }      /**    * 重命名遠程FTP文件    *    * @param name    *      新遠程文件名稱(路徑-必須保證在同一路徑下)    *          * @param remote    *      遠程文件路徑    *          * @return 是否成功    *    * @throws IOException    */   public FTPStatus rename(String name,String remote) throws IOException   {     ftpClient.enterLocalPassiveMode();      ftpClient.setFileType(FTP.BINARY_FILE_TYPE);      FTPStatus result = null;      FTPFile[] files = ftpClient.listFiles(remote);     if (files.length == 1)     {       boolean status = ftpClient.rename(remote, name);       result = status ? FTPStatus.Remote_Rename_Success : FTPStatus.Remote_Rename_Faild;     }     else     {       result = FTPStatus.Not_Exist_File;     }     Log.getLogger(this.getClass()).info("FTP服務器文件名更新標識："+result);     return result;   }      /**    *    * 從FTP服務器上下載文件    *    * @param fileName    *      下載文件的名字(包括后綴名)    *    * @param remote    *      遠程文件路徑    *    * @param local    *      本地文件路徑    *    * @return 是否成功    *    * @throws IOException    */    public FTPStatus download(String fileName,String remote,HttpServletResponse response) throws IOException   {     // 開啟輸出流彈出文件保存路徑選擇窗口     response.setContentType("application/octet-stream");          response.setContentType("application/OCTET-STREAM;charset=UTF-8");          response.setHeader("Content-Disposition", "attachment;filename=" +fileName);      ftpClient.enterLocalPassiveMode();      ftpClient.setFileType(FTP.BINARY_FILE_TYPE);          FTPStatus result;          OutputStream out = response.getOutputStream();          boolean status = ftpClient.retrieveFile(remote, out);          result=status?FTPStatus.Download_From_Break_Success:FTPStatus.Download_From_Break_Faild;          Log.getLogger(this.getClass()).info("FTP服務器文件下載標識："+result);          out.close();          return result;   }    /**    *    * 從FTP服務器上下載文件    *    * @param remote    *      遠程文件路徑    *    * @param local    *      本地文件路徑    *    * @return 是否成功    *    * @throws IOException    */    @SuppressWarnings("resource")   public FTPStatus download(String remote, String local) throws IOException   {      ftpClient.enterLocalPassiveMode();      ftpClient.setFileType(FTP.BINARY_FILE_TYPE);      FTPStatus result;      File f = new File(local);      FTPFile[] files = ftpClient.listFiles(remote);      if (files.length != 1)     {       Log.getLogger(this.getClass()).info("遠程文件不唯一");       return FTPStatus.File_Not_Unique;     }      long lRemoteSize = files[0].getSize();      if (f.exists())     {       OutputStream out = new FileOutputStream(f, true);       Log.getLogger(this.getClass()).info("本地文件大小為:" + f.length());        if (f.length() >= lRemoteSize)       {          Log.getLogger(this.getClass()).info("本地文件大小大于遠程文件大小，下載中止");         return FTPStatus.Remote_smaller_local;        }        ftpClient.setRestartOffset(f.length());        boolean status = ftpClient.retrieveFile(remote, out);       result=status?FTPStatus.Download_From_Break_Success:FTPStatus.Download_From_Break_Faild;       out.close();      } else     {       OutputStream out = new FileOutputStream(f);       boolean status = ftpClient.retrieveFile(remote, out);       result=status?FTPStatus.Download_From_Break_Success:FTPStatus.Download_From_Break_Faild;       out.close();     }      return result;    }    /**    *    * 上傳文件到FTP服務器，支持斷點續傳    *    * @param local    *      本地文件名稱，絕對路徑    *    * @param remote    *      遠程文件路徑，使用/home/directory1/subdirectory/file.ext    *      按照Linux上的路徑指定方式，支持多級目錄嵌套，支持遞歸創建不存在的目錄結構    *    * @return 上傳結果    *    * @throws IOException    */    @SuppressWarnings("resource")   public FTPStatus upload(String local, String remote) throws IOException   {     // 設置PassiveMode傳輸     ftpClient.enterLocalPassiveMode();      // 設置以二進制流的方式傳輸     ftpClient.setFileType(FTP.BINARY_FILE_TYPE);      FTPStatus result;      // 對遠程目錄的處理     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))       {          // 如果遠程目錄不存在，則遞歸創建遠程服務器目錄          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             {                Log.getLogger(this.getClass()).info("創建目錄失敗");                return FTPStatus.Create_Directory_Fail;              }            }            start = end + 1;            end = directory.indexOf("/", start);            // 檢查所有目錄是否創建完畢            if (end <= start)           {              break;            }          }        }      }      // 檢查遠程是否存在文件      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 FTPStatus.File_Exits;        } else if (remoteSize > localSize)       {          return FTPStatus.Remote_Bigger_Local;        }        // 嘗試移動文件內讀取指針,實現斷點續傳        InputStream is = new FileInputStream(f);        if (is.skip(remoteSize) == remoteSize)       {          ftpClient.setRestartOffset(remoteSize);          if (ftpClient.storeFile(remote, is))         {            return FTPStatus.Upload_From_Break_Success;          }        }        // 如果斷點續傳沒有成功，則刪除服務器上文件，重新上傳        if (!ftpClient.deleteFile(remoteFileName))       {          return FTPStatus.Delete_Remote_Faild;        }        is = new FileInputStream(f);        if (ftpClient.storeFile(remote, is))       {          result = FTPStatus.Upload_New_File_Success;        } else       {          result = FTPStatus.Upload_New_File_Failed;        }        is.close();      } else     {        InputStream is = new FileInputStream(local);        if (ftpClient.storeFile(remoteFileName, is))       {          result = FTPStatus.Upload_New_File_Success;        } else       {          result = FTPStatus.Upload_New_File_Failed;        }        is.close();     }      return result;    }    /**    *    * 斷開與遠程服務器的連接    *    * @throws IOException    */    public void disconnect() throws IOException   {      if (ftpClient.isConnected())     {       ftpClient.disconnect();     }    }    public static void main(String[] args)   {     FTPUtils myFtp = new FTPUtils();     try     {        myFtp.connect("192.168.1.200", 21, "duser", "HTPDuserXP32");        Log.getLogger(FTPUtils.class).info(myFtp.upload("C://Users//Administrator//Desktop//swing.drawer.jar", "/jars/swing.drawer.jar"));        myFtp.disconnect();      } catch (IOException e)     {        Log.getLogger(FTPUtils.class).info("FTP上傳文件異常：" + e.getMessage());      }    }  }