FTPClient.listFiles() 获取目录里的文件为空的解决

电玩女神 2022-09-03 15:12 312阅读 0赞

写个功能要从ftp服务下载文件，在本地的ftp服务一切ok(window环境),但是在Linux环境发现不管切换到哪个目录，获取什么文件，调用FTPClient.listFiles()方法时返回的始终为空，但是代码又运行正常没有异常抛出。然后断点ftp.getReplyCode()也返回230登陆成功.  
在调用FTPClient.listFiles()方法前，先调用FTPClient.enterLocalPassiveMode();就可以了。  
下面是完整的ftp util例子

package com.tesst.util;
    
    import lombok.extern.slf4j.Slf4j;
    import org.apache.commons.collections.CollectionUtils;
    import org.apache.commons.lang.StringUtils;
    import org.apache.commons.net.ftp.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.*;
    import java.util.ArrayList;
    import java.util.List;
    
    @Slf4j
    public class FtpUtil { 
    	/** * Description: 向FTP服务器上传文件 * * @param host FTP服务器hostname * @param port FTP服务器端口 * @param username FTP登录账号 * @param password FTP登录密码 * @param basePath FTP服务器基础目录 * @param filePath FTP服务器文件存放路径。文件的路径为basePath+filePath * @param filename 上传到FTP服务器上的文件名 * @param input 输入流 * @return 成功返回true，否则返回false */
    	public static boolean uploadFile(String host, int port, String username, String password, String basePath,
    	                                 String filePath, String filename, InputStream input) { 
    		boolean result = false;
    		FTPClient ftp = new FTPClient();
    		try { 
    			int reply;
    			ftp.connect(host, port);// 连接FTP服务器
    			// 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器
    			ftp.login(username, password);// 登录
    			reply = ftp.getReplyCode();
    			if (!FTPReply.isPositiveCompletion(reply)) { 
    				ftp.disconnect();
    				return result;
    			}
    			ftp.enterLocalPassiveMode();
    			//切换到上传目录
    			if (!ftp.changeWorkingDirectory(basePath + filePath)) { 
    				//如果目录不存在创建目录
    				String[] dirs = filePath.split("/");
    				String tempPath = basePath;
    				for (String dir : dirs) { 
    					if (null == dir || "".equals(dir)) continue;
    					tempPath += "/" + dir;
    					if (!ftp.changeWorkingDirectory(tempPath)) {   //进不去目录，说明该目录不存在
    						if (!ftp.makeDirectory(tempPath)) {  //创建目录
    							//如果创建文件目录失败，则返回
    							System.out.println("uploadFile 创建文件目录" + tempPath + "失败");
    							return result;
    						} else { 
    							//目录存在，则直接进入该目录
    							ftp.changeWorkingDirectory(tempPath);
    						}
    					}
    				}
    			}
    			//设置上传文件的类型为二进制类型
    			ftp.setFileType(FTP.BINARY_FILE_TYPE);
    			//上传文件
    			if (!ftp.storeFile(filename, input)) { 
    				return result;
    			}
    			input.close();
    			ftp.logout();
    			result = true;
    		} catch (IOException e) { 
    			log.error("FtpUtil uploadFile, 发生异常:{}", e.getMessage());
    		} finally { 
    			if (ftp.isConnected()) { 
    				try { 
    					ftp.disconnect();
    				} catch (IOException ioe) { 
    					log.error("FtpUtil uploadFile, 发生异常:{}", ioe.getMessage());
    				}
    			}
    		}
    		return result;
    	}
    
    	/** * Description: 从FTP服务器下载文件 * * @param host FTP服务器hostname * @param port FTP服务器端口 * @param username FTP登录账号 * @param password FTP登录密码 * @param remotePath FTP服务器上的相对路径 * @param fileName 要下载的文件名 * @param localPath 下载后保存到本地的路径 * @return */
    	public static boolean downloadFile(String host, int port, String username, String password, String remotePath,
    	                                   String fileName, String localPath) { 
    		boolean result = false;
    		FTPClient ftp = new FTPClient();
    		try { 
    			int reply;
    			ftp.connect(host, port);
    			// 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器
    			ftp.login(username, password);// 登录
    			reply = ftp.getReplyCode();
    			if (!FTPReply.isPositiveCompletion(reply)) { 
    				ftp.disconnect();
    				return result;
    			}
    			ftp.enterLocalPassiveMode();
    			if (StringUtils.isNotBlank(remotePath)) { 
    				if (!ftp.changeWorkingDirectory(remotePath)) { 
    					log.error("downloadFile change to direcotory {} failed", remotePath);
    					return result;
    				}
    			}
    			FTPFile[] fs = ftp.listFiles();
    			for (FTPFile ff : fs) { 
    				if (ff.getName().equals(fileName)) { 
    					File localFile = new File(localPath + "/" + ff.getName());
    					OutputStream is = new FileOutputStream(localFile);
    					ftp.retrieveFile(ff.getName(), is);
    					is.close();
    				}
    			}
    			ftp.logout();
    			result = true;
    		} catch (IOException e) { 
    			log.error("FtpUtil:downloadFile, 发生异常:{}", e.getMessage());
    		} finally { 
    			if (ftp.isConnected()) { 
    				try { 
    					ftp.disconnect();
    				} catch (IOException ioe) { 
    					log.error("FtpUtil:downloadFile, 发生异常:{}", ioe.getMessage());
    				}
    			}
    		}
    		return result;
    	}
    
    	/** * @param host * @param port * @param username * @param password * @param remotePath * @param FileNameprefix * @param FileNamesuffix * @return */
    	public static List<String> getFileNameList(String host, int port, String username, String password, String remotePath, String FileNameprefix, String FileNamesuffix) { 
    		List<String> ftpfileNameList = new ArrayList<>();
    		FTPClient ftp = new FTPClient();
    		try { 
    			int reply;
    			ftp.connect(host, port);
    			// 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器
    			ftp.login(username, password);// 登录
    			reply = ftp.getReplyCode();
    			if (!FTPReply.isPositiveCompletion(reply)) { 
    				ftp.disconnect();
    				log.error("FtpUtil getFileNameList, 登录ftp server失败");
    				return null;
    			}
    			ftp.enterLocalPassiveMode();
    			if (StringUtils.isNotBlank(remotePath)) { 
    				if (!ftp.changeWorkingDirectory(remotePath)) { 
    					log.error("FtpUtil getFileNameList change to direcotory {} failed", remotePath);
    					return null;
    				}
    			}
    			FTPFile[] fs = ftp.listFiles();
    			for (FTPFile ff : fs) { 
    				log.info("FtpUtil filename:{}", ff.getName());
    				if (StringUtils.isNotBlank(FileNameprefix)) { 
    					if (!ff.getName().startsWith(FileNameprefix)) { 
    						continue;
    					}
    				}
    				if (StringUtils.isNotBlank(FileNamesuffix)) { 
    					if (!ff.getName().endsWith(FileNamesuffix)) { 
    						continue;
    					}
    				}
    				ftpfileNameList.add(ff.getName());
    			}
    			ftp.logout();
    		} catch (IOException e) { 
    			log.error("FtpUtil getFileNameList, 发生异常:{}", e.getMessage());
    		} finally { 
    			if (ftp.isConnected()) { 
    				try { 
    					ftp.disconnect();
    				} catch (IOException ioe) { 
    					log.error("FtpUtil getFileNameList , 发生异常:{}", ioe.getMessage());
    				}
    			}
    		}
    		if (CollectionUtils.isEmpty(ftpfileNameList)) { 
    			log.info("FtpUtil getFileNameList 没有匹配的文件名");
    		}
    		return ftpfileNameList;
    	}
    	//ftp上传文件测试main函数
    	//test
    	/* public static void main(String[] args) { try { FileInputStream in=new FileInputStream(new File("D:\\Tomcat 5.5\\pictures\\t0176ee418172932841.jpg")); boolean flag = uploadFile("192.168.111.128", 21, "用户名", "密码", "/www/images","/2017/11/19", "hello.jpg", in); System.out.println(flag); } catch (FileNotFoundException e) { e.printStackTrace(); } } */
    
    }