SFTPUtils工具類及使用

配置maven

<dependency><groupId>com.jcraft</groupId><artifactId>jsch</artifactId><version>0.1.54</version>
</dependency>

工具類

package com.sftp;import com.jcraft.jsch.*;
import com.jcraft.jsch.ChannelSftp.LsEntry;
import org.apache.log4j.Logger;import java.io.File;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;
import java.util.Vector;/*** SFTP(Secure File Transfer Protocol),安全文件傳送協議。*/
public class Sftp {/** 日志記錄器  */private Logger logger = Logger.getLogger(Sftp.class);/** Session */private Session session = null;/** Channel */private ChannelSftp channel = null;/** SFTP服務器IP地址 */private String host;/** SFTP服務器端口 */private int port;/** 連接超時時間,單位毫秒  */private int timeout;/** 用戶名 */private String username;/** 密碼 */private String password;/*** SFTP 安全文件傳送協議* @param host SFTP服務器IP地址* @param port SFTP服務器端口* @param timeout 連接超時時間,單位毫秒 * @param username 用戶名* @param password 密碼*/public Sftp(String host,int port,int timeout,String username,String password){this.host = host;this.port = port;this.timeout = timeout;this.username = username;this.password = password;}/*** 登陸SFTP服務器* @return boolean*/public boolean login() {try {JSch jsch = new JSch();session = jsch.getSession(username, host, port);if(password != null){session.setPassword(password);}Properties config = new Properties();config.put("StrictHostKeyChecking", "no");session.setConfig(config);session.setTimeout(timeout);session.connect();logger.debug("sftp session connected");logger.debug("opening channel");channel = (ChannelSftp)session.openChannel("sftp");channel.connect();logger.debug("connected successfully");return true;} catch (JSchException e) {logger.error("sftp login failed",e);return false;}}/*** 上傳文件* <p>* 使用示例,SFTP服務器上的目錄結構如下:/testA/testA_B/* <table border="1">* <tr><td>當前目錄</td><td>方法</td><td>參數:絕對路徑/相對路徑</td><td>上傳后</td></tr>* <tr><td>/</td><td>uploadFile("testA","upload.txt",new FileInputStream(new File("up.txt")))</td><td>相對路徑</td><td>/testA/upload.txt</td></tr>* <tr><td>/</td><td>uploadFile("testA/testA_B","upload.txt",new FileInputStream(new File("up.txt")))</td><td>相對路徑</td><td>/testA/testA_B/upload.txt</td></tr>* <tr><td>/</td><td>uploadFile("/testA/testA_B","upload.txt",new FileInputStream(new File("up.txt")))</td><td>絕對路徑</td><td>/testA/testA_B/upload.txt</td></tr>* </table>* </p>* @param pathName SFTP服務器目錄* @param fileName 服務器上保存的文件名* @param input 輸入文件流* @return boolean*/public boolean uploadFile(String pathName,String fileName,InputStream input){String currentDir = currentDir();if(!changeDir(pathName)){return false;}try {channel.put(input,fileName,ChannelSftp.OVERWRITE);if(!existFile(fileName)){logger.debug("upload failed");return false;}logger.debug("upload successful");return true;} catch (SftpException e) {logger.error("upload failed",e);return false;} finally {changeDir(currentDir);}}/*** 上傳文件* <p>* 使用示例,SFTP服務器上的目錄結構如下:/testA/testA_B/* <table border="1">* <tr><td>當前目錄</td><td>方法</td><td>參數:絕對路徑/相對路徑</td><td>上傳后</td></tr>* <tr><td>/</td><td>uploadFile("testA","upload.txt","up.txt")</td><td>相對路徑</td><td>/testA/upload.txt</td></tr>* <tr><td>/</td><td>uploadFile("testA/testA_B","upload.txt","up.txt")</td><td>相對路徑</td><td>/testA/testA_B/upload.txt</td></tr>* <tr><td>/</td><td>uploadFile("/testA/testA_B","upload.txt","up.txt")</td><td>絕對路徑</td><td>/testA/testA_B/upload.txt</td></tr>* </table>* </p>* @param pathName SFTP服務器目錄* @param fileName 服務器上保存的文件名* @param localFile 本地文件* @return boolean*/public boolean uploadFile(String pathName,String fileName,String localFile){String currentDir = currentDir();if(!changeDir(pathName)){return false;}try {channel.put(localFile,fileName,ChannelSftp.OVERWRITE);if(!existFile(fileName)){logger.debug("upload failed");return false;}logger.debug("upload successful");return true;} catch (SftpException e) {logger.error("upload failed",e);return false;} finally {changeDir(currentDir);}}/*** 下載文件* <p>* 使用示例,SFTP服務器上的目錄結構如下:/testA/testA_B/* <table border="1">* <tr><td>當前目錄</td><td>方法</td><td>參數:絕對路徑/相對路徑</td><td>下載后</td></tr>* <tr><td>/</td><td>downloadFile("testA","down.txt","D:\\downDir")</td><td>相對路徑</td><td>D:\\downDir\\down.txt</td></tr>* <tr><td>/</td><td>downloadFile("testA/testA_B","down.txt","D:\\downDir")</td><td>相對路徑</td><td>D:\\downDir\\down.txt</td></tr>* <tr><td>/</td><td>downloadFile("/testA/testA_B","down.txt","D:\\downDir")</td><td>絕對路徑</td><td>D:\\downDir\\down.txt</td></tr>* </table>* </p>* @param remotePath SFTP服務器目錄* @param fileName 服務器上需要下載的文件名* @param localPath 本地保存路徑* @return boolean*/public boolean downloadFile(String remotePath,String fileName,String localPath){String currentDir = currentDir();if(!changeDir(remotePath)){return false;}try {String localFilePath = localPath + File.separator + fileName;channel.get(fileName,localFilePath);File localFile = new File(localFilePath);if(!localFile.exists()){logger.debug("download file failed");return false;}logger.debug("download successful");return true;} catch (SftpException e) {logger.error("download file failed",e);return false;} finally {changeDir(currentDir);}}/*** 切換工作目錄* <p>* 使用示例,SFTP服務器上的目錄結構如下:/testA/testA_B/* <table border="1">* <tr><td>當前目錄</td><td>方法</td><td>參數(絕對路徑/相對路徑)</td><td>切換后的目錄</td></tr>* <tr><td>/</td><td>changeDir("testA")</td><td>相對路徑</td><td>/testA/</td></tr>* <tr><td>/</td><td>changeDir("testA/testA_B")</td><td>相對路徑</td><td>/testA/testA_B/</td></tr>* <tr><td>/</td><td>changeDir("/testA")</td><td>絕對路徑</td><td>/testA/</td></tr>* <tr><td>/testA/testA_B/</td><td>changeDir("/testA")</td><td>絕對路徑</td><td>/testA/</td></tr>* </table>* </p>* @param pathName 路徑* @return boolean*/public boolean changeDir(String pathName){if(pathName == null || pathName.trim().equals("")){logger.debug("invalid pathName");return false;}try {channel.cd(pathName.replaceAll("\\\\", "/"));logger.debug("directory successfully changed,current dir=" + channel.pwd());return true;} catch (SftpException e) {logger.error("failed to change directory",e);return false;}}/*** 切換到上一級目錄* <p>* 使用示例,SFTP服務器上的目錄結構如下:/testA/testA_B/* <table border="1">* <tr><td>當前目錄</td><td>方法</td><td>切換后的目錄</td></tr>* <tr><td>/testA/</td><td>changeToParentDir()</td><td>/</td></tr>* <tr><td>/testA/testA_B/</td><td>changeToParentDir()</td><td>/testA/</td></tr>* </table>* </p>* @return boolean*/public boolean changeToParentDir(){return changeDir("..");}/*** 切換到根目錄* @return boolean*/public boolean changeToHomeDir(){String homeDir = null;try {homeDir = channel.getHome();} catch (SftpException e) {logger.error("can not get home directory",e);return false;}return changeDir(homeDir);}/*** 創建目錄* <p>* 使用示例,SFTP服務器上的目錄結構如下:/testA/testA_B/* <table border="1">* <tr><td>當前目錄</td><td>方法</td><td>參數(絕對路徑/相對路徑)</td><td>創建成功后的目錄</td></tr>* <tr><td>/testA/testA_B/</td><td>makeDir("testA_B_C")</td><td>相對路徑</td><td>/testA/testA_B/testA_B_C/</td></tr>* <tr><td>/</td><td>makeDir("/testA/testA_B/testA_B_D")</td><td>絕對路徑</td><td>/testA/testA_B/testA_B_D/</td></tr>* </table>* <br/>* <b>注意</b>,當<b>中間目錄不存在</b>的情況下,不能夠使用絕對路徑的方式期望創建中間目錄及目標目錄。* 例如makeDir("/testNOEXIST1/testNOEXIST2/testNOEXIST3"),這是錯誤的。* </p>* @param dirName 目錄* @return boolean*/public boolean makeDir(String dirName){try {channel.mkdir(dirName);logger.debug("directory successfully created,dir=" + dirName);return true;} catch (SftpException e) {logger.error("failed to create directory", e);return false;}}/*** 刪除文件夾* @param dirName* @return boolean*/@SuppressWarnings("unchecked")public boolean delDir(String dirName){if(!changeDir(dirName)){return false;}Vector<LsEntry> list = null;try {list = channel.ls(channel.pwd());} catch (SftpException e) {logger.error("can not list directory",e);return false;}for(LsEntry entry : list){String fileName = entry.getFilename();if(!fileName.equals(".") && !fileName.equals("..")){if(entry.getAttrs().isDir()){delDir(fileName);} else {delFile(fileName);}}}if(!changeToParentDir()){return false;}try {channel.rmdir(dirName);logger.debug("directory " + dirName + " successfully deleted");return true;} catch (SftpException e) {logger.error("failed to delete directory " + dirName,e);return false;}}/*** 刪除文件* @param fileName 文件名* @return boolean*/public boolean delFile(String fileName){if(fileName == null || fileName.trim().equals("")){logger.debug("invalid filename");return false;}try {channel.rm(fileName);logger.debug("file " + fileName + " successfully deleted");return true;} catch (SftpException e) {logger.error("failed to delete file " + fileName,e);return false;}}/*** 當前目錄下文件及文件夾名稱列表* @return String[]*/public String[] ls(){return list(Filter.ALL);}/*** 指定目錄下文件及文件夾名稱列表* @return String[]*/public String[] ls(String pathName){String currentDir = currentDir();if(!changeDir(pathName)){return new String[0];};String[] result = list(Filter.ALL);if(!changeDir(currentDir)){return new String[0];}return result;}/*** 當前目錄下文件名稱列表* @return String[]*/public String[] lsFiles(){return list(Filter.FILE);}/*** 指定目錄下文件名稱列表* @return String[]*/public String[] lsFiles(String pathName){String currentDir = currentDir();if(!changeDir(pathName)){return new String[0];};String[] result = list(Filter.FILE);if(!changeDir(currentDir)){return new String[0];}return result;}/*** 當前目錄下文件夾名稱列表* @return String[]*/public String[] lsDirs(){return list(Filter.DIR);}/*** 指定目錄下文件夾名稱列表* @return String[]*/public String[] lsDirs(String pathName){String currentDir = currentDir();if(!changeDir(pathName)){return new String[0];};String[] result = list(Filter.DIR);if(!changeDir(currentDir)){return new String[0];}return result;}/*** 當前目錄是否存在文件或文件夾* @param name 名稱* @return boolean*/public boolean exist(String name){return exist(ls(), name);}/*** 指定目錄下,是否存在文件或文件夾* @param path 目錄* @param name 名稱* @return boolean*/public boolean exist(String path,String name){return exist(ls(path),name);}/*** 當前目錄是否存在文件* @param name 文件名* @return boolean*/public boolean existFile(String name){return exist(lsFiles(),name);}/*** 指定目錄下,是否存在文件* @param path 目錄* @param name 文件名* @return boolean*/public boolean existFile(String path,String name){return exist(lsFiles(path), name);}/*** 當前目錄是否存在文件夾* @param name 文件夾名稱* @return boolean*/public boolean existDir(String name){return exist(lsDirs(), name);}/*** 指定目錄下,是否存在文件夾* @param path 目錄* @param name 文家夾名稱* @return boolean*/public boolean existDir(String path,String name){return exist(lsDirs(path), name);}/*** 當前工作目錄* @return String*/public String currentDir(){try {return channel.pwd();} catch (SftpException e) {logger.error("failed to get current dir",e);return homeDir();}}/*** 登出*/public void logout(){if(channel != null){channel.quit();channel.disconnect();}if(session != null){session.disconnect();}logger.debug("logout successfully");}//------private method ------/** 枚舉,用于過濾文件和文件夾  */private enum Filter {/** 文件及文件夾 */ ALL ,/** 文件 */ FILE ,/** 文件夾 */ DIR };/*** 列出當前目錄下的文件及文件夾* @param filter 過濾參數* @return String[]*/@SuppressWarnings("unchecked")private String[] list(Filter filter){Vector<LsEntry> list = null;try {//ls方法會返回兩個特殊的目錄,當前目錄(.)和父目錄(..)list = channel.ls(channel.pwd());} catch (SftpException e) {logger.error("can not list directory",e);return new String[0];}List<String> resultList = new ArrayList<String>();for(LsEntry entry : list){if(filter(entry, filter)){resultList.add(entry.getFilename());}}return resultList.toArray(new String[0]);}/*** 判斷是否是否過濾條件* @param entry LsEntry* @param f 過濾參數* @return boolean*/private boolean filter(LsEntry entry,Filter f){if(f.equals(Filter.ALL)){return !entry.getFilename().equals(".") && !entry.getFilename().equals("..");} else if(f.equals(Filter.FILE)){return !entry.getFilename().equals(".") && !entry.getFilename().equals("..") && !entry.getAttrs().isDir();} else if(f.equals(Filter.DIR)){return !entry.getFilename().equals(".") && !entry.getFilename().equals("..") && entry.getAttrs().isDir();}return false;}/*** 根目錄* @return String*/private String homeDir(){try {return channel.getHome();} catch (SftpException e) {return "/";}}/*** 判斷字符串是否存在于數組中* @param strArr 字符串數組* @param str 字符串* @return boolean*/private boolean exist(String[] strArr,String str){if(strArr == null || strArr.length == 0){return false;}if(str == null || str.trim().equals("")){return false;}for(String s : strArr){if(s.equalsIgnoreCase(str)){return true;}}return false;}}

?

轉載于:https://www.cnblogs.com/xiaofengfree/p/10309839.html

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/450075.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/450075.shtml
英文地址,請注明出處:http://en.pswp.cn/news/450075.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

國內手機產業混亂:產業一窩蜂 企業撈快錢

對于當前國內手機行業的現狀&#xff0c;本報記者采訪的多位業內人士表示&#xff0c;目前國內手機行業仍是“紅海”格局&#xff0c;多數企業并不了解手機產業規律&#xff0c;看到有錢賺就“一窩蜂”上項目。有行業人士認為&#xff0c;要走出目前行業的現狀&#xff0c;企業…

查看私密文章方法

前些天發現了一個巨牛的人工智能學習網站&#xff0c;通俗易懂&#xff0c;風趣幽默&#xff0c;忍不住分享一下給大家。點擊跳轉到教程。 我只是記錄下&#xff0c;曾經寫過一次文章&#xff0c;勾選了私密&#xff0c;再后來就找不到了。 下面這個鏈接可以查出那篇文章&…

SDUT-3364_歐拉回路

數據結構實驗之圖論八&#xff1a;歐拉回路 Time Limit: 1000 ms Memory Limit: 65536 KiB Problem Description 在哥尼斯堡的一個公園里&#xff0c;有七座橋將普雷格爾河中兩個島及島與河岸連接起來。 能否走過這樣的七座橋&#xff0c;并且每橋只走一次&#xff1f;瑞士數學…

Tcp三次握手和四次揮手狀態圖

三次握手 四次揮手 正常情況下 同時揮手 SYN攻擊&#xff1a; 在三次握手過程中&#xff0c;Server發送SYN-ACK之后&#xff0c;收到Client的ACK之前的TCP連接稱為半連接&#xff08;half-open connect&#xff09;&#xff0c;此時Server處于SYN_RCVD狀態&#xff0c;當…

QEMU 3.0.0 新特性一覽

QEMU 在 2018年8月15發布了版本3.0.0&#xff0c; 正式從 2.12 進入了3.0 時代。 而且到今年位為止&#xff0c;QEMU 已經有15個年頭了&#xff0c;出乎意料的長阿&#xff0c;:) 其主要新特性如下&#xff1a; ARM&#xff1a; 在virt機器中支持SMMUv3 IOMMU 在v8M中支持VLLDM…

OpenCL、OpenGL 同時工作

視頻處理如果能使用OpenCL、OpenGL、omap將大量提高運算速度&#xff0c;簡單介紹OpenCL、OpenGL 同時工作。 OpenCL和OpenGL都能用于操作GPU&#xff0c;但是前者主要用于通用計算&#xff0c;而后者主要用于圖像渲染。在某些情況下&#xff0c;我們希望能用OpenCL計得到算圖像…

財務自由之路——為什么選擇淘寶(下)

接上文~一、淘寶之前的大佬們是怎么試錯的?我們看看在淘寶之前的大佬們是怎么試錯迭代產品的。都知道飛機是萊特兄弟發明的&#xff0c;但很少有人知道為什么是他們。在內燃機發明后的很長一段時間內全球各地發明家都在投入研究飛機&#xff0c;萊特兄弟相對于其他競爭者&…

java參數后面跟三個點是什么意思

前些天發現了一個巨牛的人工智能學習網站&#xff0c;通俗易懂&#xff0c;風趣幽默&#xff0c;忍不住分享一下給大家。點擊跳轉到教程。 AVA中類型后面跟三個點是什么來的。 看代碼中那個三點&#xff0c;這樣做起到重載的作用&#xff0c;但這是什么意思&#xff1f; cla…

一只視頻程序猿的移動直播SDK初體驗

本文轉自一只視頻程序猿的移動直播SDK初體驗&#xff0c;此處僅做排版改動。 今早老板召開站會&#xff0c;“移動直播這么火&#xff0c;市面上有一百多個APP&#xff0c;小斌&#xff0c;你下周交個原型APP瞅瞅!” 小弟心中一萬匹草泥馬奔過&#xff0c;這玩意兒哪兒是幾天就…

Xilinx zynq-7000系列FPGA移植Linux操作系統詳細教程

Xilinx zynq-7000系列FPGA移植Linux操作系統詳細教程 一&#xff1a;前言 最近手上壓了一塊米聯客的Miz7035&#xff0c;一塊xilinx zynq-7000系列的開發板&#xff0c;想著正好學習一下linux在ARM9上的移植&#xff0c;網上基本都是ZC702、zed的教程&#xff0c;這對于買了非標…

程序員的創業困境 誰來幫助出出主意?

【編者按】有人說&#xff0c;程序員是吃青春飯的&#xff0c;到一定年齡就得考慮轉行&#xff0c;也有人選擇自己創業。而當創業使你偏離了之前持續學習專業知識的軌道時&#xff0c;你會選擇在創業路上繼續堅持還是回歸自己的老本行&#xff1f;編程編了十幾年的Dan McComas半…

節選—Android 視頻直播 ( 從快播到直播,從高清到無碼 )十年視頻開發項目

本文轉載自Android 視頻直播 &#xff08; 從快播到直播&#xff0c;從高清到無碼 )十年視頻開發項目&#xff0c;截取其中技術概念比較相關的部分&#xff0c;并做了重新的排版。 視頻和直播的準備&#xff1a; android-java層&#xff1a;camera相關&#xff08;視頻&#x…

getDeclaredMethod和getMethod的區別

前些天發現了一個巨牛的人工智能學習網站&#xff0c;通俗易懂&#xff0c;風趣幽默&#xff0c;忍不住分享一下給大家。點擊跳轉到教程。 getDeclaredMethod*()獲取的是類自身聲明的所有方法&#xff0c;包含public、protected和private方法。getMethod*()獲取的是類的所有共有…

12.5PMP試題每日一題

在什么情況下項目正式受控于實施整體變更控制過程&#xff1a;A、從項目啟動到收尾的所有過程B、只有當項目基準建立之后C、在項目基準建立之前D、只要有人提起變更請求的時候 作者&#xff1a;Tracy19890201&#xff08;同微信號&#xff09; 答案將于明天和新題一起揭曉&…

在線預覽word,excel文檔

Google Doc 示例&#xff1a;https://jsfiddle.net/7xr419yb/ Microsoft Office 示例&#xff1a;https://jsfiddle.net/gcuzq343/轉載于:https://www.cnblogs.com/alexguoyihao/p/10314626.html

如何遷移整個git倉庫

轉自準備更換git托管&#xff0c;如何遷移原git倉庫一個回答 如果你想從別的 Git 托管服務那里復制一份源代碼到新的 Git 托管服務器上的話&#xff0c;可以通過以下步驟來操作。 從原地址克隆一份裸版本庫&#xff0c;比如原本托管于 GitHub。 git clone –bare git://githu…

關于創業:希望有人在N年前就告訴我的一些事兒

【編者按】原文作者為前微軟員工、創業家Amir Khella&#xff0c;他離開微軟后開始自主創業&#xff0c;并成功創辦了多家公司。他經常在博客中分享自己的創業故事和經驗。以下是其中一篇博文&#xff0c;他認為創業者想要成功&#xff0c;首先需要找到自己的方向&#xff0c;再…

Rust核心團隊前成員Brian Anderson加入PingCAP

昨天&#xff0c;國內新型分布式數據庫公司PingCAP聯合創始人兼CEO劉奇在朋友圈宣布&#xff0c;Rust核心團隊前成員Brian Anderson將加入公司。PingCAP聯合創始人兼CTO黃東旭進一步向InfoQ記者證實了此消息&#xff0c;并透露Brian將從事TiKV相關的工作&#xff0c;從存儲引擎…

JeeSite 是什么、概述

見JeeSite官網&#xff1a;http://jeesite4.mydoc.io/ 前些天發現了一個巨牛的人工智能學習網站&#xff0c;通俗易懂&#xff0c;風趣幽默&#xff0c;忍不住分享一下給大家。點擊跳轉到教程。 總體概述 快速訪問 JeeSite 官網地址&#xff1a;http://jeesite.comJeeSite 在…

單機單網卡最大tcp長連接數真的是65535嗎?

很早微博上一直討論比較多的問題&#xff0c;這里轉載個知乎的答案&#xff1a;單機單網卡最大tcp長連接數真的是65535嗎&#xff1f; 作者&#xff1a;許懷遠 鏈接&#xff1a;https://www.zhihu.com/question/66553828/answer/244313925 來源&#xff1a;知乎 著作權歸作者…