lsm/hutool
1
0
Fork 0
mirror of https://gitee.com/dromara/hutool.git synced 2025-06-28 13:34:09 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

FTP接口增加rename方法，改文件/目录名

Browse Source
This commit is contained in:
厉军 2025-04-24 16:43:39 +08:00
parent 92d3eaeead
commit 1e9c92c015
7 changed files with 193 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hutool-extra/src/main/java/cn/hutool/extra/ftp/AbstractFtp.java
View File

@ -250,6 +250,14 @@ public abstract class AbstractFtp implements Closeable {
*/
public abstract void recursiveDownloadFolder(String sourcePath, File destDir);
/**
* 重命名文件/目录
*
* @param from 原路径
* @param to 目标路径
*/
public abstract void rename(String from, String to);
// ---------------------------------------------------------------------------------------------------------------------------------------- Private method start
/**

20
hutool-extra/src/main/java/cn/hutool/extra/ftp/Ftp.java
View File

@ -726,6 +726,25 @@ public class Ftp extends AbstractFtp {
}
}
/**
* 重命名文件/目录
*
* @param from 原路径
* @param to 目标路径
*
* @throws FtpException FTP异常
*/
@Override
public void rename(String from, String to) throws FtpException {
try {
if (!client.rename(from, to)) {
throw new FtpException("rename [{}] to [{}] fail", from, to);
}
} catch (IOException e) {
throw new FtpException(e);
}
}
/**
* 获取FTPClient客户端对象
*
@ -745,4 +764,5 @@ public class Ftp extends AbstractFtp {
this.client = null;
}
}
}

17
hutool-extra/src/main/java/cn/hutool/extra/ssh/Sftp.java
View File

@ -647,6 +647,23 @@ public class Sftp extends AbstractFtp {
}
/**
* 重命名文件/目录
*
* @param from 原路径
* @param to 目标路径
*
* @throws JschRuntimeException Jsch异常
*/
@Override
public void rename(String from, String to) throws JschRuntimeException {
try {
getClient().rename(from, to);
} catch (SftpException e) {
throw new JschRuntimeException(e);
}
}
/**
* 获取远程文件
*

19
hutool-extra/src/main/java/cn/hutool/extra/ssh/SshjSftp.java
View File

@ -88,7 +88,7 @@ public class SshjSftp extends AbstractFtp {
* @param config FTP配置
* @since 5.3.3
*/
protected SshjSftp(FtpConfig config) {
public SshjSftp(FtpConfig config) {
super(config);
init();
}
@ -210,6 +210,23 @@ public class SshjSftp extends AbstractFtp {
}
}
/**
* 重命名文件/目录
*
* @param from 原路径
* @param to 目标路径
*
* @throws FtpException FTP异常
*/
@Override
public void rename(String from, String to) throws FtpException {
try {
sftp.rename(from, to);
} catch (IOException e) {
throw new FtpException(e);
}
}
@Override
public void close() {
IoUtil.close(this.session);

12
hutool-extra/src/test/java/cn/hutool/extra/ftp/FtpTest.java
View File

@ -13,6 +13,8 @@ import java.io.File;
import java.io.IOException;
import java.util.List;
import static org.junit.jupiter.api.Assertions.assertTrue;
public class FtpTest {
@Test
@ -171,4 +173,14 @@ public class FtpTest {
Console.log(ftp.pwd());
}
}
@Test
public void renameTest() {
final Ftp ftp = new Ftp("localhost", 21, "test", "test");
ftp.mkdir("/ftp-1");
assertTrue(ftp.exist("/ftp-1"));
ftp.rename("/ftp-1", "/ftp-2");
assertTrue(ftp.exist("/ftp-2"));
}
}

45
hutool-extra/src/test/java/cn/hutool/extra/ssh/SftpTest.java
View File

@ -1,33 +1,34 @@
package cn.hutool.extra.ssh;
import cn.hutool.core.util.CharsetUtil;
import org.junit.Before;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import java.io.File;
import java.util.List;
import static org.junit.jupiter.api.Assertions.*;
/**
* 基于sshj 框架SFTP 封装测试.
*
* @author youyongkun
* @since 5.7.18
*/
public class SftpTest {
class SftpTest {
private SshjSftp sshjSftp;
private static Sftp sftp;
@Before
@Disabled
public void init() {
sshjSftp = new SshjSftp("ip", 22, "test", "test", CharsetUtil.CHARSET_UTF_8);
@BeforeAll
public static void init() {
sftp = new Sftp("localhost", 22, "test", "test", CharsetUtil.CHARSET_UTF_8);
}
@Test
@Disabled
public void lsTest() {
List<String> files = sshjSftp.ls("/");
List<String> files = sftp.ls("/");
if (files != null && !files.isEmpty()) {
files.forEach(System.out::print);
}
@ -36,19 +37,19 @@ public class SftpTest {
@Test
@Disabled
public void downloadTest() {
sshjSftp.recursiveDownloadFolder("/home/test/temp", new File("C:\\Users\\akwangl\\Downloads\\temp"));
sftp.recursiveDownloadFolder("/home/test/temp", new File("C:\\Users\\akwangl\\Downloads\\temp"));
}
@Test
@Disabled
public void uploadTest() {
sshjSftp.upload("/home/test/temp/", new File("C:\\Users\\akwangl\\Downloads\\temp\\辽宁_20190718_104324.CIME"));
sftp.upload("/home/test/temp/", new File("C:\\Users\\akwangl\\Downloads\\temp\\辽宁_20190718_104324.CIME"));
}
@Test
@Disabled
public void mkDirTest() {
boolean flag = sshjSftp.mkdir("/home/test/temp");
boolean flag = sftp.mkdir("/home/test/temp");
System.out.println("是否创建成功: " + flag);
}
@ -56,12 +57,30 @@ public class SftpTest {
@Disabled
public void mkDirsTest() {
// 在当前目录下批量创建目录
sshjSftp.mkDirs("/home/test/temp");
sftp.mkDirs("/home/test/temp");
}
@Test
@Disabled
public void delDirTest() {
sshjSftp.delDir("/home/test/temp");
sftp.delDir("/home/test/temp");
}
@Test
public void pwdTest() {
// mkDirsTest();
sftp.mkdir("/ftp");
sftp.cd("/ftp");
String pwd = sftp.pwd();
System.out.println("当前目录: " + pwd);
assertEquals("/ftp", pwd);
}
@Test
public void renameTest() {
sftp.mkdir("/ftp-1");
assertTrue(sftp.exist("/ftp-1"));
sftp.rename("/ftp-1", "/ftp-2");
assertTrue(sftp.exist("/ftp-2"));
}
}

86
hutool-extra/src/test/java/cn/hutool/extra/ssh/SshjSftpTest.java Normal file
View File

@ -0,0 +1,86 @@
package cn.hutool.extra.ssh;
import cn.hutool.core.util.CharsetUtil;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import java.io.File;
import java.util.List;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertTrue;
/**
* 基于sshj 框架SFTP 封装测试.
*
* @author youyongkun
* @since 5.7.18
*/
class SshjSftpTest {
private static SshjSftp sshjSftp;
@BeforeAll
public static void init() {
sshjSftp = new SshjSftp("localhost", 22, "test", "test", CharsetUtil.CHARSET_UTF_8);
}
@Test
@Disabled
public void lsTest() {
List<String> files = sshjSftp.ls("/");
if (files != null && !files.isEmpty()) {
files.forEach(System.out::print);
}
}
@Test
@Disabled
public void downloadTest() {
sshjSftp.recursiveDownloadFolder("/home/test/temp", new File("C:\\Users\\akwangl\\Downloads\\temp"));
}
@Test
@Disabled
public void uploadTest() {
sshjSftp.upload("/home/test/temp/", new File("C:\\Users\\akwangl\\Downloads\\temp\\辽宁_20190718_104324.CIME"));
}
@Test
@Disabled
public void mkDirTest() {
boolean flag = sshjSftp.mkdir("/home/test/temp");
System.out.println("是否创建成功: " + flag);
}
@Test
@Disabled
public void mkDirsTest() {
// 在当前目录下批量创建目录
sshjSftp.mkDirs("/home/test/temp");
}
@Test
@Disabled
public void delDirTest() {
sshjSftp.delDir("/home/test/temp");
}
@Test
public void pwdTest() {
// mkDirsTest();
sshjSftp.cd("/ftp");
String pwd = sshjSftp.pwd();
System.out.println("当前目录: " + pwd);
assertEquals("/ftp", pwd);
}
@Test
public void renameTest() {
sshjSftp.mkdir("/ftp-1");
assertTrue(sshjSftp.exist("/ftp-1"));
sshjSftp.rename("/ftp-1", "/ftp-2");
assertTrue(sshjSftp.exist("/ftp-2"));
}
}