Java利用apache ftp工具实现文件上传下载和删除功能

利用apache ftp工具实现文件的上传下载和删除，具体如下

1、下载相应的jar包

     commons-net-1.4.1.jar

2、实现代码如下：

public class FtpUtils {
   //ftp服务器地址
   public String hostname = "192.168.1.249";
   //ftp服务器端口号默认为21
   public Integer port = 21 ;
   //ftp登录账号
   public String username = "root";
   //ftp登录密码
   public String password = "123";

public FTPClient ftpClient = null;

/**
    * 初始化ftp服务器
    */
   public void initFtpClient() {
     ftpClient = new FTPClient();
     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){
     boolean flag = false;
     InputStream inputStream = null;
     try{
       System.out.println("开始上传文件");
       inputStream = new FileInputStream(new File(originfilename));
       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{
       if(ftpClient.isConnected()){  
         try{
           ftpClient.disconnect();
         }catch(IOException e){
           e.printStackTrace();
         }
       }  
       if(null != inputStream){
         try {
           inputStream.close();
         } catch (IOException e) {
           e.printStackTrace();
         }  
       }  
     }
     return true;
   }
   /**
    * 上传文件
    * @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{
       if(ftpClient.isConnected()){  
         try{
           ftpClient.disconnect();
         }catch(IOException e){
           e.printStackTrace();
         }
       }  
       if(null != inputStream){
         try {
           inputStream.close();
         } catch (IOException e) {
           e.printStackTrace();
         }  
       }  
     }
     return true;
   }
   //改变目录路径
    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 {
     boolean success = true;
     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 success;
   }

//判断ftp服务器文件是否存在  
   public boolean existFile(String path) throws IOException {
       boolean flag = false;
       FTPFile[] ftpFileArr = ftpClient.listFiles(path);
       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())){  
           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{  
       if(ftpClient.isConnected()){  
         try{
           ftpClient.disconnect();
         }catch(IOException e){
           e.printStackTrace();
         }
       }  
       if(null != os){
         try {
           os.close();
         } catch (IOException e) {
           e.printStackTrace();
         }  
       }  
     }  
     return flag;  
   }

/** * 删除文件 *
   * @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 {
       if(ftpClient.isConnected()){  
         try{
           ftpClient.disconnect();
         }catch(IOException e){
           e.printStackTrace();
         }
       }  
     }
     return flag;  
   }

public static void main(String[] args) {
     FtpUtils ftp =new FtpUtils();  
     //ftp.uploadFile("ftpFile/data", "123.docx", "E://123.docx");
     //ftp.downloadFile("ftpFile/data", "123.docx", "F://");
     ftp.deleteFile("ftpFile/data", "123.docx");
     System.out.println("ok");
   }
}

来源：https://blog.csdn.net/liu_yulong/article/details/80633281