工具类---FTP工具类

古城微笑少年丶 2023-07-19 03:40 129阅读 0赞

1. 导入commons-net

  1. <dependency>
  2.     <groupId>commons-net</groupId>
  3.     <artifactId>commons-net</artifactId>
  4.     <version>3.3</version>
  5. </dependency>

2. 创建config.properties文件，配置FTP服务器信息

  1. #ftp服务器地址
  2. ftp.address=182.61.40.184
  3. #ftp默认端口是21
  4. ftp.port=21
  5. #ftp用户名
  6. ftp.username=root
  7. #ftp密码
  8. ftp.password=xxxxxxx

3. 读取config.properties配置文件的工具类ConfigReaderUtil

  1. import java.io.FileNotFoundException;
  2. import java.io.IOException;
  3. import java.io.InputStreamReader;
  4. import java.util.Properties;
  6. /**
  7.  * DESC ： 读取配置文件工具类
  8.  * 
  9.  */
  10. public class ConfigReaderUtil {
  12.     public ConfigReaderUtil(){}
  13.     private static Properties props = new Properties(); 
  14.     static{
  15.         try {
  16.             //加载配置文件，需要手动指定配置文件
  17.             props.load(new InputStreamReader(Thread.currentThread().getContextClassLoader().getResourceAsStream("config.properties"),"UTF-8"));        
  18.         } catch (FileNotFoundException e) {
  19.             e.printStackTrace();
  20.         } catch (IOException e) {
  21.             e.printStackTrace();
  22.         }
  23.     }
  25.     /*根据key获取value*/
  26.     public static String getValue(String key){
  27.         return props.getProperty(key).trim();
  28.     }
  29. }

4. FTP工具类

  1. import java.io.File;
  2. import java.io.FileInputStream;
  3. import java.io.FileOutputStream;
  4. import java.io.IOException;
  5. import java.io.InputStream;
  6. import java.io.OutputStream;
  7. import java.nio.charset.Charset;
  8. import org.apache.commons.net.ftp.FTPClient;
  9. import org.apache.commons.net.ftp.FTPFile;
  10. import org.apache.log4j.Logger;
  12. /**
  13.  * DESC : ftp工具类
  14.  * 
  15.  * @author Lonely
  16.  *
  17.  */
  18. public class FTPUtil {
  20.     private static Logger logger = Logger.getLogger(FTPUtil.class);
  21.     static FTPClient ftp = null;
  23.     private static String ftpAddress = ConfigReaderUtil.getValue("ftp.address"); // ftp服务器地址
  24.     private static Integer ftpPort = Integer.valueOf(ConfigReaderUtil.getValue("ftp.port")); // ftp端口
  25.     private static String ftpUsername = ConfigReaderUtil.getValue("ftp.username"); // ftp用户名
  26.     private static String ftpPassword = ConfigReaderUtil.getValue("ftp.password"); // ftp密码
  29.     /**
  30.      * DESC  登录FTP
  31.      * @param ip
  32.      * @param port
  33.      * @param username
  34.      * @param password
  35.      * @return
  36.      */
  37.     public static boolean login() {
  38.         try {
  39.             ftp = new FTPClient();
  40.             ftp.connect(ftpAddress, ftpPort);
  41.             boolean loginResu = ftp.login(ftpUsername, ftpPassword);
  42.             if (loginResu) {
  43.                 logger.info("登录FTP成功");
  44.                 // 设置UTF-8编码
  45.                 ftp.setCharset(Charset.forName("UTF-8"));
  46.                 ftp.setControlEncoding("UTF-8");
  47.                 return true;
  48.             } else {
  49.                 logger.info("登录FTP失败");
  50.                 return false;
  51.             }
  52.         } catch (IOException e) {
  53.             logger.info("登录FTP出现异常");
  54.             e.printStackTrace();
  55.             return false;
  56.         }
  57.     }
  60.     /**
  61.      * DESC  登出FTP
  62.      */
  63.     public static void disconnect() {
  64.         if (null != ftp && ftp.isConnected()) {
  65.             try {
  66.                 ftp.logout();
  67.                 ftp.disconnect();
  68.                 logger.info("登出FTP......");
  69.                 logger.info("断开FTP......");
  70.             } catch (IOException ex) {
  72.             }
  73.         }
  74.     }
  77.     /**
  78.      * DESC 下载文件
  79.      * 
  80.      * @param remoteFileUrl FTP服务器文件路径 例：/index.html
  81.      * @param localFileUrl  要保存到本地的路径 例：D:/index.html
  82.      * @return
  83.      */
  84.     public static boolean downloadFile(String remoteFileUrl, String localFileUrl) {
  85.         FileOutputStream fos = null;
  86.         InputStream is = null;
  87.         boolean loginResu = login(); // 登录
  88.         try {
  89.             if (loginResu) {
  90.                 is = ftp.retrieveFileStream(remoteFileUrl);
  91.                 fos = new FileOutputStream(new File(localFileUrl));
  92.                 byte[] b = new byte[1024];
  93.                 int len = 0;
  94.                 while ((len = is.read(b)) != -1) {
  95.                     fos.write(b, 0, len);
  96.                 }
  97.                 logger.info("下载文件：" + remoteFileUrl + "  成功----------------------");
  98.                 return true;
  99.             } else {
  100.                 logger.info("下载文件 ：" + remoteFileUrl + "  失败----------------------");
  101.                 return false;
  102.             }
  103.         } catch (IOException e) {
  104.             e.printStackTrace();
  105.             logger.info("下载文件失败");
  106.             return false;
  107.         } finally {
  108.             if (fos != null) {
  109.                 try {
  110.                     fos.close();
  111.                 } catch (IOException e) {
  112.                     e.printStackTrace();
  113.                 }
  114.             }
  115.             if (is != null) {
  116.                 try {
  117.                     is.close();
  118.                 } catch (IOException e) {
  119.                     e.printStackTrace();
  120.                 }
  121.             }
  122.         }
  123.     }
  125.     /**
  126.      * DESC 上传文件
  127.      * 
  128.      * @param remoteFileUrl 要保存文件的路径 例：/index.html
  129.      * @param localFileUrl  要上传的文件路径 例：D:/index.html
  130.      * @return
  131.      */
  132.     public static boolean uploadFile(String remoteFileUrl, String localFileUrl) {
  133.         FileInputStream fis = null;
  134.         OutputStream os = null;
  135.         boolean loginResu = login(); // 登录
  136.         try {
  137.             if (loginResu) {
  138.                 os = ftp.storeFileStream(remoteFileUrl);
  139.                 fis = new FileInputStream(new File(localFileUrl));
  140.                 byte[] b = new byte[1024];
  141.                 int len = 0;
  142.                 while ((len = fis.read(b)) != -1) {
  143.                     os.write(b, 0, len);
  144.                 }
  145.                 logger.info("上传文件：" + localFileUrl + "  成功----------------");
  146.                 return true;
  147.             } else {
  148.                 logger.info("上传文件：" + localFileUrl + "  失败----------------");
  149.                 return false;
  150.             }
  151.         } catch (IOException e) {
  152.             e.printStackTrace();
  153.             return false;
  154.         } finally {
  155.             if (fis != null) {
  156.                 try {
  157.                     fis.close();
  158.                 } catch (IOException e) {
  159.                     e.printStackTrace();
  160.                 }
  161.             }
  162.             if (os != null) {
  163.                 try {
  164.                     os.close();
  165.                 } catch (IOException e) {
  166.                     e.printStackTrace();
  167.                 }
  168.             }
  169.         }
  170.     }
  172.     /**
  173.      * DESC 获取ftp某一文件（路径）下的文件名字,用于查看文件列表
  174.      * @param remotedir 远程地址目录
  175.      * @return
  176.      */
  177.     public static boolean getFilesName(String remotedir){
  178.         boolean loginResu = login(); // 登录
  179.         if (loginResu) {
  180.             FTPFile[] files;
  181.             try {
  182.                 files = ftp.listFiles(remotedir);
  183.                 for (int i = 0; i < files.length; i++) {
  184.                     logger.info(files[i].getName() + "----");
  185.                     //其他操作
  186.                 }
  187.             } catch (IOException e) {
  188.                 e.printStackTrace();
  189.             }
  190.             return true;
  191.         } else {
  192.             return false;
  193.         }
  195.     }
  197.      /**
  198.      * DESC  删除FTP服务器文件
  199.      * @param ftpFileName 要删除的文件路径
  200.      */
  201.     public static boolean deleteFile(String ftpFileName){
  202.         boolean loginResu = login(); // 登录
  203.         if (loginResu) {
  204.             boolean delResu;
  205.             try {
  206.                 delResu = ftp.deleteFile(ftpFileName);        //删除文件
  207.                 if(delResu) {
  208.                     logger.info("删除FTP服务器文件：" + ftpFileName + "成功");
  209.                     return true;
  210.                 }else {
  211.                     logger.info("删除FTP服务器文件：" + ftpFileName + "失败");
  212.                     return false;
  213.                 }
  214.             } catch (IOException e) {
  215.                 e.printStackTrace();
  216.                 return false;
  217.             }
  218.         }else {
  219.             return false;
  220.         }
  222.     }
  225. }

调用测试

  1. public static void main(String[] args) {
  2.         //打印 /usr 下的文件(文件夹)名
  3.         FTPUtil.getFilesName("/usr");        
  5.         //上传本地 D:/G(other)/temp/index.html 到   FTP服务器 /index.html
  6.         FTPUtil.uploadFile("/index.html", "D:/G(other)/temp/index.html");
  8.         //下载FTP服务器中的 /index.html  到   本地 D:/G(other)/temp/index.html
  9.         FTPUtil.downloadFile("/index.html", "D:/G(other)/temp/index.html");
  11.         //删除FTP服务器文件 /index.html
  12.         FTPUtil.deleteFile("/index.html");
  14.         //登出 断开连接
  15.         FTPUtil.disconnect();
  16. }

发表评论

表情：
评论列表 （有 0 条评论，129人围观）

还没有评论，来说两句吧...

相关阅读

    相关 FTP测试工具类

    在进入正文前，先给大家分享一款比较好用的服务器连接工具： IIS7服务器管理工具是一款windows全系下用于连接并操控基于windows和linux系统的VPS、VNC、

    忘是亡心i忘是亡心i/ 0 赞/ 327 阅读