如何从SFTP服务器获取文件列表?

5

我有一个问题,希望得到解决。我已经编写了一些代码,但是需要进行一些修改。

问题: 我需要连接到一个SFTP服务器(出于隐私原因,我将给出虚拟凭证)。

服务器名称:server-name
端口号:22
用户名:username
密码:password

当我连接到服务器时,它会自动将我放在/FGV目录下。在这个目录里面有一些其他的文件夹。我需要从/FGV/US/BS/目录中获取一组xml消息列表,并将它们放入一个列表中(以File形式的文件)。在列表中,我需要有文件的目录、文件名和文件正文。我想创建一个对象,把这些信息放在那里并创建一个该对象的列表。

我的当前代码创建了一个连接,并仅下载一个xml文件。如果有两个xml文件,则本地机器上的文件没有任何内容。

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.OutputStream;

import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.Session;

public class SFTPinJava {

    public SFTPinJava() {
    }

    public static void main(String[] args) {
        String SFTPHOST = "server-name";
        int SFTPPORT = 22;
        String SFTPUSER = "username";
        String SFTPPASS = "password";
        String SFTPWORKINGDIR = "/FGV";

        Session session = null;
        Channel channel = null;
        ChannelSftp channelSftp = null;

        try {
            JSch jsch = new JSch();
            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();
            channelSftp = (ChannelSftp) channel;
            channelSftp.cd(SFTPWORKINGDIR);
            byte[] buffer = new byte[1024];
            BufferedInputStream bis = new BufferedInputStream(
                channelSftp.get("/FGV/US/BS/FGVCustomsEntryLoaderService.xml"));
            File newFile = new File(
                "C:\\workspace\\Crap\\src\\org\\raghav\\stuff\\XML_FROM_SERVER.xml");
            OutputStream os = new FileOutputStream(newFile);
            BufferedOutputStream bos = new BufferedOutputStream(os);
            int readCount;
            //System.out.println("Getting: " + theLine);
            while ((readCount = bis.read(buffer)) > 0) {
                //System.out.println("Writing: ");
                bos.write(buffer, 0, readCount);
            }
            
            while(session != null){
                System.out.println("Killing the session");
                session.disconnect();
                bis.close();
                bos.close();
                System.exit(0);
            }
            
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }
}

我需要修改这段代码,使其能够获取多个文件并将它们放入对象列表中。该对象应该包含文件的目录、文件名和文件正文。


你尝试查看过 jsch SFTP 示例代码 吗?其中包含列出文件的示例代码,可以参考 "ls"。 - jtahlborn
4个回答

17

使用以下命令可以列出给定目录中的所有文件:

Vector<ChannelSftp.LsEntry> list = channelSftp.ls("*.csv");
for(ChannelSftp.LsEntry entry : list) {
     System.out.println(entry.getFilename()); 
}

在此处添加代码

channelSftp.cd(SFTPWORKINGDIR);

现在你将获得文件对象列表。 文件对象是条目。如果您想下载所有文件,请将此代码添加到for循环中。

byte[] buffer = new byte[1024];
BufferedInputStream bis = new BufferedInputStream(channelSftp.get(entry.getFilename()));
File newFile = new File("C:/Users/Desktop/sftpStuff/"+entry.getFilename());
OutputStream os = new FileOutputStream(newFile);
BufferedOutputStream bos = new BufferedOutputStream(os);
int readCount;
//System.out.println("Getting: " + theLine);
while( (readCount = bis.read(buffer)) > 0) {
  System.out.println("Writing: "+entry.getFilename() );
  bos.write(buffer, 0, readCount);
}
bis.close();
bos.close();

2
这是一种列出目标目录文件的方法。
Vector filelist = channelSftp.ls(SFTPWORKINGDIR);
for(int i=0; i<filelist.size();i++){
     System.out.println(filelist.get(i).toString());
     // Grap and get the file by WORKING_DIR/filelist.get(i).toString();
     // Save it to your local directory with its original name. 

}

第二,当您在for循环中时,如果请求的是所需的xml文件,则可以下载所有文件。

2

ChannelSftp有一个方法可以从路径获取文件列表。我假设您想要下载的文件都在同一个目录中,并且您会执行以下操作:

channelSftp.cd("/FGV/US/BS/");
Vector ls = channelSftp.ls("*")

http://epaul.github.io/jsch-documentation/simple.javadoc/com/jcraft/jsch/ChannelSftp.html#ls(java.lang.String)

获取文件列表后(返回Vector),设置for循环或迭代器来使用Vector中的每个ChannelSftp.LsEntry,使用getFilename方法获取文件名。您可以检查它是否具有.xml扩展名。从代码中的行开始的所有内容都在循环内部。如果要保留文件内容,则需要将连续读取添加到StringBuffer中。

至于存储每个文件名、内容和目录,您可以使用简单的包装器。例如:

public class SFTPFileList {
    public String directory;
    public ArrayList<String> filenames;
    public ArrayList<StringBuffer> fileContents;  

    /**
     *Simple method to add a filename and its contents.
     *filenames and fileContents will have the same index
     *for filename<->content. 
     **/
    public void addFile(String filename, StringBuffer content) {
        filenames.add(filename);
        fileContents.add(content);
    }
}

您可以添加方法、构造函数等来正确获取、设置。或者直接访问。对于后者,在循环之外:
SFTPFileList sftpFileList = new SFTPFileList();
sftpFileList.directory = "/FGV/US/BS/";
ArrayList<String> fileNames = new ArrayList<>();
ArrayList<String,StringBuffer> contents = new ArrayList<>();
sftpFileList.filenames = filenames;
sftpFileList.contents = contents;

在你的循环中:

ChannelSftp.LsEntry entry = iter.next();  //or from a for loop
String fileName = entry.getFileName();
StringBuffer fileContent = new StringBuffer(); //this where you will add the results of each read -> buffer 
...
read content
...
sftpFileList.addFile(fileName,fileContent);

然后,在循环之外,您将通过另一种方法或多种方法访问所有文件名及其内容。或根据需要直接访问这些成员。


0

这段代码运行良好。

        @SuppressWarnings("null")
        Vector<ChannelSftp.LsEntry> filesList = channelSftp.ls("*.txt");
        logger.info("filesList size:" + filesList.size()); 
        if(filesList != null) {
            for(ChannelSftp.LsEntry entry : filesList) {
                InputStream stream = channelSftp.get(entry.getFilename());
                br = new BufferedReader(new InputStreamReader(stream));
                if(br != null) {
                    while ((line = br.readLine()) != null) {
                    }
                }
           }
        }

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接