FTPJAVA工具类（连接FTP，上传文件到FTP，删除FTP文件，下载FTP文件，检索FTP文件）

共1个文件

java：1个

需积分: 23 142 浏览量 2017-12-01 10:19:50 上传评论 2 收藏 3KB RAR 举报

FTP (File Transfer Protocol) 是一种用于在网络上进行文件传输的标准协议，广泛应用于Web开发、系统管理和数据备份等场景。Java作为一种跨平台的编程语言，提供了多种库来实现FTP操作，如Apache Commons Net库。本篇文章将详细讲解如何使用Java编写一个FTP工具类，实现连接FTP服务器、上传文件、删除文件、下载文件以及检索文件的功能。我们需要引入Apache Commons Net库，该库提供了丰富的FTP客户端API。在`pom.xml`文件中添加如下依赖： ```xml <dependency> <groupId>commons-net</groupId> <artifactId>commons-net</artifactId> <version>3.6</version> </dependency> ``` 现在，我们创建一个名为`FTPUtils`的Java工具类，开始编写FTP相关的功能。 1. **连接FTP服务器** 连接FTP服务器需要提供服务器地址、用户名和密码。我们可以使用`FTPClient`类来实现这一功能： ```java import org.apache.commons.net.ftp.FTPClient; public class FTPUtils { private FTPClient ftpClient = new FTPClient(); public boolean connect(String host, int port, String username, String password) { try { ftpClient.connect(host, port); return ftpClient.login(username, password); } catch (IOException e) { e.printStackTrace(); return false; } } } ``` 2. **上传文件到FTP** 使用`FTPClient`的`storeFile`方法可以将本地文件上传到FTP服务器： ```java public boolean uploadFile(String remoteFilePath, File localFile) { try { ftpClient.setFileType(FTP.BINARY_FILE_TYPE); return ftpClient.storeFile(remoteFilePath, new FileInputStream(localFile)); } catch (IOException e) { e.printStackTrace(); return false; } finally { try { if (ftpClient.isConnected()) { ftpClient.logout(); ftpClient.disconnect(); } } catch (IOException e) { e.printStackTrace(); } } } ``` 3. **删除FTP文件** 调用`FTPClient`的`deleteFile`方法可以删除FTP服务器上的文件： ```java public boolean deleteFile(String filePath) { try { return ftpClient.deleteFile(filePath); } catch (IOException e) { e.printStackTrace(); return false; } finally { // 关闭连接 closeConnection(); } } private void closeConnection() { try { if (ftpClient.isConnected()) { ftpClient.logout(); ftpClient.disconnect(); } } catch (IOException e) { e.printStackTrace(); } } ``` 4. **下载FTP文件** 使用`FTPClient`的`retrieveFile`方法下载FTP服务器上的文件到本地： ```java public boolean downloadFile(String remoteFilePath, File localFile) { try { OutputStream outputStream = new FileOutputStream(localFile); ftpClient.setFileType(FTP.BINARY_FILE_TYPE); boolean success = ftpClient.retrieveFile(remoteFilePath, outputStream); outputStream.close(); return success; } catch (IOException e) { e.printStackTrace(); return false; } finally { closeConnection(); } } ``` 5. **检索FTP文件** 要列出FTP服务器上的文件和目录，可以使用`FTPClient`的`listNames`方法： ```java public List<String> listFiles(String dirPath) { try { ftpClient.changeWorkingDirectory(dirPath); String[] files = ftpClient.listNames(); return Arrays.asList(files); } catch (IOException e) { e.printStackTrace(); return Collections.emptyList(); } finally { closeConnection(); } } ``` 以上就是`FTPUtils`工具类的主要功能，包括连接FTP服务器、上传文件、删除文件、下载文件和检索文件。通过这个工具类，开发者可以方便地在Java应用中进行FTP操作。在实际项目中，还可以根据需求增加异常处理、重试机制等功能，以提高代码的健壮性和可靠性。

资源推荐

资源详情

资源评论

收起资源包目录

FTPUtils.rar （1个子文件）

FTPUtils.java 14KB

package cn.rojao.utils; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.io.PrintWriter; import java.util.ArrayList; import java.util.Date; import java.util.Iterator; import org.apache.commons.lang.StringUtils; import org.apache.commons.net.PrintCommandListener; 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; /** * 连接ftp * 列出FTP服务器上指定目录下面的所有文件 */ public class FTPUtils { //private static Logger logger = Logger.getLogger(FTPListAllFiles.class); public FTPClient ftp; public ArrayList<String> arFiles; /** * 重载构造函数 * @param isPrintCommmand 是否打印与FTPServer的交互命令 */ public FTPUtils(boolean isPrintCommmand){ ftp = new FTPClient(); arFiles = new ArrayList<String>(); if(isPrintCommmand){ ftp.addProtocolCommandListener(new PrintCommandListener(new PrintWriter(System.out))); } } /** * 登陆FTP服务器 * @param host FTPServer IP地址 * @param port FTPServer 端口 * @param username FTPServer 登陆用户名 * @param password FTPServer 登陆密码 * @return 是否登录成功 * @throws IOException */ public boolean login(String host,int port,String username,String password) throws IOException{ this.ftp.connect(host,port); if(FTPReply.isPositiveCompletion(this.ftp.getReplyCode())){ if(this.ftp.login(username, password)){ this.ftp.setControlEncoding("GBK"); return true; } } if(this.ftp.isConnected()){ this.ftp.disconnect(); } return false; } /** * 关闭数据链接 * @throws IOException */ public void disConnection() throws IOException{ if(this.ftp.isConnected()){ this.ftp.disconnect(); } } /** * 递归遍历出目录下面所有文件 * @param pathName 需要遍历的目录，必须以"/"开始和结束 * @throws IOException */ public void List(String pathName) throws IOException{ if(pathName.startsWith("/")&&pathName.endsWith("/")){ String directory = pathName; //更换目录到当前目录 this.ftp.changeWorkingDirectory(directory); FTPFile[] files = this.ftp.listFiles(); for(FTPFile file:files){ if(file.isFile()){ arFiles.add(directory+file.getName()); }else if(file.isDirectory()){ List(directory+file.getName()+"/"); } } } } /** * 递归遍历目录下面指定的文件名 * @param pathName 需要遍历的目录，必须以"/"开始和结束 * @param ext 文件的扩展名 * @throws IOException */ public void loadList(String pathName,String ext,String path) throws IOException{ if(pathName.startsWith("/")&&pathName.endsWith("/")){ String directory = pathName; //更换目录到当前目录 this.ftp.changeWorkingDirectory(directory); FTPFile[] files = this.ftp.listFiles(); File pathFile = new File(path); if(!pathFile.exists()){ pathFile.mkdirs(); } for(FTPFile file:files){ if(file.isFile()){ //if(file.getName().startsWith(ext)){ File localFile = new File( path+ File.separatorChar + file.getName()); if(localFile.exists()){ System.out.println( file.getName()+"已存在"); }else{ arFiles.add(directory+file.getName()); OutputStream os = new FileOutputStream(localFile); this.ftp.retrieveFile(file.getName(), os); this.ftp.deleteFile( directory + file.getName());//下载完成后删除文件 } //} } /* else if(file.isDirectory()){ List(directory+file.getName()+"/",ext,""); } */ } } } /** * Description: 向FTP服务器上传文件 * @param host FTP服务器hostname * @param port FTP服务器端口 * @param username FTP登录账号 * @param password FTP登录密码 * @param basePath FTP服务器基础目录 * @param filePath FTP服务器文件存放路径。例如分日期存放：/2015/01/01。文件的路径为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; } //切换到上传目录 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)) { 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) { e.printStackTrace(); } finally { if (ftp.isConnected()) { try { ftp.disconnect(); } catch (IOException ioe) { } } } return result; } /** * 上传的文件或文件夹到ftp * @param host * @param port * @param username * @param password * @param basePath * @param filePath * @param file * @return */ public static boolean uploadFileFtp(String host, int port, String username, String password, String basePath, St

评论收藏

内容反馈