转帖：http://blog.csdn.net/liuzuochen/article/details/1516522#d20101
1.引言
2.实现代码
2.2.1. AjaxWrapper.js
2.2.2. fileUpload.html
2.2.3. result.jsp
2.2.4. fileUpload.css
2.1.3. 后台服务类（BackGroundService）
3. 结语
1.引言
基于浏览器的文件上传，特别是对于通过<input type="file">标签来实现上传的情况，
存在着严重的性能问题，因为用户提交了文件之后，在浏览器把文件上传到服务器的过程中，界面看上去似乎是静止的，如果是小文件还好些，如果不幸需要上传的是几兆、几十兆甚至上百兆的文件，我相信那是一种非常痛苦的体验，我们中间的很多人应该都有过此种不堪的经历。（一笑）
现在我就针对这个问题给出一个解决方案，我们将实现一个具有监控能力的WEB上传的程序――它不仅把文件上传到服务器，而且"实时地"监视文件上传的实际过程。
解决方案的基本思路是这样的：
在介绍源代码之前，我们先来看看程序运行界面：
2. 实现代码
实现代码想当然的有服务器端代码和客户端代码（呵呵），我们先从服务器端开始。
2.1. 服务器端代码
2.1.1. 文件上传状态类（FileUploadStatus）
使用FileUploadStatus这个类记录文件上传状态，并将其作为服务器端与
web客户端之间通信的媒介，通过对这个类对象提供上传状态作为服务器回应发送给web客户端，
web客户端使用JavaScript获得文件上传状态。源代码如下：
/** *本例程演示了通过Web上传文件过程中的进度显示。您可以对本例程进行任何修改和使用。 * *如需要转载，请注明作者。 * *作者：刘作晨 * */ packageliuzuochen.sample.upload; importjava.util.*; publicclassFileUploadStatus{ //上传用户地址 privateStringuploadAddr; //上传总量 privatelonguploadTotalSize=0; //读取上传总量 privatelongreadTotalSize=0; //当前上传文件号 privateintcurrentUploadFileNum=0; //成功读取上传文件数 privateintsuccessUploadFileCount=0; //状态 privateStringstatus=""; //处理起始时间 privatelongprocessStartTime=0l; //处理终止时间 privatelongprocessEndTime=0l; //处理执行时间 privatelongprocessRunningTime=0l; //上传文件URL列表 privateListuploadFileUrlList=newArrayList(); //取消上传 privatebooleancancel=false; //上传base目录 privateStringbaseDir=""; publicFileUploadStatus(){ } publicStringgetBaseDir(){ returnbaseDir; } publicvoidsetBaseDir(StringbaseDir){ this.baseDir=baseDir; } publicbooleangetCancel(){ returncancel; } publicvoidsetCancel(booleancancel){ this.cancel=cancel; } publicListgetUploadFileUrlList(){ returnuploadFileUrlList; } publicvoidsetUploadFileUrlList(ListuploadFileUrlList){ this.uploadFileUrlList=uploadFileUrlList; } publiclonggetProcessRunningTime(){ returnprocessRunningTime; } publicvoidsetProcessRunningTime(longprocessRunningTime){ this.processRunningTime=processRunningTime; } publiclonggetProcessEndTime(){ returnprocessEndTime; } publicvoidsetProcessEndTime(longprocessEndTime){ this.processEndTime=processEndTime; } publiclonggetProcessStartTime(){ returnprocessStartTime; } publicvoidsetProcessStartTime(longprocessStartTime){ this.processStartTime=processStartTime; } publiclonggetReadTotalSize(){ returnreadTotalSize; } publicvoidsetReadTotalSize(longreadTotalSize){ this.readTotalSize=readTotalSize; } publicintgetSuccessUploadFileCount(){ returnsuccessUploadFileCount; } publicvoidsetSuccessUploadFileCount(intsuccessUploadFileCount){ this.successUploadFileCount=successUploadFileCount; } publicintgetCurrentUploadFileNum(){ returncurrentUploadFileNum; } publicvoidsetCurrentUploadFileNum(intcurrentUploadFileNum){ this.currentUploadFileNum=currentUploadFileNum; } publicStringgetStatus(){ returnstatus; } publicvoidsetStatus(Stringstatus){ this.status=status; } publiclonggetUploadTotalSize(){ returnuploadTotalSize; } publicStringgetUploadAddr(){ returnuploadAddr; } publicvoidsetUploadTotalSize(longuploadTotalSize){ this.uploadTotalSize=uploadTotalSize; } publicvoidsetUploadAddr(StringuploadAddr){ this.uploadAddr=uploadAddr; } publicStringtoJSon(){ StringBufferstrJSon=newStringBuffer(); strJSon.append("{UploadTotalSize:").append(getUploadTotalSize()).append(",") .append("ReadTotalSize:").append(getReadTotalSize()).append(",") .append("CurrentUploadFileNum:").append(getCurrentUploadFileNum()) .append(",") .append("SuccessUploadFileCount:").append(getSuccessUploadFileCount()) .append(",") .append("Status:'").append(getStatus()).append("',") .append("ProcessStartTime:").append(getProcessStartTime()) .append(",") .append("ProcessEndTime:").append(getProcessEndTime()).append(",") .append("ProcessRunningTime:").append(getProcessRunningTime()) .append(",") .append("Cancel:").append(getCancel()).append("}"); returnstrJSon.toString(); } }
2.1.2. 文件上传状态侦听类（FileUploadListener）
使用Common-FileUpload 1.2版本(20070103)。此版本提供了能够监视文件上传情况的
ProcessListener接口，使开发者通过FileUploadBase类对象的setProcessListener方法植
入自己的Listener。 FileUploadListener类实现了ProcessListener，在整个文件上传过程
中，它对上传进度进行监控，并且根据上传 情况实时的更新上传状态Bean。源代码如下：
/** *本例程演示了通过Web上传文件过程中的进度显示。您可以对本例程进行任何修改和使用。 * *如需要转载，请注明作者。 * *作者：刘作晨 * */ packageliuzuochen.sample.upload; importorg.apache.commons.fileupload.ProgressListener; importjavax.servlet.http.HttpServletRequest; publicclassFileUploadListenerimplementsProgressListener{ privateHttpServletRequestrequest=null; publicFileUploadListener(HttpServletRequestrequest){ this.request=request; } /** *更新状态 */ publicvoidupdate(longpBytesRead,longpContentLength,intpItems){ FileUploadStatusstatusBean=BackGroundService.getStatusBean(request); statusBean.setUploadTotalSize(pContentLength); //读取完成 if(pContentLength==-1){ statusBean.setStatus("完成对"+pItems+"个文件的读取:读取了"+pBytesRead +"bytes."); statusBean.setReadTotalSize(pBytesRead); statusBean.setSuccessUploadFileCount(pItems); statusBean.setProcessEndTime(System.currentTimeMillis()); statusBean.setProcessRunningTime(statusBean.getProcessEndTime()); //读取中 }else{ statusBean.setStatus("当前正在处理第"+pItems+"个文件:已经读取了"+pBytesRead +"/"+pContentLength+"bytes."); statusBean.setReadTotalSize(pBytesRead); statusBean.setCurrentUploadFileNum(pItems); statusBean.setProcessRunningTime(System.currentTimeMillis()); } BackGroundService.saveStatusBean(request,statusBean); } }
2.1.3. 后台服务类（BackGroundService）
BackGroundService这个Servlet类负责接收Form Post数据、回应状态轮询请求、处理取
消文件上传的请求。 尽管可以把这些功能相互分离开来，但为了简单明了，还是将它们放到
/** *本例程演示了通过Web上传文件过程中的进度显示。您可以对本例程进行任何修改和使用。 * *如需要转载，请注明作者。 * *作者：刘作晨 * */ packageliuzuochen.sample.upload; importjava.io.File; importjava.io.IOException; importjava.util.List; importjavax.servlet.ServletException; importjavax.servlet.http.HttpServletRequest; importjavax.servlet.http.HttpServletResponse; importorg.apache.commons.fileupload.FileItem; importorg.apache.commons.fileupload.FileUploadException; importorg.apache.commons.fileupload.disk.DiskFileItemFactory; importorg.apache.commons.fileupload.servlet.*; publicclassBackGroundServiceextendsjavax.servlet.http.HttpServletimplements javax.servlet.Servlet{ publicstaticfinalStringUPLOAD_DIR="/upload"; publicstaticfinalStringDEFAULT_UPLOAD_FAILURE_URL="./result.jsp"; publicBackGroundService(){ super(); } protectedvoiddoGet(HttpServletRequestrequest,HttpServletResponseresponse)throwsServletException,IOException{ doPost(request,response); } /** *从文件路径中取出文件名 */ privateStringtakeOutFileName(StringfilePath){ intpos=filePath.lastIndexOf(File.separator); if(pos>0){ returnfilePath.substring(pos+1); }else{ returnfilePath; } } /** *从request中取出FileUploadStatusBean */ publicstaticFileUploadStatusgetStatusBean(HttpServletRequestrequest){ BeanControlerbeanCtrl=BeanControler.getInstance(); returnbeanCtrl.getUploadStatus(request.getRemoteAddr()); } /** *把FileUploadStatusBean保存到类控制器BeanControler */ publicstaticvoidsaveStatusBean(HttpServletRequestrequest,FileUploadStatusstatusBean){ statusBean.setUploadAddr(request.getRemoteAddr()); BeanControlerbeanCtrl=BeanControler.getInstance(); beanCtrl.setUploadStatus(statusBean); } /** *删除已经上传的文件 */ privatevoiddeleteUploadedFile(HttpServletRequestrequest){ FileUploadStatussatusBean=getStatusBean(request); for(inti=0;i<satusBean.getUploadFileUrlList().size();i++){ FileuploadedFile=newFile(request.getRealPath(UPLOAD_DIR) +File.separator+satusBean.getUploadFileUrlList().get(i)); uploadedFile.delete(); } satusBean.getUploadFileUrlList().clear(); satusBean.setStatus("删除已上传的文件"); saveStatusBean(request,satusBean); } /** *上传过程中出错处理 */ privatevoiduploadExceptionHandle(HttpServletRequestrequest,StringerrMsg) throwsServletException,IOException{ //首先删除已经上传的文件 deleteUploadedFile(request); FileUploadStatussatusBean=getStatusBean(request); satusBean.setStatus(errMsg); saveStatusBean(request,satusBean); } /** *初始化文件上传状态Bean */ privateFileUploadStatusinitStatusBean(HttpServletRequestrequest){ FileUploadStatussatusBean=newFileUploadStatus(); satusBean.setStatus("正在准备处理"); satusBean.setUploadTotalSize(request.getContentLength()); satusBean.setProcessStartTime(System.currentTimeMillis()); satusBean.setBaseDir(request.getContextPath()+UPLOAD_DIR); returnsatusBean; } /** *处理文件上传 */ privatevoidprocessFileUpload(HttpServletRequestrequest,IOException{ DiskFileItemFactoryfactory=newDiskFileItemFactory(); //设置内存缓冲区，超过后写入临时文件 factory.setSizeThreshold(10240000); //设置临时文件存储位置 factory.setRepository(newFile(request.getRealPath("/upload/temp"))); ServletFileUploadupload=newServletFileUpload(factory); //设置单个文件的最大上传值 upload.setFileSizeMax(102400000); //设置整个request的最大值 upload.setSizeMax(102400000); upload.setProgressListener(newFileUploadListener(request)); //保存初始化后的FileUploadStatusBean saveStatusBean(request,initStatusBean(request)); StringforwardURL=""; try{ Listitems=upload.parseRequest(request); //获得返回url for(inti=0;i<items.size();i++){ FileItemitem=(FileItem)items.get(i); if(item.isFormField()){ forwardURL=item.getString(); break; } } //处理文件上传 for(inti=0;i<items.size();i++){ FileItemitem=(FileItem)items.get(i); //取消上传 if(getStatusBean(request).getCancel()){ deleteUploadedFile(request); break; } //保存文件 elseif(!item.isFormField()&&item.getName().length()>0){ StringfileName=takeOutFileName(item.getName()); FileuploadedFile=newFile( request.getRealPath(UPLOAD_DIR)+File.separator +fileName); item.write(uploadedFile); //更新上传文件列表 FileUploadStatussatusBean=getStatusBean(request); satusBean.getUploadFileUrlList().add(fileName); saveStatusBean(request,satusBean); Thread.sleep(500); } } }catch(FileUploadExceptione){ uploadExceptionHandle(request,"上传文件时发生错误:"+e.getMessage()); }catch(Exceptione){ uploadExceptionHandle(request,"保存上传文件时发生错误:"+e.getMessage()); } if(forwardURL.length()==0){ forwardURL=DEFAULT_UPLOAD_FAILURE_URL; } request.getRequestDispatcher(forwardURL).forward(request,response); } /** *回应上传状态查询 */ privatevoidresponseStatusQuery(HttpServletRequestrequest,HttpServletResponseresponse)throwsIOException{ response.setContentType("text/xml"); response.setCharacterEncoding("UTF-8"); response.setHeader("Cache-Control","no-cache"); FileUploadStatussatusBean=getStatusBean(request); response.getWriter().write(satusBean.toJSon()); } /** *处理取消文件上传 */ privatevoidprocessCancelFileUpload(HttpServletRequestrequest,HttpServletResponseresponse)throwsIOException{ FileUploadStatussatusBean=getStatusBean(request); satusBean.setCancel(true); saveStatusBean(request,satusBean); responseStatusQuery(request,response); } protectedvoiddoPost(HttpServletRequestrequest,IOException{ booleanisMultipart=ServletFileUpload.isMultipartContent(request); if(isMultipart){ processFileUpload(request,response); }else{ request.setCharacterEncoding("UTF-8"); if(request.getParameter("uploadStatus")!=null){ responseStatusQuery(request,response); } if(request.getParameter("cancelUpload")!=null){ processCancelFileUpload(request,response); } } } }
2.1.4. 文件上传状态控制类（BeanControler）
这是一个单例类，它的功能是为客户端保存文件上传状态，这里我没有使用Session来存储
文件上传状态，因为对于AJAX这种异步调用，服务器会开启不同的Session，所以无法通过Session
保存文件上传状态。 我并不认为这种方法最好，如果有更好的方法，欢迎大家一起讨论。 源代码如下：
/** *本例程演示了通过Web上传文件过程中的进度显示。您可以对本例程进行任何修改和使用。 * *如需要转载，请注明作者。 * *作者：刘作晨 * */ packageliuzuochen.sample.upload; importjava.util.Vector; publicclassBeanControler{ privatestaticBeanControlerbeanControler=newBeanControler(); privateVectorvector=newVector(); privateBeanControler(){ } publicstaticBeanControlergetInstance(){ returnbeanControler; } /** *取得相应FileUploadStatus类对象的存储位置 */ privateintindexOf(StringstrID){ intnReturn=-1; for(inti=0;i<vector.size();i++){ FileUploadStatusstatus=(FileUploadStatus)vector.elementAt(i); if(status.getUploadAddr().equals(strID)){ nReturn=i; break; } } returnnReturn; } /** *取得相应FileUploadStatus类对象 */ publicFileUploadStatusgetUploadStatus(StringstrID){ return(FileUploadStatus)vector.elementAt(indexOf(strID)); } /** *存储FileUploadStatus类对象 */ publicvoidsetUploadStatus(FileUploadStatusstatus){ intnIndex=indexOf(status.getUploadAddr()); if(-1==nIndex){ vector.add(status); }else{ vector.insertElementAt(status,nIndex); vector.removeElementAt(nIndex+1); } } /** *删除FileUploadStatus类对象 */ publicvoidremoveUploadStatus(StringstrID){ intnIndex=indexOf(strID); if(-1!=nIndex) vector.removeElementAt(nIndex); } }
2.2. 客户端代码
客户端我们采用Prototype框架。
2.2.1. AjaxWrapper.js
AjaxWrapper.js对Prototype进行了封装。 源代码如下：
//类工具
varClassUtils=Class.create();
ClassUtils.prototype={
_ClassUtilsName:'ClassUtils',initialize:function(){
},/**
*给类的每个方法注册一个对类对象的自我引用
*@paramreference对类对象的引用
*/
registerFuncSelfLink:function(reference){
for(varninreference){
varitem=reference[n];
if(iteminstanceofFunction)
item.$=reference;
}
}
}
//Ajax操作封装类：
//由于调用AjaxRequest类进行XMLHTTPRequest操作时，this引用（指向当前的对象）会出现了callstack问题，从而指向当前的对象。
//所以，对putRequest、callBackHandler、以及callback方法都要使用arguments.callee.$来获得正确的类对象引用
varAjaxWrapper=Class.create();
AjaxWrapper.prototype={
debug_flag:false,xml_source:'',/**
*初始化
*@paramisDebug是否显示调试信息
*/
initialize:function(isDebug){
newClassUtils().registerFuncSelfLink(this);
this.debug_flag=isDebug;
},/**
*以get的方式向server发送request
*@paramurl
*@paramparams
*@paramcallBackFunction发送成功后回调的函数或者函数名
*/
putRequest:function(url,params,callBackFunction){
varfuncHolder=arguments.callee.$;
varxmlHttp=newAjax.Request(url,{
method:'get',parameters:params,requestHeaders:['my-header-encoding','utf-8'],onFailure:function(){
alert('对不起，网络通讯失败，请重新刷新！');
},onSuccess:function(transport){
},onComplete:function(transport){
funcHolder.callBackHandler.apply(funcHolder,[transport,callBackFunction]);
}
});
},/**
*以post的方式向server发送xml请求
*@paramurl
*@parampostDataBody
*@paramcallBackFunction发送成功后回调的函数或者函数名
*/
pushRequest:function(url,postDataBody,callBackFunction){
varfuncHolder=arguments.callee.$;
varoptions={
method:'post',parameters:'',postBody:postDataBody,onFailure:function(transport){
alert('对不起，网络通讯失败，请重新发送！');
},callBackFunction]);
}
};
varxmlHttp=newAjax.Request(url,options);
},/**
*远程调用的回调处理
*@paramtransportxmlhttp的transport
*@paramcallBackFunction回调时call的方法，可以是函数也可以是函数名
*/
callBackHandler:function(transport,callBackFunction){
varfuncHolder=arguments.callee.$;
if(transport.status!=200){
alert("获得回应失败,请求状态:"+transport.status);
}
else{
funcHolder.xml_source=transport.responseText;
if(funcHolder.debug_flag)
alert('callcallbackfunction');
if(typeof(callBackFunction)=='function'){
if(funcHolder.debug_flag){
alert('invokecallbackFunc');
}
callBackFunction(transport.responseText);
}
else{
if(funcHolder.debug_flag){
alert('evalFunccallbackFunc');
}
newexecute().evalFunc(callBackFunction,transport.responseText);
}
if(funcHolder.debug_flag)
alert('endcallbackfunction');
}
},//显示xml信息
showXMLResponse:function(){
varfuncHolder=arguments.callee.$;
alert(funcHolder.xml_source);
}
}
varXMLDomForAjax=Class.create();
XMLDomForAjax.prototype={
isDebug:false,//dom节点类型常量
ELEMENT_NODE:1,ATTRIBUTE_NODE:2,TEXT_NODE:3,CDATA_SECTION_NODE:4,ENTITY_REFERENCE_NODE:5,ENTITY_NODE:6,PROCESSING_INSTRUCTION_NODE:7,COMMENT_NODE:8,DOCUMENT_NODE:9,DOCUMENT_TYPE_NODE:10,DOCUMENT_FRAGMENT_NODE:11,NOTATION_NODE:12,initialize:function(isDebug){
newClassUtils().registerFuncSelfLink(this);
this.isDebug=isDebug;
},/**
*建立跨平台的dom解析器
*@paramxmlxml字符串
*@returndom解析器
*/
createDomParser:function(xml){
//codeforIE
if(window.ActiveXObject){
vardoc=newActiveXObject("Microsoft.XMLDOM");
doc.async="false";
doc.loadXML(xml);
}
//codeforMozilla,Firefox,Opera,etc.
else{
varparser=newDOMParser();
vardoc=parser.parseFromString(xml,"text/xml");
}
returndoc;
},/**
*反向序列化xml到javascriptBean
*@paramxmlxml字符串
*@returnjavascriptBean
*/
deserializedBeanFromXML:function(xml){
varfuncHolder=arguments.callee.$;
vardoc=funcHolder.createDomParser(xml);
//documentElement总表示文档的root
varobjDomTree=doc.documentElement;
varobj=newObject();
for(vari=0;i<objDomTree.childNodes.length;i++){
//获得节点
varnode=objDomTree.childNodes[i];
//取出其中的field元素进行处理
if((node.nodeType==funcHolder.ELEMENT_NODE)&&(node.tagName=='field')){
varnodeText=funcHolder.getNodeText(node);
if(funcHolder.isDebug){
alert(node.getAttribute('name')+'type:'+node.getAttribute('type')+'text:'+nodeText);
}
varobjFieldValue=null;
//如果为列表
if(node.getAttribute('type')=='java.util.List'){
if(objFieldValue&&typeof(objFieldValue)=='Array'){
if(nodeText.length>0){
objFieldValue[objFieldValue.length]=nodeText;
}
}
else{
objFieldValue=newArray();
}
}
elseif(node.getAttribute('type')=='long'
||node.getAttribute('type')=='java.lang.Long'
||node.getAttribute('type')=='int'
||node.getAttribute('type')=='java.lang.Integer'){
objFieldValue=parseInt(nodeText);
}
elseif(node.getAttribute('type')=='double'
||node.getAttribute('type')=='float'
||node.getAttribute('type')=='java.lang.Double'
||node.getAttribute('type')=='java.lang.Float'){
objFieldValue=parseFloat(nodeText);
}
elseif(node.getAttribute('type')=='java.lang.String'){
objFieldValue=nodeText;
}
else{
objFieldValue=nodeText;
}
//赋值给对象
obj[node.getAttribute('name')]=objFieldValue;
if(funcHolder.isDebug){
alert(eval('obj.'+node.getAttribute('name')));
}
}
elseif(node.nodeType==funcHolder.TEXT_NODE){
if(funcHolder.isDebug){
//alert('TEXT_NODE');
}
}
elseif(node.nodeType==funcHolder.CDATA_SECTION_NODE){
if(funcHolder.isDebug){
//alert('CDATA_SECTION_NODE');
}
}
}
returnobj;
},/**
*获得dom节点的text
*/
getNodeText:function(node){
varfuncHolder=arguments.callee.$;
//isthisatextorCDatanode?
if(node.nodeType==funcHolder.TEXT_NODE||node.nodeType==funcHolder.CDATA_SECTION_NODE){
returnnode.data;
}
vari;
varreturnValue=[];
for(i=0;i<node.childNodes.length;i++){
//采用递归算法
returnValue.push(funcHolder.getNodeText(node.childNodes[i]));
}
returnreturnValue.join('');
}
}
//委托者类
varDispatcher=Class.create();
Dispatcher.prototype={
name:'Dispatcher',//对class中的每个function都赋值一个值为this的$属性
initialize:function(){
newClassUtils().registerFuncSelfLink(this);
},/**
*委托调用
*@paramcaller调用者，func的拥有者
*@paramfunc如果是function对象，则使用Dispatcher对象自己的name作为参数；否则直接调用func
*/
dispatch:function(caller,func){
if(funcinstanceofFunction){
varfuncArguments=newArray();
funcArguments[0]=arguments.callee.$.name;
func.apply(caller,funcArguments);
}
else{
eval(func);
}
}
}
//祈祷者类
varInvoker=Class.create();
Invoker.prototype={
name:'Invoker',invoke:function(showMsg){
alert(showMsg+"――this.name="+this.name);
}
}
2.2.2. fileUpload.html
fileUpload.html是文件上传界面。 源代码如下：
<html> <html> <head> <Metahttp-equiv="Content-Type"content="text/html;charset=GBK"> <scripttype="text/javascript"src="./javascript/prototype.js"></script> <scripttype="text/javascript"src="./javascript/AjaxWrapper.js"></script> <linkhref="./css/fileUpload.css"type="text/css"rel="stylesheet"/> <title>文件上传</title> </head> <body> <divid="controlPanel"> <divid="readme">测试说明:最大上传量:100M，单个文件最大长度:100M</div> <divid="uploadFileUrl"></div> <formid="fileUploadForm"name="fileUploadForm"action="./BackGroundService.action" enctype="multipart/form-data"method="post"> <inputtype="file"name="file"id="file"size="40"/><br> <inputtype="file"name="file"id="file"size="40"/><br> <inputtype="file"name="file"id="file"size="40"/><br> <inputtype="submit"name="uploadButton"id="uploadButton"value="开始上传"/> <inputtype="button"name="cancelUploadButton"id="cancelUploadButton"value="取消上传"/><br> </form> <divid="progressBar"> <divid="theMeter"> <divid="progressBarText"></div> <divid="totalProgressBarBox"> <divid="totalProgressBarBoxContent"></div> </div> </div> <divid="progressStatusText"></div> </div> </div> <script> Element.hide('progressBar'); Event.observe('fileUploadForm','submit',startProgress,false); Event.observe('cancelUploadButton','click',cancelProgress,false); //刷新上传状态 functionrefreshUploadStatus(){ varajaxW=newAjaxWrapper(false); ajaxW.putRequest( './BackGroundService.action','uploadStatus=',function(responseText){ eval("uploadInfo="+responseText); varprogressPercent=Math.ceil( (uploadInfo.ReadTotalSize)/uploadInfo.UploadTotalSize*100); $('progressBarText').innerHTML='上传处理进度:'+progressPercent+'%['+ (uploadInfo.ReadTotalSize)+'/'+uploadInfo.UploadTotalSize+'bytes]'+ '正在处理第'+uploadInfo.CurrentUploadFileNum+'个文件'+ '耗时:'+(uploadInfo.ProcessRunningTime-uploadInfo.ProcessStartTime)+'ms'; $('progressStatusText').innerHTML='反馈状态:'+uploadInfo.Status; $('totalProgressBarBoxContent').style.width=parseInt(progressPercent*3.5)+'px'; } ); } //上传处理 functionstartProgress(){ Element.show('progressBar'); $('progressBarText').innerHTML='上传处理进度:0%'; $('progressStatusText').innerHTML='反馈状态:'; $('uploadButton').disabled=true; varperiodicalExe=newPeriodicalExecuter(refreshUploadStatus,0.5); returntrue; } //取消上传处理 functioncancelProgress(){ $('cancelUploadButton').disabled=true; varajaxW=newAjaxWrapper(false); ajaxW.putRequest( './BackGroundService.action','cancelUpload=true',//因为form的提交，这可能不会执行 function(responseText){ eval("uploadInfo="+responseText); $('progressStatusText').innerHTML='反馈状态:'+uploadInfo.status; if(msgInfo.cancel=='true'){ alert('删除成功!'); window.location.reload(); }; } ); } </script> </body> </html>
2.2.3. result.jsp
<%@pagelanguage="java" contentType="text/html;charset=GBK" pageEncoding="GBK"%> <%@pageimport="liuzuochen.sample.upload.*"%> <!DOCTYPEHTMLPUBLIC"-//W3C//DTDHTML4.01Transitional//EN"> <html> <head> <Metahttp-equiv="Content-Type"content="text/html;charset=GBK"> <linkhref="./css/fileUpload.css"type="text/css"rel="stylesheet"/> <title>文件上传结果</title> </head> <body> <divid="resultPanel"> <div><span>上传文件列表:</span></div> <% FileUploadStatusfUploadStatus=BackGroundService.getStatusBean(request); for(inti=0;i<fUploadStatus.getUploadFileUrlList().size();i++){ StringfileName=(String)fUploadStatus.getUploadFileUrlList().get(i); Stringurl=fUploadStatus.getBaseDir()+"/"+fileName; %> <div><ahref="<%=url%>"_fcksavedurl="<%=url%>"_fcksavedurl="<%=url%>" _fcksavedurl="<%=url%>"><%=fileName%></a></div> <% } if(fUploadStatus.getStatus().indexOf("错误")>=0){ %> <divid='errorArea'><span>错误信息:<%=fUploadStatus.getStatus()%></span></div> <% } elseif(fUploadStatus.getCancel()){ %> <divid='normalMessageArea'><span>由于用户取消上传，所以已经上传的文件均被删除</span></div> <% } BeanControler.getInstance().removeUploadStatus(request.getRemoteAddr()); %> </div> </body> </html>
2.2.4. fileUpload.css
body{
color:#000;
background-color:white;
font:15pxGeorgia,"LucidaGrande",Arial,sans-serif;
letter-spacing:0.01em;
margin:15px;
}
#controlPanel,#resultPanel{
width:700px;
margin:20pxauto;
padding:25px;
border:3pxsolidgray;
-moz-border-radius:10px;
background:#f8f8f8;
}
#errorArea{
width:400px;
margin:20pxauto;
padding:25px;
border:3pxsolidgray;
-moz-border-radius:10px;
background:red;
}
#normalMessageArea{
width:400px;
margin:20pxauto;
padding:25px;
border:3pxsolidgray;
-moz-border-radius:10px;
background:yellow;
}
#progressBar{padding-top:5px;}
#totalProgressBarBox{
width:350px;
height:20px;
border:1pxinset;
background:#eee;
}
#totalProgressBarBoxContent{
width:0;
height:20px;
border-right:1pxsolid#444;
background:#9ACB34;
}
2.3. 配置文件
把如下代码加入web.xml中完成Servlet的配置。
<servlet> <br><description> <br></description> <br><display-name> <br>BackGroundService</display-name> <br><servlet-name>BackGroundService</servlet-name> <br><servlet-class> <br>liuzuochen.sample.upload.BackGroundService</servlet-class> <br></servlet> <br><servlet-mapping> <servlet-name>BackGroundService</servlet-name> <url-pattern>*.action</url-pattern> </servlet-mapping>
3. 结语
整个程序到这里就介绍完了，希望它多少能为您的工作或学习带来点儿帮助。
