使用Struts2如何实现一个进度条功能

这篇文章将为大家详细讲解有关使用Struts2如何实现一个进度条功能，文章内容质量较高，因此小编分享给大家做个参考，希望大家阅读完这篇文章后对相关知识有一定的了解。

10年积累的成都做网站、成都网站设计、成都外贸网站建设经验，可以快速应对客户对网站的新想法和需求。提供各种问题对应的解决方案。让选择我们的客户得到更好、更有力的网络服务。我虽然不认识你，你也不认识我。但先网站制作后付款的网站建设流程，更有栾川免费网站建设让你可以放心的选择与我们合作。

前台的页面效果图：

前台进度条控件选择使用easyui 的progressbar控件。

一.前台的代码:

<%@ page language="java" import="java.util.*" pageEncoding="utf-8"%>
<%@ taglib prefix="s" uri="/struts-tags"%>
<%
String path = request.getContextPath();
String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
%>



 
  
  My JSP 'uploadVideo.jsp' starting page
  
  
    
  
  
  
  
  
  
  
  
  
 
 
  
    
        
          
            
              主站
              视频栏
              资源区
              个人中心
            
            
        

        
          
            
            
            ${msg }
          
           
           
             当前上传：
             文件名
           
           
           
             当前上传的速度:80.23k/s
             已上传:10.86M/10.86M
             剩余时间:00秒
           
           
           
             
               
                 
                   文件上传
                    
                 
               
               
                 
                   标题
                   
                 
               
               
                 
                   分类
                   
                
               
               
                 
                   标签
                   
                 
               
               
                 
                   描述
                                      
                 
               
               
               
             
           
           
        
        
    
    
         
           
             
               关于我们
               |
               联系合作
               |
               帮助中心
               |
               合伙人计划
               |
               版权声明
             
             
               江西师范大学瑶湖校区
               java工作室
               

               copyright© 大白

二.点击上传后，如何获得文上传的进度信息。

1.自定义一个UploadListener类实现org.apache.commons.fileupload中的ProgressListener接口，从而获得当前上传的文件的已读取的数据长度，文件总长度，正在保存第几个文件；

2.重写一个MyMultiPartRequest类，覆盖org.apache.struts2.dispatcher.multipart.JakartaMultiPartRequest，改写parseRequest方法，在其中为上传添加监听器；

3.定义一个UploadStatus bean类存放上传的状态信息，并将获得上传进度信息的UploadStatus对象存在在Session域中;

4.编写UploadListenAction，获取Session域中的UploadStatus对象，进行相应的数据处理，然后将需要的数据放入Map中以json的形式返回给jsp;

5.编写UploadFile.action，实现文件的上传存储;

三.相对应的代码。

package video.action;

import org.apache.commons.fileupload.ProgressListener;

public class UploadListener implements ProgressListener {
  private UploadStatus status;
  
  public UploadListener(UploadStatus status) {
    this.status = status;
  }

   public void update(long bytesRead, long contentLength, int items) {
      // 上传组件会调用该方法
      status.setBytesRead(bytesRead); // 已读取的数据长度
      status.setContentLength(contentLength); // 文件总长度
      status.setItems(items); // 正在保存第几个文件
      
   }
  
}

对于步骤2中MyMultiPartRequest修改后的方法代码。

protected List parseRequest(HttpServletRequest servletRequest, String saveDir) throws FileUploadException {
     UploadStatus status = new UploadStatus(); // 上传状态
     UploadListener listner = new UploadListener(status); // 监听器
     servletRequest.getSession().setAttribute("uploadStatus", status);//将上传的进度状态存放进Session;
    
     DiskFileItemFactory fac = createDiskFileItemFactory(saveDir);
     ServletFileUpload upload = createServletFileUpload(fac);
     
     upload.setProgressListener(listner);// 添加监听器
    return upload.parseRequest(createRequestContext(servletRequest));
  }

package video.action;

public class UploadStatus {
  private long bytesRead; // 已经上传的字节数，单位：字节
  private long contentLength; // 所有文件的总长度，单位：字节
  private int items; // 正在上传第几个文件
  private long startTime = System.currentTimeMillis(); // 开始上传的时间，用于计算上传速度等
  
  public long getBytesRead() {
    return bytesRead;
  }

  public void setBytesRead(long bytesRead) {
    this.bytesRead = bytesRead;
  }

  public long getContentLength() {
    return contentLength;
  }

  public void setContentLength(long contentLength) {
    this.contentLength = contentLength;
  }

  public int getItems() {
    return items;
  }

  public void setItems(int items) {
    this.items = items;
  }

  public long getStartTime() {
    return startTime;
  }

  public void setStartTime(long startTime) {
    this.startTime = startTime;
  }
}

package video.action;

import java.util.HashMap;
import java.util.Map;

import org.apache.struts2.interceptor.SessionAware;

import com.opensymphony.xwork2.ActionSupport;

public class UploadListenAction extends ActionSupport implements SessionAware{
  private UploadStatus status;
  Map session;
  Map progressInfo=new HashMap<>();
  @Override
  public String execute() throws Exception {
    // TODO Auto-generated method stub
    status=(UploadStatus)session.get("uploadStatus");
    if(status!=null){
      long startTime = status.getStartTime(); //上传开始时间
      long currentTime = System.currentTimeMillis(); //现在时间
      long time = (currentTime - startTime)/ 1000 + 1; //已传输的时间 单位:s
      //传输速度单位:byte/s
      double velocity = ((double)status.getBytesRead()/1000) / (double)time;
     //估计总时间
      double totalTime = status.getContentLength()/velocity;
     //估计剩余时间
      double timeLeft = totalTime - time;
      //已经完成的百分比
      int percent = (int)(100 * (double)status.getBytesRead() / (double)status.getContentLength());
      //已经完成数单位:m
      double length = ((double) status.getBytesRead())/1024/1024;
      //总长度 单位:m
      double totalLength = ((double) status.getContentLength())/1024/1024;
      progressInfo.put("percent", String.valueOf(percent));
      progressInfo.put("velocity", String.valueOf(velocity));
      progressInfo.put("totalTime", String.valueOf(totalTime));
      progressInfo.put("timeLeft", String.valueOf(timeLeft));
      progressInfo.put("length", String.valueOf(length));
      progressInfo.put("totalLength", String.valueOf(totalLength));
    }
    
    return super.execute();
  }
  @Override
  public void setSession(Map session) {
    // TODO Auto-generated method stub
    this.session=session;
  }
  public Map getProgressInfo() {
    return progressInfo;
  }
  
  /*public UploadStatus getStatus() {
    return status;
  }*/
  
}

package video.action;

import java.io.File;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Map;

import javax.servlet.ServletContext;

import org.apache.commons.io.FileUtils;
import org.apache.struts2.ServletActionContext;
import org.apache.struts2.interceptor.SessionAware;

import video.dao.UploadDao;
import video.daoimpl.UploadDaoImpl;
import videomodel.VideoInfo;
import cn.history.pojo.User;

import com.opensymphony.xwork2.ActionContext;
import com.opensymphony.xwork2.ActionSupport;

public class UploadFile extends ActionSupport{
  private static final long serialVersionUID = 4182168930616232826L;
  private String name;  //标题名
  private File video;    
  private String videoFileName;
  private String videoContentType;
  private String videoDesc;  //描述
  private int cate;      //类型
  private String tag;      //标签
  /*private VideoInfo videoInfo=new VideoInfo();*/
  private String msg;

  private UploadDao uploadDao=new UploadDaoImpl();
  public String upload() throws Exception{
    //完成上传
    ServletContext sc=ServletActionContext.getServletContext();
    String directory=sc.getRealPath("/video");//得到存放文件的真是目录
    //根据视频的不同类型，存放在不同的目录下
    if(cate==1){  //如果是传统文学
      directory=directory+"/guoxue";
    }else if(cate==2){
      directory=directory+"/minjian";
    }else{
      directory=directory+"/jiari";
    }
    SimpleDateFormat sdf=new SimpleDateFormat("yyyyMMddHHmmssS");//格式化时间输出
    String Rname=null;
    if(name!=null&&!name.equals("")){
      Rname=name+"_"+sdf.format(new Date())+".mp4";
    }else{
      Rname=videoFileName;
    }
    System.out.println(Rname);
    //构建目标文件
    File target=new File(directory,Rname);
    FileUtils.copyFile(video, target);
    System.out.println(Rname+"\n"+videoFileName+"\n"+videoDesc+"\n"+videoContentType);
    //将成功上传的视频基本信息保存至数据库m
    String filePath=target.getPath();
    filePath=filePath.substring(filePath.indexOf("video")).replace("\\", "/");
    System.out.println(filePath);
    VideoInfo videoInfo=new VideoInfo();
    videoInfo.setVideoName(Rname);
    videoInfo.setVideoDesc(videoDesc);
    videoInfo.setVideoUrl(filePath);
    videoInfo.setCate(cate);
    videoInfo.setTag(tag);
    //ActionContext.getContext().getSession().get("name");
    if(ActionContext.getContext().getSession().get("user")!=null){
      User user=(User) ActionContext.getContext().getSession().get("user");
      videoInfo.setAuthorId(user.getUser_id());
    }else{
      //设置为管理员的id，默认是管理员上传的
      videoInfo.setAuthorId(1);
    }
    int tag=uploadDao.saveVideo(videoInfo);
    if(tag==0){
      msg="上传失败(存储数据库过程出错)";
      return INPUT;
    }else{
      msg="视频上传成功";
    }
    return SUCCESS;
  }
  
/*  public VideoInfo getVideoInfo() {
    return videoInfo;
  }

  public void setVideoInfo(VideoInfo videoInfo) {
    this.videoInfo = videoInfo;
  }*/

  /*public String getName() {
    return name;
  }*/

  public void setName(String name) {
    this.name = name;
  }

//  public File getVideo() {
//    return video;
//  }

  public void setVideo(File video) {
    System.out.println(video);
    this.video = video;
  }
  
//  public String getVideoDesc() {
//    return videoDesc;
//  }
  public void setVideoDesc(String videoDesc) {
    this.videoDesc = videoDesc;
  }
  
  /*public int getCate() {
    return cate;
  }*/

  public void setCate(int cate) {
    this.cate = cate;
  }
  
  /*public String getTag() {
    return tag;
  }*/

  public void setTag(String tag) {
    this.tag = tag;
  }

//  public String getVideoFileName() {
//    return videoFileName;
//  }

  public void setVideoFileName(String videoFileName) {
    this.videoFileName = videoFileName;
  }

  /*public String getVideoContentType() {
    return videoContentType;
  }*/

  public void setVideoContentType(String videoContentType) {
    this.videoContentType = videoContentType;
  }
  public String getMsg() {
    return msg;
  }
  public void setMsg(String msg) {
    this.msg = msg;
  }
}

关于使用Struts2如何实现一个进度条功能就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。

当前文章：使用Struts2如何实现一个进度条功能
网站路径：http://dzwzjz.com/article/gejipc.html

大橙子网站建设，新征程启航

使用Struts2如何实现一个进度条功能

其他资讯