论坛 › FTP服务器 › FTP文件的下载

ndlli 发表于 2015-5-28 13:31:24

FTP文件的下载

　　官方文档：http://commons.apache.org/net/api-3.1/org/apache/commons/net/ftp/package-summary.html
　　package com.iengine.data.filter;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.FilterConfig;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
public class LogFilter implements Filter{
　 /**
   * 从187,195服务器上拉日志文件
   */
    public void init(FilterConfig filterConfig) throws ServletException{
      String path187 = "E:\\www.360iii.com\\WebLog\\log187\\";
      String path195 = "E:\\www.360iii.com\\WebLog\\log195\\";
      FTPClient client = new FTPClient();
      client.setControlEncoding("UTF-8");
      try {
            /**
             * 连接187服务器
             */
            client.connect("ip");
            client.login("user", "password");
            System.out.println("ip:Login\t FTP Statu:" + client.getReplyCode() + "\tFTP Success:" + client.getReplyString());
            
            FTPFile[] files187 = client.listFiles("");
            System.out.println(files187.length);
            byte filesFlag[] = new byte;
            System.out.println(filesFlag.length);
            
            File directory187 = new File(path187);
            if(directory187.isDirectory()){
                File[] localFiles187 = directory187.listFiles();
//                for(int i = 0; i < localFiles187.length; i ++){
//                  System.out.println("本地文件：" + i + "---" + localFiles187.getName());
//                }
                System.out.println("localFiles187 size:" + localFiles187.length);
                for(int i = 0; i < files187.length; i ++ ){
//                  System.out.println(files187.getName());
                  for(int j = 0; j < localFiles187.length; j ++ ){
//                        System.out.println(localFiles187.getName());
                        if(localFiles187.getName().equals(files187.getName())){
                            filesFlag = 1;
//                            System.out.println("标记位置:" + filesFlag);
//                            System.out.println(files187.getName() + "在本地存在，标记不下载！");
                            break;
                        }
                  }
                }
                for(int i = 0; i < files187.length; i ++ ){
                  if(filesFlag == 0){
                        File log = new File(path187 + files187.getName());
                        boolean flag = client.retrieveFile(files187.getName(), new FileOutputStream(log));
                        System.out.println("ip Log Download:" + log.getName() + "\t Success:" + flag + "\t FTP Statu:" + client.getReplyCode() + "\t FTP Connetion:" + client.getReplyString());
                  }
                }
            }
            client.disconnect();
            System.out.println("ip Download Complete! Exit 187 " + client.getReplyCode() + " " + client.getReplyString());
            
            /**
             * 连接195服务器
             */
            client.connect("ip");
            client.login("user", "password");
            System.out.println("ip:Login\t FTP Statu:" + client.getReplyCode() + "\tFTP Success:" + client.getReplyString());
            System.out.println();
            
            FTPFile[] files195 = client.listFiles("");
            byte filesFlag195[] = new byte;
            
            File directory195 = new File(path195);
            if(directory195.isDirectory()){
                File[] localFiles195 = directory195.listFiles();
//                for(int i = 0; i < localFiles195.length; i ++){
//                  System.out.println(localFiles195.getName());
//                }
                for(int i = 0; i < files195.length; i ++ ){
//                  System.out.println(files195.getName());
                  for(int j = 0; j < localFiles195.length; j ++ ){
//                        System.out.println(localFiles195.getName());
                        if(localFiles195.getName().equals(files195.getName())){
                            filesFlag195 = 1;
//                            System.out.println(filesFlag195);
//                            System.out.println(files195.getName() + "在本地存在，标记不下载！");
                            break;
                        }
                  }
                }
                for(int i = 0; i < files195.length; i ++ ){
                  if(filesFlag195 == 0){
                        File log = new File(path195 + files195.getName());
                        boolean flag = client.retrieveFile(files195.getName(), new FileOutputStream(log));
                        System.out.println("ip Log Download:" + log.getName() + "\t Success:" + flag + "\t FTP Statu:" + client.getReplyCode() + "\t FTP Connetion:" + client.getReplyString());
                  }
                }
            }
            client.disconnect();
            System.out.println("ip Download Complete! Exit 195" + client.getReplyCode() + " " + client.getReplyString());
      } catch (IOException e) {
            e.printStackTrace();
      }
    }
    /**
   * 重写Filter接口的 destroy()方法
   */
    public void destroy() {
    }
    /**
   * 重写Filter接口的 doFilter(ServletRequest request, ServletResponse response,FilterChain chain)方法
   */
    public void doFilter(ServletRequest request, ServletResponse response,
            FilterChain chain) throws IOException, ServletException {
    }
}
注：在项目布署时，检测本地文件是否和服务器上的文件相同，如果有不同的文件就从服务器上拉文件

查看完整版本: FTP文件的下载