正在 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/