JavaWeb文件上传下载实例讲解(酷炫的文件上传技术)

<form action="/itheimaUpload/UploadServlet" method="post" enctype="multipart/form-data">
请选择上传的文件：<input type="file" name="attach"/><br/>
<input type="submit" value="提交"/>
</form>

//Java后台代码：Commons-fileUpload组件上传文件
public class UploadServlet extends HttpServlet {
public void doGet(HttpServletRequest request,HttpServletResponse response)
throws ServletException,IOException {
//1.配置缓存
DiskFileItemFactory factory = new DiskFileItemFactory(1*1024*1024,new File("c:/tempFiles/"));
//2.创建ServleFileUpload对象
ServletFileUpload sfu = new ServletFileUpload(factory);
//解决文件名称中文问题
sfu.setHeaderEncoding("utf-8");
//3.解析
try {
List<FileItem> list = sfu.parseRequest(request);
//解析所有内容
if(list!=null){
for(FileItem item:list){
//判断是否为普通表单参数
if(item.isFormField()){
//普通表单参数
//获取表单的name属性名称
String fieldName = item.getFieldName();
//获取表单参数值
String value = item.getString("utf-8"); 
}else{
//文件
if(item.getName()!=null && !item.getName().equals("")) {
//保存到服务器硬盘 
FileUtils.copyInputStreamToFile(item.getInputStream(),new File("c:/targetFiles/"+item.getName()));
item.delete();
}
}
}
}
} catch (FileUploadException e) {
e.printStackTrace();
}
}
public void doPost(HttpServletRequest request,IOException {
doGet(request,response);
}
}

<link rel="stylesheet" type="text/css"
href="${pageContext.request.contextPath}/css/webuploader.css">
<script type="text/javascript"
src="${pageContext.request.contextPath }/js/jquery-1.10.2.min.js"></script>
<script type="text/javascript"
src="${pageContext.request.contextPath }/js/webuploader.js"></script>

<!-- 上传div -->
<div id="uploader">
<!-- 显示文件列表信息 -->
<ul id="fileList"></ul>
<!-- 选择文件区域 -->
<div id="filePicker">点击选择文件</div>
</div>

<script type="text/javascript">
//1.初始化WebUpload，以及配置全局的参数
var uploader = WebUploader.create(
{
//flashk控件的地址
swf: "${pageContext.request.contextPath}/js/Uploader.swf",//后台提交地址
server:"${pageContext.request.contextPath}/UploadServlet",//选择文件控件的标签
pick:"#filePicker",//自动上传文件
auto:true,}
);
//2.选择文件后，文件信息队列展示
// 注册fileQueued事件：当文件加入队列后触发
// file: 代表当前选择的文件
uploader.on("fileQueued",function(file){
//追加文件信息div
$("#fileList").append("<div id='"+file.id+"' class='fileInfo'><span>"+file.name+"</span><div class='state'>等待上传...</div><span class='text'></span></div>");
});
//3.注册上传进度监听
//file: 正在上传的文件
//percentage: 当前进度的比例。最大为1.例如:0.2
uploader.on("uploadProgress",function(file,percentage){
var id = $("#"+file.id);
//更新状态信息
id.find("div.state").text("上传中...");
//更新上传百分比
id.find("span.text").text(Math.round(percentage*100)+"%");
});
//4.注册上传完毕监听
//file:上传完毕的文件
//response:后台回送的数据，以json格式返回
uploader.on("uploadSuccess",response){
//更新状态信息
$("#"+file.id).find("div.state").text("上传完毕");
});

DiskFileItemFactory factory = new DiskFileItemFactory();
ServletFileUpload sfu = new ServletFileUpload(factory);
sfu.setHeaderEncoding("utf-8");
try {
List<FileItem> items = sfu.parseRequest(request);
for(FileItem item:items){
if(item.isFormField()){
//普通信息
}else{
//文件信息
//判断只有文件才需要进行保存处理
System.out.println("接收的文件名称:"+item.getName());
//拷贝文件到后台的硬盘
FileUtils.copyInputStreamToFile(item.getInputStream(),new File(serverPath+"/"+item.getName()));
System.out.println("文件保存成功");
}
}
} catch (FileUploadException e) {
e.printStackTrace();
}

uploader.on("fileQueued",function(file){
//追加文件信息div
$("#fileList").append("<div id='"+file.id+"' class='fileInfo'><img/><span>"+file.name+"</span><div class='state'>等待上传...</div><span class='text'></span></div>");
//制造图片缩略图：调用makeThumb()方法
//error: 制造缩略图失败
//src: 缩略图的路径
uploader.makeThumb(file,function(error,src){
var id = $("#"+file.id);
//如果失败，则显示“不能预览”
if(error){
id.find("img").replaceWith("不能预览");
} 
//成功，则显示缩略图到指定位置
id.find("img").attr("src",src); 
});
});

<!-- 上传div -->
<div id="uploader">
<!-- 文件拖拽区域 -->
<div id="dndArea">
<p>将文件直接拖拽到这里即可自动上传</p>
</div>
<!-- 显示文件列表信息 -->
<ul id="fileList"></ul>
<!-- 选择文件区域 -->
<div id="filePicker">点击选择文件</div>
</div>

//1.初始化WebUpload，以及配置全局的参数
var uploader = WebUploader.create(
{
//flashk控件的地址
swf: "${pageContext.request.contextPath}/js/Uploader.swf",//开启拖拽功能，指定拖拽区域
dnd:"#dndArea",//禁用页面其他地方的拖拽功能，防止页面直接打开文件
disableGlobalDnd:true
//开启黏贴功能
paste:"#uploader"
}
);

//1.初始化WebUpload，以及配置全局的参数
var uploader = WebUploader.create(
{
//flashk控件的地址
swf: "${pageContext.request.contextPath}/js/Uploader.swf",//禁用页面其他地方的拖拽功能，防止页面直接打开文件
disableGlobalDnd:true,//开启黏贴功能
paste:"#uploader",//分块上传设置
//是否分块上传
chunked:true,//每块文件大小（默认5M）
chunkSize:5*1024*1024,//开启几个并发线程（默认3个）
threads:3,//在上传当前文件时，准备好下一个文件
prepareNextFile:true
}
);

before-send-file : 在所有分块发送之前调用 
before-send: 如果有分块，在每个分块发送之前调用 
after-send-file: 在所有分块发送完成之后调用
//5.监控文件上传的三个时间点(注意：该段代码必须放在WebUploader.create之前)
//时间点1：:所有分块进行上传之前（1.可以计算文件的唯一标记;2.可以判断是否秒传） 
//时间点2： 如果分块上传，每个分块上传之前（1.询问后台该分块是否已经保存成功，用于断点续传）
//时间点3：所有分块上传成功之后（1.通知后台进行分块文件的合并工作）
WebUploader.Uploader.register({
"before-send-file":"beforeSendFile","before-send":"beforeSend","after-send-file":"afterSendFile"
},{
//时间点1：:所有分块进行上传之前调用此函数
beforeSendFile:function(){
//1.计算文件的唯一标记，用于断点续传和秒传
//2.请求后台是否保存过该文件，如果存在，则跳过该文件，实现秒传功能
},//时间点2：如果有分块上传，则 每个分块上传之前调用此函数
beforeSend:function(){
//1.请求后台是否保存过当前分块，如果存在，则跳过该分块文件，实现断点续传功能
},//时间点3：所有分块上传成功之后调用此函数
afterSendFile:function(){
//1.如果分块上传，则通过后台合并所有分块文件
}
});

//利用md5File（）方法计算文件的唯一标记符
//该函数接收一个deferred
beforeSendFile:function(file){
//创建一个deffered
var deferred = WebUploader.Deferred();
//1.计算文件的唯一标记，用于断点续传和秒传
(new WebUploader.Uploader()).md5File(file,5*1024*1024)
.progress(function(percentage){
$("#"+file.id).find("div.state").text("正在获取文件信息...");
})
.then(function(val){
uniqueFileTag = val;
$("#"+file.id).find("div.state").text("成功获取文件信息");
//只有文件信息获取成功，才进行下一步操作
deferred.resolve();
});
//alert(uniqueFileTag);
//2.请求后台是否保存过该文件，如果存在，则跳过该文件，实现秒传功能
//返回deffered
return deferred.promise();
}

//向后台发送当前文件的唯一标记，用于后台创建保存分块文件的目录
beforeSend:function(){
//携带当前文件的唯一标记到后台，用于让后台创建保存该文件分块的目录
this.owner.options.formData.fileMd5 = fileMd5;
}

//为每个文件创建一个目录，并保存这个文件的所有分块文件
//判断是否已经分块上传
if(chunks!=null){
System.out.println("分块处理...");
//进行分块上传了
//建立一个临时目录，用于保存所有分块文件
File chunksDir = new File(serverPath+"/"+fileMd5);
if(!chunksDir.exists()){
chunksDir.mkdir();
}
if(chunk!=null){
//保存分块文件
File chunkFile = new File(chunksDir.getPath()+"/"+chunk);
FileUtils.copyInputStreamToFile(item.getInputStream(),chunkFile);
}

//前台通知后台合并文件
after-send-file逻辑：
afterSendFile:function(file){
//1.如果分块上传，则通过后台合并所有分块文件
//请求后台合并文件
$.ajax(
{
type:"POST",url:"${pageContext.request.contextPath}/UploadCheckServlet?action=mergeChunks",data:{
//文件唯一标记
fileMd5:fileMd5,//文件名称
fileName:file.name
},dataType:"json",success:function(response){
alert(response.msg);
}
}
);
}
//后台合并所有分块文件
if("mergeChunks".equals(action)){
System.out.println("开始合并文件...");
//合并文件
String fileMd5 = request.getParameter("fileMd5");
String fileName = request.getParameter("fileName");
//读取目录里面的所有文件
File f = new File(serverPath+"/"+fileMd5);
File[] fileArray = f.listFiles(new FileFilter(){
//排除目录，只要文件
public boolean accept(File pathname) {
if(pathname.isDirectory()){
return false;
}
return true;
}
});
//转成集合，便于排序
List<File> fileList = new ArrayList<File>(Arrays.asList(fileArray));
//从小到大排序
Collections.sort(fileList,new Comparator<File>() {
public int compare(File o1,File o2) {
if(Integer.parseInt(o1.getName()) < Integer.parseInt(o2.getName())){
return -1;
}
return 1;
}
});
File outputFile = new File(serverPath+"/"+fileName);
//创建文件
outputFile.createNewFile();
//输出流
FileChannel outChannel = new FileOutputStream(outputFile).getChannel();
//合并
FileChannel inChannel;
for(File file : fileList){
inChannel = new FileInputStream(file).getChannel();
inChannel.transferTo(0,inChannel.size(),outChannel);
inChannel.close();
//删除分片
file.delete();
}
//清除文件夹
File tempFile = new File(serverPath+"/"+fileMd5);
if(tempFile.isDirectory() && tempFile.exists()){
tempFile.delete();
}
//关闭流
outChannel.close();
response.setContentType("text/html;charset=utf-8");
response.getWriter().write("{"msg":"合并成功"}");
}

//时间点2：如果有分块上传，则 每个分块上传之前调用此函数
//block:代表当前分块对象
beforeSend:function(block){
//1.请求后台是否保存过当前分块，如果存在，则跳过该分块文件，实现断点续传功能
var deferred = WebUploader.Deferred();
//请求后台是否保存完成该文件信息，如果保存过，则跳过，如果没有，则发送该分块内容
$.ajax(
{
type:"POST",url:"${pageContext.request.contextPath}/UploadCheckServlet?action=checkChunk",//当前分块下标
chunk:block.chunk,//当前分块大小
chunkSize:block.end-block.start
},success:function(response){
if(response.ifExist){
//分块存在，跳过该分块
deferred.reject();
}else{
//分块不存在或者不完整，重新发送该分块内容
deferred.resolve();
}
}
}
);
//携带当前文件的唯一标记到后台，用于让后台创建保存该文件分块的目录
this.owner.options.formData.fileMd5 = fileMd5;
return deferred.promise(); 
},

//检查该分块是否存在或者完整保存
private void checkChunk(HttpServletRequest request,HttpServletResponse response) throws IOException,FileNotFoundException {
System.out.println("checkChunk...");
String fileMd5 = request.getParameter("fileMd5");
String chunk = request.getParameter("chunk");
String chunkSize = request.getParameter("chunkSize");
File checkFile = new File(serverPath+"/"+fileMd5+"/"+chunk);
response.setContentType("text/html;charset=utf-8");
//检查文件是否存在，且大小是否一致
if(checkFile.exists() && checkFile.length()==Integer.parseInt(chunkSize)){
response.getWriter().write("{"ifExist":1}");
}else{
response.getWriter().write("{"ifExist":0}");
}
}

beforeSendFile:function(file){
//创建一个deffered
var deferred = WebUploader.Deferred();
//1.计算文件的唯一标记，用于断点续传和秒传
(new WebUploader.Uploader()).md5File(file,5*1024*1024)
.progress(function(percentage){
$("#"+file.id).find("div.state").text("正在获取文件信息...");
})
.then(function(val){
fileMd5 = val;
$("#"+file.id).find("div.state").text("成功获取文件信息");
//2.请求后台是否保存过该文件，如果存在，则跳过该文件，实现秒传功能
$.ajax(
{
type:"POST",url:"${pageContext.request.contextPath}/UploadCheckServlet?action=fileCheck",data:{
//文件唯一标记
fileMd5:fileMd5
},success:function(response){
if(response.ifExist){
$("#"+file.id).find("div.state").text("秒传成功"); 
//如果存在，则跳过该文件，秒传成功
deferred.reject();
}else{
//继续上传
deferred.resolve();
}
}
}
);
});
//返回deffered
return deferred.promise();
},

//检查文件的md5数据是否跟在数据库存在
private void fileCheck(HttpServletRequest request,FileNotFoundException {
String fileMd5 = request.getParameter("fileMd5");
//模拟数据库
Map<String,String> database = new HashMap<String,String>();
database.put("576018603f4091782b68b78af85704a1","01.课程回顾.itcast");
response.setContentType("text/html;charset=utf-8");
if(database.containsKey(fileMd5)){
response.getWriter().write("{"ifExist":1}");
}else{
response.getWriter().write("{"ifExist":0}");
}
}