Apache FTP 是應用比較廣泛的FTP上傳客戶端工具，它易於操作，代碼簡略，結構清晰，是做FTP文件客戶端管理軟件的優先之選。 FTP的操作包括：FTP文件上傳（斷點續傳）、FTP文件下載、FTP文件重命名、FTP文件刪除，這些操作已經將FTP應用管理的方式發揮的淋漓盡致了，So 我一直都用此種方式來實現FTP文件服務器的管理工作；下附FTP工具代碼。
1、FTP文件操作狀態枚舉類
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; } } 2、FTP文件操作工具代碼
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()); } } }以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持武林網。