apache-commons-net Ftp 进行文件、文件夹的上传下载及日志的输出

时间:2021-07-18 22:30:27

apache-commons-net Ftp 进行文件、文件夹的上传下载及日志的输出

标签: ftp服务器stringfileexception服务器null 12057人阅读 评论(5) 收藏 举报 apache-commons-net Ftp 进行文件、文件夹的上传下载及日志的输出 分类: 

用到了apache 的 commons-net-3.0.1.jar 和 log4j-1.2.15.jar 这连个jar包

Java 代码如下:

[java] view plain copy print?
  1. package com.bjut.edu.cn.ftp;  
  2.   
  3. import java.io.BufferedInputStream;  
  4. import java.io.BufferedOutputStream;  
  5. import java.io.File;  
  6. import java.io.FileInputStream;  
  7. import java.io.FileNotFoundException;  
  8. import java.io.FileOutputStream;  
  9. import java.io.IOException;  
  10. import java.util.TimeZone;  
  11. import org.apache.commons.net.ftp.FTPClient;  
  12. import org.apache.commons.net.ftp.FTPClientConfig;  
  13. import org.apache.commons.net.ftp.FTPFile;  
  14. import org.apache.commons.net.ftp.FTPReply;  
  15.   
  16. import org.apache.log4j.Logger;  
  17.   
  18. public class Ftp {  
  19.     private FTPClient ftpClient;  
  20.     private String strIp;  
  21.     private int intPort;  
  22.     private String user;  
  23.     private String password;  
  24.   
  25.     private static Logger logger = Logger.getLogger(Ftp.class.getName());  
  26.   
  27.     /* * 
  28.      * Ftp构造函数 
  29.      */  
  30.     public Ftp(String strIp, int intPort, String user, String Password) {  
  31.         this.strIp = strIp;  
  32.         this.intPort = intPort;  
  33.         this.user = user;  
  34.         this.password = Password;  
  35.         this.ftpClient = new FTPClient();  
  36.     }  
  37.     /** 
  38.      * @return 判断是否登入成功 
  39.      * */  
  40.     public boolean ftpLogin() {  
  41.         boolean isLogin = false;  
  42.         FTPClientConfig ftpClientConfig = new FTPClientConfig();  
  43.         ftpClientConfig.setServerTimeZoneId(TimeZone.getDefault().getID());  
  44.         this.ftpClient.setControlEncoding("GBK");  
  45.         this.ftpClient.configure(ftpClientConfig);  
  46.         try {  
  47.             if (this.intPort > 0) {  
  48.                 this.ftpClient.connect(this.strIp, this.intPort);  
  49.             } else {  
  50.                 this.ftpClient.connect(this.strIp);  
  51.             }  
  52.             // FTP服务器连接回答  
  53.             int reply = this.ftpClient.getReplyCode();  
  54.             if (!FTPReply.isPositiveCompletion(reply)) {  
  55.                 this.ftpClient.disconnect();  
  56.                 logger.error("登录FTP服务失败!");  
  57.                 return isLogin;  
  58.             }  
  59.             this.ftpClient.login(this.user, this.password);  
  60.             // 设置传输协议  
  61.             this.ftpClient.enterLocalPassiveMode();  
  62.             this.ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);  
  63.             logger.info("恭喜" + this.user + "成功登陆FTP服务器");  
  64.             isLogin = true;  
  65.         } catch (Exception e) {  
  66.             e.printStackTrace();  
  67.             logger.error(this.user + "登录FTP服务失败!" + e.getMessage());  
  68.         }  
  69.         this.ftpClient.setBufferSize(1024 * 2);  
  70.         this.ftpClient.setDataTimeout(30 * 1000);  
  71.         return isLogin;  
  72.     }  
  73.   
  74.     /** 
  75.      * @退出关闭服务器链接 
  76.      * */  
  77.     public void ftpLogOut() {  
  78.         if (null != this.ftpClient && this.ftpClient.isConnected()) {  
  79.             try {  
  80.                 boolean reuslt = this.ftpClient.logout();// 退出FTP服务器  
  81.                 if (reuslt) {  
  82.                     logger.info("成功退出服务器");  
  83.                 }  
  84.             } catch (IOException e) {  
  85.                 e.printStackTrace();  
  86.                 logger.warn("退出FTP服务器异常!" + e.getMessage());  
  87.             } finally {  
  88.                 try {  
  89.                     this.ftpClient.disconnect();// 关闭FTP服务器的连接  
  90.                 } catch (IOException e) {  
  91.                     e.printStackTrace();  
  92.                     logger.warn("关闭FTP服务器的连接异常!");  
  93.                 }  
  94.             }  
  95.         }  
  96.     }  
  97.   
  98.     /*** 
  99.      * 上传Ftp文件 
  100.      * @param localFile 当地文件 
  101.      * @param romotUpLoadePath上传服务器路径 - 应该以/结束 
  102.      * */  
  103.     public boolean uploadFile(File localFile, String romotUpLoadePath) {  
  104.         BufferedInputStream inStream = null;  
  105.         boolean success = false;  
  106.         try {  
  107.             this.ftpClient.changeWorkingDirectory(romotUpLoadePath);// 改变工作路径  
  108.             inStream = new BufferedInputStream(new FileInputStream(localFile));  
  109.             logger.info(localFile.getName() + "开始上传.....");  
  110.             success = this.ftpClient.storeFile(localFile.getName(), inStream);  
  111.             if (success == true) {  
  112.                 logger.info(localFile.getName() + "上传成功");  
  113.                 return success;  
  114.             }  
  115.         } catch (FileNotFoundException e) {  
  116.             e.printStackTrace();  
  117.             logger.error(localFile + "未找到");  
  118.         } catch (IOException e) {  
  119.             e.printStackTrace();  
  120.         } finally {  
  121.             if (inStream != null) {  
  122.                 try {  
  123.                     inStream.close();  
  124.                 } catch (IOException e) {  
  125.                     e.printStackTrace();  
  126.                 }  
  127.             }  
  128.         }  
  129.         return success;  
  130.     }  
  131.   
  132.     /*** 
  133.      * 下载文件 
  134.      * @param remoteFileName   待下载文件名称 
  135.      * @param localDires 下载到当地那个路径下 
  136.      * @param remoteDownLoadPath remoteFileName所在的路径 
  137.      * */  
  138.   
  139.     public boolean downloadFile(String remoteFileName, String localDires,  
  140.             String remoteDownLoadPath) {  
  141.         String strFilePath = localDires + remoteFileName;  
  142.         BufferedOutputStream outStream = null;  
  143.         boolean success = false;  
  144.         try {  
  145.             this.ftpClient.changeWorkingDirectory(remoteDownLoadPath);  
  146.             outStream = new BufferedOutputStream(new FileOutputStream(  
  147.                     strFilePath));  
  148.             logger.info(remoteFileName + "开始下载....");  
  149.             success = this.ftpClient.retrieveFile(remoteFileName, outStream);  
  150.             if (success == true) {  
  151.                 logger.info(remoteFileName + "成功下载到" + strFilePath);  
  152.                 return success;  
  153.             }  
  154.         } catch (Exception e) {  
  155.             e.printStackTrace();  
  156.             logger.error(remoteFileName + "下载失败");  
  157.         } finally {  
  158.             if (null != outStream) {  
  159.                 try {  
  160.                     outStream.flush();  
  161.                     outStream.close();  
  162.                 } catch (IOException e) {  
  163.                     e.printStackTrace();  
  164.                 }  
  165.             }  
  166.         }  
  167.         if (success == false) {  
  168.             logger.error(remoteFileName + "下载失败!!!");  
  169.         }  
  170.         return success;  
  171.     }  
  172.   
  173.     /*** 
  174.      * @上传文件夹 
  175.      * @param localDirectory 
  176.      *            当地文件夹 
  177.      * @param remoteDirectoryPath 
  178.      *            Ftp 服务器路径 以目录"/"结束 
  179.      * */  
  180.     public boolean uploadDirectory(String localDirectory,  
  181.             String remoteDirectoryPath) {  
  182.         File src = new File(localDirectory);  
  183.         try {  
  184.             remoteDirectoryPath = remoteDirectoryPath + src.getName() + "/";  
  185.             this.ftpClient.makeDirectory(remoteDirectoryPath);  
  186.             // ftpClient.listDirectories();  
  187.         } catch (IOException e) {  
  188.             e.printStackTrace();  
  189.             logger.info(remoteDirectoryPath + "目录创建失败");  
  190.         }  
  191.         File[] allFile = src.listFiles();  
  192.         for (int currentFile = 0; currentFile < allFile.length; currentFile++) {  
  193.             if (!allFile[currentFile].isDirectory()) {  
  194.                 String srcName = allFile[currentFile].getPath().toString();  
  195.                 uploadFile(new File(srcName), remoteDirectoryPath);  
  196.             }  
  197.         }  
  198.         for (int currentFile = 0; currentFile < allFile.length; currentFile++) {  
  199.             if (allFile[currentFile].isDirectory()) {  
  200.                 // 递归  
  201.                 uploadDirectory(allFile[currentFile].getPath().toString(),  
  202.                         remoteDirectoryPath);  
  203.             }  
  204.         }  
  205.         return true;  
  206.     }  
  207.   
  208.     /*** 
  209.      * @下载文件夹 
  210.      * @param localDirectoryPath本地地址 
  211.      * @param remoteDirectory 远程文件夹 
  212.      * */  
  213.     public boolean downLoadDirectory(String localDirectoryPath,String remoteDirectory) {  
  214.         try {  
  215.             String fileName = new File(remoteDirectory).getName();  
  216.             localDirectoryPath = localDirectoryPath + fileName + "//";  
  217.             new File(localDirectoryPath).mkdirs();  
  218.             FTPFile[] allFile = this.ftpClient.listFiles(remoteDirectory);  
  219.             for (int currentFile = 0; currentFile < allFile.length; currentFile++) {  
  220.                 if (!allFile[currentFile].isDirectory()) {  
  221.                     downloadFile(allFile[currentFile].getName(),localDirectoryPath, remoteDirectory);  
  222.                 }  
  223.             }  
  224.             for (int currentFile = 0; currentFile < allFile.length; currentFile++) {  
  225.                 if (allFile[currentFile].isDirectory()) {  
  226.                     String strremoteDirectoryPath = remoteDirectory + "/"+ allFile[currentFile].getName();  
  227.                     downLoadDirectory(localDirectoryPath,strremoteDirectoryPath);  
  228.                 }  
  229.             }  
  230.         } catch (IOException e) {  
  231.             e.printStackTrace();  
  232.             logger.info("下载文件夹失败");  
  233.             return false;  
  234.         }  
  235.         return true;  
  236.     }  
  237.     // FtpClient的Set 和 Get 函数  
  238.     public FTPClient getFtpClient() {  
  239.         return ftpClient;  
  240.     }  
  241.     public void setFtpClient(FTPClient ftpClient) {  
  242.         this.ftpClient = ftpClient;  
  243.     }  
  244.       
  245.     public static void main(String[] args) throws IOException {  
  246.         Ftp ftp=new Ftp("10.3.15.1",21,"ghips","ghipsteam");  
  247.         ftp.ftpLogin();  
  248.         //上传文件夹  
  249.         ftp.uploadDirectory("d://DataProtemp""/home/data/");  
  250.         //下载文件夹  
  251.         ftp.downLoadDirectory("d://tmp//""/home/data/DataProtemp");  
  252.         ftp.ftpLogOut();          
  253.     }  
  254. }