Java对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.net.MalformedURLException;

public class FtpUtils {
　　// ftp服务器地址
　　private String hostName;
　　// ftp服务器端口号
　　private Integer port;
　　private String userName;
　　// ftp登录密码
　　private String password;

　　private final FTPClient ftpClient = new FTPClient();

　　/**
　　  * 初始化ftp服务器
　　  */
　　public FtpUtils(String hostName, Integer port, String userName, String password) {
　　　　this.hostName = hostName;
　　　　this.port = port;
　　　　this.userName = userName;
　　　　this.password = password;
　　　　ftpClient.setControlEncoding("utf-8");
　　　　try {
　　　　　　System.out.println("connecting...ftp服务器:" + this.hostName + ":" + this.port);
　　　　　　ftpClient.connect(hostName, port); // 连接ftp服务器
　　　　　　ftpClient.login(userName, password); // 登录ftp服务器
　　　　　　int replyCode = ftpClient.getReplyCode(); // 是否成功登录服务器
　　　　　　if (!FTPReply.isPositiveCompletion(replyCode)) {
　　　　　　　　System.out.println("connect failed...ftp服务器:" + this.hostName + ":" + this.port);
　　　　　　}
　　　　　　System.out.println("connect successfu...ftp服务器:" + this.hostName + ":" + this.port);
　　　　} catch (MalformedURLException e) {
　　　　　　e.printStackTrace();
　　　　} catch (IOException e) {
　　　　　　e.printStackTrace();
　　　　}
　　}

　　/**
　　  * 上传文件
　　  *
　　  * @param pathName ftp服务保存地址
　　  * @param fileName 上传到ftp的文件名
　　  * @param originfilename 待上传文件的名称（绝对地址） *
　　  * @return
　　  */
　　public boolean uploadFile(String pathName, String fileName, String originfilename) {
　　　　InputStream inputStream = null;
　　　　try {
　　　　　　inputStream = new FileInputStream(new File(originfilename));
　　　　} catch (FileNotFoundException e) {
　　　　　　e.printStackTrace();
　　　　}
　　　　return this.uploadFile(pathName, fileName, inputStream);
　　}

　　/**
　　  * 上传文件
　　  *
　　  * @param pathName ftp服务保存地址
　　  * @param fileName 上传到ftp的文件名
　　  * @param inputStream 输入文件流
　　  * @return
　　  */
　　public boolean uploadFile(String pathName, String fileName, InputStream inputStream) {
　　　　boolean flag = false;
　　　　try {
　　　　　　System.out.println("开始上传文件");
　　　　　　// initFtpClient();
　　　　　　ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
　　　　　　createDirecroty(pathName);
　　　　　　ftpClient.makeDirectory(pathName);
　　　　　　ftpClient.changeWorkingDirectory(pathName);
　　　　　　ftpClient.storeFile(fileName, inputStream);
　　　　　　inputStream.close();
　　　　　　ftpClient.logout();
　　　　　　flag = true;
　　　　　　System.out.println("上传文件成功");
　　　　} catch (Exception e) {
　　　　　　System.out.println("上传文件失败");
　　　　　　e.printStackTrace();
　　　　} finally {
　　　　　　this.close(ftpClient, null, inputStream);
　　　　}
　　　　return flag;
　　}

　　// 改变目录路径
　　public boolean changeWorkingDirectory(String directory) {
　　　　boolean flag = true;
　　　　try {
　　　　　　flag = ftpClient.changeWorkingDirectory(directory);
　　　　　　if (flag) {
　　　　　　　　System.out.println("进入文件夹" + directory + " 成功！");
　　　　　　} else {
　　　　　　　　System.out.println("进入文件夹" + directory + " 失败！开始创建文件夹");
　　　　　　}
　　　　} catch (IOException ioe) {
　　　　　　ioe.printStackTrace();
　　　　}
　　　　return flag;
　　}

　　// 创建多层目录文件，如果有ftp服务器已存在该文件，则不创建，如果无，则创建
　　public boolean createDirecroty(String remote) throws IOException {
　　　　String directory = remote + "/";
　　　　// 如果远程目录不存在，则递归创建远程服务器目录
　　　　if (!directory.equalsIgnoreCase("/") && !changeWorkingDirectory(new String(directory))) {
　　　　　　int start = 0;
　　　　　　int end = 0;
　　　　　　if (directory.startsWith("/")) {
　　　　　　　　start = 1;
　　　　　　} else {
　　　　　　　　start = 0;
　　　　　　}
　　　　　　end = directory.indexOf("/", start);
　　　　　　String path = "";
　　　　　　String paths = "";
　　　　　　while (true) {
　　　　　　　　String subDirectory = new String(remote.substring(start, end).getBytes("GBK"), "iso-8859-1");
　　　　　　　　path = path + "/" + subDirectory;
　　　　　　　　if (!existFile(path)) {
　　　　　　　　　　if (makeDirectory(subDirectory)) {
　　　　　　　　　　　　changeWorkingDirectory(subDirectory);
　　　　　　　　　　} else {
　　　　　　　　　　　　System.out.println("创建目录[" + subDirectory + "]失败");
　　　　　　　　　　　　changeWorkingDirectory(subDirectory);
　　　　　　　　　　}
　　　　　　　　} else {
　　　　　　　　　　changeWorkingDirectory(subDirectory);
　　　　　　　　}
　　　　　　　　paths = paths + "/" + subDirectory;
　　　　　　　　start = end + 1;
　　　　　　　　end = directory.indexOf("/", start);
　　　　　　　　// 检查所有目录是否创建完毕
　　　　　　　　if (end <= start) {
　　　　　　　　　　break;
　　　　　　　　}
　　　　　　}
　　　　}
　　　　return true;
　　}

　　// 判断ftp服务器文件是否存在
　　public boolean existFile(String path) throws IOException {
　　　　boolean flag = false;
　　　　ftpClient.changeWorkingDirectory(path);
　　　　FTPFile[] ftpFileArr = ftpClient.listFiles();
　　　　if (ftpFileArr.length > 0) {
　　　　　　flag = true;
　　　　}
　　　　return flag;
　　}

　　// 创建目录
　　public boolean makeDirectory(String dir) {
　　　　boolean flag = true;
　　　　try {
　　　　　　flag = ftpClient.makeDirectory(dir);
　　　　　　if (flag) {
　　　　　　　　System.out.println("创建文件夹" + dir + " 成功！");

　　　　　　} else {
　　　　　　　　System.out.println("创建文件夹" + dir + " 失败！");
　　　　　　}
　　　　} catch (Exception e) {
　　　　　　e.printStackTrace();
　　　　}
　　　　return flag;
　　}

　　/**
  　　* 下载文件 *
　　  *
　　  * @param pathName FTP服务器文件目录 *
　　  * @param fileName 文件名称 *
　　  * @param localpath 下载后的文件路径 *
　　  * @return
　　  */
　　public boolean downloadFile(String pathName, String fileName, String localpath) {
　　　　boolean flag = false;
　　　　OutputStream os = null;
　　　　try {
　　　　　　System.out.println("开始下载文件");
　　　　　　// initFtpClient();
　　　　　　// 切换FTP目录
　　　　　　ftpClient.changeWorkingDirectory(pathName);
　　　　　　FTPFile[] ftpFiles = ftpClient.listFiles();
　　　　　　for (FTPFile file : ftpFiles) {
　　　　　　　　if (fileName.equalsIgnoreCase(file.getName())) {
　　　　　　　　　　//如果该目录下有同名文件,则执行删除操作.
　　　　　　　　　　if (new File(localpath + "/" + file.getName()).exists()) {
　　　　　　　　　　　　new File(localpath + "/" + file.getName()).delete();
　　　　　　　　　　}

　　　　　　　　　　File localFile = new File(localpath + "/" + file.getName());
　　　　　　　　　　os = new FileOutputStream(localFile);
　　　　　　　　　　ftpClient.retrieveFile(file.getName(), os);
　　　　　　　　　　os.close();
　　　　　　　　}
　　　　　　}
　　　　　　ftpClient.logout();
　　　　　　flag = true;
　　　　　　System.out.println("下载文件成功");
　　　　} catch (Exception e) {
　　　　　　System.out.println("下载文件失败");
　　　　　　e.printStackTrace();
　　　　} finally {

　　　　}
　　　　return flag;
　　}

　　/**
　　  * @return
　　  * @description: 关闭相关流操作方法
　　  * @exception:
　　  * @date: 2019/6/17 15:50
　　  * @version: 1.0
　　  */
　　private void close(FTPClient ftpClient, OutputStream out, InputStream in) {
　　　　if (ftpClient.isConnected()) {
　　　　　　try {
　　　　　　　　ftpClient.disconnect();
　　　　　　} catch (IOException e) {
　　　　　　　　e.printStackTrace();
　　　　　　}
　　　　}
　　　　if (null != out) {
　　　　　　try {
　　　　　　　　out.close();
　　　　　　} catch (IOException e) {
　　　　　　　　e.printStackTrace();
　　　　　　}
　　　　}
　　　　if (null != in) {
　　　　　　try {
　　　　　　　　in.close();
　　　　　　} catch (IOException e) {
　　　　　　　　e.printStackTrace();
　　　　　　}
　　　　}
　　}

　　/**
　　  * 删除文件 *
　　  *
　　  * @param pathName FTP服务器保存目录 *
　　  * @param fileName 要删除的文件名称 *
　　  * @return
　　  */
　　public boolean deleteFile(String pathName, String fileName) {
　　　　boolean flag = false;
　　　　try {
　　　　　　System.out.println("开始删除文件");
　　　　　　// initFtpClient();
　　　　　　// 切换FTP目录
　　　　　　ftpClient.changeWorkingDirectory(pathName);
　　　　　　ftpClient.dele(fileName);
　　　　　　ftpClient.logout();
　　　　　　flag = true;
　　　　　　System.out.println("删除文件成功");
　　　　} catch (Exception e) {
　　　　　　System.out.println("删除文件失败");
　　　　　　e.printStackTrace();
　　　　} finally {
　　　　　　this.close(ftpClient, null, null);
　　　　}
　　　　return flag;
　　}
}