原文:Java实现FTP服务器的上传、下载、删除、查看文件列表?源代码下载地址:http://www.zuidaima.com/share/1550463298030592.htm
Java实现FTP服务器的上传、下载、删除、查看文件列表
class="java" name="code">package com.zuidaima.zhangjun.ftp; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import java.util.ArrayList; import java.util.List; import org.apache.commons.io.IOUtils; import org.apache.commons.net.ftp.FTPClient; import org.apache.commons.net.ftp.FTPFile; import org.apache.commons.net.ftp.FTPReply; /** * <p> * ftp连接管理(使用apache commons-net-1.4.1 lib) * </p> * <p>Description:从FTP上下载对账单</p> * @author 张军,www.zuidaima.com * @version 1.0 20120912 */ public class FtpClientUtil { private FTPClient ftpClient = null; private String server; private int port; private String userName; private String userPassword; public static void main(String[] args) { FtpClientUtil f = new FtpClientUtil("10.3.12.17", 21, "was", "was"); try { if (f.open()) { f.get("/opt/IBM/WebSphere/AppServer/profiles/AppSrv01/qunarlog.txt", "E:/zhangjun.txt");// 远程路径为相对路径 f.close(); } } catch (Exception e) { e.printStackTrace(); } } public FtpClientUtil(String server, int port, String userName, String userPassword) { this.server = server; this.port = port; this.userName = userName; this.userPassword = userPassword; } /** * 链接到服务器 * * @return * @throws Exception */ public boolean open() { if (ftpClient != null && ftpClient.isConnected()) { return true; } try { ftpClient = new FTPClient(); // 连接 ftpClient.connect(this.server, this.port); ftpClient.login(this.userName, this.userPassword); // 检测连接是否成功 int reply = ftpClient.getReplyCode(); if (!FTPReply.isPositiveCompletion(reply)) { this.close(); System.err.println("FTP server refused connection."); System.exit(1); } System.out.println("open FTP success:" + this.server+";port:"+this.port + ";name:" + this.userName + ";pwd:" + this.userPassword); ftpClient.setFileType(ftpClient.BINARY_FILE_TYPE); // 设置上传模式.binally // or ascii return true; } catch (Exception ex) { // 关闭 this.close(); ex.printStackTrace(); return false; } } private boolean cd(String dir) throws IOException { if (ftpClient.changeWorkingDirectory(dir)) { return true; } else { return false; } } /** * 获取目录下所有的文件名称 * * @param filePath * @return * @throws IOException */ private FTPFile[] getFileList(String filePath) throws IOException { FTPFile[] list = ftpClient.listFiles(); return list; } /** * 循环将设置工作目录 */ public boolean changeDir(String ftpPath) { if (!ftpClient.isConnected()) { return false; } try { // 将路径中的斜杠统一 char[] chars = ftpPath.toCharArray(); StringBuffer sbStr = new StringBuffer(256); for (int i = 0; i < chars.length; i++) { if ('\\' == chars[i]) { sbStr.append('/'); } else { sbStr.append(chars[i]); } } ftpPath = sbStr.toString(); // System.out.println("ftpPath"+ftpPath); if (ftpPath.indexOf('/') == -1) { // 只有一层目录 // System.out.println("change"+ftpPath); ftpClient.changeWorkingDirectory(new String(ftpPath.getBytes(), "iso-8859-1")); } else { // 多层目录循环创建 String[] paths = ftpPath.split("/"); // String pathTemp = ""; for (int i = 0; i < paths.length; i++) { // System.out.println("change "+paths[i]); ftpClient.changeWorkingDirectory(new String(paths[i] .getBytes(), "iso-8859-1")); } } return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 循环创建目录,并且创建完目录后,设置工作目录为当前创建的目录下 */ public boolean mkDir(String ftpPath) { if (!ftpClient.isConnected()) { return false; } try { // 将路径中的斜杠统一 char[] chars = ftpPath.toCharArray(); StringBuffer sbStr = new StringBuffer(256); for (int i = 0; i < chars.length; i++) { if ('\\' == chars[i]) { sbStr.append('/'); } else { sbStr.append(chars[i]); } } ftpPath = sbStr.toString(); System.out.println("ftpPath" + ftpPath); if (ftpPath.indexOf('/') == -1) { // 只有一层目录 ftpClient.makeDirectory(new String(ftpPath.getBytes(), "iso-8859-1")); ftpClient.changeWorkingDirectory(new String(ftpPath.getBytes(), "iso-8859-1")); } else { // 多层目录循环创建 String[] paths = ftpPath.split("/"); // String pathTemp = ""; for (int i = 0; i < paths.length; i++) { ftpClient.makeDirectory(new String(paths[i].getBytes(), "iso-8859-1")); ftpClient.changeWorkingDirectory(new String(paths[i] .getBytes(), "iso-8859-1")); } } return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 上传文件到FTP服务器 * * @param localPathAndFileName * 本地文件目录和文件名 * @param ftpFileName * 上传后的文件名 * @param ftpDirectory * FTP目录如:/path1/pathb2/,如果目录不存在回自动创建目录 * @throws Exception */ public boolean put(String localDirectoryAndFileName, String ftpFileName, String ftpDirectory) { if (!ftpClient.isConnected()) { return false; } boolean flag = false; if (ftpClient != null) { File srcFile = new File(localDirectoryAndFileName); FileInputStream fis = null; try { fis = new FileInputStream(srcFile); // 创建目录 this.mkDir(ftpDirectory); ftpClient.setBufferSize(1024); ftpClient.setControlEncoding("UTF-8"); // 设置文件类型(二进制) ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE); // 上传 flag = ftpClient.storeFile(new String(ftpFileName.getBytes(), "iso-8859-1"), fis); } catch (Exception e) { this.close(); e.printStackTrace(); return false; } finally { IOUtils.closeQuietly(fis); } } System.out.println("success put file " + localDirectoryAndFileName + " to " + ftpDirectory + ftpFileName); return flag; } /** * 从FTP服务器上下载文件并返回下载文件长度 * * @param ftpDirectoryAndFileName * @param localDirectoryAndFileName * @return * @throws Exception */ public long get(String ftpDirectoryAndFileName,String localDirectoryAndFileName) { long result = 0; if (!ftpClient.isConnected()) { return 0; } ftpClient.enterLocalPassiveMode(); try { // 将路径中的斜杠统一 char[] chars = ftpDirectoryAndFileName.toCharArray(); StringBuffer sbStr = new StringBuffer(256); for (int i = 0; i < chars.length; i++) { if ('\\' == chars[i]) { sbStr.append('/'); } else { sbStr.append(chars[i]); } } ftpDirectoryAndFileName = sbStr.toString(); String filePath = ftpDirectoryAndFileName.substring(0,ftpDirectoryAndFileName.lastIndexOf("/")); String fileName = ftpDirectoryAndFileName.substring(ftpDirectoryAndFileName.lastIndexOf("/") + 1); this.changeDir(filePath); ftpClient.retrieveFile( new String(fileName.getBytes(),"iso-8859-1"), new FileOutputStream(localDirectoryAndFileName)); // download System.out.print(ftpClient.getReplyString()); // check result } catch (IOException e) { e.printStackTrace(); } System.out.println("Success get file" + ftpDirectoryAndFileName + " from " + localDirectoryAndFileName); return result; } /** * 返回FTP目录下的文件列表 * * @param ftpDirectory * @return */ public List getFileNameList(String ftpDirectory) { List list = new ArrayList(); // if (!open()) // return list; // try { // DataInputStream dis = new DataInputStream(ftpClient // .nameList(ftpDirectory)); // String filename = ""; // while ((filename = dis.readLine()) != null) { // list.add(filename); // } // } catch (Exception e) { // e.printStackTrace(); // } return list; } /** * 删除FTP上的文件 * * @param ftpDirAndFileName */ public boolean deleteFile(String ftpDirAndFileName) { if (!ftpClient.isConnected()) { return false; } //Todo return true; } /** * 删除FTP目录 * * @param ftpDirectory */ public boolean deleteDirectory(String ftpDirectory) { if (!ftpClient.isConnected()) { return false; } //ToDo return true; } /** * 关闭链接 */ public void close() { try { if (ftpClient != null && ftpClient.isConnected()) ftpClient.disconnect(); } catch (Exception e) { e.printStackTrace(); } System.out.println("Close Server Success :"+this.server+";port:"+this.port); } public FTPClient getFtpClient() { return ftpClient; } public void setFtpClient(FTPClient ftpClient) { this.ftpClient = ftpClient; } }
?标签:?ftp?java?上传?下载?查看?文件列表话题:?网络客户端和服务端组件?网络编程