sftp和ftp兩種方式區別，還不清楚的，請自行百度查詢，此處不多贅述。完整代碼地址在結尾！！

<!-- FTP依賴包 --><dependency> <groupId>commons-net</groupId> <artifactId>commons-net</artifactId> <version>3.6</version></dependency><!-- SFTP依賴包 --><dependency> <groupId>com.jcraft</groupId> <artifactId>jsch</artifactId> <version>0.1.55</version></dependency><dependency> <groupId>commons-io</groupId> <artifactId>commons-io</artifactId> <version>2.6</version></dependency>第二步，創建并編寫SftpUtils類，運行main方法查看效果，如下

import com.jcraft.jsch.*;import lombok.extern.slf4j.Slf4j;import org.apache.commons.io.IOUtils;import java.io.File;import java.io.FileInputStream;import java.io.FileOutputStream;import java.io.InputStream;import java.util.Properties;import java.util.Vector;/** * @Description: sftp上傳下載工具類 * @Author: jinhaoxun * @Date: 2020/1/16 16:13 * @Version: 1.0.0 */@Slf4jpublic class SftpUtils { public static void main(String[] args) throws Exception { log.info('測試開始!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!'); // 1 File file = new File('E:2.xlsx'); InputStream inputStream = new FileInputStream(file); SftpUtils.uploadFile('', '', '', 22, '/usr/local','/testfile/', 'test.xlsx', null, inputStream); // 2 SftpUtils.downloadFile('', '', '', 22,null,'/usr/local/testfile/', 'test.csv','/Users/ao/Desktop/test.csv'); // 3 SftpUtils.deleteFile('', '', '', 22,null,'/usr/local/testfile/', 'test.xlsx'); // 4 Vector<?> fileList = SftpUtils.getFileList('', '', '',22, null,'/usr/local/testfile/'); log.info(fileList.toString()); log.info('測試結束!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!'); } /** * @Author: jinhaoxun * @Description: 下載文件 * @param userName 用戶名 * @param password 密碼 * @param host ip * @param port 端口 * @param basePath 根路徑 * @param filePath 文件路徑（加上根路徑） * @param filename 文件名 * @param privateKey 秘鑰 * @param input 文件流 * @Date: 2020/1/16 21:23 * @Return: void * @Throws: Exception */ public static void uploadFile(String userName, String password, String host, int port, String basePath, String filePath, String filename, String privateKey, InputStream input) throws Exception { Session session = null; ChannelSftp sftp = null; // 連接sftp服務器 try { JSch jsch = new JSch(); if (privateKey != null) {// 設置私鑰jsch.addIdentity(privateKey); } session = jsch.getSession(userName, host, port); if (password != null) {session.setPassword(password); } Properties config = new Properties(); config.put('StrictHostKeyChecking', 'no'); session.setConfig(config); session.connect(); Channel channel = session.openChannel('sftp'); channel.connect(); sftp = (ChannelSftp) channel; } catch (JSchException e) { e.printStackTrace(); } // 將輸入流的數據上傳到sftp作為文件 try { sftp.cd(basePath); sftp.cd(filePath); } catch (SftpException e) { //目錄不存在，則創建文件夾 String [] dirs=filePath.split('/'); String tempPath=basePath; for(String dir:dirs){if(null== dir || ''.equals(dir)){ continue;}tempPath+='/'+dir;try{ sftp.cd(tempPath);}catch(SftpException ex){ sftp.mkdir(tempPath); sftp.cd(tempPath);} } } //上傳文件 sftp.put(input, filename); //關閉連接 server if (sftp != null) { if (sftp.isConnected()) {sftp.disconnect(); } } //關閉連接 server if (session != null) { if (session.isConnected()) {session.disconnect(); } } } /** * @Author: jinhaoxun * @Description: 下載文件 * @param userName 用戶名 * @param password 密碼 * @param host ip * @param port 端口 * @param privateKey 秘鑰 * @param directory 文件路徑 * @param downloadFile 文件名 * @param saveFile 存在本地的路徑 * @Date: 2020/1/16 21:22 * @Return: void * @Throws: Exception */ public static void downloadFile(String userName, String password, String host, int port, String privateKey, String directory,String downloadFile, String saveFile) throws Exception{ Session session = null; ChannelSftp sftp = null; // 連接sftp服務器 try { JSch jsch = new JSch(); if (privateKey != null) {// 設置私鑰jsch.addIdentity(privateKey); } session = jsch.getSession(userName, host, port); if (password != null) {session.setPassword(password); } Properties config = new Properties(); config.put('StrictHostKeyChecking', 'no'); session.setConfig(config); session.connect(); Channel channel = session.openChannel('sftp'); channel.connect(); sftp = (ChannelSftp) channel; } catch (JSchException e) { e.printStackTrace(); } if (directory != null && !''.equals(directory)) { sftp.cd(directory); } File file = new File(saveFile); sftp.get(downloadFile, new FileOutputStream(file)); } /** * @Author: jinhaoxun * @Description: 下載文件 * @param userName 用戶名 * @param password 密碼 * @param host ip * @param port 端口 * @param privateKey 秘鑰 * @param directory 文件路徑 * @param downloadFile 文件名 * @Date: 2020/1/16 21:21 * @Return: byte[] * @Throws: Exception */ public static byte[] downloadFile(String userName, String password, String host, int port, String privateKey, String directory, String downloadFile) throws Exception{ Session session = null; ChannelSftp sftp = null; // 連接sftp服務器 try { JSch jsch = new JSch(); if (privateKey != null) {// 設置私鑰jsch.addIdentity(privateKey); } session = jsch.getSession(userName, host, port); if (password != null) {session.setPassword(password); } Properties config = new Properties(); config.put('StrictHostKeyChecking', 'no'); session.setConfig(config); session.connect(); Channel channel = session.openChannel('sftp'); channel.connect(); sftp = (ChannelSftp) channel; } catch (JSchException e) { e.printStackTrace(); } if (directory != null && !''.equals(directory)) { sftp.cd(directory); } InputStream is = sftp.get(downloadFile); byte[] fileData = IOUtils.toByteArray(is); return fileData; } /** * @Author: jinhaoxun * @Description: 刪除文件 * @param userName 用戶名 * @param password 密碼 * @param host ip * @param port 端口 * @param privateKey 秘鑰 * @param directory 文件路徑 * @param deleteFile 文件名 * @Date: 2020/1/16 21:24 * @Return: void * @Throws: Exception */ public static void deleteFile(String userName, String password, String host, int port, String privateKey, String directory, String deleteFile) throws Exception{ Session session = null; ChannelSftp sftp = null; // 連接sftp服務器 try { JSch jsch = new JSch(); if (privateKey != null) {// 設置私鑰jsch.addIdentity(privateKey); } session = jsch.getSession(userName, host, port); if (password != null) {session.setPassword(password); } Properties config = new Properties(); config.put('StrictHostKeyChecking', 'no'); session.setConfig(config); session.connect(); Channel channel = session.openChannel('sftp'); channel.connect(); sftp = (ChannelSftp) channel; } catch (JSchException e) { e.printStackTrace(); } sftp.cd(directory); sftp.rm(deleteFile); } /** * @Author: jinhaoxun * @Description: 列出目錄下的文件 * @param userName 用戶名 * @param password 密碼 * @param host ip * @param port 端口 * @param privateKey 秘鑰 * @param directory 要列出的目錄 * @Date: 2020/1/16 21:25 * @Return: java.util.Vector<?> * @Throws: Exception */ public static Vector<?> getFileList(String userName, String password, String host, int port, String privateKey, String directory) throws Exception { Session session = null; ChannelSftp sftp = null; // 連接sftp服務器 try { JSch jsch = new JSch(); if (privateKey != null) {// 設置私鑰jsch.addIdentity(privateKey); } session = jsch.getSession(userName, host, port); if (password != null) {session.setPassword(password); } Properties config = new Properties(); config.put('StrictHostKeyChecking', 'no'); session.setConfig(config); session.connect(); Channel channel = session.openChannel('sftp'); channel.connect(); sftp = (ChannelSftp) channel; } catch (JSchException e) { e.printStackTrace(); } return sftp.ls(directory); }}第三步，創建并編寫FtpUtils類，運行main方法查看效果，如下

import lombok.extern.slf4j.Slf4j;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 java.io.*;/** * @Description: ftp上傳下載工具類 * @Author: jinhaoxun * @Date: 2020/1/16 15:46 * @Version: 1.0.0 */@Slf4jpublic class FtpUtils { public static void main(String[] args) throws Exception { log.info('測試開始!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!'); // 1 File file = new File('E:2.xlsx'); InputStream inputStream = new FileInputStream(file); FtpUtils.uploadFile('', 21, '', '', '/usr/local','/testfile/', 'test.xlsx', inputStream); // 2 FtpUtils.downloadFile('', 21, '', '','/usr/local/testfile/','test.csv', '/Users/ao/Desktop/test.csv'); log.info('測試結束!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!'); } /** * @Author: jinhaoxun * @Description: 向FTP服務器上傳文件 * @param host FTP服務器hostname * @param port FTP服務器端口 * @param userName FTP登錄賬號 * @param password FTP登錄密碼 * @param basePath FTP服務器基礎目錄 * @param filePath FTP服務器文件存放路徑。例如分日期存放：/2015/01/01。文件的路徑為basePath+filePath * @param filename 上傳到FTP服務器上的文件名 * @param input 本地要上傳的文件的 輸入流 * @Date: 2020/1/16 19:31 * @Return: boolean * @Throws: Exception */ public static boolean uploadFile(String host, int port, String userName, String password, String basePath, String filePath, String filename, InputStream input) throws Exception{ boolean result = false; FTPClient ftp = new FTPClient(); try { int reply; // 連接FTP服務器 ftp.connect(host, port); // 如果采用默認端口，可以使用ftp.connect(host)的方式直接連接FTP服務器 // 登錄 ftp.login(userName, password); reply = ftp.getReplyCode(); if (!FTPReply.isPositiveCompletion(reply)) {ftp.disconnect();return result; } //切換到上傳目錄 if (!ftp.changeWorkingDirectory(basePath+filePath)) {//如果目錄不存在創建目錄String[] dirs = filePath.split('/');String tempPath = basePath;for (String dir : dirs) { if (null == dir || ''.equals(dir)){ continue; } tempPath += '/' + dir; if (!ftp.changeWorkingDirectory(tempPath)) { if (!ftp.makeDirectory(tempPath)) { return result; } else { ftp.changeWorkingDirectory(tempPath); } }} } //設置上傳文件的類型為二進制類型 ftp.setFileType(FTP.BINARY_FILE_TYPE); //上傳文件 if (!ftp.storeFile(filename, input)) {return result; } input.close(); ftp.logout(); result = true; } catch (IOException e) { e.printStackTrace(); } finally { if (ftp.isConnected()) {try { ftp.disconnect();} catch (IOException ioe) {} } } return result; } /** * @Author: jinhaoxun * @Description: 從FTP服務器下載文件 * @param host FTP服務器hostname * @param port FTP服務器端口 * @param userName FTP登錄賬號 * @param password FTP登錄密碼 * @param remotePath FTP服務器上的相對路徑 * @param fileName 要下載的文件名 * @param localPath 下載后保存到本地的路徑 * @Date: 2020/1/16 19:34 * @Return: boolean * @Throws: Exception */ public static boolean downloadFile(String host, int port, String userName, String password, String remotePath, String fileName, String localPath) throws Exception { boolean result = false; FTPClient ftp = new FTPClient(); try { int reply; ftp.connect(host, port); // 如果采用默認端口，可以使用ftp.connect(host)的方式直接連接FTP服務器 // 登錄 ftp.login(userName, password); reply = ftp.getReplyCode(); if (!FTPReply.isPositiveCompletion(reply)) {ftp.disconnect();return result; } // 轉移到FTP服務器目錄 ftp.changeWorkingDirectory(remotePath); FTPFile[] fs = ftp.listFiles(); for (FTPFile ff : fs) {if (ff.getName().equals(fileName)) { java.io.File localFile = new File(localPath + '/' + ff.getName()); OutputStream is = new FileOutputStream(localFile); ftp.retrieveFile(ff.getName(), is); is.close();} } ftp.logout(); result = true; } catch (IOException e) { e.printStackTrace(); } finally { if (ftp.isConnected()) {try { ftp.disconnect();} catch (IOException ioe) {} } } return result; } }

完整代碼地址：https://github.com/luoyusoft/java-demo注：此工程包含多個包，FtpUtils代碼均在com.luoyu.java.ftp包下注：此工程包含多個包，SftpUtils代碼均在com.luoyu.java.sftp包下

到此這篇關于Java使用Sftp和Ftp實現對文件的上傳和下載的文章就介紹到這了,更多相關Java使用Sftp和Ftp文件上傳和下載內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網！