?

一、Java實現對SFTP服務器的文件的上傳下載：

1、添加maven依賴：

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

2、SFTPUtil工具類：

import java.io.ByteArrayInputStream; 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.UnsupportedEncodingException; import java.util.Properties; import java.util.Vector; import org.apache.commons.io.IOUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.jcraft.jsch.Channel; import com.jcraft.jsch.ChannelSftp; import com.jcraft.jsch.JSch; import com.jcraft.jsch.JSchException; import com.jcraft.jsch.Session; import com.jcraft.jsch.SftpException; /** * 類說明 sftp工具類 */ public class SFTPUtil {private transient Logger log = LoggerFactory.getLogger(this.getClass()); private ChannelSftp sftp; private Session session; /** SFTP 登錄用戶名*/ private String username; /** SFTP 登錄密碼*/ private String password; /** 私鑰 */ private String privateKey; /** SFTP 服務器地址IP地址*/ private String host; /** SFTP 端口*/ private int port; /** * 構造基于密碼認證的sftp對象 */ public SFTPUtil(String username, String password, String host, int port) { this.username = username; this.password = password; this.host = host; this.port = port; } /** * 構造基于秘鑰認證的sftp對象 */ public SFTPUtil(String username, String host, int port, String privateKey) { this.username = username; this.host = host; this.port = port; this.privateKey = privateKey; } public SFTPUtil(){} /** * 連接sftp服務器 */ public void login(){ 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();} } /** * 關閉連接 server */ public void logout(){ if (sftp != null) { if (sftp.isConnected()) { sftp.disconnect(); } } if (session != null) { if (session.isConnected()) { session.disconnect(); } } } /** * 將輸入流的數據上傳到sftp作為文件。文件完整路徑=basePath+directory* @param basePath 服務器的基礎路徑 * @param directory 上傳到該目錄 * @param sftpFileName sftp端文件名 * @param in 輸入流 */ public void upload(String basePath,String directory, String sftpFileName, InputStream input) throws SftpException{ try { sftp.cd(basePath);sftp.cd(directory); } catch (SftpException e) { //目錄不存在，則創建文件夾String [] dirs=directory.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, sftpFileName); //上傳文件} /** * 下載文件。* @param directory 下載目錄 * @param downloadFile 下載的文件 * @param saveFile 存在本地的路徑 */ public void download(String directory, String downloadFile, String saveFile) throws SftpException, FileNotFoundException{ if (directory != null && !"".equals(directory)) { sftp.cd(directory); } File file = new File(saveFile); sftp.get(downloadFile, new FileOutputStream(file)); } /** * 下載文件 * @param directory 下載目錄 * @param downloadFile 下載的文件名 * @return 字節數組 */ public byte[] download(String directory, String downloadFile) throws SftpException, IOException{ if (directory != null && !"".equals(directory)) { sftp.cd(directory); } InputStream is = sftp.get(downloadFile); byte[] fileData = IOUtils.toByteArray(is); return fileData; } /** * 刪除文件 * @param directory 要刪除文件所在目錄 * @param deleteFile 要刪除的文件 */ public void delete(String directory, String deleteFile) throws SftpException{ sftp.cd(directory); sftp.rm(deleteFile); } /** * 列出目錄下的文件 * @param directory 要列出的目錄 * @param sftp */ public Vector<?> listFiles(String directory) throws SftpException { return sftp.ls(directory); } //上傳文件測試public static void main(String[] args) throws SftpException, IOException { SFTPUtil sftp = new SFTPUtil("用戶名", "密碼", "ip地址", 22); sftp.login(); File file = new File("D:\\圖片\\t0124dd095ceb042322.jpg"); InputStream is = new FileInputStream(file); sftp.upload("基礎路徑","文件路徑", "test_sftp.jpg", is); sftp.logout(); } }

?

二、Java實現對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.FTP; import org.apache.commons.net.ftp.FTPClient; import org.apache.commons.net.ftp.FTPFile; import org.apache.commons.net.ftp.FTPReply;/*** ftp上傳下載工具類*/ public class FtpUtil {/** * Description: 向FTP服務器上傳文件 * @param host FTP服務器hostname * @param port FTP服務器端口 * @param username FTP登錄賬號 * @param password FTP登錄密碼 * @param basePath FTP服務器基礎目錄* @param filePath FTP服務器文件存放路徑。文件的路徑為basePath+filePath* @param filename 上傳到FTP服務器上的文件名 * @param input 輸入流 * @return 成功返回true，否則返回false */ public static boolean uploadFile(String host, int port, String username, String password, String basePath,String filePath, String filename, InputStream input) {boolean result = false;FTPClient ftp = new FTPClient();try {int reply;ftp.connect(host, port);// 連接FTP服務器// 如果采用默認端口，可以使用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)) { //創建目錄//如果創建文件目錄失敗，則返回System.out.println("創建文件目錄"+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;}/** * Description: 從FTP服務器下載文件 * @param host FTP服務器hostname * @param port FTP服務器端口 * @param username FTP登錄賬號 * @param password FTP登錄密碼 * @param remotePath FTP服務器上的相對路徑 * @param fileName 要下載的文件名 * @param localPath 下載后保存到本地的路徑 * @return */ public static boolean downloadFile(String host, int port, String username, String password, String remotePath,String fileName, String localPath) {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.changeWorkingDirectory(remotePath);// 轉移到FTP服務器目錄FTPFile[] fs = ftp.listFiles();for (FTPFile ff : fs) {if (ff.getName().equals(fileName)) {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;}//ftp上傳文件測試main函數public static void main(String[] args) {try { FileInputStream in=new FileInputStream(new File("D:\\Tomcat 5.5\\pictures\\t0176ee418172932841.jpg")); boolean flag = uploadFile("192.168.111.128", 21, "用戶名", "密碼", "/www/images","/2017/11/19", "hello.jpg", in); System.out.println(flag); } catch (FileNotFoundException e) { e.printStackTrace(); } } }

?

?

?

與50位技術專家面對面20年技術見證，附贈技術全景圖

總結

以上是生活随笔為你收集整理的Java使用SFTP和FTP两种连接服务器的方式实现对文件的上传下载的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。