Java利用apache ftp工具實現(xiàn)文件上傳下載和刪除功能
更新時間:2018年06月10日 13:30:10 作者:悠悠-我心
這篇文章主要為大家詳細介紹了Java利用apache ftp工具實現(xiàn)文件上傳下載、刪除功能,具有一定的參考價值,感興趣的小伙伴們可以參考一下
利用apache ftp工具實現(xiàn)文件的上傳下載和刪除,具體如下
1、下載相應(yīng)的jar包
commons-net-1.4.1.jar
2、實現(xiàn)代碼如下:
public class FtpUtils { //ftp服務(wù)器地址 public String hostname = "192.168.1.249"; //ftp服務(wù)器端口號默認為21 public Integer port = 21 ; //ftp登錄賬號 public String username = "root"; //ftp登錄密碼 public String password = "123"; public FTPClient ftpClient = null; /** * 初始化ftp服務(wù)器 */ public void initFtpClient() { ftpClient = new FTPClient(); ftpClient.setControlEncoding("utf-8"); try { System.out.println("connecting...ftp服務(wù)器:"+this.hostname+":"+this.port); ftpClient.connect(hostname, port); //連接ftp服務(wù)器 ftpClient.login(username, password); //登錄ftp服務(wù)器 int replyCode = ftpClient.getReplyCode(); //是否成功登錄服務(wù)器 if(!FTPReply.isPositiveCompletion(replyCode)){ System.out.println("connect failed...ftp服務(wù)器:"+this.hostname+":"+this.port); } System.out.println("connect successfu...ftp服務(wù)器:"+this.hostname+":"+this.port); }catch (MalformedURLException e) { e.printStackTrace(); }catch (IOException e) { e.printStackTrace(); } } /** * 上傳文件 * @param pathname ftp服務(wù)保存地址 * @param fileName 上傳到ftp的文件名 * @param originfilename 待上傳文件的名稱(絕對地址) * * @return */ public boolean uploadFile( String pathname, String fileName,String originfilename){ boolean flag = false; InputStream inputStream = null; try{ System.out.println("開始上傳文件"); inputStream = new FileInputStream(new File(originfilename)); initFtpClient(); ftpClient.setFileType(ftpClient.BINARY_FILE_TYPE); CreateDirecroty(pathname); ftpClient.makeDirectory(pathname); ftpClient.changeWorkingDirectory(pathname); ftpClient.storeFile(fileName, inputStream); inputStream.close(); ftpClient.logout(); flag = true; System.out.println("上傳文件成功"); }catch (Exception e) { System.out.println("上傳文件失敗"); e.printStackTrace(); }finally{ if(ftpClient.isConnected()){ try{ ftpClient.disconnect(); }catch(IOException e){ e.printStackTrace(); } } if(null != inputStream){ try { inputStream.close(); } catch (IOException e) { e.printStackTrace(); } } } return true; } /** * 上傳文件 * @param pathname ftp服務(wù)保存地址 * @param fileName 上傳到ftp的文件名 * @param inputStream 輸入文件流 * @return */ public boolean uploadFile( String pathname, String fileName,InputStream inputStream){ boolean flag = false; try{ System.out.println("開始上傳文件"); initFtpClient(); ftpClient.setFileType(ftpClient.BINARY_FILE_TYPE); CreateDirecroty(pathname); ftpClient.makeDirectory(pathname); ftpClient.changeWorkingDirectory(pathname); ftpClient.storeFile(fileName, inputStream); inputStream.close(); ftpClient.logout(); flag = true; System.out.println("上傳文件成功"); }catch (Exception e) { System.out.println("上傳文件失敗"); e.printStackTrace(); }finally{ if(ftpClient.isConnected()){ try{ ftpClient.disconnect(); }catch(IOException e){ e.printStackTrace(); } } if(null != inputStream){ try { inputStream.close(); } catch (IOException e) { e.printStackTrace(); } } } return true; } //改變目錄路徑 public boolean changeWorkingDirectory(String directory) { boolean flag = true; try { flag = ftpClient.changeWorkingDirectory(directory); if (flag) { System.out.println("進入文件夾" + directory + " 成功!"); } else { System.out.println("進入文件夾" + directory + " 失敗!開始創(chuàng)建文件夾"); } } catch (IOException ioe) { ioe.printStackTrace(); } return flag; } //創(chuàng)建多層目錄文件,如果有ftp服務(wù)器已存在該文件,則不創(chuàng)建,如果無,則創(chuàng)建 public boolean CreateDirecroty(String remote) throws IOException { boolean success = true; String directory = remote + "/"; // 如果遠程目錄不存在,則遞歸創(chuàng)建遠程服務(wù)器目錄 if (!directory.equalsIgnoreCase("/") && !changeWorkingDirectory(new String(directory))) { int start = 0; int end = 0; if (directory.startsWith("/")) { start = 1; } else { start = 0; } end = directory.indexOf("/", start); String path = ""; String paths = ""; while (true) { String subDirectory = new String(remote.substring(start, end).getBytes("GBK"), "iso-8859-1"); path = path + "/" + subDirectory; if (!existFile(path)) { if (makeDirectory(subDirectory)) { changeWorkingDirectory(subDirectory); } else { System.out.println("創(chuàng)建目錄[" + subDirectory + "]失敗"); changeWorkingDirectory(subDirectory); } } else { changeWorkingDirectory(subDirectory); } paths = paths + "/" + subDirectory; start = end + 1; end = directory.indexOf("/", start); // 檢查所有目錄是否創(chuàng)建完畢 if (end <= start) { break; } } } return success; } //判斷ftp服務(wù)器文件是否存在 public boolean existFile(String path) throws IOException { boolean flag = false; FTPFile[] ftpFileArr = ftpClient.listFiles(path); if (ftpFileArr.length > 0) { flag = true; } return flag; } //創(chuàng)建目錄 public boolean makeDirectory(String dir) { boolean flag = true; try { flag = ftpClient.makeDirectory(dir); if (flag) { System.out.println("創(chuàng)建文件夾" + dir + " 成功!"); } else { System.out.println("創(chuàng)建文件夾" + dir + " 失?。?); } } catch (Exception e) { e.printStackTrace(); } return flag; } /** * 下載文件 * * @param pathname FTP服務(wù)器文件目錄 * * @param filename 文件名稱 * * @param localpath 下載后的文件路徑 * * @return */ public boolean downloadFile(String pathname, String filename, String localpath){ boolean flag = false; OutputStream os=null; try { System.out.println("開始下載文件"); initFtpClient(); //切換FTP目錄 ftpClient.changeWorkingDirectory(pathname); FTPFile[] ftpFiles = ftpClient.listFiles(); for(FTPFile file : ftpFiles){ if(filename.equalsIgnoreCase(file.getName())){ File localFile = new File(localpath + "/" + file.getName()); os = new FileOutputStream(localFile); ftpClient.retrieveFile(file.getName(), os); os.close(); } } ftpClient.logout(); flag = true; System.out.println("下載文件成功"); } catch (Exception e) { System.out.println("下載文件失敗"); e.printStackTrace(); } finally{ if(ftpClient.isConnected()){ try{ ftpClient.disconnect(); }catch(IOException e){ e.printStackTrace(); } } if(null != os){ try { os.close(); } catch (IOException e) { e.printStackTrace(); } } } return flag; } /** * 刪除文件 * * @param pathname FTP服務(wù)器保存目錄 * * @param filename 要刪除的文件名稱 * * @return */ public boolean deleteFile(String pathname, String filename){ boolean flag = false; try { System.out.println("開始刪除文件"); initFtpClient(); //切換FTP目錄 ftpClient.changeWorkingDirectory(pathname); ftpClient.dele(filename); ftpClient.logout(); flag = true; System.out.println("刪除文件成功"); } catch (Exception e) { System.out.println("刪除文件失敗"); e.printStackTrace(); } finally { if(ftpClient.isConnected()){ try{ ftpClient.disconnect(); }catch(IOException e){ e.printStackTrace(); } } } return flag; } public static void main(String[] args) { FtpUtils ftp =new FtpUtils(); //ftp.uploadFile("ftpFile/data", "123.docx", "E://123.docx"); //ftp.downloadFile("ftpFile/data", "123.docx", "F://"); ftp.deleteFile("ftpFile/data", "123.docx"); System.out.println("ok"); } }
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
您可能感興趣的文章:
- Apache Calcite進行SQL解析(java代碼實例)
- Java使用Apache.POI中HSSFWorkbook導(dǎo)出到Excel的實現(xiàn)方法
- java操作Apache druid的實例代碼
- 淺析Java中Apache BeanUtils和Spring BeanUtils的用法
- Caused by: java.lang.ClassNotFoundException: org.apache.commons.collections.Transformer異常
- Java常用類庫Apache Commons工具類說明及使用實例詳解
- Java?Apache?common-pool對象池介紹
相關(guān)文章
Python單元測試_使用裝飾器實現(xiàn)測試跳過和預(yù)期故障的方法
下面小編就為大家?guī)硪黄狿ython單元測試_使用裝飾器實現(xiàn)測試跳過和預(yù)期故障的方法。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2017-06-06java輸入多個數(shù)據(jù)(不確定),排序,并求最大值的方法
今天小編就為大家分享一篇java輸入多個數(shù)據(jù)(不確定),排序,并求最大值的方法,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2018-07-07SpringBoot結(jié)果封裝和異常攔截的實現(xiàn)示例
SpringBoot 項目中,我們通常需要將結(jié)果數(shù)據(jù)封裝成特定的格式,以方便客戶端進行處理,本文主要介紹了SpringBoot?優(yōu)雅的結(jié)果封裝和異常攔截,感興趣的可以了解一下2023-08-08SpringBoot集成FTP文件服務(wù)器簡單應(yīng)用方式
這篇文章主要介紹了SpringBoot集成FTP文件服務(wù)器簡單應(yīng)用方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-07-07