diff --git a/hutool-extra/src/main/java/cn/hutool/extra/ftp/AbstractFtp.java b/hutool-extra/src/main/java/cn/hutool/extra/ftp/AbstractFtp.java index ffc5bd1b8..48b37d2b2 100644 --- a/hutool-extra/src/main/java/cn/hutool/extra/ftp/AbstractFtp.java +++ b/hutool-extra/src/main/java/cn/hutool/extra/ftp/AbstractFtp.java @@ -163,13 +163,13 @@ public abstract class AbstractFtp implements Closeable { if (StrUtil.isNotEmpty(s)) { boolean exist = true; try { - if (false == cd(s)) { + if (!cd(s)) { exist = false; } } catch (FtpException e) { exist = false; } - if (false == exist) { + if (!exist) { //目录不存在时创建 mkdir(s); cd(s); diff --git a/hutool-extra/src/main/java/cn/hutool/extra/ftp/Ftp.java b/hutool-extra/src/main/java/cn/hutool/extra/ftp/Ftp.java index 0045b451a..98568b493 100755 --- a/hutool-extra/src/main/java/cn/hutool/extra/ftp/Ftp.java +++ b/hutool-extra/src/main/java/cn/hutool/extra/ftp/Ftp.java @@ -21,6 +21,7 @@ import java.nio.charset.Charset; import java.nio.charset.StandardCharsets; import java.util.ArrayList; import java.util.List; +import java.util.Objects; /** * FTP客户端封装
@@ -219,7 +220,7 @@ public class Ftp extends AbstractFtp { throw new IORuntimeException(e); } final int replyCode = client.getReplyCode(); // 是否成功登录服务器 - if (false == FTPReply.isPositiveCompletion(replyCode)) { + if (!FTPReply.isPositiveCompletion(replyCode)) { try { client.disconnect(); } catch (IOException e) { @@ -354,7 +355,7 @@ public class Ftp extends AbstractFtp { String fileName; for (FTPFile ftpFile : ftpFiles) { fileName = ftpFile.getName(); - if (false == StrUtil.equals(".", fileName) && false == StrUtil.equals("..", fileName)) { + if (!StrUtil.equals(".", fileName) && !StrUtil.equals("..", fileName)) { if (null == filter || filter.accept(ftpFile)) { result.add(ftpFile); } @@ -375,7 +376,7 @@ public class Ftp extends AbstractFtp { String pwd = null; if (StrUtil.isNotBlank(path)) { pwd = pwd(); - if (false == cd(path)) { + if (!cd(path)) { throw new FtpException("Change dir to [{}] error, maybe path not exist!", path); } } @@ -439,7 +440,7 @@ public class Ftp extends AbstractFtp { final String pwd = pwd(); final String fileName = FileUtil.getName(path); final String dir = StrUtil.removeSuffix(path, fileName); - if (false == cd(dir)) { + if (!cd(dir)) { throw new FtpException("Change dir to [{}] error, maybe dir not exist!", path); } @@ -470,7 +471,7 @@ public class Ftp extends AbstractFtp { childPath = StrUtil.format("{}/{}", dirPath, name); if (ftpFile.isDirectory()) { // 上级和本级目录除外 - if (false == ".".equals(name) && false == "..".equals(name)) { + if (!".".equals(name) && !"..".equals(name)) { delDir(childPath); } } else { @@ -557,7 +558,7 @@ public class Ftp extends AbstractFtp { if (StrUtil.isNotBlank(destPath)) { mkDirs(destPath); - if (false == cd(destPath)) { + if (!cd(destPath)) { throw new FtpException("Change dir to [{}] error, maybe dir not exist!", destPath); } } @@ -573,6 +574,54 @@ public class Ftp extends AbstractFtp { } } + /** + * 上传文件或目录(包含当前及子孙目录的所有文件) + * + * @param destPath 目标路径 + * @param uploadFile 上传文件或目录 + */ + public void uploadFileOrDirectory(String destPath, final File uploadFile) { + if (uploadFile.isFile()) { + this.upload(destPath, uploadFile); + return; + } + + this.mkDirs(destPath); + recursiveUpload(destPath, uploadFile); + } + + /** + * 递归上传文件(支持目录) + * + * @param destPath 目录路径 + * @param uploadFile 上传文件或目录 + */ + public void recursiveUpload(String destPath, final File uploadFile) { + if (uploadFile.isFile()) { + this.upload(destPath, uploadFile); + return; + } + File[] files = uploadFile.listFiles(); + if (Objects.isNull(files)) { + return; + } + + //第一次只处理文件,防止目录在前面导致先处理子孙目录,而引发文件所在目录不正确 + for (File f : files) { + if (f.isFile()) { + this.upload(destPath, f); + } + } + //第二次只处理目录 + for (File f : files) { + if (f.isDirectory()) { + destPath = destPath + File.separator + f.getName(); + this.mkDirs(destPath); + recursiveUpload(destPath, f); + } + } + } + /** * 下载文件 * @@ -602,9 +651,9 @@ public class Ftp extends AbstractFtp { srcFile = StrUtil.format("{}/{}", sourcePath, fileName); destFile = FileUtil.file(destDir, fileName); - if (false == ftpFile.isDirectory()) { + if (!ftpFile.isDirectory()) { // 本地不存在文件或者ftp上文件有修改则下载 - if (false == FileUtil.exist(destFile) + if (!FileUtil.exist(destFile) || (ftpFile.getTimestamp().getTimeInMillis() > destFile.lastModified())) { download(srcFile, destFile); } @@ -628,7 +677,7 @@ public class Ftp extends AbstractFtp { if (outFile.isDirectory()) { outFile = new File(outFile, fileName); } - if (false == outFile.exists()) { + if (!outFile.exists()) { FileUtil.touch(outFile); } try (OutputStream out = FileUtil.getOutputStream(outFile)) { @@ -665,7 +714,7 @@ public class Ftp extends AbstractFtp { pwd = pwd(); } - if (false == cd(path)) { + if (!cd(path)) { throw new FtpException("Change dir to [{}] error, maybe dir not exist!", path); } diff --git a/hutool-extra/src/test/java/cn/hutool/extra/ftp/FtpTest.java b/hutool-extra/src/test/java/cn/hutool/extra/ftp/FtpTest.java index 6dc04d292..70f20b801 100644 --- a/hutool-extra/src/test/java/cn/hutool/extra/ftp/FtpTest.java +++ b/hutool-extra/src/test/java/cn/hutool/extra/ftp/FtpTest.java @@ -33,6 +33,15 @@ public class FtpTest { IoUtil.close(ftp); } + @Test + @Ignore + public void uploadDirectorTest() { + final Ftp ftp = new Ftp("localhost"); + + ftp.uploadFileOrDirectory("/temp", FileUtil.file("d:/test/")); + IoUtil.close(ftp); + } + @Test @Ignore public void reconnectIfTimeoutTest() throws InterruptedException {