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