Java动态显示文件上传进度实现代码

实现文件上传的进度显示,我们先看看都有哪些问题我们要解决。
1 上传数据的处理进度跟踪
2 进度数据在用户页面的显示

就这么2个问题,
第一个问题,主要是组件的选择
必须支持数据处理侦听或通知的组件。当然,我肯定只用我自己的组件啦。基本原理是

1 使用request.getContentLength() 读取到处理数据的总长度,注意这个长度不等于文件的长度,因为Base64等编码会增加数据量,如果超过了允许的长度,直接返回-1;

2 在每读取一部分数据时(比如一行,或者64K,或者你自定义的字节数),将读取的字节数通知我们的进度跟踪程序。我取名为 UploadListener代码如下

/*
* 处理附件上传的通知。

* 各位可以继承这个类,来实现自己的特殊处理。
*
* @author 赵学庆 www.java2000.net
*/
 public  class UploadListener ... {
  // 调试模式将在控制台打印出一些数据
  private  boolean debug;

  // 总数据字节数
  private  int total;

  // 当前已经处理的数据字节数
  private  int totalCurrent =  0 ;

  // 延迟,用来调试用,免得速度太快,根本卡看不到进度
  private  int delay =  0 ;

   /** */ /**
  * 处理数据通知的方法。

  * 保存已经处理的数据。并且在一定的比例进行延迟。默认每1%

  * 如果不需用延迟,可以删掉内部的代码,加快速度。
  *
  * @param size 增加的字节数
   */
   public  void increaseTotalCurrent( long size) ... {
   this .totalCurrent += size;
    try  ... {
    currentRate = totalCurrent *  100  / total;
     if (currentRate > lastRate) ... {
      if (delay >  0 ) ... {
      Thread.sleep(delay);
     }
      if (debug) ... {
      System.out.println( " rate= "  + totalCurrent +  " / "  + total +  " / "  + (totalCurrent *  100  / total));
     }
     lastRate = currentRate;
    }
   }  catch (Exception e) ... {
    e.printStackTrace();
   }
  } 

   /** */ /**
  * 读取全部自己数
  *
  * @return
   */
   public  int getTotal() ... {
   return total;
  } 

   /** */ /**
  * 读取已经处理的字节数
  *
  * @return
   */
   public  int getTotalCurrent() ... {
   return totalCurrent;
  } 

  private  long lastRate =  0 ;

  private  long currentRate =  0 ;

   public  int getDelay() ... {
   return delay;
  } 

   public  void setDelay( int delay) ... {
   this .delay = delay;
  } 

   public  void setTotal( int total) ... {
   this .total = total;
  } 

   public  boolean isDebug() ... {
   return debug;
  } 

   public  void setDebug( boolean debug) ... {
   this .debug = debug;
  }
}

3 下面我们来看上传的处理部分

  Upload upload =  new Upload(request);
  // 增加了侦听进度的代码
  UploadListener uploadListener =  new UploadListener();
  // 这句话我们后面再讨论,这个可是关键
  session.setAttribute( " uploadListener " ,uploadListener);
  uploadListener.setDelay( 0 );
  uploadListener.setDebug( true );
  upload.setUploadListener(uploadListener);
  upload.parse();
  // 这句话同样重要,我们后面再讨论
  session.setAttribute( " uploadListener " , null );

4 我们再看上传的表单部分

< script. type = " text/javascript. " >
 function checkForm() ... {
  $( " SHOW_FRAME. " ).src = " link.jsp " ;
  $( ' SUBMIT ' ).disabled = true ;
  Ext.MessageBox.show( ... {
   title: ' Please wait... ' ,
   msg: ' Initializing... ' ,
   width: 240 ,
   progress: true ,
   closable: false
  } );
  $( " MAIN_FORM. " ).submit();
  return  false ;
}
 function setUploadProcess(total,current) ... {
  var rate = Number(current) / Number(total);
  Ext.MessageBox.updateProgress(rate, ' Uploading... ' + current + " / " + total);
   if (Number(current) >= Number(total)) ... {
   closeUploadProcess();
  }
}
 function closeUploadProcess() ... {
  Ext.MessageBox.hide();
}
</ script. >
< iframe. name = " ACTION_FRAME. " id = " ACTION_FRAME. " width = " 0 " height = " 0 " ></ iframe. >
< iframe. name = " SHOW_FRAME. " id = " SHOW_FRAME. " width = " 0 " height = " 0 " ></ iframe. >
< form. method = " OST " id = " MAIN_FORM. " nsubmit = " return checkForm() " enctype = " multipart/form-data "
  action = " uploadFileSave.jsp " target = " ACTION_FRAME. " >
  < input type = " file " size = " 50 " name = " file " >
  < input type = " submit " ID = " SUBMIT " value = " Upload It " >
</ form. >

第一个iframe用于提交表单数据,第二个就是我们用来获取处理数据进度信息的。
提交表单很简单,target指向了我们的第一个iframe.
我们看一下JS
checkForm. 里面第一句就是关键的读取进度信息的页面,我们在第二个iframe里面获得。然后就是弹出进度的显示框,我使用了Ext. 然后提交上传表单
setUploadProcess 用来更新进度框上面的数据,第一个参数是数据总共的大小,第二个参数是已经处理的大小。
closeUploadProcess 关闭进度框

5 最后,我们来看读取进度信息的页面

<% @ page language = " java " contentType = " text/html; charset=utf-8 " pageEncoding = " utf-8 " %>
<% @include file = " ../package.inc.jsp " %>
<%
  response.setHeader( " ragma " , " no-cache " );
  response.setHeader( " Cache-Control " , " no-cache " );
  response.setDateHeader( " Expires " , 0 );
  response.setBufferSize( 0 );
  UploadListener uploadListener =  null ;
   while (uploadListener ==  null  || uploadListener.getTotalCurrent() <=  0 ) ... {
   uploadListener = (UploadListener) session.getAttribute( " uploadListener " );
   out.print( " . " );
   out.flush();
   Thread.sleep( 10 );
  }
  long total = uploadListener.getTotal();
  out.println(total);
  long current;
  out.flush();
   while ( true ) ... {
   current = uploadListener.getTotalCurrent();
    if (current >= total) ... {
    break ;
   }
   out.println( " <script. type='text/javascript'>parent.setUploadProcess(' "  + total +  " ',' "  + current +  " ');</script> " );
   out.flush();
   Thread.sleep( 10 );
  }
%>< script. type = " text/javascript. " > parent.closeUploadProcess(); </ script. >

其中前面的循环,用来判断是否产生了上传的信息,如果没有则等待。
然后就是读取上传的信息,并计算后生成调用上级窗口的更新进度条的JS, 请注意out.print后面必须跟上out.flush,否则不会持续输出到客户端,也就不会看到连续的进度条变化。

总结:

上面的部分比较乱,我这里总结一下关键点。

1、在上传组件里面,把总大小和当前读取了的大小放到一个类里面,并持续更新,直到处理完毕
2、上传的进度类,放在session里面,供进度读取页面读取
3、进度读取页面,从session里面拿到数据,并返回结果。

有几个疑问解释一下。

1、由于Http协议决定了,必须等request处理完毕才会返回输出,所以不能在upload页面里进行处理进度的显示。我前面测试到1M左右的文件不成功,就是没有考虑到这个问题。所以必须单独用一个GET的程序进行读取
2、读取是一个持续不断的过程,因为上传大文件是很慢的!
3、如果你的应用服务器启用了GZIP压缩,是容器管理的,那么很不幸,因为容易必须拿到所有的数据,至少是一部分数据才会返回,所以造成我们返回的那些很少的字节经常会被截住,造成无法显示上传的连续过程。 
  解决方法 
  1) 关闭GZIP, 我想许多人不会这么做 
  2) 使用自定义的GZIP压缩,判断某些东西(比如URL),对他们不进行压缩处理

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。

(0)

相关推荐

  • Java中FTPClient上传中文目录、中文文件名乱码问题解决方法

    问题描述: 使用org.apache.commons.net.ftp.FTPClient创建中文目录.上传中文文件名时,目录名及文件名中的中文显示为"??". 原因: FTP协议里面,规定文件名编码为iso-8859-1,所以目录名或文件名需要转码. 解决方案: 1.将中文的目录或文件名转为iso-8859-1编码的字符.参考代码: 复制代码 代码如下: String name="目录名或文件名"; name=new String(name.getBytes(&qu

  • java使用ftp上传文件示例分享

    复制代码 代码如下: import java.io.ByteArrayInputStream;  import java.io.FileOutputStream;  import java.io.IOException;  import java.net.SocketException;  import java.text.SimpleDateFormat;  import java.util.Date; import org.apache.commons.io.IOUtils;  import

  • JAVA技术实现上传下载文件到FTP服务器(完整)

    具体详细介绍请看下文: 在使用文件进行交互数据的应用来说,使用FTP服务器是一个很好的选择.本文使用Apache Jakarta Commons Net(commons-net-3.3.jar) 基于FileZilla Server服务器实现FTP服务器上文件的上传/下载/删除等操作. 关于FileZilla Server服务器的详细搭建配置过程,详情请见 FileZilla Server安装配置教程 .之前有朋友说,上传大文件(几百M以上的文件)到FTP服务器时会重现无法重命名的问题,但本人亲

  • Java通过FTP服务器上传下载文件的方法

    对于使用文件进行交换数据的应用来说,使用FTP 服务器是一个很不错的解决方案. 关于FileZilla Server服务器的详细搭建配置过程,详情请见FileZilla Server安装配置教程.之前有朋友说,上传大文件(几百M以上的文件)到FTP服务器时会重现无法重命名的问题,但本人亲测上传2G的文件到FileZilla Server都没有该问题,朋友们可以放心使用该代码. FavFTPUtil.Java package com.favccxx.favsoft.util; import jav

  • Java中使用WebUploader插件上传大文件单文件和多文件的方法小结

    一.使用webuploader插件的原因说明 被现在做的项目坑了. 先说一下我的项目架构spring+struts2+mybatis+MySQL 然后呢.之前说好的按照2G上传就可以了,于是乎,用了ajaxFileUpload插件,因为之前用图片上传也是用这个,所以上传附件的时候就直接拿来用了 各种码代码,测试也测过了,2G文件上传没问题,坑来了,项目上线后,客户又要求上传4G文件,甚至还有20G以上的..纳尼,你不早说哦... 在IE11下用ajaxFileUpload.js插件上传超过4G的

  • JavaWeb实现文件上传下载功能实例解析

    在Web应用系统开发中,文件上传和下载功能是非常常用的功能,今天来讲一下JavaWeb中的文件上传和下载功能的实现. 对于文件上传,浏览器在上传的过程中是将文件以流的形式提交到服务器端的,如果直接使用Servlet获取上传文件的输入流然后再解析里面的请求参数是比较麻烦,所以一般选择采用apache的开源工具common-fileupload这个文件上传组件.这个common-fileupload上传组件的jar包可以去apache官网上面下载,也可以在struts的lib文件夹下面找到,stru

  • java中struts2实现文件上传下载功能实例解析

    本文实例讲述了java中struts2实现文件上传下载功能实现方法.分享给大家供大家参考.具体分析如下: 1.文件上传 首先是jsp页面的代码 在jsp页面中定义一个上传标签 复制代码 代码如下: <tr>      <td align="right" bgcolor="#F5F8F9"><b>附件:</b></td>      <td bgcolor="#FFFFFF">

  • java实现文件上传下载和图片压缩代码示例

    分享一个在项目中用的到文件上传下载和对图片的压缩,直接从项目中扒出来的:) 复制代码 代码如下: package com.eabax.plugin.yundada.utils; import java.awt.image.BufferedImage; import java.io.File; import java.io.IOException; import java.text.SimpleDateFormat; import java.util.Date; import java.util.

  • java使用smartupload组件实现文件上传的方法

    本文实例讲述了java使用smartupload组件实现文件上传的方法.分享给大家供大家参考.具体分析如下: 文件上传几乎是所有网站都具有的功能,用户可以将文件上传到服务器的指定文件夹中,也可以保存在数据库中,这里主要说明smartupload组件上传. 在讲解smartupload上传前,我们先来看看不使用组件是怎么完成上传的原理的? 废话不多说直接上代码: 复制代码 代码如下: import java.io.*; import java.util.*; import javax.servle

  • java实现分段读取文件并通过HTTP上传的方法

    本文实例讲述了java实现分段读取文件并通过HTTP上传的方法.分享给大家供大家参考.具体如下: 1.首先将文件分段,用RandomAccessFile 2.分段后将分出的内容上传到http URL url = new URL(actionUrl); HttpURLConnection con = (HttpURLConnection) url.openConnection(); /** 允许Input.Output,不使用Cache */ con.setDoInput(true); con.s

随机推荐