Java通过FTP服务器上传下载文件的方法

 更新时间:2015年07月23日 16:05:11   作者:genuinecx  
本文介绍了如何使用Apache Jakarta Commons Net(commons-net-3.3.jar)基于FileZilla Server服务器实现FTP服务器上文件的上传/下载/删除等操作,需要的朋友可以参考下

对于使用文件进行交换数据的应用来说,使用FTP 服务器是一个很不错的解决方案。

关于FileZilla Server服务器的详细搭建配置过程,详情请见FileZilla Server安装配置教程。之前有朋友说,上传大文件(几百M以上的文件)到FTP服务器时会重现无法重命名的问题,但本人亲测上传2G的文件到FileZilla Server都没有该问题,朋友们可以放心使用该代码。

FavFTPUtil.Java

package com.favccxx.favsoft.util;
 
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 org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
 
public class FavFTPUtil {
   
  /**
   * 上传文件(可供Action/Controller层使用)
   * @param hostname FTP服务器地址
   * @param port  FTP服务器端口号
   * @param username  FTP登录帐号
   * @param password  FTP登录密码
   * @param pathname  FTP服务器保存目录
   * @param fileName  上传到FTP服务器后的文件名称
   * @param inputStream 输入文件流
   * @return
   */
  public static boolean uploadFile(String hostname, int port, String username, String password, String pathname, String fileName, InputStream inputStream){
    boolean flag = false;
    FTPClient ftpClient = new FTPClient();
    ftpClient.setControlEncoding("UTF-8");
    try {
      //连接FTP服务器
      ftpClient.connect(hostname, port);
      //登录FTP服务器
      ftpClient.login(username, password);
      //是否成功登录FTP服务器
      int replyCode = ftpClient.getReplyCode();
      if(!FTPReply.isPositiveCompletion(replyCode)){
        return flag;
      }
       
      ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
      ftpClient.makeDirectory(pathname);
      ftpClient.changeWorkingDirectory(pathname);
      ftpClient.storeFile(fileName, inputStream);
      inputStream.close();
      ftpClient.logout();
      flag = true;
    } catch (Exception e) {
      e.printStackTrace();
    } finally{
      if(ftpClient.isConnected()){
        try {
          ftpClient.disconnect();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
    }
    return flag;
  }
   
   
  /**
   * 上传文件(可对文件进行重命名)
   * @param hostname FTP服务器地址
   * @param port  FTP服务器端口号
   * @param username  FTP登录帐号
   * @param password  FTP登录密码
   * @param pathname  FTP服务器保存目录
   * @param filename  上传到FTP服务器后的文件名称
   * @param originfilename 待上传文件的名称(绝对地址)
   * @return
   */
  public static boolean uploadFileFromProduction(String hostname, int port, String username, String password, String pathname, String filename, String originfilename){
    boolean flag = false;
    try {
      InputStream inputStream = new FileInputStream(new File(originfilename));
      flag = uploadFile(hostname, port, username, password, pathname, filename, inputStream);
    } catch (Exception e) {
      e.printStackTrace();
    }
    return flag;
  }
   
  /**
   * 上传文件(不可以进行文件的重命名操作)
   * @param hostname FTP服务器地址
   * @param port  FTP服务器端口号
   * @param username  FTP登录帐号
   * @param password  FTP登录密码
   * @param pathname  FTP服务器保存目录
   * @param originfilename 待上传文件的名称(绝对地址)
   * @return
   */
  public static boolean uploadFileFromProduction(String hostname, int port, String username, String password, String pathname, String originfilename){
    boolean flag = false;
    try {
      String fileName = new File(originfilename).getName();
      InputStream inputStream = new FileInputStream(new File(originfilename));
      flag = uploadFile(hostname, port, username, password, pathname, fileName, inputStream);
    } catch (Exception e) {
      e.printStackTrace();
    }
    return flag;
  }
   
   
  /**
   * 删除文件
   * @param hostname FTP服务器地址
   * @param port  FTP服务器端口号
   * @param username  FTP登录帐号
   * @param password  FTP登录密码
   * @param pathname  FTP服务器保存目录
   * @param filename  要删除的文件名称
   * @return
   */
  public static boolean deleteFile(String hostname, int port, String username, String password, String pathname, String filename){
    boolean flag = false;
    FTPClient ftpClient = new FTPClient();
    try {
      //连接FTP服务器
      ftpClient.connect(hostname, port);
      //登录FTP服务器
      ftpClient.login(username, password);
      //验证FTP服务器是否登录成功
      int replyCode = ftpClient.getReplyCode();
      if(!FTPReply.isPositiveCompletion(replyCode)){
        return flag;
      }
      //切换FTP目录
      ftpClient.changeWorkingDirectory(pathname);
      ftpClient.dele(filename);
      ftpClient.logout();
      flag = true;
    } catch (Exception e) {
      e.printStackTrace();
    } finally{
      if(ftpClient.isConnected()){
        try {
          ftpClient.logout();
        } catch (IOException e) {
         
        }
      }
    }
    return flag;
  }
   
  /**
   * 下载文件
   * @param hostname FTP服务器地址
   * @param port  FTP服务器端口号
   * @param username  FTP登录帐号
   * @param password  FTP登录密码
   * @param pathname  FTP服务器文件目录
   * @param filename  文件名称
   * @param localpath 下载后的文件路径
   * @return
   */
  public static boolean downloadFile(String hostname, int port, String username, String password, String pathname, String filename, String localpath){
    boolean flag = false;
    FTPClient ftpClient = new FTPClient();
    try {
      //连接FTP服务器
      ftpClient.connect(hostname, port);
      //登录FTP服务器
      ftpClient.login(username, password);
      //验证FTP服务器是否登录成功
      int replyCode = ftpClient.getReplyCode();
      if(!FTPReply.isPositiveCompletion(replyCode)){
        return flag;
      }
      //切换FTP目录
      ftpClient.changeWorkingDirectory(pathname);
      FTPFile[] ftpFiles = ftpClient.listFiles();
      for(FTPFile file : ftpFiles){
        if(filename.equalsIgnoreCase(file.getName())){
          File localFile = new File(localpath + "/" + file.getName());
          OutputStream os = new FileOutputStream(localFile);
          ftpClient.retrieveFile(file.getName(), os);
          os.close();
        }
      }
      ftpClient.logout();
      flag = true;
    } catch (Exception e) {
      e.printStackTrace();
    } finally{
      if(ftpClient.isConnected()){
        try {
          ftpClient.logout();
        } catch (IOException e) {
         
        }
      }
    }
    return flag;
  }
 
}

FavFTPUtilTest.java

package com.favccxx.favsoft.util;
 
import junit.framework.TestCase;
 
public class FavFTPTest extends TestCase {
   
  public void testFavFTPUtil(){
    String hostname = "127.0.0.1";
    int port = 21;
    String username = "business";
    String password = "business";
    String pathname = "business/ebook"; 
    String filename = "big.rar"; 
    String originfilename = "C:\\Users\\Downloads\\Downloads.rar";
    FavFTPUtil.uploadFileFromProduction(hostname, port, username, password, pathname, filename, originfilename);
//   String localpath = "D:/";
     
//   FavFTPUtil.downloadFile(hostname, port, username, password, pathname, filename, localpath);
  }
 
}

以上是本文的全部内容,希望大家喜欢。

相关文章

  • 使用Digester解析XML文件的三种方式小结

    使用Digester解析XML文件的三种方式小结

    Digester是apache开源项目Commons中的一个子项目,用于解析XML文档的工具,本文为大家整理了Digester解析XML文件的三种方式,希望对大家有所帮助
    2024-01-01
  • 深入理解Java设计模式之适配器模式

    深入理解Java设计模式之适配器模式

    这篇文章主要介绍了JAVA设计模式之适配器模式的的相关资料,文中示例代码非常详细,供大家参考和学习,感兴趣的朋友可以了解
    2021-11-11
  • SpringBoot如何读取配置文件参数并全局使用

    SpringBoot如何读取配置文件参数并全局使用

    这篇文章主要介绍了SpringBoot如何读取配置文件参数并全局使用,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-12-12
  • MybatisPlus操作符和运算值详解

    MybatisPlus操作符和运算值详解

    在前端到后端的数据传递中,处理动态运算条件是一个常见的需求,本文介绍了如何在MybatisPlus中处理运算符和运算值的动态拼接问题,感兴趣的朋友一起看看吧
    2024-10-10
  • java求解集合的子集的实例

    java求解集合的子集的实例

    这篇文章主要介绍了 java求解集合的子集的实例的相关资料,希望通过本文能帮助到大家,让大家掌握这样的方法,需要的朋友可以参考下
    2017-10-10
  • Java8中的Lambda表达式理解与使用示例详解

    Java8中的Lambda表达式理解与使用示例详解

    Lambda表达式是Java8引入的一种简洁写法,用于实现函数式接口,可以简化匿名函数的代码,本文给大家介绍Java8中的Lambda表达式理解与使用示例,感兴趣的朋友一起看看吧
    2024-11-11
  • java多线程累加计数的实现方法

    java多线程累加计数的实现方法

    在多线程协作任务中,如何计算也是很重的,这篇文章主要介绍了java多线程累加计数的实现方法,感兴趣的朋友可以了解一下
    2021-05-05
  • mybatis 在typeAliases别名时报错的解决

    mybatis 在typeAliases别名时报错的解决

    这篇文章主要介绍了mybatis 在typeAliases别名时报错的解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-09-09
  • JAVA中Collections工具类sort()排序方法

    JAVA中Collections工具类sort()排序方法

    这篇文章主要介绍了JAVA中Collections工具类sort()排序方法,非常具有实用价值,需要的朋友可以参考下。
    2016-11-11
  • Spring Boot整合Bootstrap的超详细步骤

    Spring Boot整合Bootstrap的超详细步骤

    之前做前端开发,在使用bootstrap的时候都是去官网下载,然后放到项目中,在页面引用,下面这篇文章主要给大家介绍了关于Spring Boot整合Bootstrap的超详细步骤,需要的朋友可以参考下
    2023-05-05

最新评论