Java實現跨服務器上傳文件功能

前幾天做個項目，本身客戶端和管理員端是寫在一起的，共用一台服務器，客戶上傳的文件都是存在服務器的硬盤上的。老龍提出要把客戶端和管理員端分離，這時候用戶上傳的附件的存儲就出現問題了。顯然，把大到幾百M的apk文件存到數據庫不現實，查了半天，在兩端建立ftp服務器傳文件是最快的方法。

具體流程是，用戶登錄外網客戶端，上傳文件到外網的服務器硬盤上，在此同時，文件通過外網服務器訪問內網管理員服務器的ftp服務器，傳到內網服務器的硬盤上。這樣內網服務器可以對上傳的文件進行加密簽名工作，之後也通過ftp的方式把文件回傳到外網服務器硬盤上，供用戶進行其他操作。

具體實現時用到的工具：Serv-U。 Serv-U是一個方便我們在windows上建立ftp服務器的工具。下載破解後，按照步驟，設置好Ip、端口、賬戶密碼、允許ftp訪問的磁盤路徑、操作權限等，就可以使用了。 IP在本機測試的時候就選127.0.0.1，內網測試時就選192.168.0.x。

在java項目中的實現，我自己寫了個工具類，用到了apache的commons-net包，有上傳，下載以及刪除功能。附上代碼：

 package app.ftp; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import org.apache.commons.net.ftp.FTPClient; import org.apache.commons.net.ftp.FTPFile; import org.apache.commons.net.ftp.FTPReply; /** * FTP服務器工具類* */ public class FTPUtils { /** * 上傳文件至FTP服務器* * @param url * 服務器IP地址* @param port * 服務器端口* @param userName * 用戶登錄名* @param password * 用戶登錄密碼* @param storePath * 服務器文件存儲路徑* @param fileName * 服務器文件存儲名稱* @param is * 文件輸入流* @return * <b>true</b>：上傳成功* <br/> * <b>false</b>：上傳失敗*/ public static boolean storeFile (String url, int port, String userName, String password, String storePath, String fileName, InputStream is) { boolean result = false; FTPClient ftp = new FTPClient(); try { // 連接至服務器，端口默認為21時，可直接通過URL連接ftp.connect(url ,port); // 登錄服務器ftp.login(userName, password); // 判斷返回碼是否合法if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) { // 不合法時斷開連接ftp.disconnect(); // 結束程序return result; } // 判斷ftp目錄是否存在，如果不存在則創建目錄，包括創建多級目錄String s = "/"+storePath; String[] dirs = s.split("/"); ftp.changeWorkingDirectory("/"); //按順序檢查目錄是否存在，不存在則創建目錄for(int i=1; dirs!=null&&i<dirs.length; i++) { if(!ftp.changeWorkingDirectory(dirs[i])) { if(ftp.makeDirectory(dirs[i])) { if(!ftp.changeWorkingDirectory(dirs[i])) { return false; } }else { return false; } } } // 設置文件操作目錄ftp.changeWorkingDirectory(storePath); // 設置文件類型，二進制ftp.setFileType(FTPClient.BINARY_FILE_TYPE); // 設置緩衝區大小ftp.setBufferSize(3072); // 上傳文件result = ftp.storeFile(fileName, is); // 關閉輸入流is.close(); // 登出服務器ftp.logout(); } catch (IOException e) { e.printStackTrace(); } finally { try { // 判斷輸入流是否存在if (null != is) { // 關閉輸入流is.close(); } // 判斷連接是否存在if (ftp.isConnected()) { // 斷開連接ftp.disconnect(); } } catch (IOException e) { e.printStackTrace(); } } return result; } /** * 從FTP服務器下載文件至本地* * @param url * 服務器IP地址* @param port * 服務器端口* @param userName * 用戶登錄名* @param password * 用戶登錄密碼* @param remotePath * 服務器文件存儲路徑* @param fileName * 服務器文件存儲名稱* @param localPath * 本地文件存儲路徑* @return * <b>true</b>：下載成功* <br/> * <b>false</b>：下載失敗*/ public static boolean retrieveFile (String url, int port, String userName, String password, String remotePath, String fileName, String localPath) { boolean result = false; FTPClient ftp = new FTPClient(); OutputStream os = null; try { // 連接至服務器，端口默認為21時，可直接通過URL連接ftp.connect(url ,port); // 登錄服務器ftp.login(userName, password); // 判斷返回碼是否合法if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) { // 不合法時斷開連接ftp.disconnect(); // 結束程序return result; } // 設置文件操作目錄ftp.changeWorkingDirectory(remotePath); // 設置文件類型，二進制ftp.setFileType(FTPClient.BINARY_FILE_TYPE); // 設置緩衝區大小ftp.setBufferSize(3072); // 設置字符編碼ftp.setControlEncoding("UTF-8"); // 構造本地文件對象File localFile = new File(localPath + "/" + fileName); // 獲取文件操作目錄下所有文件名稱String[] remoteNames = ftp.listNames(); // 循環比對文件名稱，判斷是否含有當前要下載的文件名for (String remoteName: remoteNames) { if (fileName.equals(remoteName)) { result = true; } } // 文件名稱比對成功時，進入下載流程if (result) { // 構造文件輸出流os = new FileOutputStream(localFile); // 下載文件result = ftp.retrieveFile(fileName, os); // 關閉輸出流os.close(); } // 登出服務器ftp.logout(); } catch (IOException e) { e.printStackTrace(); } finally { try { // 判斷輸出流是否存在if (null != os) { // 關閉輸出流os.close(); } // 判斷連接是否存在if (ftp.isConnected()) { // 斷開連接ftp.disconnect(); } } catch (IOException e) { e.printStackTrace(); } } return result; } /** * 從FTP服務器刪除文件* * @param url * 服務器IP地址* @param port * 服務器端口* @param userName * 用戶登錄名* @param password * 用戶登錄密碼* @param remotePath * 服務器文件存儲路徑* @param fileName * 服務器文件存儲名稱* @return * <b>true</b>：刪除成功* <br/> * <b>false</b>：刪除失敗*/ public static boolean deleteFile (String url, int port, String userName, String password, String remotePath, String fileName) { boolean result = false; FTPClient ftp = new FTPClient(); try { // 連接至服務器，端口默認為21時，可直接通過URL連接ftp.connect(url ,port); // 登錄服務器ftp.login(userName, password); // 判斷返回碼是否合法if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) { // 不合法時斷開連接ftp.disconnect(); // 結束程序return result; } // 設置文件操作目錄ftp.changeWorkingDirectory(remotePath); // 設置文件類型，二進制ftp.setFileType(FTPClient.BINARY_FILE_TYPE); // 設置緩衝區大小ftp.setBufferSize(3072); // 設置字符編碼ftp.setControlEncoding("UTF-8"); // 獲取文件操作目錄下所有文件名稱String[] remoteNames = ftp.listNames(); // 循環比對文件名稱，判斷是否含有當前要下載的文件名for (String remoteName: remoteNames) { if (fileName.equals(remoteName)) { result = true; } } // 文件名稱比對成功時，進入刪除流程if (result) { // 刪除文件result = ftp.deleteFile(fileName); } // 登出服務器ftp.logout(); } catch (IOException e) { e.printStackTrace(); } finally { try { // 判斷連接是否存在if (ftp.isConnected()) { // 斷開連接ftp.disconnect(); } } catch (IOException e) { e.printStackTrace(); } } return result; } public static void main(String[] args) throws FileNotFoundException { // try { // FileInputStream fis = new FileInputStream(new File("D:/Soft Storage/軟件工具箱/HTML_Help_WorkShop_1.3_XiaZaiBa.zip")); // System.out.println(storeFile("192.168.1.2", 21, "admin", "1", "C:/Documents and Settings/Administrator/桌面", RandomUUID.random() + ".zip", fis)); // } catch (FileNotFoundException e) { // e.printStackTrace(); // } // //File file = new File("C:/Users/freed/Desktop/1.txt"); //InputStream is = new FileInputStream(file); //System.out.println(storeFile("127.0.0.1", 21, "feili", "feili", "examples", "2.txt", is)); //System.out.println(retrieveFile("127.0.0.1", 21, "feili", "feili", "examples/jsp", "index.html", "C:/Users/freed/Desktop")); //System.out.println(deleteFile("127.0.0.1", 21, "feili", "feili", "testpath", "1.txt")); } }

需要注意的是上傳文件的時候要將File文件先放入fileinputstream中。

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持武林網。