FTPClient連續讀取文件

最近在使用FTPClient連續讀取ftp上的多個文件內容時，遇到了兩個問題：

1. 在for循環中，FTPClient只能讀取到第一個文件內容，讀取第二個時遇到NPE問題。

2. 遇到程序鎖死。

下面就遇到問題進行還原分析，並提供解決辦法：

現在使用FTPClient讀取ftp服務器/aaa/bbb/目錄下a.txt,b.txt兩個文件

 問題1：

 通過Debug發現在讀取第一個文件前FTPClient的_replyCode=226(226 Transter complete.) 數據傳輸完的狀態，當開始讀第一個文件之后_replyCode=125（125 Data connection already open; Transter starting.）數據傳輸開始正在傳輸，表明第一文件還沒有傳輸完，導致讀第二個文件時inputStrean為null。

 

 解決辦法是在讀完第一文件之后，執行 ftpClient.completePendingCommand(); 告訴FTPClient數據已經傳完。

問題2：

ftpClient.completePendingCommand();  在讀取執行執行造成鎖死。

解決辦法 ftpClient.completePendingCommand(); 只能在數據傳輸之后執行。

最后貼上完整的代碼：

package com.shipc.demo.ftp;

import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;

import java.io.*;

/**
 * @author shipc 2019/10/24 10:00
 * @version 1.0
 */
public class TestFTP {

    private FTPClient connectServer() {
        FTPClient ftpClient = new FTPClient();
        ftpClient.setConnectTimeout(1000 * 60 * 30);
        ftpClient.setControlEncoding("UTF-8");
        ftpClient.enterLocalPassiveMode(); //設置被動模式，文件傳輸端口設置
        try {
            ftpClient.connect("172.17.0.16", 21);
            ftpClient.login("ftp-user", "123456");
            ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE); // 設置文件傳輸模式為二進制
            final int replyCode = ftpClient.getReplyCode();
            if (!FTPReply.isPositiveCompletion(replyCode)) {
                ftpClient.disconnect();
            }
        } catch (Exception e) {
            System.out.println(e.getMessage());
        }
        return ftpClient;
    }
    
    private void readFiles(FTPClient ftpClient) throws IOException {
        ftpClient.changeWorkingDirectory("/aaa/bbb");
        final FTPFile[] ftpFiles = ftpClient.listFiles();
        for (FTPFile ftpFile : ftpFiles) {
            if (ftpFile.isFile()) {
                System.out.println("********文件" + ftpFile.getName() + "的內容如下**********");
//                ftpClient.completePendingCommand(); // 一定不能在讀之前執行，否則會鎖死
                
                InputStream inputStream = ftpClient.retrieveFileStream(ftpFile.getName());
                try (BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream))) {
                    while (true) {
                        final String s = reader.readLine();
                        if (s == null) {
                            break;
                        }
                        System.out.println(s);
                    }
                }
                inputStream.close();
                ftpClient.completePendingCommand(); // 每當讀完一個文件時，要執行該語句
            }
        }
    }

    public static void main(String[] args) {
        final TestFTP testFTP = new TestFTP();
        FTPClient ftpClient = testFTP.connectServer();
        try {
            testFTP.readFiles(ftpClient);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}