FTP和SFTP的工具类

2024-06-14 10:48
文章标签 工具 ftp sftp

本文主要是介绍FTP和SFTP的工具类，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！ 

<dependency><groupId>commons-net</groupId><artifactId>commons-net</artifactId><version>3.6</version>
</dependency>@Slf4j
public class FTPUtils {/*** 连接，如果失败重试3次，间隔1s** @param server* @return*/public static FTPClient connectFtp(FTPServer server) {FTPClient ftpClient = new FTPClient();ftpClient.setControlEncoding(server.getEncoding());for (int i = 0; i < 3; i++) {try {log.info("connecting...ftp服务器:" + server.getIp() + ":" + server.getPort());ftpClient.connect(server.getIp(), server.getPort()); //连接ftp服务器ftpClient.login(server.getAccount(), server.getPwd()); //登录ftp服务器int replyCode = ftpClient.getReplyCode(); //是否成功登录服务器if (FTPReply.isPositiveCompletion(replyCode)) {log.info("连接成功...ftp服务器" + server.getIp() + ":" + server.getPort());break;}Thread.sleep(1000);log.info("连接失败...ftp服务器" + server.getIp() + ":" + server.getPort());} catch (Exception e) {log.error(e.getMessage(), e);}}return ftpClient;}/*** 下载文件 *** @param pathname  FTP服务器文件目录 ** @param filename  文件名称 ** @param localpath 下载后的文件路径 ** @return*/public static boolean downloadFile(FTPClient ftpClient, String pathname, String filename, String localpath) {OutputStream os = null;try {log.info("开始下载文件");ftpClient.enterLocalPassiveMode();//切换FTP目录ftpClient.changeWorkingDirectory(pathname);FTPFile[] ftpFiles = ftpClient.listFiles();for (FTPFile file : ftpFiles) {if (filename.equalsIgnoreCase(file.getName())) {File localFile = new File(localpath + file.getName());os = new FileOutputStream(localFile);ftpClient.setFileType(FTP.BINARY_FILE_TYPE);boolean flag = ftpClient.retrieveFile(file.getName(), os);if (!flag) {log.info("下载文件失败:" + file.getName());return false;} else {log.info("下载文件成功" + file.getName());}}}} catch (Exception e) {log.info("下载文件失败" + e.getMessage(), e);return false;} finally {if (os != null) {try {os.close();} catch (IOException e) {}}}return true;}/*** 删除文件 *** @param filename 要删除的文件名称 ** @return*/public static boolean deleteFile(FTPClient ftpClient, String filename, String pathname) {try {ftpClient.enterLocalPassiveMode();ftpClient.changeWorkingDirectory(pathname);log.info("开始删除文件");boolean flag = ftpClient.deleteFile(pathname + filename);log.info("删除文件成功");return flag;} catch (Exception e) {log.error("删除文件失败", e);return false;}}/*** 递归遍历出目录下面所有文件** @param pathName 需要遍历的目录，必须以"/"开始和结束* @throws IOException*/public static void list(FTPClient ftpClient, String pathName, List<String> arFiles) throws IOException {ftpClient.enterLocalPassiveMode();if (pathName.startsWith("/") && pathName.endsWith("/")) {String directory = pathName;//更换目录到当前目录ftpClient.changeWorkingDirectory(directory);FTPFile[] files = ftpClient.listFiles();for (FTPFile file : files) {if (file.isFile()) {arFiles.add(directory + file.getName());} else if (file.isDirectory()) {list(ftpClient, directory + file.getName() + "/", arFiles);}}}}/*** 递归遍历目录下面指定的文件名** @param pathName 需要遍历的目录，必须以"/"开始和结束* @param ext      文件的扩展名* @throws IOException*/public static void list(FTPClient ftpClient, String pathName, String ext, List<String> arFiles) throws IOException {ftpClient.enterLocalPassiveMode();if (pathName.startsWith("/") && pathName.endsWith("/")) {String directory = pathName;//更换目录到当前目录ftpClient.changeWorkingDirectory(directory);FTPFile[] files = ftpClient.listFiles();for (FTPFile file : files) {if (file.isFile()) {if (file.getName().endsWith(ext)) {arFiles.add(file.getName());}} else if (file.isDirectory()) {list(ftpClient, directory + file.getName() + "/", ext, arFiles);}}}}/*** 上传文件** @param pathname       ftp服务保存地址* @param fileName       上传到ftp的文件名* @param originfilename 待上传文件的名称（绝对地址） ** @return*/public static boolean uploadFile(FTPClient ftpClient, String pathname, String fileName, String originfilename) {InputStream inputStream = null;try {log.info("开始上传文件");ftpClient.enterLocalPassiveMode();inputStream = new FileInputStream(new File(originfilename));ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);ftpClient.changeWorkingDirectory(pathname);ftpClient.storeFile(fileName, inputStream);log.info("上传文件成功");} catch (Exception e) {log.info("上传文件失败" + e.getMessage(), e);return false;} finally {if (inputStream != null) {try {inputStream.close();} catch (IOException e) {}}}return true;}/*** 上传文件** @param pathname    ftp服务保存地址 必须是绝对地址* @param fileName    上传到ftp的文件名* @param inputStream 输入文件流* @return*/public static boolean uploadFile(FTPClient ftpClient, String pathname, String fileName, InputStream inputStream) {try {log.info("开始上传文件：{}/{}",pathname,fileName);ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);ftpClient.changeWorkingDirectory(pathname);ftpClient.storeFile(fileName, inputStream);log.info("上传文件成功");} catch (Exception e) {log.info("上传文件失败:{}/{}" + e.getMessage(),pathname,fileName, e);return false;}return true;}//创建多层目录文件，如果有ftp服务器已存在该文件，则不创建，如果无，则创建public static boolean createDirectory(FTPClient ftpClient, String remote) throws IOException {boolean success = true;String directory = remote + "/";// 如果远程目录不存在，则递归创建远程服务器目录if (!directory.equalsIgnoreCase("/") && !ftpClient.changeWorkingDirectory(directory)) {int start = 0;int end = 0;if (directory.startsWith("/")) {start = 1;} else {start = 0;}end = directory.indexOf("/", start);String path = "";String paths = "";while (true) {String subDirectory = new String(remote.substring(start, end).getBytes("GBK"), "iso-8859-1");path = path + "/" + subDirectory;if (!existFile(ftpClient, path)) {if (ftpClient.makeDirectory(subDirectory)) {ftpClient.changeWorkingDirectory(subDirectory);} else {log.info("创建目录[" + subDirectory + "]失败");ftpClient.changeWorkingDirectory(subDirectory);}} else {ftpClient.changeWorkingDirectory(subDirectory);}paths = paths + "/" + subDirectory;start = end + 1;end = directory.indexOf("/", start);// 检查所有目录是否创建完毕if (end <= start) {break;}}}return success;}//判断ftp服务器文件是否存在public static boolean existFile(FTPClient ftpClient, String path) {try {FTPFile[] ftpFileArr = ftpClient.listFiles(path);if (ftpFileArr != null && ftpFileArr.length > 0) {return false;}return false;} catch (Exception e) {return false;}}public static void close(FTPClient ftpClient) throws IOException {if (ftpClient == null) {return;}try {if (ftpClient.isConnected()) {ftpClient.logout();ftpClient.disconnect();}} catch (Exception e) {log.error(e.getMessage(), e);}}public static class FTPServer {private String ip;private Integer port;private String account;private String pwd;private String encoding;public FTPServer() {}public FTPServer(String ip, Integer port, String account, String pwd, String encoding) {this.ip = ip;this.port = port;this.account = account;this.pwd = pwd;this.encoding = encoding;}public String getIp() {return ip;}public void setIp(String ip) {this.ip = ip;}public Integer getPort() {return port;}public void setPort(Integer port) {this.port = port;}public String getAccount() {return account;}public void setAccount(String account) {this.account = account;}public String getPwd() {return pwd;}public void setPwd(String pwd) {this.pwd = pwd;}public String getEncoding() {return encoding;}public void setEncoding(String encoding) {this.encoding = encoding;}}
}

<dependency><groupId>com.jcraft</groupId><artifactId>jsch</artifactId><version>0.1.55</version>	
</dependency>@Slf4j
public class SFTPUtils {/*** 连接，如果失败重试3次，间隔1s** @param server* @return*/public static ChannelSftp connectFtp(SFTPServer server) {ChannelSftp sftp = null;for (int i = 0; i < 3; i++) {try {log.info("connecting...ftp服务器:" + server.getIp() + ":" + server.getPort());JSch jsch = new JSch();Session sshSession = jsch.getSession(server.getAccount(), server.getIp(), server.getPort());sshSession.setPassword(server.getPwd());Properties sshConfig = new Properties();sshConfig.put("StrictHostKeyChecking", "no");sshSession.setConfig(sshConfig);sshSession.connect();Channel channel = sshSession.openChannel("sftp");channel.connect();sftp = (ChannelSftp) channel;log.info("连接成功...ftp服务器" + server.getIp() + ":" + server.getPort());break;} catch (Exception e) {try {Thread.sleep(1000);log.info("连接失败...ftp服务器" + server.getIp() + ":" + server.getPort() + ":" + e.getMessage(), e);} catch (InterruptedException e1) {log.error(e.getMessage(), e);}}}return sftp;}/*** 下载文件 *** @param pathname  FTP服务器文件目录 ** @param filename  文件名称 ** @param localpath 下载后的文件路径 ** @return*/public static void downloadFile(ChannelSftp sftp, String pathname, String filename, String localpath) {if (StringUtils.isEmpty(pathname) || !pathname.endsWith("/")) {throw new IllegalArgumentException("path is not illegal:" + pathname);}try (FileOutputStream outputStream = new FileOutputStream(localpath)) {log.info("开始下载文件：{}", pathname + filename);sftp.cd(pathname);sftp.get(filename, outputStream);log.info("文件已下载至{}", localpath);} catch (Exception e) {log.error(e.getMessage(), e);}}/*** 删除文件 *** @param filename 要删除的文件名称 ** @return*/public static boolean deleteFile(ChannelSftp sftp, String filename, String pathname) {if (StringUtils.isEmpty(pathname) || !pathname.endsWith("/")) {throw new IllegalArgumentException("path is not illegal:" + pathname);}try {sftp.cd(pathname);sftp.rm(filename);log.info("已删除{}", pathname + filename);return true;} catch (Exception e) {log.error(e.getMessage(), e);}return false;}/*** 递归遍历出目录下面所有文件** @param pathName 需要遍历的目录，必须以"/"开始和结束* @throws IOException*/public static void list(ChannelSftp sftp, String pathName, List<String> arFiles) throws IOException {if (StringUtils.isEmpty(pathName) || !pathName.endsWith("/")) {return;}try {sftp.cd(pathName);Vector<String> files = sftp.ls("*");for (int i = 0; i < files.size(); i++) {Object obj = files.elementAt(i);if (obj instanceof com.jcraft.jsch.ChannelSftp.LsEntry) {ChannelSftp.LsEntry entry = (ChannelSftp.LsEntry) obj;if (!entry.getAttrs().isDir()) {String file = pathName + entry.getFilename();arFiles.add(file);} else {if (!entry.getFilename().equals(".") && !entry.getFilename().equals("..")) {String folder = pathName + entry.getFilename() + "/";arFiles.add(folder);list(sftp, folder, arFiles);}}}}} catch (Exception e) {log.error(e.getMessage(), e);}}/*** 递归遍历目录下面指定的文件名** @param pathName 需要遍历的目录，必须以"/"开始和结束* @param ext      文件的扩展名* @throws IOException*/public static void list(ChannelSftp sftp, String pathName, String ext, List<String> arFiles) throws IOException {if (StringUtils.isEmpty(pathName) || !pathName.endsWith("/")) {return;}try {sftp.cd(pathName);Vector<String> files = sftp.ls("*");for (int i = 0; i < files.size(); i++) {Object obj = files.elementAt(i);if (obj instanceof com.jcraft.jsch.ChannelSftp.LsEntry) {ChannelSftp.LsEntry entry = (ChannelSftp.LsEntry) obj;if (!entry.getAttrs().isDir()) {if (entry.getFilename().endsWith(ext)) {String file = pathName + entry.getFilename();arFiles.add(file);}} else {if (!entry.getFilename().equals(".") && !entry.getFilename().equals("..")) {String folder = pathName + entry.getFilename() + "/";arFiles.add(folder);list(sftp, folder, arFiles);}}}}} catch (Exception e) {log.error(e.getMessage(), e);}}/*** 上传文件** @param pathname       ftp服务保存地址* @param fileName       上传到ftp的文件名* @param originfilename 待上传文件的名称（绝对地址） ** @return*/public static boolean uploadFile(ChannelSftp sftp, String pathname, String fileName, String originfilename) {if (StringUtils.isEmpty(pathname) || !pathname.endsWith("/")) {throw new IllegalArgumentException("path is not illegal:" + pathname);}try (InputStream inputStream = new FileInputStream(new File(originfilename));) {sftp.cd(pathname);sftp.put(inputStream, fileName);  //上传文件log.info("上传文件成功：{}，源文件:{}", pathname + fileName, originfilename);return true;} catch (Exception e) {log.info("上传文件失败:{}" + e.getMessage(), pathname + fileName, e);log.error(e.getMessage(), e);return false;}}/*** 上传文件** @param pathname    ftp服务保存地址 必须是绝对地址* @param fileName    上传到ftp的文件名* @param inputStream 输入文件流* @return*/public static boolean uploadFile(ChannelSftp sftp, String pathname, String fileName, InputStream inputStream) {if (StringUtils.isEmpty(pathname) || !pathname.endsWith("/")) {throw new IllegalArgumentException("path is not illegal:" + pathname);}try {sftp.cd(pathname);sftp.put(inputStream, fileName);  //上传文件log.info("上传文件成功：{}", pathname + fileName);} catch (Exception e) {log.info("上传文件失败:{}" + e.getMessage(), pathname + fileName, e);return false;}return true;}/*** 递归根据路径创建文件夹*/public static boolean createDirectory(ChannelSftp sftp, String remote) throws IOException {if (StringUtils.isEmpty(remote) || !remote.endsWith("/")) {throw new IllegalArgumentException("path is not illegal:" + remote);}try {if (!existFolder(sftp, remote)) {sftp.mkdir(remote);}log.info("创建目录成功：{}", remote);return true;} catch (Exception e) {log.error(e.getMessage(), e);}return false;}//判断ftp服务器文件是否存在public static boolean existFile(ChannelSftp sftp, String path) {if (StringUtils.isEmpty(path) || path.endsWith("/")) {throw new IllegalArgumentException("path is not illegal:" + path);}boolean isExist = false;try {SftpATTRS sftpATTRS = sftp.lstat(path);isExist = true;return !sftpATTRS.isDir();} catch (Exception e) {if (e.getMessage().toLowerCase().equals("no such file")) {isExist = false;}}return isExist;}public static boolean existFolder(ChannelSftp sftp, String path) {if (StringUtils.isEmpty(path) || !path.endsWith("/")) {throw new IllegalArgumentException("path is not illegal:" + path);}boolean isExist = false;try {SftpATTRS sftpATTRS = sftp.lstat(path);isExist = true;return sftpATTRS.isDir();} catch (Exception e) {if (e.getMessage().toLowerCase().equals("no such file")) {isExist = false;}}return isExist;}public static void close(ChannelSftp sftp) {if (sftp == null) {return;}try {sftp.disconnect();sftp.getSession().disconnect();log.info("ftp连接已关闭");} catch (JSchException e) {log.error(e.getMessage(), e);log.info("ftp连接关闭失败");}}public static class SFTPServer {private String ip;private Integer port;private String account;private String pwd;private String encoding;public SFTPServer() {}public SFTPServer(String ip, Integer port, String account, String pwd, String encoding) {this.ip = ip;this.port = port;this.account = account;this.pwd = pwd;this.encoding = encoding;}public String getIp() {return ip;}public void setIp(String ip) {this.ip = ip;}public Integer getPort() {return port;}public void setPort(Integer port) {this.port = port;}public String getAccount() {return account;}public void setAccount(String account) {this.account = account;}public String getPwd() {return pwd;}public void setPwd(String pwd) {this.pwd = pwd;}public String getEncoding() {return encoding;}public void setEncoding(String encoding) {this.encoding = encoding;}}
}

这篇关于FTP和SFTP的工具类的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1060189。

相关文章

Python基于wxPython和FFmpeg开发一个视频标签工具

Python基于wxPython和FFmpeg开发一个视频标签工具

《Python基于wxPython和FFmpeg开发一个视频标签工具》在当今数字媒体时代,视频内容的管理和标记变得越来越重要,无论是研究人员需要对实验视频进行时间点标记,还是个人用户希望对家庭视频进行... 目录引言1. 应用概述2. 技术栈分析2.1 核心库和模块2.2 wxpython作为GUI选择的优
阅读更多...
使用Java实现通用树形结构构建工具类

使用Java实现通用树形结构构建工具类

《使用Java实现通用树形结构构建工具类》这篇文章主要为大家详细介绍了如何使用Java实现通用树形结构构建工具类,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录完整代码一、设计思想与核心功能二、核心实现原理1. 数据结构准备阶段2. 循环依赖检测算法3. 树形结构构建4. 搜索子
阅读更多...
利用Python开发Markdown表格结构转换为Excel工具

利用Python开发Markdown表格结构转换为Excel工具

《利用Python开发Markdown表格结构转换为Excel工具》在数据管理和文档编写过程中,我们经常使用Markdown来记录表格数据,但它没有Excel使用方便,所以本文将使用Python编写一... 目录1.完整代码2. 项目概述3. 代码解析3.1 依赖库3.2 GUI 设计3.3 解析 Mark
阅读更多...
利用Go语言开发文件操作工具轻松处理所有文件

利用Go语言开发文件操作工具轻松处理所有文件

《利用Go语言开发文件操作工具轻松处理所有文件》在后端开发中,文件操作是一个非常常见但又容易出错的场景,本文小编要向大家介绍一个强大的Go语言文件操作工具库,它能帮你轻松处理各种文件操作场景... 目录为什么需要这个工具？核心功能详解1. 文件/目录存javascript在性检查2. 批量创建目录3. 文件
阅读更多...
jvm调优常用命令行工具详解

jvm调优常用命令行工具详解

《jvm调优常用命令行工具详解》：本文主要介绍jvm调优常用命令行工具的用法,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一 jinfo命令查看参数1.1 查看jvm参数二 jstack命令2.1 查看现场堆栈信息三 jstat 实时查看堆内存，gc情况3.1
阅读更多...
Windows Server服务器上配置FileZilla后，FTP连接不上？

Windows Server服务器上配置FileZilla后，FTP连接不上？

《WindowsServer服务器上配置FileZilla后，FTP连接不上？》WindowsServer服务器上配置FileZilla后,FTP连接错误和操作超时的问题,应该如何解决?首先,通过... 目录在Windohttp://www.chinasem.cnws防火墙开启的情况下，遇到的错误如下：无法与
阅读更多...
MySQL使用binlog2sql工具实现在线恢复数据功能

MySQL使用binlog2sql工具实现在线恢复数据功能

《MySQL使用binlog2sql工具实现在线恢复数据功能》binlog2sql是大众点评开源的一款用于解析MySQLbinlog的工具,根据不同选项,可以得到原始SQL、回滚SQL等,下面我们就来... 目录背景目标步骤准备工作恢复数据结果验证结论背景生产数据库执行 SQL 脚本，一般会经过正规的审批
阅读更多...
基于Python开发批量提取Excel图片的小工具

基于Python开发批量提取Excel图片的小工具

《基于Python开发批量提取Excel图片的小工具》这篇文章主要为大家详细介绍了如何使用Python中的openpyxl库开发一个小工具,可以实现批量提取Excel图片,有需要的小伙伴可以参考一下... 目前有一个需求，就是批量读取当前目录下所有文件夹里的Excel文件，去获取出Excel文件中的图片，并
阅读更多...
Java导入、导出excel用法步骤保姆级教程(附封装好的工具类)

Java导入、导出excel用法步骤保姆级教程(附封装好的工具类)

《Java导入、导出excel用法步骤保姆级教程(附封装好的工具类)》：本文主要介绍Java导入、导出excel的相关资料,讲解了使用Java和ApachePOI库将数据导出为Excel文件,包括... 目录前言一、引入Apache POI依赖二、用法&步骤2.1 创建Excel的元素2.3 样式和字体2.
阅读更多...
基于Python开发PDF转PNG的可视化工具

基于Python开发PDF转PNG的可视化工具

《基于Python开发PDF转PNG的可视化工具》在数字文档处理领域,PDF到图像格式的转换是常见需求,本文介绍如何利用Python的PyMuPDF库和Tkinter框架开发一个带图形界面的PDF转P... 目录一、引言二、功能特性三、技术架构1. 技术栈组成2. 系统架构javascript设计3.效果图
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2