我們平時經常做的是上傳文(wén)件，上傳文(wén)件夾與上傳文(wén)件類似，但也有一些不同之處，這次做了上傳文(wén)件夾就記錄下(xià)以備後用。

這次項目的需求：

支持大文(wén)件的上傳和(hé)續傳，要求續傳支持所有浏覽器(qì)，包括ie6,ie7,ie8,ie9,Chrome,Firefox,360安全浏覽器(qì)，并且刷新浏覽器(qì)後仍然能夠續傳，重啟浏覽器(qì)（關(guān)閉浏覽器(qì)後再打開）仍然能夠繼續上傳，重啟電腦後仍然能夠上傳

支持文(wén)件夾的上傳，要求服務端能夠保留層級結構，并且能夠續傳。需要支持10萬個(gè)以上的文(wén)件夾上傳。

支持低版本的系統和(hé)浏覽器(qì)，因為這個(gè)項目的最終運行環境在政府，政府的配置都一般，職員都是辦公用，内存都不大，基本上以Windows XP的系統為主。

1、介紹enctype

enctype 屬性規定發送到服務器(qì)之前應該如(rú)何對表單數據進行編碼。

enctype作用是告知服務器(qì)請求正文(wén)的MIME類型（請求消息頭content-type的作用一樣）

1、1 enctype的取值有三種

值

描述

application/x-www-form-urlencoded

在發送前編碼所有字符（默認）

multipart/form-data

不對字符編碼。每一個(gè)表單項分割為一個(gè)部件

text/plain

空格轉換為 “+” 加号，但不對特殊字符編碼。

1. 當enctype=’application/x-www-form-urlencoded’

2.當enctype=’multipart/form-data’

通(tōng)過觀察發現這個(gè)的請求體就發生了變化。這種請求體被稱之為多部件請求體。

什麼是多部件請求體：就是把每一個(gè)表單項分割為一個(gè)部件。

以請求頭的content-type的boundary後面的一串随機字符串作為分割标識

普通(tōng)表單項：

//name的意思是文(wén)本框裡面name的屬性值，而admin是我們輸入的文(wén)本值

Content-Disposition: form-data; name="username"

admin

文(wén)件表單項

//filename的意思是：我們上傳的文(wén)件名稱，content-Type的意思是：MIME類型，asdasdas的意思是：文(wén)件裡面的内容

Content-Disposition: form-data; name="upload"; filename="a.txt"

Content-Type: text/plain

asdasdas

3. 當enctype=’text/plain’

w3c稱：空格會變成”+”加号，但是我這裡沒有發現，隻有當get請求的時候，空格會變成”+”号

進入正題

完成上傳需要滿足3個(gè)必要的條件

提供form表單，method必須是post，因為get請求的傳輸數據一般為2kb，不同浏覽器(qì)不一樣。

form表單屬性enctype的必須是multipart/form-data

提供input type=”file”類的上傳輸入域

大緻實現原理：當enctype的值是multipart/form-data時，浏覽器(qì)會把每個(gè)表單項進行分割，分割成不同的部件，以boundary的值為分割标識，這個(gè)标識的字符串是随機生成的，最後一個(gè)表單項的分割标識字符串末尾會多兩個(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 = "";

//參數為空

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);

%>

下(xià)載的必須條件

兩個(gè)頭一個(gè)流

content-type

Content-Type是返回消息中(zhōng)非常重要的内容，表示文(wén)檔内容屬于什麼MIME類型。

浏覽器(qì)會根據Content-Type來決定如(rú)何顯示返回的消息體内容。

默認值是text/html

可(kě)以使用request.getServletContext().getMimeType(“文(wén)件名”)獲取MIME類型。

Content-Disposition

Content-disposition 是 MIME 協議的擴展，MIME 協議指示 MIME 用戶代理如(rú)何顯示附加的文(wén)件。

默認值是inline，表示在浏覽器(qì)窗口中(zhōng)打開。

服務端向客戶端遊覽器(qì)發送文(wén)件時，如(rú)果是浏覽器(qì)支持的文(wén)件類型，一般會默認使用浏覽器(qì)打開，比如(rú)txt、jpg等，會直接在浏覽器(qì) 中(zhōng)顯示。

如(rú)果需要提示用戶保存，利用Content-Disposition進行一下(xià)處理，關(guān)鍵在于一定要加上attachment。

例如(rú)：Content-Disposition:attachment;filename=xxx，浏覽器(qì)就會激活下(xià)載框對話框， attachment 表示附件, filname 後面跟随的是顯示在下(xià)載框中(zhōng)的文(wén)件名稱。

流

下(xià)載就是向客戶端響應字節數據! 将一個(gè)文(wén)件變成字節數組, 使用 response.getOutputStream()

來響應給浏覽器(qì)。

代碼如(rú)下(xià)，此代碼已經實現了斷點續傳功能，用戶在下(xià)載過程可(kě)以暫停，和(hé)繼續下(xià)載，對服務器(qì)造成的壓力也比較小。

String fid = request.getHeader("id");

String blockIndex = request.getHeader("blockIndex");//基于1

String blockOffset = request.getHeader("blockOffset");//塊偏移，相對于整個(gè)文(wén)件

String blockSize = request.getHeader("blockSize");//塊大小（當前需要下(xià)載的大小）

String pathSvr = request.getHeader("pathSvr");//文(wén)件在服務器(qì)的位置

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","參數為空");

return;

}

File f = new File(pathSvr);

//文(wén)件不存在

if(!f.exists())

{

response.setStatus(500);

OutputStream os = response.getOutputStream();

System.out.println(String.format("%s 文(wén)件不存在",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();

}%>

加載文(wén)件列表，在下(xià)載列表中(zhōng)顯示出來

後端代碼邏輯大部分是相同的，目前能夠支持MySQL,Oracle,SQL。在使用前需要配置一下(xià)數據庫，可(kě)以參考我寫的這篇文(wén)章：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/