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

<!-- 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>第二步，創(chuàng)建并編寫SftpUtils類，運(yùn)行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('測(cè)試開始!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!'); // 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('測(cè)試結(jié)束!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!'); } /** * @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服務(wù)器 try { JSch jsch = new JSch(); if (privateKey != null) {// 設(shè)置私鑰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(); } // 將輸入流的數(shù)據(jù)上傳到sftp作為文件 try { sftp.cd(basePath); sftp.cd(filePath); } catch (SftpException e) { //目錄不存在，則創(chuàng)建文件夾 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); //關(guān)閉連接 server if (sftp != null) { if (sftp.isConnected()) {sftp.disconnect(); } } //關(guān)閉連接 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服務(wù)器 try { JSch jsch = new JSch(); if (privateKey != null) {// 設(shè)置私鑰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服務(wù)器 try { JSch jsch = new JSch(); if (privateKey != null) {// 設(shè)置私鑰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服務(wù)器 try { JSch jsch = new JSch(); if (privateKey != null) {// 設(shè)置私鑰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服務(wù)器 try { JSch jsch = new JSch(); if (privateKey != null) {// 設(shè)置私鑰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); }}第三步，創(chuàng)建并編寫FtpUtils類，運(yùn)行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('測(cè)試開始!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!'); // 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('測(cè)試結(jié)束!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!'); } /** * @Author: jinhaoxun * @Description: 向FTP服務(wù)器上傳文件 * @param host FTP服務(wù)器hostname * @param port FTP服務(wù)器端口 * @param userName FTP登錄賬號(hào) * @param password FTP登錄密碼 * @param basePath FTP服務(wù)器基礎(chǔ)目錄 * @param filePath FTP服務(wù)器文件存放路徑。例如分日期存放：/2015/01/01。文件的路徑為basePath+filePath * @param filename 上傳到FTP服務(wù)器上的文件名 * @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服務(wù)器 ftp.connect(host, port); // 如果采用默認(rèn)端口，可以使用ftp.connect(host)的方式直接連接FTP服務(wù)器 // 登錄 ftp.login(userName, password); reply = ftp.getReplyCode(); if (!FTPReply.isPositiveCompletion(reply)) {ftp.disconnect();return result; } //切換到上傳目錄 if (!ftp.changeWorkingDirectory(basePath+filePath)) {//如果目錄不存在創(chuàng)建目錄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); } }} } //設(shè)置上傳文件的類型為二進(jìn)制類型 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服務(wù)器下載文件 * @param host FTP服務(wù)器hostname * @param port FTP服務(wù)器端口 * @param userName FTP登錄賬號(hào) * @param password FTP登錄密碼 * @param remotePath FTP服務(wù)器上的相對(duì)路徑 * @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); // 如果采用默認(rèn)端口，可以使用ftp.connect(host)的方式直接連接FTP服務(wù)器 // 登錄 ftp.login(userName, password); reply = ftp.getReplyCode(); if (!FTPReply.isPositiveCompletion(reply)) {ftp.disconnect();return result; } // 轉(zhuǎn)移到FTP服務(wù)器目錄 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注：此工程包含多個(gè)包，F(xiàn)tpUtils代碼均在com.luoyu.java.ftp包下注：此工程包含多個(gè)包，SftpUtils代碼均在com.luoyu.java.sftp包下

到此這篇關(guān)于Java使用Sftp和Ftp實(shí)現(xiàn)對(duì)文件的上傳和下載的文章就介紹到這了,更多相關(guān)Java使用Sftp和Ftp文件上傳和下載內(nèi)容請(qǐng)搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！