Struts2 文件上传进度条的实现实例代码

网友投稿 210 2023-05-18


Struts2 文件上传进度条的实现实例代码

最近在写我们大三项目的一个视频文件上传的页面,实现后台对上传的进度进行监听,然后将监听的信息返回给前台页面。

前台的页面效果图:

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

详细的使用说明参考官网文档:http://jeasyui.com/documentation/index.php

所有需要引入jquery-1.11.1.min.js 以及jquery.easyui.min.js

一.前台的代码:

<%@ 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+"/";

%>

${msg }

当前上传:

文件名

已上传:10.86M/10.86M

关于我们

|

联系合作

|

帮助中心

|

合伙人计划

|

版权声明

江西师范大学瑶湖校区

java工作室


copyright&copy 大白

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

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.getStartwmnXTTime(); //上传开始时间

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");//得wmnXT到存放文件的真是目录

//根据视频的不同类型,存放在不同的目录下

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;

}

}


版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:Vue中使用vux的配置详解
下一篇:java统计汉字字数的方法示例
相关文章

 发表评论

暂时没有评论,来抢沙发吧~