FTPClient连续读取文件

 1 package com.shipc.demo.ftp;
 2 
 3 import org.apache.commons.net.ftp.FTPClient;
 4 import org.apache.commons.net.ftp.FTPFile;
 5 import org.apache.commons.net.ftp.FTPReply;
 6 
 7 import java.io.*;
 8 
 9 /**
10  * @author shipc 2019/10/24 10:00
11  * @version 1.0
12  */
13 public class TestFTP {
14 
15     private FTPClient connectServer() {
16         FTPClient ftpClient = new FTPClient();
17         ftpClient.setConnectTimeout(1000 * 60 * 30);
18         ftpClient.setControlEncoding("UTF-8");
19         ftpClient.enterLocalPassiveMode(); //设置被动模式，文件传输端口设置
20         try {
21             ftpClient.connect("172.17.0.16", 21);
22             ftpClient.login("ftp-user", "123456");
23             ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE); // 设置文件传输模式为二进制
24             final int replyCode = ftpClient.getReplyCode();
25             if (!FTPReply.isPositiveCompletion(replyCode)) {
26                 ftpClient.disconnect();
27             }
28         } catch (Exception e) {
29             System.out.println(e.getMessage());
30         }
31         return ftpClient;
32     }
33     
34     private void readFiles(FTPClient ftpClient) throws IOException {
35         ftpClient.changeWorkingDirectory("/aaa/bbb");
36         final FTPFile[] ftpFiles = ftpClient.listFiles();
37         for (FTPFile ftpFile : ftpFiles) {
38             if (ftpFile.isFile()) {
39                 System.out.println("********文件" + ftpFile.getName() + "的内容如下**********");
40 //                ftpClient.completePendingCommand(); // 一定不能在读之前执行，否则会锁死
41                 
42                 InputStream inputStream = ftpClient.retrieveFileStream(ftpFile.getName());
43                 try (BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream))) {
44                     while (true) {
45                         final String s = reader.readLine();
46                         if (s == null) {
47                             break;
48                         }
49                         System.out.println(s);
50                     }
51                 }
52                 inputStream.close();
53                 ftpClient.completePendingCommand(); // 每当读完一个文件时，要执行该语句
54             }
55         }
56     }
57 
58     public static void main(String[] args) {
59         final TestFTP testFTP = new TestFTP();
60         FTPClient ftpClient = testFTP.connectServer();
61         try {
62             testFTP.readFiles(ftpClient);
63         } catch (IOException e) {
64             e.printStackTrace();
65         }
66     }
67 }