快捷導(dǎo)航

Java通過(guò)FTP服務(wù)器上傳下載文件的方法

更新時(shí)間：2015年07月23日 16:05:11 作者：genuinecx

本文介紹了如何使用Apache Jakarta Commons Net（commons-net-3.3.jar）基于FileZilla Server服務(wù)器實(shí)現(xiàn)FTP服務(wù)器上文件的上傳/下載/刪除等操作，需要的朋友可以參考下

對(duì)于使用文件進(jìn)行交換數(shù)據(jù)的應(yīng)用來(lái)說(shuō)，使用FTP 服務(wù)器是一個(gè)很不錯(cuò)的解決方案。

關(guān)于FileZilla Server服務(wù)器的詳細(xì)搭建配置過(guò)程，詳情請(qǐng)見(jiàn)FileZilla Server安裝配置教程。之前有朋友說(shuō)，上傳大文件（幾百M(fèi)以上的文件）到FTP服務(wù)器時(shí)會(huì)重現(xiàn)無(wú)法重命名的問(wèn)題，但本人親測(cè)上傳2G的文件到FileZilla Server都沒(méi)有該問(wèn)題，朋友們可以放心使用該代碼。

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服務(wù)器地址
   * @param port  FTP服務(wù)器端口號(hào)
   * @param username  FTP登錄帳號(hào)
   * @param password  FTP登錄密碼
   * @param pathname  FTP服務(wù)器保存目錄
   * @param fileName  上傳到FTP服務(wù)器后的文件名稱
   * @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服務(wù)器
      ftpClient.connect(hostname, port);
      //登錄FTP服務(wù)器
      ftpClient.login(username, password);
      //是否成功登錄FTP服務(wù)器
      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;
  }
   
   
  /**
   * 上傳文件（可對(duì)文件進(jìn)行重命名）
   * @param hostname FTP服務(wù)器地址
   * @param port  FTP服務(wù)器端口號(hào)
   * @param username  FTP登錄帳號(hào)
   * @param password  FTP登錄密碼
   * @param pathname  FTP服務(wù)器保存目錄
   * @param filename  上傳到FTP服務(wù)器后的文件名稱
   * @param originfilename 待上傳文件的名稱（絕對(duì)地址）
   * @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;
  }
   
  /**
   * 上傳文件（不可以進(jìn)行文件的重命名操作）
   * @param hostname FTP服務(wù)器地址
   * @param port  FTP服務(wù)器端口號(hào)
   * @param username  FTP登錄帳號(hào)
   * @param password  FTP登錄密碼
   * @param pathname  FTP服務(wù)器保存目錄
   * @param originfilename 待上傳文件的名稱（絕對(duì)地址）
   * @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服務(wù)器地址
   * @param port  FTP服務(wù)器端口號(hào)
   * @param username  FTP登錄帳號(hào)
   * @param password  FTP登錄密碼
   * @param pathname  FTP服務(wù)器保存目錄
   * @param filename  要?jiǎng)h除的文件名稱
   * @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服務(wù)器
      ftpClient.connect(hostname, port);
      //登錄FTP服務(wù)器
      ftpClient.login(username, password);
      //驗(yàn)證FTP服務(wù)器是否登錄成功
      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服務(wù)器地址
   * @param port  FTP服務(wù)器端口號(hào)
   * @param username  FTP登錄帳號(hào)
   * @param password  FTP登錄密碼
   * @param pathname  FTP服務(wù)器文件目錄
   * @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服務(wù)器
      ftpClient.connect(hostname, port);
      //登錄FTP服務(wù)器
      ftpClient.login(username, password);
      //驗(yàn)證FTP服務(wù)器是否登錄成功
      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);
  }
 
}

以上是本文的全部?jī)?nèi)容，希望大家喜歡。

您可能感興趣的文章: