本文主要介紹如何使用Apache工具集commons-net提供的ftp工具實現向ftp伺服器上傳和下載檔案。

一、準備

需要引用commons-net-3.5.jar包。

• 使用maven匯入:

<dependency>
    <groupId>commons-net</groupId>
    <artifactId>commons-net</artifactId>
    <version>3.5</version>
</dependency>

• 手動下載：

二、連線FTP Server

    /**
     * 連線FTP Server
     * @throws IOException
     */
    public static final String ANONYMOUS_USER="anonymous";
    private FTPClient connect(){        
        FTPClient client = new FTPClient();
        try{
            //連線FTP Server
            client.connect(this.host, this.port);
            //登陸
 

            if(this.user==null||"".equals(this.user)){
                //使用匿名登陸
                client.login(ANONYMOUS_USER, ANONYMOUS_USER);
            }else{
                client.login(this.user, this.password);
            }
            //設定檔案格式
            client.setFileType(FTPClient.BINARY_FILE_TYPE);
            //獲取FTP Server 應答
 

            int reply = client.getReplyCode();
            if(!FTPReply.isPositiveCompletion(reply)){
                client.disconnect();
                return null;
            }
            //切換工作目錄
            changeWorkingDirectory(client);
            System.out.println("===連線到FTP："+host+":"+port);
        }catch(IOException e){
            return null;
        }
        return client;
    }
    /**
     * 切換工作目錄，遠端目錄不存在時，建立目錄
     * @param client
     * @throws IOException
     */
    private void changeWorkingDirectory(FTPClient client) throws IOException{
        if(this.ftpPath!=null&&!"".equals(this.ftpPath)){
            boolean ok = client.changeWorkingDirectory(this.ftpPath);
            if(!ok){
                //ftpPath 不存在，手動建立目錄
                StringTokenizer token = new StringTokenizer(this.ftpPath,"\\//");
                while(token.hasMoreTokens()){
                    String path = token.nextToken();
                    client.makeDirectory(path);
                    client.changeWorkingDirectory(path);
                }
            }
        }
    }
    /**
     * 斷開FTP連線
     * @param ftpClient
     * @throws IOException
     */
    public void close(FTPClient ftpClient) throws IOException{
        if(ftpClient!=null && ftpClient.isConnected()){
            ftpClient.logout();
            ftpClient.disconnect();
        }
        System.out.println("!!!斷開FTP連線："+host+":"+port);
    }

host：ftp伺服器ip地址
port：ftp伺服器埠
user：登陸使用者
password：登陸密碼
登陸使用者為空時，使用匿名使用者登陸。
ftpPath：ftp路徑，ftp路徑不存在時自動建立，如果是多層目錄結構，需要迭代建立目錄。

三、上傳檔案

    /**
     * 上傳檔案
     * @param targetName 上傳到ftp檔名
     * @param localFile 本地檔案路徑
     * @return
     */
    public boolean upload(String targetName,String localFile){
        //連線ftp server
        FTPClient ftpClient = connect();

        if(ftpClient==null){
            System.out.println("連線FTP伺服器["+host+":"+port+"]失敗！");
            return false;
        }
        File file = new File(localFile);
        //設定上傳後文件名
        if(targetName==null||"".equals(targetName))
            targetName = file.getName();
        FileInputStream fis = null;
        try{
            long now = System.currentTimeMillis();
            //開始上傳檔案
            fis = new FileInputStream(file);
            System.out.println(">>>開始上傳檔案："+file.getName());
            boolean ok = ftpClient.storeFile(targetName, fis);
            if(ok){//上傳成功
                long times = System.currentTimeMillis() - now;
                System.out.println(String.format(">>>上傳成功：大小：%s,上傳時間：%d秒", formatSize(file.length()),times/1000));
            }else//上傳失敗
                System.out.println(String.format(">>>上傳失敗：大小：%s", formatSize(file.length())));
        }catch(IOException e){
            System.err.println(String.format(">>>上傳失敗：大小：%s", formatSize(file.length())));
            e.printStackTrace();
            return false;
        }finally{
            try{
                if(fis!=null)
                    fis.close();
                close(ftpClient);
            }catch(Exception e){}
        }
        return true;
    }

四、下載檔案

    /**
     * 下載檔案
     * @param localPath 本地存放路徑
     * @return
     */
    public int download(String localPath){
        //  連線ftp server
        FTPClient ftpClient = connect();
        if(ftpClient==null){
            System.out.println("連線FTP伺服器["+host+":"+port+"]失敗！");
            return 0;
        }

        File dir = new File(localPath);
        if(!dir.exists())
            dir.mkdirs();
        FTPFile[] ftpFiles = null;
        try{
            ftpFiles = ftpClient.listFiles();
            if(ftpFiles==null||ftpFiles.length==0)
                return 0;
        }catch(IOException e){
            return 0;
        }
        int c = 0;
        for(int i=0;i<ftpFiles.length;i++){
            FileOutputStream fos = null;
            try{
                String name = ftpFiles[i].getName();
                fos = new FileOutputStream(new File(dir.getAbsolutePath()+File.separator+name));
                System.out.println("<<<開始下載檔案："+name);

                long now = System.currentTimeMillis();
                boolean ok = ftpClient.retrieveFile(new String(name.getBytes("UTF-8"),"ISO-8859-1"), fos);
                if(ok){//下載成功
                    long times = System.currentTimeMillis() - now;
                    System.out.println(String.format("<<<下載成功：大小：%s,上傳時間：%d秒", formatSize(ftpFiles[i].getSize()),times/1000));
                    c++;
                }else{
                    System.out.println("<<<下載失敗");
                }
            }catch(IOException e){
                System.err.println("<<<下載失敗");
                e.printStackTrace();
            }finally{
                try{
                    if(fos!=null)
                        fos.close();
                    close(ftpClient);
                }catch(Exception e){}
            }
        }
        return c;
    }

格式化檔案大小

private static final DecimalFormat DF = new DecimalFormat("#.##");
    /**
     * 格式化檔案大小（B，KB，MB，GB）
     * @param size
     * @return
     */
    private String formatSize(long size){
        if(size<1024){
            return size + " B";
        }else if(size<1024*1024){
            return size/1024 + " KB";
        }else if(size<1024*1024*1024){
            return (size/(1024*1024)) + " MB";
        }else{
            double gb = size/(1024*1024*1024);
            return DF.format(gb)+" GB";
        }
    }

五、測試

public static void main(String args[]){
        FTPTest ftp = new FTPTest("192.168.1.10",21,null,null,"/temp/2016/12");
        ftp.upload("newFile.rar", "D:/ftp/TeamViewerPortable.rar");
        System.out.println("");
        ftp.download("D:/ftp/");
    }

結果

===連線到FTP：192.168.1.10:21
>>>開始上傳檔案：TeamViewerPortable.rar
>>>上傳成功：大小：5 MB,上傳時間：3秒
!!!斷開FTP連線：192.168.1.10:21

===連線到FTP：192.168.1.10:21
<<<開始下載檔案：newFile.rar
<<<下載成功：大小：5 MB,上傳時間：4秒
!!!斷開FTP連線：192.168.1.10:21