ftp 根據特定正則匹配文件名 下載到本地 並且上傳文件到ftp java *** 最愛那水貨

    /**
     *  建立FTP鏈接，FTP服務器地址、端口、登陸用戶信息都在配置里配置即可。
     * @throws IOException
     */
    public  boolean connectFtp(String ftpAddress, String ftpPort, String frpUserName, String frpPassword) throws IOException{
        log.info("*****連接FTP服務器...*****");
        try{
            ftpClient.connect(ftpAddress, Integer.valueOf(ftpPort).intValue());
            ftpClient.setControlEncoding("GB2312");
            int reply = ftpClient.getReplyCode();
            if(FTPReply.isPositiveCompletion(reply)){
                if(ftpClient.login(frpUserName,frpPassword)){
                    log.info("*****連接FTP服務器成功！*****");
                    return true;
                }
            }else{
                log.error("*****連接失敗!響應代碼為【"+ reply+"】*****");
            }
            disconnect();
        }catch (Exception e) {
            log.error("*****連接失敗：" + e.getMessage());
        }
        return false;
    }
    
    /**
     *  設置FTP客戶端 被動模式、數據模式為二進制、字符編碼GBK
     */
    public  void setConnectType(){
        try {
            ftpClient.enterLocalPassiveMode();
            ftpClient.setDefaultTimeout(1000 * 120);//120秒
            ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
            ftpClient.setControlEncoding("GB2312");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    
    /**
     * 斷開與遠程服務器的連接
     * @throws IOException
     */
    public  void disconnect() {
        if(ftpClient.isConnected()){
            try {
                ftpClient.disconnect();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    
    /**
     * 過濾不符合的文件並批量下載   
     * @param remoteFileReg 文件前綴的正則表達式
     * @param localPath  本地路徑 .property 文件配置
     * @param remote_down_path ftp文件路徑
     * @return  List 下載到本地的文件路徑 集合
     * @throws IOException
     */
    @SuppressWarnings("unchecked")
    public List downloads(String remoteFileReg,String localPath,String remote_down_path) throws IOException{
        List<String> fileNames = new ArrayList<String>();
        log.info("*****轉移到服務器目錄：" + remote_down_path);
        setConnectType();
        boolean changeFlag = ftpClient.changeWorkingDirectory(remote_down_path);
        FTPFile[] files = ftpClient.listFiles();
        //String[] names = ftpClient.listNames();
        log.info("*****改變目錄是否成功：" + changeFlag);
        log.info("*****服務器上report目錄下所有校驗報告的文件數為：【" +files.length + "】" );
        if(files.length == 0){
            log.info("*****未在服務器上找到文件！*****");
            return null;
        }else{//目錄下有文件
            //把 bak文件的前綴找出來   ，區分讀取和未讀取的xls 和 xlsx ,只下載 未讀取的文件 
            List<String> bakList = new ArrayList<String>();
            List<String> list = new ArrayList<String>();
            
            for (int i = 0; i < files.length; i++) {
                FTPFile ftpFile = files[i];
                String fileName = ftpFile.getName();
                
                if(!fileName.endsWith(".bak") && ftpFile == null){
                    log.info("*******  "+ fileName + "文件無數據!");
                    continue;
                }
                //匹配指定的文件前綴 和后綴 為    .bak 格式的文件
                //bak 文件是文件讀取完畢后生成的標記文件
                Pattern bak = Pattern.compile("^"+remoteFileReg+"\\.bak"); 
                Matcher m = bak.matcher(fileName); 
                if (m.find()) {
                    //取.bak文件的 前綴
                    //System.out.println(fileName);
                    //System.out.println(fileName.split("\\.")[0]);
                    bakList.add(fileName.split("\\.")[0]);
                    continue;
                }
                
                //匹配指定的文件前綴 和后綴 為    .xls   .xlsx 格式的文件
                //TODO 以后遇到其他的格式文件 需要把后綴抽出來作為參數傳入
                Pattern xls = Pattern.compile("^"+remoteFileReg+"\\.xls$"+"|"+"^"+remoteFileReg+"\\.xlsx$"+"|"+"^"+remoteFileReg+"\\.csv$");
                Matcher mm = xls.matcher(fileName);
                if(mm.find()){
                    list.add(fileName);
                    continue;
                }
            }
        
            Iterator<String> it = list.iterator();
            while (it.hasNext()) {
                String xls = it.next();
                for (int i = 0; i < bakList.size(); i++) {
                    String bak = bakList.get(i);
                    //bak文件存在 , 去掉此文件
                    if (xls.indexOf(bak) !=-1) {
                        it.remove();
                        bakList.remove(i);
                    }
                }    
            }

    
            for (String fFile : list) {
                //下載未讀取的文件
                File downFile = new File(localPath + fFile); 
                //System.out.println(localPath);
                File downPath = new File(localPath);
                if(!downPath.exists()){
                    downPath.mkdirs();
                }
                String fileDir = remote_down_path + fFile;
                OutputStream os = new FileOutputStream(downFile);
                ftpClient.retrieveFile(new String(fileDir.getBytes("GB2312"),"ISO-8859-1"), os);
                log.info("*****文件已下載到：" + downFile.getAbsolutePath() + "******");
                fileNames.add(downFile.getAbsolutePath());
                os.close();    
            }
            log.info("**** 此次共下載了【"+list.size()+"】個文件! *****");        
        }
        return fileNames;
    }
    
    /**
     * 上傳標志文件
     * @param remoteFile
     * @param localFile
     * @return
     */
    public boolean upload(String localFileName,String remoteFileName){
        
        boolean b = false;
        try {
            File file = new File(localFileName);      
            FileInputStream input = new FileInputStream(file);
            b = ftpClient.changeWorkingDirectory(remoteFileName);
            log.info("*****改變目錄是否成功：" + b);
            String remoteFile = remoteFileName + file.getName();
            b = ftpClient.storeFile(new String(remoteFile.getBytes("GB2312"),"ISO-8859-1"), input);
            if(b){
                log.info(" ****** 標志文件"+localFileName+"上傳成功!");
            }
            input.close();
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }       
        return b;
    }