文件上传

时间 2013-06-27

原文原文链接

package com.ad.web.servlet; import java.io.File; import java.io.IOException; import java.io.PrintWriter; import java.net.URLEncoder; import java.util.Iterator; import java.util.List; import javax.servlet.ServletException; import javax.servlet.http.Cookie; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import net.sf.json.JSONObject; import org.apache.commons.fileupload.FileItem; import org.apache.commons.fileupload.FileUploadException; import org.apache.commons.fileupload.disk.DiskFileItemFactory; import org.apache.commons.fileupload.servlet.ServletFileUpload; import org.apache.commons.lang.StringEscapeUtils; import org.apache.log4j.Logger; import richinfo.rmapi.common.ReturnCode; import richinfo.tools.Tools; import cn.richinfo.cmail.common.config.PropertiesUtil; import com.ad.web.common.CommonConst; import com.ad.web.servlet.common.ImpProcess; import com.ad.web.servlet.common.Informations; /** * 说明：个人通讯录人员导入入口类 * @author zxkj * */ public class FileUploadServlet extends HttpServlet { private static final long serialVersionUID = 1L; private static final Logger log = Logger.getLogger(FileUploadServlet.class); final long MAX_SIZE = 1 * 1024 * 1024;// 设置上传文件最大为 1M final String[] allowtype = new String[] { "csv", "vcf" }; // 允许上传的文件格式的列表 public FileUploadServlet() { super(); } public void destroy() { super.destroy(); } @SuppressWarnings( { "deprecation", "unchecked" }) @Override protected void service(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { String rmkey = ""; String maindomain=""; Cookie [] cookies=request.getCookies(); if(cookies!=null) { for(int i=0;i<cookies.length;i++) { String cookieName = cookies[i].getName(); if("maindomain".equals(cookieName)) { maindomain=cookies[i].getValue(); } if ("RMKEY".equals(cookieName)) { rmkey = cookies[i].getValue(); } } } int imp_size=1; String max=PropertiesUtil.getProperty(CommonConst.IMP_SIZE); if(max!=null && !"".equals(max)) { imp_size=Integer.parseInt(max); } String sid =request.getParameter("sid"); String rp = request.getParameter("rp"); String retr =""; String fc=request.getParameter("func"); if(fc!=null && !"".equals(fc)) { fc=StringEscapeUtils.escapeHtml(fc); retr=URLEncoder.encode(fc, "UTF-8"); } String path = null; FileItem fileItem = null; FileItem fileUploadItem = null; File file=null; response.setContentType("text/html"); response.setCharacterEncoding("utf-8"); // 实例化一个硬盘文件工厂,用来配置上传组件ServletFileUpload DiskFileItemFactory dfif = new DiskFileItemFactory(); // 设置上传文件时用于临时存放文件的内存大小,这里是4K.多于的部分将临时存在硬盘 dfif.setSizeThreshold(4 * 1024); if (!(new File(request.getRealPath("/") + "uploadtemp").isDirectory())) { new File(request.getRealPath("/") + "uploadtemp").mkdir(); } // 设置存放临时文件的目录,web根目录下的uploadtemp目录 dfif.setRepository(new File(request.getRealPath("/") + "uploadtemp")); // 用以上工厂实例化上传组件 ServletFileUpload sfu = new ServletFileUpload(dfif); sfu.setHeaderEncoding("utf-8"); // 设置最大上传尺寸 PrintWriter out = response.getWriter(); List fileList = null; try { fileList = sfu.parseRequest(request); // 没有文件上传 if (fileList == null || fileList.size() == 0) { Informations.resMessage(out, "请选择上传文件", retr,maindomain); return; } // 得到所有上传的文件 Iterator fileItr = fileList.iterator(); // 循环处理所有文件 while (fileItr.hasNext()) { long size = 0; // 得到当前文件 fileItem = (FileItem) fileItr.next(); if (fileItem.isFormField()) { String name = fileItem.getFieldName(); String v = fileItem.getString(); if ("sid".equals(name)) { sid = v; } else if ("func".equals(name)) { retr = v; } else if ("rp".equals(name)) { rp = v; } } else { fileUploadItem=fileItem; // 得到文件的完整路径 path = fileItem.getName(); // 得到文件的大小 size = fileItem.getSize(); if ("".equals(path) || size == 0) { Informations.resMessage(out, "请选择上传文件或上传文件为空", retr,maindomain); return; } if(size>(1024*1024*imp_size)) { Informations.resMessage(out, "文件大小超过"+imp_size+"M", retr,maindomain); return; } } } // 得到去除路径的文件名 String t_name = path.substring(path.lastIndexOf("\\") + 1); // 得到文件的扩展名(无扩展名时将得到全名) String t_ext = t_name.substring(t_name.lastIndexOf(".") + 1); // 拒绝接受规定文件格式之外的文件类型 int allowFlag = 0; int allowedExtCount = allowtype.length; for (; allowFlag < allowedExtCount; allowFlag++) { if (allowtype[allowFlag].equals(t_ext)) { break; } } if (allowFlag == allowedExtCount) { String message = ""; for (allowFlag = 0; allowFlag < allowedExtCount; allowFlag++) { message += "*." + allowtype[allowFlag] + " "; } Informations.resMessage(out, "请选择：" + message + "类型文件", retr,maindomain); return; } long now = System.currentTimeMillis(); // 根据系统时间生成上传后保存的文件名 String prefix = String.valueOf(now); // 保存的最终文件完整路径,保存在web根目录下的upload目录下 if (!(new File(request.getRealPath("/") + "upload").isDirectory())) { new File(request.getRealPath("/") + "upload").mkdir(); } // 现在文件名 path = request.getRealPath("/") + "upload/" + prefix + "." + t_ext; // 保存文件 fileUploadItem.write(new File(path)); // 开始处理上传文件,进行数据入库操作 String msg = ImpProcess.importUsers(path, sid, rp, t_ext,rmkey); // 操作完成删除文件 file = new File(path); JSONObject jsonObject = JSONObject.fromObject(msg); String code = jsonObject.get("code").toString(); if (Tools.isNotEmpty(code) && code.trim().equals(ReturnCode.S_OK)) { Informations.serviceMessage(out, msg, retr,maindomain); return; } else { Informations.serviceMessage(out, msg, retr,maindomain); return; } } catch (FileUploadException e) { Informations.resMessage(out, "导入失败", retr,maindomain); log.error("sid="+sid +" | result=failure",e); return; } catch (Exception e) { Informations.resMessage(out, "导入失败", retr,maindomain); log.error("sid="+sid+" | result=failure",e); } finally { if (out != null) { out.close(); } if(file!=null) { if (file.exists()) { file.delete(); } } } } }