java上传处理-Servlet 批量上传大文件

新建类UploadServlet

 

 

package org.action;

import java.io.File;
import java.io.IOException;
import java.util.Iterator;
import java.util.List;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
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;

@SuppressWarnings("unchecked")
public class UploadServlet extends HttpServlet{

    private static final long serialVersionUID = 1L ;

    @Override
    protected void doGet(HttpServletRequest req, HttpServletResponse resp)
            throws ServletException, IOException {
        doPost(req, resp) ;
    }

    @Override
    protected void doPost(HttpServletRequest request, HttpServletResponse response )
            throws ServletException, IOException {
        DiskFileItemFactory factory = new DiskFileItemFactory() ;
        factory.setSizeThreshold( 8192 ) ;
        String tempPath = request.getSession().getServletContext().getRealPath( "/")
            + "/upload" ;
        File file = new File( tempPath ) ;
        if(!file.isDirectory()){
            file.mkdirs();
        }
        factory.setRepository( file ) ;
        ServletFileUpload upload = new ServletFileUpload( factory ) ;

        List<FileItem> items;
        try {
            items = upload.parseRequest(request);
            Iterator<FileItem> itr = items.iterator();
            while (itr.hasNext()) {// 依次处理每个 form field
                   FileItem item = (FileItem) itr.next();
                   if(!item.isFormField()){ /* 判断是否为表单控件（非File控件），如果不是表单控件，则上传此文件 */
                       File savedFile = new File( tempPath ,  item.getName() ) ;
                       item.write(savedFile) ;
                   }else{/* 如果是表单控件，则保存其值*/
                       System.out.println( item.getFieldName() + "-->" + item.getString() ) ;
                   }
            }
        }catch (Exception e){
            e.printStackTrace() ;
        }
    }

}

package org.action;

import java.io.File;
import java.io.IOException;
import java.util.Iterator;
import java.util.List;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
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;

@SuppressWarnings("unchecked")
public class UploadServlet extends HttpServlet{

	private static final long serialVersionUID = 1L ; 

	@Override
	protected void doGet(HttpServletRequest req, HttpServletResponse resp)
			throws ServletException, IOException {
		doPost(req, resp) ;
	}

	@Override
	protected void doPost(HttpServletRequest request, HttpServletResponse response )
			throws ServletException, IOException {
		DiskFileItemFactory factory = new DiskFileItemFactory() ;
		factory.setSizeThreshold( 8192 ) ;
		String tempPath = request.getSession().getServletContext().getRealPath( "/")
			+ "/upload" ;  
		File file = new File( tempPath ) ;
		if(!file.isDirectory()){
			file.mkdirs();
		}
		factory.setRepository( file ) ;  
		ServletFileUpload upload = new ServletFileUpload( factory ) ;  
		 
		List<FileItem> items;
		try {
			items = upload.parseRequest(request);
			Iterator<FileItem> itr = items.iterator();   
			while (itr.hasNext()) {// 依次处理每个 form field
				   FileItem item = (FileItem) itr.next();
				   if(!item.isFormField()){ /* 判断是否为表单控件（非File控件），如果不是表单控件，则上传此文件 */
					   File savedFile = new File( tempPath ,  item.getName() ) ;  
					   item.write(savedFile) ;
				   }else{/* 如果是表单控件，则保存其值*/
					   System.out.println( item.getFieldName() + "-->" + item.getString() ) ; 
				   }
			}
		}catch (Exception e){
			e.printStackTrace() ; 
		}
	}
	
}

在web.xml 中配置:

 

 

 

<servlet>
    <servlet-name>upload</servlet-name>
    <servlet-class>org.action.UploadServlet</servlet-class>
 </servlet>
 <servlet-mapping>
    <servlet-name>upload</servlet-name>
    <url-pattern>/upload</url-pattern>
 </servlet-mapping>

 <servlet>
  	<servlet-name>upload</servlet-name>
  	<servlet-class>org.action.UploadServlet</servlet-class>
  </servlet>
  <servlet-mapping>
  	<servlet-name>upload</servlet-name>
  	<url-pattern>/upload</url-pattern>
  </servlet-mapping>
  

页面代码：

 

 

<%@ page language="java" import="java.util.*" pageEncoding="ISO-8859-1"%>
<%
String path = request.getContextPath();
String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
%>

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
  <head>
    <base href="<%=basePath%>">

    <title>My JSP 'index.jsp' starting page</title>
    <meta http-equiv="pragma" content="no-cache">
    <meta http-equiv="cache-control" content="no-cache">
    <meta http-equiv="expires" content="0">
    <meta http-equiv="keywords" content="keyword1,keyword2,keyword3">
    <meta http-equiv="description" content="This is my page">
  </head>

  <body>
        <form action="<%=basePath %>upload" method="post" enctype="multipart/form-data">
            <input type="file" name="file"/>
            <input value="name" name="name" type="text" />
            <input type="submit"/>
        </form>
  </body>
</html>

<%@ page language="java" import="java.util.*" pageEncoding="ISO-8859-1"%>
<%
String path = request.getContextPath();
String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
%>

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
  <head>
    <base href="<%=basePath%>">
    
    <title>My JSP 'index.jsp' starting page</title>
	<meta http-equiv="pragma" content="no-cache">
	<meta http-equiv="cache-control" content="no-cache">
	<meta http-equiv="expires" content="0">    
	<meta http-equiv="keywords" content="keyword1,keyword2,keyword3">
	<meta http-equiv="description" content="This is my page">
  </head>
  
  <body>
    	<form action="<%=basePath %>upload" method="post" enctype="multipart/form-data">
    		<input type="file" name="file"/>
    		<input value="name" name="name" type="text" />
    		<input type="submit"/>
    	</form>
  </body>
</html>

 

依赖的jar包，commons-fileupload-1.1.jar 和commons-io-1.1.jar

评论

16 楼 覃永波 2012-10-15  

引用

引用

[img][/img][flash=200,200][/flash][/i][i][b][/b]           

15 楼 ccccccc2003 2012-08-16  

wm920 写道

采用多线程进行分块上传操作。就可以解决内村溢出问题.呵呵

我在生产环境上就遇到了内存撑爆的情况，假设2台应用，每台2G内存，分布式，请求不定向到哪一台机器，一个文件500M，4个人并发请求，tomcat多线程处理请求么，首先tomcat会把这些上传的文件，缓存成临时文件在自己的temp文件夹下，因此当第5个人来的时候，你应用的内存就爆了一台机器。原理就是这样，浏览器B，接受文件转发给flash，flash上传文件到tomcat，你的web容器。然后当都传完的时候，才进入你的代码web层，因此，你无论在代码里做异步线程池也好，当在你的web层代码处理前，你的应用就爆掉了。

14 楼 activexme 2012-06-27  

liguocai2009 写道

wm920 写道

采用多线程进行分块上传操作。就可以解决内村溢出问题.呵呵

能详细讲解下方案么？应该是要前后台结合的吧。
楼主的文章一句说明都没有...不觉得有什么特别的处理

试试Xproer.HttpUploader4这个插件。现在大文件上传一般都是用插件来搞，比如QQ邮箱，DBank网盘，115网盘等。
插件介绍：http://www.cnblogs.com/xproer/archive/2012/02/17/2355440.html
此控件支持100G文件的断点续传操作，提供了完善的开发文档，支持文件MD5验证，支持文件批量上传。
文件MD5值计算进度：

文件MD5值计算完毕

服务器根据MD5检测是否存在相同文件

续传文件

从服务器加载文件列表

文件上传中

文件上传完毕

上传文件夹

与Discuz!X2整合-后台安装断点续传控件

与Discuz!X2整合-后台启用断点续传控件

与Discuz!X2整合-后台断点续传控件启用成功

与Discuz!X2整合-前台发帖页面

与Discuz!X2整合-上传

13 楼 122829827 2012-06-26  

w156445045 写道

稍微大点的文件，你服务器就受不了，生产上是不会用你写的这种代码的~

生产上的代码是怎么样的呢？
感觉这段代码是用在注册头像上的。。。

12 楼 lsjinpeng 2012-06-26  

mark 一下回头看看

11 楼 w156445045 2012-06-26  

稍微大点的文件，你服务器就受不了，生产上是不会用你写的这种代码的~

10 楼 122829827 2012-06-26  

学习先

9 楼 ChineseThink 2012-06-26  

8 楼 xpp02 2012-06-25  

会撑爆内存的。http来传输不是根本之道

7 楼 aijuans 2012-06-25  

确实是简化了的情况

6 楼 liguocai2009 2012-06-25  

wm920 写道

采用多线程进行分块上传操作。就可以解决内村溢出问题.呵呵

能详细讲解下方案么？应该是要前后台结合的吧。
楼主的文章一句说明都没有...不觉得有什么特别的处理

5 楼 wm920 2012-06-25  

采用多线程进行分块上传操作。就可以解决内村溢出问题.呵呵

4 楼 wutao8818 2012-06-25  

确实是简化了的情况

3 楼 paskaa 2012-06-25  

很好，这文章最近我需要

2 楼 aijuans1 2012-06-25  

1 楼 ccccccc2003 2012-06-25  

并发下，会撑爆内存的。http来传输不是根本之道。