和上一份简单 上传下载一样
来，任何的方法不懂的，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 }
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 }
删除方法中，调用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
最后注意一点：
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
解决方法：
jakarta-oro-2.0.8.jar