Java web開發——文件夾的(de)上(shàng)傳和(hé / huò)下載
發表時(shí)間:2019-12-17
發布人(rén):融晨科技
浏覽次數:46
我們平時(shí)經常做的(de)是(shì)上(shàng)傳文件,上(shàng)傳文件夾與上(shàng)傳文件類似,但也(yě)有一些不(bù)同之(zhī)處,這(zhè)次做了(le/liǎo)上(shàng)傳文件夾就(jiù)記錄下以(yǐ)備後用。
這(zhè)次項目的(de)需求:
支持大(dà)文件的(de)上(shàng)傳和(hé / huò)續傳,要(yào / yāo)求續傳支持所有浏覽器,包括ie6,ie7,ie8,ie9,Chrome,Firefox,360安全浏覽器,并且刷新浏覽器後仍然能夠續傳,重啓浏覽器(關閉浏覽器後再打開)仍然能夠繼續上(shàng)傳,重啓電腦後仍然能夠上(shàng)傳
支持文件夾的(de)上(shàng)傳,要(yào / yāo)求服務端能夠保留層級結構,并且能夠續傳。需要(yào / yāo)支持10萬個(gè)以(yǐ)上(shàng)的(de)文件夾上(shàng)傳。
支持低版本的(de)系統和(hé / huò)浏覽器,因爲(wéi / wèi)這(zhè)個(gè)項目的(de)最終運行環境在(zài)政府,政府的(de)配置都一般,職員都是(shì)辦公用,内存都不(bù)大(dà),基本上(shàng)以(yǐ)Windows XP的(de)系統爲(wéi / wèi)主。
1、介紹enctype
enctype 屬性規定發送到(dào)服務器之(zhī)前應該如何對表單數據進行編碼。
enctype作用是(shì)告知服務器請求正文的(de)MIME類型(請求消息頭content-type的(de)作用一樣)
1、1 enctype的(de)取值有三種
值
描述
application/x-www-form-urlencoded
在(zài)發送前編碼所有字符(默認)
multipart/form-data
不(bù)對字符編碼。每一個(gè)表單項分割爲(wéi / wèi)一個(gè)部件
text/plain
空格轉換爲(wéi / wèi) “+” 加号,但不(bù)對特殊字符編碼。
1. 當enctype=’application/x-www-form-urlencoded’
2.當enctype=’multipart/form-data’
通過觀察發現這(zhè)個(gè)的(de)請求體就(jiù)發生了(le/liǎo)變化。這(zhè)種請求體被稱之(zhī)爲(wéi / wèi)多部件請求體。
什麽是(shì)多部件請求體:就(jiù)是(shì)把每一個(gè)表單項分割爲(wéi / wèi)一個(gè)部件。
以(yǐ)請求頭的(de)content-type的(de)boundary後面的(de)一串随機字符串作爲(wéi / wèi)分割标識
普通表單項:
//name的(de)意思是(shì)文本框裏面name的(de)屬性值,而(ér)admin是(shì)我們輸入的(de)文本值
Content-Disposition: form-data; name="username"
admin
文件表單項
//filename的(de)意思是(shì):我們上(shàng)傳的(de)文件名稱,content-Type的(de)意思是(shì):MIME類型,asdasdas的(de)意思是(shì):文件裏面的(de)内容
Content-Disposition: form-data; name="upload"; filename="a.txt"
Content-Type: text/plain
asdasdas
3. 當enctype=’text/plain’
w3c稱:空格會變成”+”加号,但是(shì)我這(zhè)裏沒有發現,隻有當get請求的(de)時(shí)候,空格會變成”+”号
進入正題
完成上(shàng)傳需要(yào / yāo)滿足3個(gè)必要(yào / yāo)的(de)條件
提供form表單,method必須是(shì)post,因爲(wéi / wèi)get請求的(de)傳輸數據一般爲(wéi / wèi)2kb,不(bù)同浏覽器不(bù)一樣。
form表單屬性enctype的(de)必須是(shì)multipart/form-data
提供input type=”file”類的(de)上(shàng)傳輸入域
大(dà)緻實現原理:當enctype的(de)值是(shì)multipart/form-data時(shí),浏覽器會把每個(gè)表單項進行分割,分割成不(bù)同的(de)部件,以(yǐ)boundary的(de)值爲(wéi / wèi)分割标識,這(zhè)個(gè)标識的(de)字符串是(shì)随機生成的(de),最後一個(gè)表單項的(de)分割标識字符串末尾會多兩個(gè)”- -“,代表結束。服務端用request.getHeader(“content-type”)獲取分割字符串,然後進行解析。
代碼實現
一、開發環境搭建
準備兩個(gè)第三方jar包
commons-io包
commons-upload包
所有依賴包
代碼實現
<%@ page language="java" import="up6.DBFile" pageEncoding="UTF-8"%>
<%@ page contentType="text/html;charset=UTF-8"%>
<%@ page import="up6.FileBlockWriter" %>
<%@ page import="up6.XDebug" %>
<%@ page import="up6.*" %>
<%@ page import="up6.biz.*" %>
<%@ page import="org.apache.commons.fileupload.FileItem" %>
<%@ page import="org.apache.commons.fileupload.FileItemFactory" %>
<%@ page import="org.apache.commons.fileupload.FileUploadException" %>
<%@ page import="org.apache.commons.fileupload.disk.DiskFileItemFactory" %>
<%@ page import="org.apache.commons.fileupload.servlet.ServletFileUpload" %>
<%@ page import="org.apache.commons.lang.*" %>
<%@ page import="java.net.URLDecoder"%>
<%@ page import="java.util.Iterator"%>
<%@ page import="net.sf.json.JSONObject"%>
<%@ page import="java.util.List"%>
<%
out.clear();
String uid = request.getHeader("uid");//
String id = request.getHeader("id");
String lenSvr = request.getHeader("lenSvr");
String lenLoc = request.getHeader("lenLoc");
String blockOffset = request.getHeader("blockOffset");
String blockSize = request.getHeader("blockSize");
String blockIndex = request.getHeader("blockIndex");
String blockMd5 = request.getHeader("blockMd5");
String complete = request.getHeader("complete");
String pathSvr = "";
//參數爲(wéi / wèi)空
if( StringUtils.isBlank( uid )
|| StringUtils.isBlank( id )
|| StringUtils.isBlank( blockOffset ))
{
XDebug.Output("param is null");return;
}
boolean isMultipart = ServletFileUpload.isMultipartContent(request);
FileItemFactory factory = new DiskFileItemFactory();
ServletFileUpload upload = new ServletFileUpload(factory);
List files = null;
try {files = upload.parseRequest(request);}
catch (FileUploadException e)
{out.println("read file data error:" + e.toString());return;}
FileItem rangeFile = null;
Iterator fileItr = files.iterator();
while (fileItr.hasNext())
{
rangeFile = (FileItem) fileItr.next();
if(StringUtils.equals( rangeFile.getFieldName(),"pathSvr"))
{
pathSvr = rangeFile.getString();
pathSvr = PathTool.url_decode(pathSvr);
}
}
boolean verify = false;
String msg = "";
String md5Svr = "";
long blockSizeSvr = rangeFile.getSize();
if(!StringUtils.isBlank(blockMd5)){md5Svr = Md5Tool.fileToMD5(rangeFile.getInputStream());}
verify = Integer.parseInt(blockSize) == blockSizeSvr;
if(!verify){ msg = "block size error sizeSvr:" + blockSizeSvr + "sizeLoc:" + blockSize;}
if(verify && !StringUtils.isBlank(blockMd5))
{
verify = md5Svr.equals(blockMd5); if(!verify) msg = "block md5 error";
}
if(verify)
{
FileBlockWriter res = new FileBlockWriter();
if( Integer.parseInt(blockIndex)==1) res.CreateFile(pathSvr,Long.parseLong(lenLoc));
res.write( Long.parseLong(blockOffset),pathSvr,rangeFile);
up6_biz_event.file_post_block(id,Integer.parseInt(blockIndex));
JSONObject o = new JSONObject();
o.put("msg", "ok");
o.put("md5", md5Svr);
o.put("offset", blockOffset);
msg = o.toString();
}
rangeFile.delete();
out.write(msg);
%>
下載的(de)必須條件
兩個(gè)頭一個(gè)流
content-type
Content-Type是(shì)返回消息中非常重要(yào / yāo)的(de)内容,表示文檔内容屬于(yú)什麽MIME類型。
浏覽器會根據Content-Type來(lái)決定如何顯示返回的(de)消息體内容。
默認值是(shì)text/html
可以(yǐ)使用request.getServletContext().getMimeType(“文件名”)獲取MIME類型。
Content-Disposition
Content-disposition 是(shì) MIME 協議的(de)擴展,MIME 協議指示 MIME 用戶代理如何顯示附加的(de)文件。
默認值是(shì)inline,表示在(zài)浏覽器窗口中打開。
服務端向客戶端遊覽器發送文件時(shí),如果是(shì)浏覽器支持的(de)文件類型,一般會默認使用浏覽器打開,比如txt、jpg等,會直接在(zài)浏覽器 中顯示。
如果需要(yào / yāo)提示用戶保存,利用Content-Disposition進行一下處理,關鍵在(zài)于(yú)一定要(yào / yāo)加上(shàng)attachment。
例如:Content-Disposition:attachment;filename=xxx,浏覽器就(jiù)會激活下載框對話框, attachment 表示附件, filname 後面跟随的(de)是(shì)顯示在(zài)下載框中的(de)文件名稱。
流
下載就(jiù)是(shì)向客戶端響應字節數據! 将一個(gè)文件變成字節數組, 使用 response.getOutputStream()
來(lái)響應給浏覽器。
代碼如下,此代碼已經實現了(le/liǎo)斷點續傳功能,用戶在(zài)下載過程可以(yǐ)暫停,和(hé / huò)繼續下載,對服務器造成的(de)壓力也(yě)比較小。
String fid = request.getHeader("id");
String blockIndex = request.getHeader("blockIndex");//基于(yú)1
String blockOffset = request.getHeader("blockOffset");//塊偏移,相對于(yú)整個(gè)文件
String blockSize = request.getHeader("blockSize");//塊大(dà)小(當前需要(yào / yāo)下載的(de)大(dà)小)
String pathSvr = request.getHeader("pathSvr");//文件在(zài)服務器的(de)位置
pathSvr = PathTool.url_decode(pathSvr);
if ( StringUtils.isBlank(fid)
||StringUtils.isBlank(blockIndex)
||StringUtils.isEmpty(blockOffset)
||StringUtils.isBlank(blockSize)
||StringUtils.isBlank(pathSvr))
{
response.setStatus(500);
response.setHeader("err","參數爲(wéi / wèi)空");
return;
}
File f = new File(pathSvr);
//文件不(bù)存在(zài)
if(!f.exists())
{
response.setStatus(500);
OutputStream os = response.getOutputStream();
System.out.println(String.format("%s 文件不(bù)存在(zài)",pathSvr));
os.close();
return;
}
long fileLen = f.length();
response.setContentType("application/x-download");
response.setHeader("Pragma","No-cache");
response.setHeader("Cache-Control","no-cache");
response.addHeader("Content-Length",blockSize);
response.setDateHeader("Expires", 0);
OutputStream os = response.getOutputStream();
try
{
RandomAccessFile raf = new RandomAccessFile(pathSvr,"r");
int readToLen = Integer.parseInt(blockSize);
int readLen = 0;
raf.seek( Long.parseLong(blockOffset) );//定位索引
byte[] data = new byte[1048576];
while( readToLen > 0 )
{
readLen = raf.read(data,0,Math.min(1048576,readToLen) );
readToLen -= readLen;
os.write(data, 0, readLen);
}
os.flush();
os.close();
raf.close();
os = null;
response.flushBuffer();
out.clear();
out = pageContext.pushBody();
}
catch(Exception e)
{
response.setStatus(500);
os.close();
out.close();
e.printStackTrace();
}
finally
{
if(os != null)
{
os.close();
os = null;
}
out.clear();
out = pageContext.pushBody();
}%>
加載文件列表,在(zài)下載列表中顯示出(chū)來(lái)
後端代碼邏輯大(dà)部分是(shì)相同的(de),目前能夠支持MySQL,Oracle,SQL。在(zài)使用前需要(yào / yāo)配置一下數據庫,可以(yǐ)參考我寫的(de)這(zhè)篇文章:http://blog.ncmem.com/wordpress/2019/08/12/java-http%E5%A4%A7%E6%96%87%E4%BB%B6%E6%96%AD%E7%82%B9%E7%BB%AD%E4%BC%A0%E4%B8%8A%E4%BC%A0/