package com.why.ftp;      

import java.io.DataInputStream;      
import java.io.File;      
import java.io.FileInputStream;      
import java.io.FileOutputStream;      
import java.io.IOException;      
import java.io.OutputStream;      
import java.util.ArrayList;      
import java.util.List;      
import java.util.StringTokenizer;      
import sun.net.TelnetInputStream;      
import sun.net.TelnetOutputStream;      
import sun.net.ftp.FtpClient;      

/**    
 * ftp上傳，下載    
 * @author why 2009-07-30    
 *    
 */     
public class FtpUtil {      

    private String ip = "";      

    private String username = "";      

    private String password = "";      

    private int port = -1;      

    private String path = "";      

    FtpClient ftpClient = null;      

    OutputStream os = null;      

    FileInputStream is = null;      

    public FtpUtil(String serverIP, String username, String password) {      
        this.ip = serverIP;      
        this.username = username;      
        this.password = password;      
    }      

    public FtpUtil(String serverIP, int port, String username, String password) {      
        this.ip = serverIP;      
        this.username = username;      
        this.password = password;      
        this.port = port;      
    }      

    /**    
     * 連線ftp伺服器    
     *     
     * @throws IOException    
     */     
    public boolean connectServer(){      
        ftpClient = new FtpClient();      
        try {      
            if(this.port != -1){      
                    ftpClient.openServer(this.ip,this.port);      
            }else{      
                ftpClient.openServer(this.ip);      
            }      
            ftpClient.login(this.username, this.password);      
            if (this.path.length() != 0){      
                ftpClient.cd(this.path);// path是ftp服務下主目錄的子目錄                 
            }      
            ftpClient.binary();// 用2進位制上傳、下載      
            System.out.println("已登入到\"" + ftpClient.pwd() + "\"目錄");      
            return true;      
        }catch (IOException e){      
            e.printStackTrace();      
            return false;      
        }      
    }      

    /**    
     * 斷開與ftp伺服器連線    
     *     
     * @throws IOException    
     */     
    public boolean closeServer(){      
        try{      
            if (is != null) {      
                is.close();      
            }      
            if (os != null) {      
                os.close();      
            }      
            if (ftpClient != null) {      
                ftpClient.closeServer();      
            }      
            System.out.println("已從伺服器斷開");      
            return true;      
        }catch(IOException e){      
            e.printStackTrace();      
            return false;      
        }      
    }      

    /**    
     * 檢查資料夾在當前目錄下是否存在    
     * @param dir    
     * @return    
     */     
     private boolean isDirExist(String dir){      
         String pwd = "";      
         try {      
             pwd = ftpClient.pwd();      
             ftpClient.cd(dir);      
             ftpClient.cd(pwd);      
         }catch(Exception e){      
             return false;      
         }      
         return true;       
     }      

    /**    
     * 在當前目錄下建立資料夾    
     * @param dir    
     * @return    
     * @throws Exception    
     */     
     private boolean createDir(String dir){      
         try{      
            ftpClient.ascii();      
            StringTokenizer s = new StringTokenizer(dir, "/"); //sign      
            s.countTokens();      
            String pathName = ftpClient.pwd();      
            while(s.hasMoreElements()){      
                pathName = pathName + "/" + (String) s.nextElement();      
                try {      
                    ftpClient.sendServer("MKD " + pathName + "\r\n");      
                } catch (Exception e) {      
                    e = null;      
                    return false;      
                }      
                ftpClient.readServerResponse();      
            }      
            ftpClient.binary();      
            return true;      
        }catch (IOException e1){      
            e1.printStackTrace();      
            return false;      
        }      
     }      

     /**    
      * ftp上傳    
      * 如果伺服器段已存在名為filename的資料夾，該資料夾中與要上傳的資料夾中同名的檔案將被替換    
      *     
      * @param filename 要上傳的檔案（或資料夾）名    
      * @return    
      * @throws Exception    
      */     
    public boolean upload(String filename){      
        String newname = "";      
        if(filename.indexOf("/") > -1){      
            newname = filename.substring(filename.lastIndexOf("/") + 1);      
        }else{      
            newname = filename;      
        }      
        return upload(filename, newname);      
    }      

     /**    
      * ftp上傳    
      * 如果伺服器段已存在名為newName的資料夾，該資料夾中與要上傳的資料夾中同名的檔案將被替換    
      *     
      * @param fileName 要上傳的檔案（或資料夾）名    
      * @param newName 伺服器段要生成的檔案（或資料夾）名    
      * @return    
      */     
     public boolean upload(String fileName, String newName){      
         try{      
             String savefilename = new String(fileName.getBytes("ISO-8859-1"), "GBK");       
             File file_in = new File(savefilename);//開啟本地待長傳的檔案      
             if(!file_in.exists()){      
                 throw new Exception("此檔案或資料夾[" + file_in.getName() + "]有誤或不存在!");      
             }      
             if(file_in.isDirectory()){      
                 upload(file_in.getPath(),newName,ftpClient.pwd());      
             }else{      
                 uploadFile(file_in.getPath(),newName);      
             }      

             if(is != null){      
                 is.close();      
             }      
             if(os != null){      
                 os.close();      
             }      
             return true;      
         }catch(Exception e){       
                e.printStackTrace();       
                System.err.println("Exception e in Ftp upload(): " + e.toString());       
                return false;      
         }finally{      
             try{      
                 if(is != null){      
                     is.close();      
                 }      
                 if(os != null){       
                     os.close();       
                 }      
             }catch(IOException e){      
                 e.printStackTrace();      
            }       
         }      
     }      

     /**    
      * 真正用於上傳的方法    
      * @param fileName    
      * @param newName    
      * @param path    
      * @throws Exception    
      */     
     private void upload(String fileName, String newName,String path) throws Exception{      
             String savefilename = new String(fileName.getBytes("ISO-8859-1"), "GBK");       
             File file_in = new File(savefilename);//開啟本地待長傳的檔案      
             if(!file_in.exists()){      
                 throw new Exception("此檔案或資料夾[" + file_in.getName() + "]有誤或不存在!");      
             }      
             if(file_in.isDirectory()){      
                 if(!isDirExist(newName)){      
                     createDir(newName);      

相關推薦