package test;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.Iterator;
import java.util.Properties;
import java.util.Vector;
import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.Session;
import com.jcraft.jsch.SftpATTRS;
import com.jcraft.jsch.SftpException;
import com.jcraft.jsch.ChannelSftp.LsEntry;
public class SFTPTest {
private String host;
private String username;
private String password;
private int port = 22;
private ChannelSftp sftp = null;
private Session sshSession = null;
public SFTPTest() {
}
public SFTPTest(String host, String username, String password, int port) {
this.host = host;
this.username = username;
this.password = password;
this.port = port;
}
public SFTPTest(String host, String username, String password) {
this.host = host;
this.username = username;
this.password = password;
}
/**
* connect server via sftp
*/
public void connect() {
try {
JSch jsch = new JSch();
jsch.getSession(username, host, port);
sshSession = jsch.getSession(username, host, port);
System.out.println("Session created.");
sshSession.setPassword(password);
Properties sshConfig = new Properties();
sshConfig.put("StrictHostKeyChecking", "no");
sshSession.setConfig(sshConfig);
sshSession.connect();
System.out.println("Session connected.");
System.out.println("Opening Channel.");
Channel channel = sshSession.openChannel("sftp");
channel.connect();
sftp = (ChannelSftp) channel;
System.out.println("Connected to " + host + ".");
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 关闭资源
*/
public void disconnect() {
if (this.sftp != null) {
if (this.sftp.isConnected()) {
this.sftp.disconnect();
System.out.println("sftp is closed already");
}
}
if (this.sshSession != null) {
if (this.sshSession.isConnected()) {
this.sshSession.disconnect();
System.out.println("sshSession is closed already");
}
}
}
/**
* 批量下载文件
*
* @param remotPath
* 远程下载目录(以路径符号结束)
* @param localPath
* 本地保存目录(以路径符号结束)
* @param fileFormat
* 下载文件格式(以特定字符开头,为空不做检验)
* @param del
* 下载后是否删除sftp文件
* @return
*/
public boolean batchDownLoadFile(String remotPath, String localPath,
String fileFormat, boolean del) {
try {
connect();
Vector v = listFiles(remotPath);
if (v.size() > 0) {
Iterator it = v.iterator();
while (it.hasNext()) {
LsEntry entry = (LsEntry) it.next();
String filename = entry.getFilename();
SftpATTRS attrs = entry.getAttrs();
if (!attrs.isDir()) {
if (fileFormat != null && !"".equals(fileFormat.trim())) {
if (filename.startsWith(fileFormat)) {
if (this.downloadFile(remotPath, filename,
localPath, filename)
&& del) {
deleteSFTP(remotPath, filename);
}
}
} else {
if (this.downloadFile(remotPath, filename,
localPath, filename)
&& del) {
deleteSFTP(remotPath, filename);
}
}
}
}
}
} catch (SftpException e) {
e.printStackTrace();
} finally {
this.disconnect();
}
return false;
}
/**
* 下载单个文件
*
* @param remotPath
* 远程下载目录(以路径符号结束)
* @param remoteFileName
* 下载文件名
* @param localPath
* 本地保存目录(以路径符号结束)
* @param localFileName
* 保存文件名
* @return
*/
public boolean downloadFile(String remotePath, String remoteFileName,
String localPath, String localFileName) {
try {
sftp.cd(remotePath);
File file = new File(localPath + localFileName);
mkdirs(localPath + localFileName);
sftp.get(remoteFileName, new FileOutputStream(file));
return true;
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (SftpException e) {
e.printStackTrace();
}
return false;
}
/**
* 上传单个文件
*
* @param remotePath
* 远程保存目录
* @param remoteFileName
* 保存文件名
* @param localPath
* 本地上传目录(以路径符号结束)
* @param localFileName
* 上传的文件名
* @return
*/
public boolean uploadFile(String remotePath, String remoteFileName,
String localPath, String localFileName) {
FileInputStream in = null;
try {
createDir(remotePath);
File file = new File(localPath + localFileName);
in = new FileInputStream(file);
sftp.put(in, remoteFileName);
return true;
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (SftpException e) {
e.printStackTrace();
} finally {
if (in != null) {
try {
in.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
return false;
}
/**
* 批量上传文件
*
* @param remotePath
* 远程保存目录
* @param localPath
* 本地上传目录(以路径符号结束)
* @param del
* 上传后是否删除本地文件
* @return
*/
public boolean bacthUploadFile(String remotePath, String localPath,
boolean del) {
try {
connect();
File file = new File(localPath);
File[] files = file.listFiles();
for (int i = 0; i < files.length; i++) {
if (files[i].isFile()
&& files[i].getName().indexOf("bak") == -1) {
if (this.uploadFile(remotePath, files[i].getName(),
localPath, files[i].getName())
&& del) {
deleteFile(localPath + files[i].getName());
}
}
}
return true;
} catch (Exception e) {
e.printStackTrace();
} finally {
this.disconnect();
}
return false;
}
/**
* 删除本地文件
*
* @param filePath
* @return
*/
public boolean deleteFile(String filePath) {
File file = new File(filePath);
if (!file.exists()) {
return false;
}
if (!file.isFile()) {
return false;
}
return file.delete();
}
/**
* 创建目录
*
* @param createpath
* @return
*/
public boolean createDir(String createpath) {
try {
if (isDirExist(createpath)) {
this.sftp.cd(createpath);
return true;
}
String pathArry[] = createpath.split("/");
StringBuffer filePath = new StringBuffer("/");
for (String path : pathArry) {
if (path.equals("")) {
continue;
}
filePath.append(path + "/");
if (isDirExist(filePath.toString())) {
sftp.cd(filePath.toString());
} else {
// 建立目录
sftp.mkdir(filePath.toString());
// 进入并设置为当前目录
sftp.cd(filePath.toString());
}
}
this.sftp.cd(createpath);
return true;
} catch (SftpException e) {
e.printStackTrace();
}
return false;
}
/**
* 判断目录是否存在
*
* @param directory
* @return
*/
public boolean isDirExist(String directory) {
boolean isDirExistFlag = false;
try {
SftpATTRS sftpATTRS = sftp.lstat(directory);
isDirExistFlag = true;
return sftpATTRS.isDir();
} catch (Exception e) {
if (e.getMessage().toLowerCase().equals("no such file")) {
isDirExistFlag = false;
}
}
return isDirExistFlag;
}
/**
* 删除stfp文件
*
* @param directory
* 要删除文件所在目录
* @param deleteFile
* 要删除的文件
* @param sftp
*/
public void deleteSFTP(String directory, String deleteFile) {
try {
sftp.cd(directory);
sftp.rm(deleteFile);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 如果目录不存在就创建目录
*
* @param path
*/
public void mkdirs(String path) {
File f = new File(path);
String fs = f.getParent();
f = new File(fs);
if (!f.exists()) {
f.mkdirs();
}
}
/**
* 列出目录下的文件
*
* @param directory
* 要列出的目录
* @param sftp
* @return
* @throws SftpException
*/
public Vector listFiles(String directory) throws SftpException {
return sftp.ls(directory);
}
public String getHost() {
return host;
}
public void setHost(String host) {
this.host = host;
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public int getPort() {
return port;
}
public void setPort(int port) {
this.port = port;
}
public ChannelSftp getSftp() {
return sftp;
}
public void setSftp(ChannelSftp sftp) {
this.sftp = sftp;
}
public static void main(String[] args) {
SFTPTest ftp = new SFTPTest("127.0.0.1", "admin", "admin");
String localPath = "D:\\sftp\\";
String remotePath = "/home/itvsoap/file_interface/bill/lzj/test/";
ftp.connect();
ftp.uploadFile(remotePath, "test.txt", localPath, "test.txt");
//ftp.bacthUploadFile(remotePath,localPath,true);
// ftp.downloadFile(remotePath, "test.txt", localPath, "test.txt");
//ftp.batchDownLoadFile(remotePath, localPath, null, true);
ftp.disconnect();
System.exit(0);
}
}
相关推荐
在上面的示例代码中，我们创建了一个SFTPUtils类，其中包含了连接SFTP服务器、上传文件、下载文件等方法。这些方法使用JSch库来实现SFTP的功能。 在实际应用中，我们可以根据需要封装成一个util类，提供给其他应用...
本文将详细探讨如何使用Java实现SFTP的文件上传和下载功能，以及如何利用jcraft库来完成这一任务。 首先，jcraft是一个日本开发者团队创建的开源项目，提供了Java实现的SSH2库，其中包括对SFTP的支持。在本示例中，...
在本示例中，我们将深入探讨如何使用JSch库来实现通过SFTP上传整个文件夹的功能。 首先，我们需要在项目中添加JSch库。如果你使用Maven，可以在pom.xml文件中添加以下依赖： ```xml <groupId>...
为了更好地理解JSch的使用，你可以参考提供的压缩包文件中的文档，如"JSch - Java实现的SFTP（文件上传详解篇）"，这个文档可能包含了更多详细的示例和注意事项。在进行SFTP开发时，确保遵循最佳实践，确保数据安全...
以下是一个简单的Java SFTP上传文件的示例： 1. 引入JSch库： ```java import com.jcraft.jsch.ChannelSftp; import com.jcraft.jsch.JSch; import com.jcraft.jsch.Session; ``` 2. 创建并配置JSch对象，建立SSH...
本文将详细讲解如何使用Java实现SFTP的上传、下载以及相关的批量操作、远程目录创建和文件删除功能。 首先，我们需要一个支持SFTP的Java库，例如JSch（Java Secure Channel）。JSch是一个开放源码的Java库，它实现...
在Java编程中，SFTP（Secure File ...综上所述，Java操作SFTP上传和下载文件主要涉及到JSch库的使用，包括连接配置、通道创建、文件操作以及断开连接等步骤。在实际开发中，应结合具体需求，优化代码并确保安全性。
本文将深入探讨如何使用Java实现SFTP（Secure File Transfer Protocol）和FTP（File Transfer Protocol）进行文件的上传与下载，以满足在Linux服务器上的操作需求。 首先，FTP是一种用于在网络之间传输文件的标准...
JSch - Java实现的SFTP（文件上传详解篇）
例如，可能存在一个`uploadFile()`方法用于上传文件，另一个`downloadFile()`方法用于下载文件。这些方法通常会处理异常，提供日志记录，并可能支持重试机制，以提高文件传输的可靠性。 总的来说，`jsch.jar`和`...
- 递归上传整个目录：你可以编写一个递归函数，遍历本地目录并逐个上传文件。 - 断点续传：如果支持，可以利用SFTP的`fstat`和`position`命令来实现。 - 传输进度监控：通过监听`ChannelSftp`的`progress`事件，...
本文将详细探讨如何使用Java实现SFTP的文件上传和下载功能，并提供一个简单的示例代码。 首先，我们需要引入一个支持SFTP的Java库，如JSCH（Java Secure Channel）。JSCH是一个纯Java实现的SSH2库，可以用于执行SSH...
3. **上传文件**：使用`ChannelSftp`对象提供的方法，如`put()`，将本地文件上传到服务器： ```java File localFile = new File("/path/to/local/file"); String remotePath = "/path/on/server"; sftpChannel.put...
以上就是使用Java Swing实现SFTP文件夹上传的基本步骤，包括建立SSH连接、使用SFTP通道、上传文件和递归上传文件夹。对于生产环境，建议添加异常处理和错误提示，以及更安全的策略，如使用密钥对而非密码进行身份...
4. 上传文件：使用SFTPChannel的`put`方法将本地文件上传到服务器的指定路径。 5. 关闭连接：在完成上传后，记得关闭SFTP通道和Session。 以下是使用JSCH上传文件的示例代码： ```java JSch jsch = new JSch(); ...
使用这些工具进行Java SFTP上传的一般步骤如下： 1. **安装JCE**: 将`jce_policy-8.zip`解压并替换Java安装目录下的`jre\lib\security`文件夹中的默认策略文件。 2. **导入PuTTY生成的密钥对**: 使用PuTTYgen创建...
3. **文件上传**：在Java中实现SFTP上传文件的核心代码通常包括以下步骤： - 创建`JSch`实例。 - 使用`JSch`实例创建`Session`对象，设置主机名、端口、用户名和登录方式相关参数。 - 调用`Session`的`connect()`...
3. **上传文件**：使用SFTP通道，我们可以调用`put()`方法将本地文件上传到远程服务器： ```java FileInputStream fis = new FileInputStream("localFilePath"); sftpChannel.put(fis, "remoteFilePath"); fis....
总结来说，Java SFTP上传和下载涉及到的主要知识点包括JSch库的使用、SSH连接的建立、SFTP通道的开启和关闭，以及文件的上传和下载操作。通过提供的JAR文件和源码，开发者可以快速集成并实现自己的SFTP功能，确保...