开发者社区> angel挤一挤> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

【FTP】org.apache.commons.net.ftp.FTPClient实现复杂的上传下载,操作目录,处理编码

简介: 和上一份简单 上传下载一样 来,任何的方法不懂的,http://commons.apache.org/proper/commons-net/apidocs/org/apache/commons/net/ftp/FTPClient.
+关注继续查看

和上一份简单 上传下载一样

来,任何的方法不懂的,http://commons.apache.org/proper/commons-net/apidocs/org/apache/commons/net/ftp/FTPClient.html

API拿走不谢!!!

 

 

1.FTP配置实体

 1 package com.agen.util;
 2 
 3 public class FtpConfig {
 4      //主机ip  
 5     private String FtpHost = "192.168.18.252";  
 6     //端口号  
 7     private int FtpPort = 21;  
 8     //ftp用户名  
 9     private String FtpUser = "ftp";  
10     //ftp密码  
11     private String FtpPassword = "agenbiology";  
12     //ftp中的目录  这里先指定的根目录
13     private String FtpPath = "/";
14     
15     
16     
17     public String getFtpHost() {
18         return FtpHost;
19     }
20     public void setFtpHost(String ftpHost) {
21         FtpHost = ftpHost;
22     }
23     public int getFtpPort() {
24         return FtpPort;
25     }
26     public void setFtpPort(int ftpPort) {
27         FtpPort = ftpPort;
28     }
29     public String getFtpUser() {
30         return FtpUser;
31     }
32     public void setFtpUser(String ftpUser) {
33         FtpUser = ftpUser;
34     }
35     public String getFtpPassword() {
36         return FtpPassword;
37     }
38     public void setFtpPassword(String ftpPassword) {
39         FtpPassword = ftpPassword;
40     }
41     public String getFtpPath() {
42         return FtpPath;
43     }
44     public void setFtpPath(String ftpPath) {
45         FtpPath = ftpPath;
46     }  
47     
48     
49     
50 }
View Code

2.FTP工具类,仅有一个删除文件夹【目录】的操作方法,删除文件夹包括文件夹下所有的文件

  1 package com.agen.util;
  2 
  3 import java.io.IOException;
  4 import java.io.InputStream;
  5 import java.io.OutputStream;
  6 import java.net.URLDecoder;
  7 import java.net.URLEncoder;
  8 
  9 import org.apache.commons.net.ftp.FTPClient;
 10 import org.apache.commons.net.ftp.FTPFile;
 11 
 12 
 13 
 14 public class FtpUtils {
 15     
 16     /**
 17      * 获取FTP连接
 18      * @return
 19      */
 20     public  FTPClient getFTPClient() {
 21         FtpConfig config = new FtpConfig();
 22         FTPClient ftpClient = new FTPClient();
 23         boolean result = true;
 24         try {
 25             //连接FTP服务器
 26             ftpClient.connect(config.getFtpHost(), config.getFtpPort());
 27             //如果连接
 28             if (ftpClient.isConnected()) {
 29                 //提供用户名/密码登录FTP服务器
 30                 boolean flag = ftpClient.login(config.getFtpUser(), config.getFtpPassword());
 31                 //如果登录成功
 32                 if (flag) {
 33                     //设置编码类型为UTF-8
 34                     ftpClient.setControlEncoding("UTF-8");
 35                     //设置文件类型为二进制文件类型
 36                     ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
 37                 } else {
 38                     result = false;
 39                 }
 40             } else {
 41                 result = false;
 42             }
 43             //成功连接并 登陆成功  返回连接
 44             if (result) {
 45                 return ftpClient;
 46             } else {
 47                 return null;
 48             }
 49         } catch (Exception e) {
 50             e.printStackTrace();
 51             return null;
 52         }
 53     }
 54     /**
 55      * 删除文件夹下所有文件
 56      * @return
 57      * @throws IOException 
 58      */
 59     public boolean deleteFiles(String pathname) throws IOException{
 60         FTPClient ftpClient = getFTPClient();
 61         ftpClient.enterLocalPassiveMode();//在调用listFiles()方法之前需要调用此方法
 62         FTPFile[] ftpFiles = ftpClient.listFiles(new String((pathname).getBytes("UTF-8"),"iso-8859-1"));
 63         System.out.println(ftpFiles == null ? null :ftpFiles.length );
 64         if(ftpFiles.length > 0){
 65             for (int i = 0; i < ftpFiles.length; i++) {
 66                 System.out.println(ftpFiles[i].getName());
 67                 if(ftpFiles[i].isDirectory()){
 68                     deleteFiles(pathname+"/"+ftpFiles[i].getName());
 69                 }else{
 70                     System.out.println(pathname);
 71                     //这里需要提供删除文件的路径名 才能删除文件
 72                     ftpClient.deleteFile(new String((pathname+"/"+ftpFiles[i].getName()).getBytes("UTF-8"),"iso-8859-1"));
 73                     FTPFile [] ftFiles = ftpClient.listFiles(new String((pathname).getBytes("UTF-8"),"iso-8859-1"));
 74                     if(ftFiles.length == 0){//如果文件夹中现在已经为空了
 75                         ftpClient.removeDirectory(new String(pathname.getBytes("UTF-8"),"iso-8859-1"));
 76                     }
 77                 }
 78             }
 79         }
 80         return true;
 81     }
 82     
 83     /**
 84      * 关闭 输入流或输出流
 85      * @param in
 86      * @param out
 87      * @param ftpClient
 88      */
 89     public  void close(InputStream in, OutputStream out,FTPClient ftpClient) {
 90         if (null != in) {
 91             try {
 92                 in.close();
 93             } catch (IOException e) {
 94                 e.printStackTrace();
 95                 System.out.println("输入流关闭失败");
 96             }
 97         }
 98         if (null != out) {
 99             try {
100                 out.close();
101             } catch (IOException e) {
102                 e.printStackTrace();
103                 System.out.println("输出流关闭失败");
104             }
105         }
106         if (null != ftpClient) {
107             try {
108                 ftpClient.logout();
109                 ftpClient.disconnect();
110             } catch (IOException e) {
111                 e.printStackTrace();
112                 System.out.println("Ftp服务关闭失败!");
113             }
114         }
115     }
116     
117 }
View Code

删除方法中,调用listFiles()方法之前,需要调用ftpClient.enterLocalPassiveMode();

关于调用listFiles()方法,有以下几种情况需要注意:

①listFiles()方法可能返回为null,这个问题我也遇到了,这种原因是因为FTP服务器的语言环境,编码方式,时间戳等各种的没有处理好或者与程序端并不一致

②首先可以使用listNames()方法排除是否是路径的原因,路径编码方式等原因

③其次,调整好路径后,有如下提示的错误Caused by: java.lang.ClassNotFoundException: org.apache.oro.text.regex.MalformedPatternException,需要导入一个架包 【jakarta-oro-2.0.8.jar】

3.实际用到的FTP上传【创建多层中文目录】+下载【浏览器下载OR服务器下载】+删除       【处理FTP编码方式与本地编码不一致】

  1     /**
  2      * 上传至FTP服务器
  3      * @param partFile
  4      * @param request
  5      * @param diseaseName
  6      * @param productName
  7      * @param diseaseId
  8      * @return
  9      * @throws IOException
 10      */
 11     @RequestMapping("/uploadFiles")
 12     @ResponseBody
 13     public  boolean uploadFiles(@RequestParam("upfile")MultipartFile partFile,HttpServletRequest request,String diseaseName,String productName,String diseaseId) throws IOException{
 14              Disease disease = new Disease();
 15              disease.setDiseaseId(diseaseId);  
 16              Criteria criteria = getCurrentSession().createCriteria(Filelist.class);
 17              criteria.add(Restrictions.eq("disease", disease));
 18              Filelist flFilelist = filelistService.uniqueResult(criteria);
 19              if(flFilelist == null){
 20                  FtpUtils ftpUtils = new FtpUtils();
 21                  boolean result = true;
 22                 InputStream in = null;
 23                 FTPClient ftpClient = ftpUtils.getFTPClient();
 24                 if (null == ftpClient) {
 25                     System.out.println("FTP服务器未连接成功!!!");
 26                     return false;
 27                 }
 28                 try {
 29                     
 30                     String path = "/file-ave/";
 31                     ftpClient.changeWorkingDirectory(path);
 32                     System.out.println(ftpClient.printWorkingDirectory());
 33                     //创建产品文件夹   转码 防止在FTP服务器上创建时乱码
 34                     ftpClient.makeDirectory(new String(productName.getBytes("UTF-8"),"iso-8859-1"));
 35                     //指定当前的工作路径到产品文件夹下
 36                     ftpClient.changeWorkingDirectory(path+new String(productName.getBytes("UTF-8"),"iso-8859-1"));
 37                     //创建疾病文件夹   转码
 38                     ftpClient.makeDirectory(new String(diseaseName.getBytes("UTF-8"),"iso-8859-1"));
 39                     //指定当前的工作路径到疾病文件夹下
 40                     ftpClient.changeWorkingDirectory(path+new String(productName.getBytes("UTF-8"),"iso-8859-1")+"/"+new String(diseaseName.getBytes("UTF-8"),"iso-8859-1"));
 41                     
 42                     // 得到上传的文件的文件名
 43                     String filename = partFile.getOriginalFilename();
 44                     in = partFile.getInputStream();
 45                     ftpClient.storeFile(new String(filename.getBytes("UTF-8"),"iso-8859-1"), in);
 46                     path += productName+"/"+diseaseName+"/";
 47                     
 48                     
 49                     DecimalFormat df = new DecimalFormat();
 50                       String fileSize = partFile.getSize()/1024>100 ? (partFile.getSize()/1024/1024>100? df.format((double)partFile.getSize()/1024/1024/1024)+"GB" :df.format((double)partFile.getSize()/1024/1024)+"MB" ) :df.format((double)partFile.getSize()/1024)+"KB";
 51                       HttpSession session = request.getSession();
 52                       User user = (User) session.getAttribute("user");
 53                      
 54                       Filelist filelist = new Filelist();
 55                       filelist.setFileId(UUID.randomUUID().toString());
 56                       filelist.setFileName(filename);
 57                       filelist.setFilePath(path+filename);
 58                       filelist.setFileCre(fileSize);
 59                       filelist.setCreateDate(new Timestamp(System.currentTimeMillis()));
 60                       filelist.setUpdateDate(new Timestamp(System.currentTimeMillis()));
 61                       filelist.setTransPerson(user.getUserId());
 62                       filelist.setDisease(disease);
 63                       filelistService.save(filelist);
 64                       
 65                     
 66                     
 67                     return result;
 68                     
 69                 } catch (IOException e) {
 70                     e.printStackTrace();
 71                     return false;
 72                 } finally {
 73                     ftpUtils.close(in, null, ftpClient);
 74                 }
 75              }else{
 76                  return false;
 77              }
 78     }
 79     
 80     /**
 81      * 删除文件
 82      * @param filelistId
 83      * @return
 84      * @throws IOException 
 85      * @throws UnsupportedEncodingException 
 86      */
 87     @RequestMapping("/filelistDelete")
 88     @ResponseBody
 89       public boolean filelistDelete(String []filelistId) throws UnsupportedEncodingException, IOException{
 90         for (String string : filelistId) {
 91             Filelist filelist =  filelistService.uniqueResult("fileId", string);
 92             String filePath = filelist.getFilePath();
 93             FtpUtils ftpUtils = new FtpUtils();
 94             FTPClient ftpClient = ftpUtils.getFTPClient();
 95             InputStream inputStream = ftpClient.retrieveFileStream(new String(filePath.getBytes("UTF-8"),"iso-8859-1"));
 96             if(inputStream != null || ftpClient.getReplyCode() == 550){
 97                 ftpClient.deleteFile(filePath);
 98             }
 99             filelistService.deleteById(string);
100         }
101         return true;
102       }
103     
104     /**
105      * 下载到本地
106      * @param fileId
107      * @param response
108      * @return
109      * @throws IOException
110      * @throws InterruptedException
111      */
112     @RequestMapping("/fileDownload")
113     public String fileDownload(String fileId,HttpServletResponse response) throws IOException, InterruptedException{
114         Filelist filelist = filelistService.get(fileId);
115         Assert.notNull(filelist);
116         String filePath = filelist.getFilePath();
117         String fileName = filelist.getFileName();
118         String targetPath = "D:/biologyInfo/Download/";
119         File file = new File(targetPath);
120         while(!file.exists()){
121             file.mkdirs();
122         }
123         FtpUtils ftpUtils = new FtpUtils(); 
124         FileOutputStream out = null;
125         FTPClient ftpClient = ftpUtils.getFTPClient();
126         if (null == ftpClient) {
127             System.out.println("FTP服务器未连接成功!!!");
128         }
129         try {
130             //下载到 应用服务器而不是本地
131 //            //要写到本地的位置
132 //            File file2 = new File(targetPath + fileName);
133 //            out = new FileOutputStream(file2);
134 //            //截取文件的存储位置 不包括文件本身
135 //            filePath = filePath.substring(0, filePath.lastIndexOf("/"));
136 //            //文件存储在FTP的位置
137 //            ftpClient.changeWorkingDirectory(new String(filePath.getBytes("UTF-8"),"iso-8859-1"));
138 //            System.out.println(ftpClient.printWorkingDirectory());
139 //            //下载文件
140 //            ftpClient.retrieveFile(new String(fileName.getBytes("UTF-8"),"iso-8859-1"), out);
141 //            return true;
142             
143             //下载到  客户端 浏览器
144             InputStream inputStream = ftpClient.retrieveFileStream(new String(filePath.getBytes("UTF-8"),"iso-8859-1"));
145             response.setContentType("multipart/form-data");
146             response.setHeader("Content-Disposition", "attachment;filename="+ new String(fileName.getBytes("UTF-8"),"iso-8859-1")); 
147             OutputStream outputStream = response.getOutputStream();
148              byte[] b = new byte[1024];  
149              int length = 0;  
150              while ((length = inputStream.read(b)) != -1) {  
151                 outputStream.write(b, 0, length);  
152              }
153              
154         } catch (IOException e) {
155             e.printStackTrace();
156         } finally {
157             ftpUtils.close(null, out, ftpClient);
158         }
159         return null;
160     }
161      
View Code

 

 

最后注意一点:

FTP服务器不一样,会引发很多的问题,因为FTP服务器的语言环境,编码方式,时间戳等各种的原因,导致程序中需要进行大量的类似的处理,要跟FTP进行匹配使用。

因为FTP架包是apache的,所以使用apache自己的FTP服务器,是匹配度最高的,传入文件路径等都不需要考虑转码等各种各样的问题!!!

 

 

--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

---------------------------------------------------------附录------------------------------------------------------------------------------------

FTPFile[] ftpFiles = ftpClient.listFiles(new String((pathname).getBytes("UTF-8"),"iso-8859-1"));

方法的调用,报错如下:

 1 java.lang.NoClassDefFoundError: org/apache/oro/text/regex/MalformedPatternException
 2     at org.apache.commons.net.ftp.parser.DefaultFTPFileEntryParserFactory.createUnixFTPEntryParser(DefaultFTPFileEntryParserFactory.java:169)
 3     at org.apache.commons.net.ftp.parser.DefaultFTPFileEntryParserFactory.createFileEntryParser(DefaultFTPFileEntryParserFactory.java:94)
 4     at org.apache.commons.net.ftp.FTPClient.initiateListParsing(FTPClient.java:2358)
 5     at org.apache.commons.net.ftp.FTPClient.listFiles(FTPClient.java:2141)
 6     at com.sxd.ftp.FtpUtils.deleteFiles(FtpUtils.java:170)
 7     at com.sxd.ftp.FtpUtils.test(FtpUtils.java:200)
 8     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
 9     at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
10     at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
11     at java.lang.reflect.Method.invoke(Unknown Source)
12     at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
13     at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
14     at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
15     at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
16     at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
17     at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
18     at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
19     at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
20     at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
21     at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
22     at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
23     at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
24     at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
25     at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:50)
26     at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
27     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
28     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:675)
29     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
30     at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192)
31 Caused by: java.lang.ClassNotFoundException: org.apache.oro.text.regex.MalformedPatternException
32     at java.net.URLClassLoader.findClass(Unknown Source)
33     at java.lang.ClassLoader.loadClass(Unknown Source)
34     at sun.misc.Launcher$AppClassLoader.loadClass(Unknown Source)
35     at java.lang.ClassLoader.loadClass(Unknown Source)
36     ... 29 more
View Code

解决方法:
jakarta-oro-2.0.8.jar

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
Java:org.apache.commons.io.FilenameUtils获取文件名、扩展名
Java:org.apache.commons.io.FilenameUtils获取文件名、扩展名
34 0
Flink 1.14.0 全新的 Kafka Connector
Apache Kafka Connector# Flink 提供了一个 Apache Kafka 连接器,用于从 Kafka Topic 读取数据和向 Kafka Topic 写入数据,并保证恰好一次次语义。 Dependency# Apache Flink 附带了一个通用的 Kafka 连接器,它试图跟踪最新版本的 Kafka 客户端。它使用的客户端版本可能会在 Flink 版本之间发生变化
897 0
找不org.apache.commons.lang3.builder.EqualsBuilder和commons-lang下载链接
找不org.apache.commons.lang3.builder.EqualsBuilder和commons-lang下载链接
105 0
Java:org.apache.commons.beanutils.BeanUtils拷贝对象属性
Java:org.apache.commons.beanutils.BeanUtils拷贝对象属性
56 0
回顾 | Kafka x Flink Meetup 与世界人工智能大会大数据 AI 专场精彩回顾(附PPT下载)
8 月最后一天,由 Apache Kafka 与 Apache Flink 联合举办的 Meetup 深圳站圆满落幕,现场站无虚席,来自 Confluent 、中国农业银行 、虎牙直播、数见科技以及阿里巴巴的五位技术专家带来了丰富精彩的分享,全场干货满满!
12551 0
apache.commons.lang.StringUtils 字符串Utils
封装了常用的字符串操作。 1.依赖 &lt;/dependency&gt; &lt;span style="white-space:pre"&gt; &lt;/span&gt;&lt;dependency&gt; &lt;groupId&gt;commons-lang&lt;/groupId&gt; &lt;artifactId&gt;commons-lang&lt;/artif
1237 0
Apache Commons DbUtils使用手册
版权声明:本文为博主chszs的原创文章,未经博主允许不得转载。 https://blog.csdn.net/chszs/article/details/43051089 Apache Commons DbUtils使用手册 作者:chszs,转载需注明。
795 0
Apache Commons DbUtils使用手册
Apache Commons DbUtils使用手册 一、介绍 DBUtils是个小巧的JDBC轻量级封装的工具包,其最核心的特性是在JDBC的基础上做了一层封装,主要是对结果集的封装,可以直接将查询出来的结果集封装成JavaBean,旨在简化JDBC代码混乱与重复。
1388 0
Apache Commons DbUtils使用手册
Apache Commons DbUtils使用手册 一、介绍 DBUtils是个小巧的JDBC轻量级封装的工具包,其最核心的特性是在JDBC的基础上做了一层封装,主要是对结果集的封装,可以直接将查询出来的结果集封装成JavaBean,旨在简化JDBC代码混乱与重复。
1179 0
Ubuntu下装QQ2014(http://my.oschina.net/oscfox/blog/315951)
QQ登陆界面: QQ登陆之后: 1.首先我们需要下载一个 deb的 Wine QQ安装包 qq2014官方下载:http://www.longene.org/download/WineQQ2013SP6-20140102-Longene.deb 2.具体安装 32位系统安装说明: 1.如果之前安
1857 0
+关注
angel挤一挤
【任何0基础都能看懂的步骤和解决方法!】
文章
问答
文章排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载