使用前端插件上传文件到ftp服务器

package com.tools; import java.io.File; import java.io.FileOutputStream; import java.io.InputStream; import java.io.OutputStream; import java.io.PrintWriter; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Random; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.apache.commons.fileupload.FileItem; import org.apache.commons.fileupload.disk.DiskFileItemFactory; import org.apache.commons.fileupload.servlet.ServletFileUpload; import org.apache.commons.net.ftp.FTPClient; public class FTPClientTool { private FTPClient ftp; // 上传文件的保存路径 public static String configPath = "/attached/"; public static String dirTemp = "/attached/temp/"; public static String dirName = "file"; public Map<String,Object> upload(HttpServletRequest request, HttpServletResponse response) throws Exception{ Long betime=System.currentTimeMillis(); Boolean b=false; ftp = new FTPClient(); List<String> reList=new ArrayList<String>(); Map<String,Object> map= new HashMap<String,Object>(); //连接文件配置 PropertiesLoader pl = new PropertiesLoader("config.properties"); String HostName=pl.getProperty("HostName").trim(); String Port=pl.getProperty( "Port").trim(); String Username=pl.getProperty( "Username").trim(); String Password=pl.getProperty( "Password").trim(); String LocationUrl=pl.getProperty( "LocationUrl").trim(); String HttpPort=pl.getProperty( "HttpPort").trim(); String AllowSize=pl.getProperty( "AllowSize").trim(); String AllowType=pl.getProperty( "AllowType").trim(); Config cf = new Config(); cf.setHostName(HostName); cf.setPort(Integer.parseInt(Port)); cf.setPassword(Password); cf.setUsername(Username); Map<String, List<String>> mm = new HashMap<String,List<String>>(); List<String> list=new ArrayList<>(); list.add(LocationUrl); mm.put("uplocation",list); cf.setFilesToUpload(mm); //==== // 文件保存目录路径 String local=request.getSession().getServletContext().getRealPath("") ; String savePath = local + configPath; // 临时文件目录 String tempPath = local + dirTemp; SimpleDateFormat sdf = new SimpleDateFormat("yyyyMM" ); String ymd = sdf.format( new Date()); savePath += "/" + ymd + "/"; // 创建文件夹 File dirFile = new File(savePath); if (!dirFile.exists()) { dirFile.mkdirs(); } tempPath += "/" + ymd + "/"; // 创建临时文件夹 File dirTempFile = new File(tempPath); if (!dirTempFile.exists()) { dirTempFile.mkdirs(); } DiskFileItemFactory factory = new DiskFileItemFactory(); factory.setSizeThreshold(20 * 1024 * 1024); // 设定使用内存超过5M时，将产生临时文件并存储于临时目录中。 factory.setRepository( new File(tempPath)); // 设定存储临时文件的目录。 ServletFileUpload upload = new ServletFileUpload(factory); upload.setHeaderEncoding( "UTF-8"); try { List items = upload.parseRequest(request); Iterator itr = items.iterator(); while (itr.hasNext()) { FileItem item = (FileItem) itr.next(); String fileName = item.getName(); if("".equals(fileName)){ continue; } long fileSize = item.getSize();//上传文件大小 if(fileSize>Long.parseLong(AllowSize)){ map.put("uploadfiles", ""); map.put("uploadstatus", 1); map.put("uploadmessage", fileName+"文件过大"); return map; } String tfileName=item.getContentType();//获取文件类型 if(!AllowType.contains(tfileName)){ map.put("uploadfiles", ""); map.put("uploadstatus", 2); map.put("uploadmessage", fileName+"文件格式不正确"); return map; } if (!item.isFormField()) { String fileExt = fileName.substring(fileName.lastIndexOf("." ) + 1).toLowerCase(); SimpleDateFormat df = new SimpleDateFormat("yyyyMMddHHmmss" ); String newFileName = df.format( new Date()) + "_" + new Random().nextInt(10000) + "." + fileExt; try { File uploadedFile = new File(savePath, newFileName); OutputStream os = new FileOutputStream(uploadedFile); InputStream is = item.getInputStream(); byte buf[] = new byte[1024]; // 可以修改 1024 以提高读取速度 int length = 0; while ((length = is.read(buf)) > 0) { os.write(buf, 0, length); } // 关闭流 os.flush(); os.close(); is.close(); FtpUpload t = new FtpUpload(); SimpleDateFormat sdfs = new SimpleDateFormat("yyMMdd"); t.connect(cf.getFilesToUpload().get("uplocation").get(0)+"/"+sdfs.format(new Date()), cf.getHostName(), cf.getPort(), cf.getUsername(), cf.getPassword()); //File file = new File("F:\\turn_large.png"); b=t.upload(uploadedFile); //是否ftp上传成功 if(true==b){ reList.add("http://"+cf.getHostName()+":"+HttpPort+cf.getFilesToUpload().get("uplocation").get(0).split("webapps")[1]+"/"+sdfs.format(new Date())+"/"+newFileName); } }catch (Exception e){ e.printStackTrace(); } }else{ String filedName = item.getFieldName(); System. out.println( "FieldName：" + filedName); System. out.println( "String：" + item.getString()); // System.out.println("String()："+item.getString(item.getName())); System.out.println("===============" ); } } }catch (Exception e){ e.printStackTrace(); } //当上传完最后一个文件的时候进行删除本地临时目录 //删除本地生成文件是否成功 Boolean boo1=false; Boolean boo2=false; DelFileFolder dff = new DelFileFolder(); boo1=dff.deleteDirectory(savePath); boo2=dff.deleteDirectory(tempPath); if(true==boo1&&true==boo2&&true==b){ System. out.println( "上传成功！本地存储临时文件路径：" + savePath + " 已删除！"); for (int i = 0; i < reList.size(); i++) { System.out.println("上传文件url："+reList.get(i)); } map.put("uploadfiles", reList); map.put("uploadstatus", 0); map.put("uploadmessage", "上传成功"); }else{ map.put("uploadfiles", reList); map.put("uploadstatus", 3); map.put("uploadmessage", "上传�