ftp下載文件

import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;

public class FtpUtil {

    private static final Logger logger= LoggerFactory.getLogger(FtpUtil.class);
    //ftp服務器地址
    @Value("${ftp.hostname}")
    public String hostname;
    //ftp服務器端口號
    @Value("${ftp.port}")
    public String port;
    //ftp登錄賬號
    @Value("${ftp.username}")
    public String username;
    //ftp登錄密碼
    @Value("${ftp.password}")
    public String password;
    private FTPClient ftpClient = null;
    private OutputStream os = null;
    /**
     * FTP下載文件
     * @param pathname 目標文件目錄路徑
     * @param filename 文件名稱（帶后綴）
     * @param localpath 本地存放路徑
     * @return
     */
    public boolean downloadFile(String pathname, String filename, String localpath) {
        boolean flag = false;
        try {
            LOGGER.info("開始下載文件");
            getFtpClient();
            // ftpClient.enterLocalActiveMode();// 主動模式
            ftpClient.enterLocalPassiveMode();// 被動模式
            ftpClient.changeWorkingDirectory(pathname);
            //讀取文件
     　　　　　　 FTPFile[] ftpFiles = ftpClient.listFiles();
            for(FTPFile file : ftpFiles) {
                if (filename.equalsIgnoreCase(file.getName())) {
                    File localFile = new File(localpath);
                    if (!localFile.exists()){
                        localFile.mkdirs();
                    }
                    localFile = new File(localpath + File.separator + file.getName());
                    os = new FileOutputStream(localFile);
                    ftpClient.retrieveFile(file.getName(), os);
                    os.close();
                }
            }
            ftpClient.logout();
            flag = true;
            logger.info("下載文件成功");
        } catch (Exception e) {
            logger.info("下載文件失敗，失敗原因：" + e.getMessage(), e);
        } finally {
            close();
        }
        return flag;
    }

    private FTPClient getFtpClient() {
        ftpClient = new FTPClient();
        ftpClient.setControlEncoding("utf-8");
        try {
            logger.info("connecting...ftp server:" + this.hostname + ":" + this.port);
            ftpClient.connect(hostname, Integer.valueOf(port)); //連接ftp服務器
            ftpClient.login(username, password); //登錄ftp服務器
            ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
            int replyCode = ftpClient.getReplyCode(); //是否成功登錄服務器
            if (!FTPReply.isPositiveCompletion(replyCode)) {
                logger.info("connect failed...ftp server:" + this.hostname + ":" + this.port);
            }
            logger.info("connect success...ftp server:" + this.hostname + ":" + this.port);
        } catch (Exception e) {
            logger.error("初始化FTP客戶端失敗原因：" + e.getMessage(), e);
        }
        return ftpClient;
    }

    private void close(){
        if (ftpClient.isConnected()) {
            try {
                ftpClient.disconnect();
            } catch (IOException e) {
            }
        }
        if (null != os) {
            try {
                os.close();
            } catch (IOException e) {
            }
        }
    }
}

FTP使用了兩個端口, 一個數據端口和一個命令端口(或稱為控制端口)。通常21端口是命令端口，20端口是數據端口。當混入主動/被動模式的概念時，數據端口就有可能不是20了。

主動模式：PORT中文稱為主動模式，工作的原理： FTP客戶端連接到FTP服務器的21端口，發送用戶名和密碼登錄，登錄成功后要list列表或者讀取數據時，客戶端隨機開放一個端口（1024以上），發送 PORT命令到FTP服務器，告訴服務器客戶端采用主動模式並開放端口；FTP服務器收到PORT主動模式命令和端口號后，通過服務器的20端口和客戶端開放的端口連接，發送數據，原理如下圖：

 

被動模式：PASV是Passive的縮寫，中文成為被動模式，工作原理：FTP客戶端連接到FTP服務器的21端口，發送用戶名和密碼登錄，登錄成功后要list列表或者讀取數據時，發送PASV命令到FTP服務器， 服務器在本地隨機開放一個端口（1024以上），然后把開放的端口告訴客戶端， 客戶端再連接到服務器開放的端口進行數據傳輸，原理如下圖：

參考文章：http://my.oschina.net/binny/blog/17469