正在 java 从 sftp 服务器下载所有文件
downloading all files from sftp server in java
我正在尝试从 SFTP 服务器上的文件夹下载所有文件,下面是我的代码请提出更改建议,以便我可以从远程目录下载所有可用文件并保存到本地目录
package svb.ftp.bs.load;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.SftpException;
import java.io.FileNotFoundException;
import java.io.File;
import java.io.FileInputStream;
import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;
import java.io.InputStream;
import java.io.IOException;
import java.io.PrintWriter;
import java.io.StringWriter;
import java.util.List;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.io.IOUtils;
import org.junit.Test;
import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelExec;
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.Session;
import com.jcraft.jsch.SftpException;
import java.io.IOException;
import java.io.InputStream;
import java.util.Vector;
public class downloadFtp {
public static void main(String[] args) {
String SFTPHOST = "host";
int SFTPPORT = 22;
String SFTPUSER = "user";
String SFTPPASS = "Pass";
String privateKey = "E:\Oracle\mywork\DownloadFTP\ppk.ppk";
String SFTPWORKINGDIR = "Inbox/ARR_SI_MedicalTranscriptionBillCorp_PD_20200724_32137.TXT";
com.jcraft.jsch.Session session = null;
Channel channel = null;
ChannelSftp channelSftp = null;
JSch jsch = new JSch();
try {
jsch.addIdentity(privateKey);
session = jsch.getSession(SFTPUSER, SFTPHOST, SFTPPORT);
session.setPassword(SFTPPASS);
java.util.Properties config = new java.util.Properties();
config.put("StrictHostKeyChecking", "no");
session.setConfig(config);
session.connect();
channel = session.openChannel("sftp");
channel.connect();
System.out.println("Connected");
channelSftp = (ChannelSftp) channel;
channelSftp.cd(SFTPWORKINGDIR);
InputStream is = channelSftp.get(SFTPWORKINGDIR);
IOUtils.copy(is, System.out);
is.close();
System.out.println("File Uploaded to FTP Server Sucessfully.");
} catch (JSchException jse) {
// TODO: Add catch code
jse.printStackTrace();
} catch (SftpException se) {
// TODO: Add catch code
se.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
}
}
目前当我运行代码显示错误
4: Can't change directory: /Inbox/ARR_SI_MedicalTranscriptionBillCorp_PD_20200724_32137.TXT
at com.jcraft.jsch.ChannelSftp.cd(ChannelSftp.java:350)
at svb.ftp.bs.load.downloadFtp.main(downloadFtp.java:67)
Process exited with exit code 0.
堆栈跟踪告诉您出了什么问题。
Can't change directory: /Inbox/ARR_SI_MedicalTranscriptionBillCorp_PD_20200724_32137.TXT
问题在于:
channelSftp.cd(SFTPWORKINGDIR);
此处您传递的是文件名,但它需要一个目录(cd
代表更改目录)。无法对文件进行 CD。
如果你传递一个 folder/path 就可以了。尝试以下操作:
channelSftp.cd("/Inbox/a_folder/");
如何全部下载:
参考:https://ganeshtiwaridotcomdotnp.blogspot.com/2020/07/download-files-from-ftp-using-jsch-java.html
为了下载所有文件,首先列出根文件夹中的所有文件,遍历它..如果它是一个文件下载,如果它是一个文件夹列出内容并继续对子文件夹进行递归。
以下是如何从定义的文件夹下载文件的示例:
import com.jcraft.jsch.*;
import java.util.Properties;
import java.util.Vector;
public class JschDownload {
public static void main(String[] args) {
Session session = null;
Channel channel = null;
JSch jsch = new JSch();
try {
session = jsch.getSession("demo", "test.rebex.net", 22);
session.setPassword("password");
Properties config = new Properties();
config.put("StrictHostKeyChecking", "no");
session.setConfig(config);
session.connect();
System.out.println("session connect");
channel = session.openChannel("sftp");
channel.connect();
System.out.println("Connected");
ChannelSftp channelSftp = (ChannelSftp) channel;
downloadFromFolder(channelSftp, "/");
downloadFromFolder(channelSftp, "/pub/example/");
System.out.println("File Uploaded to FTP Server Sucessfully.");
} catch (Exception e) {
e.printStackTrace();
} finally {
if (channel != null) {
channel.disconnect();
}
session.disconnect();
}
}
static void downloadFromFolder(ChannelSftp channelSftp, String folder) throws SftpException {
Vector<ChannelSftp.LsEntry> entries = channelSftp.ls(folder);
System.out.println(entries);
//download all from root folder
for (ChannelSftp.LsEntry en : entries) {
if (en.getFilename().equals(".") || en.getFilename().equals("..") || en.getAttrs().isDir()) {
continue;
}
System.out.println(en.getFilename());
channelSftp.get(folder + en.getFilename(), en.getFilename());
}
}
}
有关 jsch 库的示例和文档,请参阅 http://www.jcraft.com/jsch/examples/。
我正在尝试从 SFTP 服务器上的文件夹下载所有文件,下面是我的代码请提出更改建议,以便我可以从远程目录下载所有可用文件并保存到本地目录
package svb.ftp.bs.load;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.SftpException;
import java.io.FileNotFoundException;
import java.io.File;
import java.io.FileInputStream;
import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;
import java.io.InputStream;
import java.io.IOException;
import java.io.PrintWriter;
import java.io.StringWriter;
import java.util.List;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.io.IOUtils;
import org.junit.Test;
import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelExec;
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.Session;
import com.jcraft.jsch.SftpException;
import java.io.IOException;
import java.io.InputStream;
import java.util.Vector;
public class downloadFtp {
public static void main(String[] args) {
String SFTPHOST = "host";
int SFTPPORT = 22;
String SFTPUSER = "user";
String SFTPPASS = "Pass";
String privateKey = "E:\Oracle\mywork\DownloadFTP\ppk.ppk";
String SFTPWORKINGDIR = "Inbox/ARR_SI_MedicalTranscriptionBillCorp_PD_20200724_32137.TXT";
com.jcraft.jsch.Session session = null;
Channel channel = null;
ChannelSftp channelSftp = null;
JSch jsch = new JSch();
try {
jsch.addIdentity(privateKey);
session = jsch.getSession(SFTPUSER, SFTPHOST, SFTPPORT);
session.setPassword(SFTPPASS);
java.util.Properties config = new java.util.Properties();
config.put("StrictHostKeyChecking", "no");
session.setConfig(config);
session.connect();
channel = session.openChannel("sftp");
channel.connect();
System.out.println("Connected");
channelSftp = (ChannelSftp) channel;
channelSftp.cd(SFTPWORKINGDIR);
InputStream is = channelSftp.get(SFTPWORKINGDIR);
IOUtils.copy(is, System.out);
is.close();
System.out.println("File Uploaded to FTP Server Sucessfully.");
} catch (JSchException jse) {
// TODO: Add catch code
jse.printStackTrace();
} catch (SftpException se) {
// TODO: Add catch code
se.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
}
}
目前当我运行代码显示错误
4: Can't change directory: /Inbox/ARR_SI_MedicalTranscriptionBillCorp_PD_20200724_32137.TXT
at com.jcraft.jsch.ChannelSftp.cd(ChannelSftp.java:350)
at svb.ftp.bs.load.downloadFtp.main(downloadFtp.java:67)
Process exited with exit code 0.
堆栈跟踪告诉您出了什么问题。
Can't change directory: /Inbox/ARR_SI_MedicalTranscriptionBillCorp_PD_20200724_32137.TXT
问题在于:
channelSftp.cd(SFTPWORKINGDIR);
此处您传递的是文件名,但它需要一个目录(cd
代表更改目录)。无法对文件进行 CD。
如果你传递一个 folder/path 就可以了。尝试以下操作:
channelSftp.cd("/Inbox/a_folder/");
如何全部下载: 参考:https://ganeshtiwaridotcomdotnp.blogspot.com/2020/07/download-files-from-ftp-using-jsch-java.html
为了下载所有文件,首先列出根文件夹中的所有文件,遍历它..如果它是一个文件下载,如果它是一个文件夹列出内容并继续对子文件夹进行递归。
以下是如何从定义的文件夹下载文件的示例:
import com.jcraft.jsch.*;
import java.util.Properties;
import java.util.Vector;
public class JschDownload {
public static void main(String[] args) {
Session session = null;
Channel channel = null;
JSch jsch = new JSch();
try {
session = jsch.getSession("demo", "test.rebex.net", 22);
session.setPassword("password");
Properties config = new Properties();
config.put("StrictHostKeyChecking", "no");
session.setConfig(config);
session.connect();
System.out.println("session connect");
channel = session.openChannel("sftp");
channel.connect();
System.out.println("Connected");
ChannelSftp channelSftp = (ChannelSftp) channel;
downloadFromFolder(channelSftp, "/");
downloadFromFolder(channelSftp, "/pub/example/");
System.out.println("File Uploaded to FTP Server Sucessfully.");
} catch (Exception e) {
e.printStackTrace();
} finally {
if (channel != null) {
channel.disconnect();
}
session.disconnect();
}
}
static void downloadFromFolder(ChannelSftp channelSftp, String folder) throws SftpException {
Vector<ChannelSftp.LsEntry> entries = channelSftp.ls(folder);
System.out.println(entries);
//download all from root folder
for (ChannelSftp.LsEntry en : entries) {
if (en.getFilename().equals(".") || en.getFilename().equals("..") || en.getAttrs().isDir()) {
continue;
}
System.out.println(en.getFilename());
channelSftp.get(folder + en.getFilename(), en.getFilename());
}
}
}
有关 jsch 库的示例和文档,请参阅 http://www.jcraft.com/jsch/examples/。