当前位置：首页 > news >正文

用sftp协议实现对文件的上传下载

news 2025/8/23 6:43:36

添加依赖，用后者而非前者，前者可能报错

        <dependency><groupId>com.jcraft</groupId><artifactId>jsch</artifactId><version>0.1.55</version></dependency><dependency><groupId>com.github.mwiede</groupId><artifactId>jsch</artifactId><version>0.2.24</version></dependency>

工具类代码

import com.jcraft.jsch.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;import java.io.File;
import java.io.FileInputStream;
import java.util.List;
import java.util.Properties;public class SFTPUtils {private static final Logger LOG = LoggerFactory.getLogger(SFTPUtils.class);/*** SFTP文件上传* @param host      SFTP服务器地址* @param port      SFTP端口* @param username  用户名* @param password  密码* @param localPath  本地文件路径* @param remoteDir 远程目录路径* @return true上传成功, false上传失败*/public static boolean uploadFile(String host, int port, String username, String password,String localPath, String remoteDir) {LOG.info(">>>>开始执行ftp上传文件,host={},port={},username={},password={},localPath={},remoteDir={}", host,port,username, password,localPath,remoteDir);ChannelSftp sftp = null;Session session = null;FileInputStream fis = null;try {// 1. 创建JSch对象JSch jsch = new JSch();// 2. 创建会话session = jsch.getSession(username, host, port);session.setPassword(password);// 3. 设置SSH配置Properties config = new Properties();config.put("StrictHostKeyChecking", "no"); // 跳过主机密钥检查session.setConfig(config);// 4. 连接会话session.connect();// 5. 打开SFTP通道Channel channel = session.openChannel("sftp");channel.connect();sftp = (ChannelSftp) channel;// 6. 确保远程目录存在try {sftp.cd(remoteDir);} catch (SftpException e) {// 目录不存在则递归创建mkdirs(sftp, remoteDir);}// 7. 上传文件File file = new File(localPath);fis = new FileInputStream(file);sftp.put(fis, file.getName());LOG.info("<<<结束执行ftp上传文件,上传成功,host={},port={},username={},password={},localPath={},remoteDir={}", host,port,username, password,localPath,remoteDir);return true;} catch (Exception e) {LOG.error("<<<结束执行ftp上传文件,上传失败,host={},port={},username={},password={},localPath={},remoteDir={}", host,port,username, password,localPath,remoteDir, e);return false;} finally {// 8. 关闭资源try {if (fis != null) fis.close();if (sftp != null) sftp.exit();if (session != null) session.disconnect();} catch (Exception e) {LOG.error("关闭ftp资源发生异常,host={},port={},username={},password={},localPath={},remoteDir={}", host,port,username, password,localPath,remoteDir, e);}}}/*** 递归创建目录*/private static void mkdirs(ChannelSftp sftp, String path) throws SftpException {String[] folders = path.split("/");for (String folder : folders) {if (folder.isEmpty()) continue;try {sftp.cd(folder);} catch (SftpException e) {sftp.mkdir(folder);sftp.cd(folder);}}}/*** SFTP文件下载* @param host      SFTP服务器地址* @param port      SFTP端口* @param username  用户名* @param password  密码* @param localDirectory  本地目录* @param remoteFilePaths 远程文件路径* @return 下载成功的文件数目*/public static int downloadFiles(String host, int port, String username, String password,String localDirectory, List<String> remoteFilePaths) {String remoteFilePathsStr = String.join(",", remoteFilePaths);LOG.info(">>>>开始执行ftp文件下载,host={},port={},username={},password={},localDirectory={},remoteFilePaths={}", host,port,username, password,localDirectory, remoteFilePathsStr);ChannelSftp sftp = null;Session session = null;int totalNum = remoteFilePaths.size();int count = 0;try {// 1. 创建JSch对象JSch jsch = new JSch();// 2. 创建会话session = jsch.getSession(username, host, port);session.setPassword(password);// 3. 设置SSH配置Properties config = new Properties();config.put("StrictHostKeyChecking", "no"); // 跳过主机密钥检查session.setConfig(config);// 4. 连接会话session.connect();// 5. 打开SFTP通道sftp = (ChannelSftp) session.openChannel("sftp");sftp.connect();File localDirectoryFile = new File(localDirectory);if (!localDirectoryFile.exists()) {localDirectoryFile.mkdirs();}//6. 执行文件的下载for (String remotePath : remoteFilePaths) {String fileName = getFileNameFromPath(remotePath);String localPath = localDirectory + File.separator + fileName;sftp.get(remotePath, localPath);count++;LOG.info("---执行ftp文件下载成功,host={},port={},remotePath={},localPath={},当前下载成功数目={}, 待下载数目={}", host,port, remotePath, localPath,count, totalNum-count);}}catch (Exception e){LOG.error("<<<<执行ftp文件下载过程中发生异常,host={},port={},username={},password={},localDirectory={},remoteFilePaths={}, 下载成功数目={}", host,port,username, password,localDirectory, remoteFilePathsStr, count, e);}finally {// 8. 关闭资源try {if (sftp != null){sftp.exit();}if (session != null){session.disconnect();}} catch (Exception e) {LOG.error("关闭ftp资源发生异常,host={},port={},username={},password={},localDirectory={},remoteFilePaths={}, 下载成功数目={}", host,port,username, password,localDirectory, remoteFilePathsStr, count, e);}}return count;}/*** 从路径中提取文件名*/private static String getFileNameFromPath(String path) {int lastSeparator = path.lastIndexOf('/');if (lastSeparator >= 0) {return path.substring(lastSeparator + 1);}return path;}
}