向ftp服务端上传文件和文件夹-20151201

碧秋8249

import java.io.File;  
import java.io.FileInputStream;  
import java.util.Map;

import org.apache.commons.net.ftp.FTPClient;  
import org.apache.commons.net.ftp.FTPReply;

import com.sitech.ismp.coll.busi.e2e.rule.AnalysisRule;

/**
* @author smj
* */
    public class upToFtp extends AnalysisRule {

public upToFtp(Map<String, String> params) {
super(params);
// TODO Auto-generated constructor stub
}

private  FTPClient ftp;   
        /**
         * Description: 向FTP服务器上传文件夹
         * @param path 上传到ftp服务器哪个路径下   
         * @param url  FTP服务器地址
         * @param port 端口号
         * @param username 用户名
         * @param password 密码
         * @author smj
         * @throws Exception
         */   
        private  boolean connect(String path,String url,int port,String username,String password) throws Exception {   
            boolean result = false;   
            ftp = new FTPClient();   
            int reply;   
            ftp.connect(url,port);   
            ftp.login(username,password);   
            ftp.setFileType(FTPClient.BINARY_FILE_TYPE);   
            reply = ftp.getReplyCode();   
            if (!FTPReply.isPositiveCompletion(reply)) {   
                ftp.disconnect();   
                return result;   
            }   
            boolean flag4=ftp.changeWorkingDirectory(path);  
            logger.info("切换工作目录："+flag4+"所要切换的路径："+path);
            result = true;   
            return result;   
        }   
        /**
         *  
         * @param file 上传的文件或文件夹
         * @throws Exception
         */
        private boolean upload(File file) throws Exception{   
            if(file.isDirectory()){         
                //ftp.makeDirectory(file.getName());              
                ftp.changeWorkingDirectory(file.getPath());   
                String[] files = file.list();  
                logger.info("文件列表有："+files.toString() );
                for (int i = 0; i < files.length; i++) {   
                    File file1 = new File(files);  
                    logger.info("我端的文件名："+file1.getName() + "\t"  );
                    if(file1.isDirectory()){   
                        upload(file1);   
                        ftp.changeToParentDirectory();   
                    }else{                  
                        File file2 = new File(files);
                        logger.info("文件名："+file2.getName() + "\t"  );
                        FileInputStream input = new FileInputStream(file1);   
                        boolean flag3= ftp.storeFile(file2.getName(), input);
                        logger.info("文件传输状态"+flag3);
                        input.close();                          
                    }               
                }   
            }else{   
                File file2 = new File(file.getPath());   
                FileInputStream input = new FileInputStream(file2);   
                ftp.storeFile(file2.getName(), input);   
                input.close();      
            }
return true;   
        }
        
        /**
         * 移动指定文件或文件夹(包括所有文件和子文件夹)
         *  
         * @param fromDir
         *            要移动的文件或文件夹
         * @param toDir
         *            目标文件夹
         * @throws Exception
         */   
        public void MoveFolderAndFileWithSelf(String from, String to) throws Exception {  
            try {  
                File dir = new File(from);  
               
                to +=  File.separator + dir.getName();  
                File moveDir = new File(to);  
                if(dir.isDirectory()){  
                    if (!moveDir.exists()) {  
                        moveDir.mkdirs();  
                    }  
                }else{  
                    File tofile = new File(to);  
                    dir.renameTo(tofile);  
                    return;  
                }  
                  
                //System.out.println("dir.isDirectory()"+dir.isDirectory());  
                //System.out.println("dir.isFile():"+dir.isFile());  
                  
             // 文件一览   
                File[] files = dir.listFiles();  
                if (files == null)  
                    return;  
      
                // 文件移动  
                for (int i = 0; i < files.length; i++) {  
                    System.out.println("文件名："+files.getName());  
                    if (files.isDirectory()) {  
                        MoveFolderAndFileWithSelf(files.getPath(), to);  
                     // 成功，删除原文件  
                        files.delete();  
                    }  
                    File moveFile = new File(moveDir.getPath() + File.separator + files.getName());  
                 // 目标文件夹下存在的话，删除  
                    if (moveFile.exists()) {  
                        moveFile.delete();  
                    }  
                    files.renameTo(moveFile);  
                }  
                //dir.delete();  
            } catch (Exception e) {  
                throw e;  
            }  
        }  
        
        protected void excute()  {
        logger.info("upToFtp start........");
      try {
  boolean flag1=connect("/ibnmsftp", "10.145.206.133", 21, "ibnmsftp", "ibnmsftp#2012");
  logger.info("连接对端ftp状态为：："+flag1 + "\t"  );
          File file = new File("/iBNMSConsole/ismp/CRM_DATA/");  
          logger.info("文件路径为："+file.getPath() + "文件名字为：" +file.getName()+ "\t"  );
          boolean flag= upload(file);
          logger.info("文件上传状态为："+flag + "\t"  );
          if(flag==true){
          MoveFolderAndFileWithSelf("/iBNMSConsole/ismp/CRM_DATA/","/iBNMSConsole/ismp/CRM_HIS/");
           }
          logger.info("upToFtp end........");
      } catch (Exception e) {
  // TODO Auto-generated catch block
  e.printStackTrace();
  logger.info("上传文件出错");
  
  }
      }  
    }