原文地址：
解析request.getInputStream()得到的流
作者：
佚名
-------------------------------------------------------------------------------------------------
瀏覽器 采用了一種編碼方式，即 "multipart/form-data" 的編碼方式，采用這種方式，瀏覽器可以很容易將表單內的數據和文件放在一起發送.這 種編碼方式先定義好一個不可能在數據中出現的字符串作為 分界符，然后用它將各個數據段分開，而對於每個數據段都對應着 HTML 頁面表單 中的一個 Input 區，包括一個 content-disposition 屬性，說明了這個數據段的一些信息，如果這個數據段的內容是一個文件，還會有 Content-Type 屬性，然后就是數據本身. 我們可以用request.getInputStream()或request.getReader()得到 提交的數據.
但想要得到文件內容,需要我們自己解析................
-------------------------------------------------------------------------------------------------
package com.csv.test;
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.io.StringReader;
import java.util.HashMap;
import java.util.Map;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import com.sun.org.apache.xalan.internal.xsltc.runtime.Hashtable;
@SuppressWarnings("serial")
public class CsvTest extends HttpServlet {
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
this.doPost(request, response);
}
public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
response.setContentType("text/html;charset=UTF-8");
PrintWriter out = response.getWriter();
final int NONE = 0; // 狀態碼，表示沒有特殊操作
final int DATAHEADER = 1; // 表示下一行要讀到報頭信息
final int FILEDATA = 2; // 表示下面要讀的是上傳文件和二進制數據
final int FIELDDATA = 3; // 表示下面要讀到表單域的文本值
// 請求消息實體的總長度(請求消息中除消息頭之外的數據長度)
int totalbytes = request.getContentLength();
File f; // 上傳文件儲存在服務器上
// 容納請求消息實體的字節數組
byte[] dataOrigin = new byte[totalbytes];
// 對於post多個文件的表單，b作為原始數據的副本提供提取文件數據的操作
byte[] b = new byte[totalbytes];
// 請求消息類型
String contentType = request.getContentType();
String fieldname = ""; // 表單域的名稱
String fieldvalue = ""; // 表單域的值
String fileFormName = ""; // 上傳的文件再表單中的名稱
String fileRealName = ""; // 上傳文件的真實名字
String boundary = ""; // 分界符字符串
String lastboundary = ""; // 結束分界符字符串
int fileSize = 0; // 文件長度
// 容納表單域的名稱/值的哈希表
Map<String, String> formfieldsTable = new HashMap<String, String>();
// 容納文件域的名稱/文件名的哈希表
Map<String, String> filenameTable = new HashMap<String, String>();
// 在消息頭類型中找到分界符的定義
int pos = contentType.indexOf("boundary=");
int pos2; // position2
if (pos != -1) {
pos += "boundary=".length();
boundary = "--" + contentType.substring(pos); // 解析出分界符
lastboundary = boundary + "--"; // 得到結束分界符
}
int state = NONE; // 起始狀態為NONE
// 得到請求消息的數據輸入流
DataInputStream in = new DataInputStream(request.getInputStream());
in.readFully(dataOrigin); // 根據長度，將消息實體的內容讀入字節數組dataOrigin中
in.close(); // 關閉數據流
String reqcontent = new String(dataOrigin); // 從字節數組中得到表示實體的字符串
// 從字符串中得到輸出緩沖流
BufferedReader reqbuf = new BufferedReader(new StringReader(reqcontent));
// 設置循環標志
boolean flag = true;
// int i = 0;
while (flag == true) {
String s = reqbuf.readLine();
if (s == lastboundary || s == null)
break;
switch (state) {
case NONE:
if (s.startsWith(boundary)) {
// 如果讀到分界符，則表示下一行一個頭信息
state = DATAHEADER;
// i += 1;
}
break;
case DATAHEADER:
pos = s.indexOf("filename=");
// 先判斷出這是一個文本表單域的頭信息，還是一個上傳文件的頭信息
if (pos == -1) {
// 如果是文本表單域的頭信息，解析出表單域的名稱
pos = s.indexOf("name=");
pos += "name=".length() + 1; // 1表示后面的"的占位
s = s.substring(pos);
int l = s.length();
s = s.substring(0, l - 1); // 應該是"
fieldname = s; // 表單域的名稱放入fieldname
out.print("fieldname=" + fieldname);
state = FIELDDATA; // 設置狀態碼，准備讀取表單域的值
} else {
// 如果是文件數據的頭，先存儲這一行，用於在字節數組中定位
String temp = s;
// 先解析出文件名
pos = s.indexOf("name=");
pos += "name=".length() + 1; // 1表示后面的"的占位
pos2 = s.indexOf("filename=");
String s1 = s.substring(pos, pos2 - 3); // 3表示";加上一個空格
fileFormName = s1;
pos2 += "filename=".length() + 1; // 1表示后面的"的占位
s = s.substring(pos2);
int l = s.length();
s = s.substring(0, l - 1);
pos2 = s.lastIndexOf("\"); // 對於IE瀏覽器的設置
s = s.substring(pos2 + 1);
fileRealName = s;
out.print("fileRealName=" + fileRealName + "<br>");
out.print("fileRealName.length()=" + fileRealName.length() + "<br>");
if (fileRealName.length() != 0) { // 確定有文件被上傳
// 下面這一部分從字節數組中取出文件的數據
b = dataOrigin; // 復制原始數據以便提取文件
pos = byteIndexOf(b, temp, 0); // 定位行
// 定位下一行，2 表示一個回車和一個換行占兩個字節
b = subBytes(b, pos + temp.getBytes().length + 2,
b.length);
// 再讀一行信息，是這一部分數據的Content-type
s = reqbuf.readLine();
// 設置文件輸入流，准備寫文件
f = new File("d:" + File.separator +fileRealName);
DataOutputStream fileout = new DataOutputStream(
new FileOutputStream(f));
// 字節數組再往下一行，4表示兩回車換行占4個字節，本行的回車換行2個字節，Content-type的下
// 一行是回車換行表示的空行，占2個字節
// 得到文件數據的起始位置
b = subBytes(b, s.getBytes().length + 4, b.length);
pos = byteIndexOf(b, boundary, 0); // 定位文件數據的結尾
b = subBytes(b, 0, pos - 1); // 取得文件數據
fileout.write(b, 0, b.length - 1); // 將文件數據存盤
fileout.close();
fileSize = b.length - 1; // 文件長度存入fileSize
out.print("fileFormName=" + fileFormName + " filename="
+ fileRealName + " fileSize=" + fileSize
+ "<br>");
filenameTable.put(fileFormName, fileRealName);
state = FILEDATA;
}
}
break;
case FIELDDATA:
// 讀取表單域的值
s = reqbuf.readLine();
fieldvalue = s; // 存入fieldvalue
out.print(" fieldvalue=" + fieldvalue + "<br>");
formfieldsTable.put(fieldname, fieldvalue);
state = NONE;
break;
case FILEDATA:
// 如果是文件數據不進行分析，直接讀過去
while ((!s.startsWith(boundary))
&& (!s.startsWith(lastboundary))) {
s = reqbuf.readLine();
if (s.startsWith(boundary)) {
state = DATAHEADER;
} else {
break;
}
}
break;
}
}
// 指定內容類型，並且可以顯示中文
out.println("<HTML");
out.println("<HEAD><TITLE>文件上傳結果</TITLE></HEAD>");
out.println("<BODY>");
out.println("<H1>文件上傳結果</H1><hr>");
out.println("ID為" + formfieldsTable.get("FileID1") + "的文件"
+ filenameTable.get("FileData1") + "已經上傳!<br>");
out.println("ID為" + formfieldsTable.get("FileID2") + "的文件"
+ filenameTable.get("FileData2") + "已經上傳!<br>");
// out.println("i = " + i + "<br>");
out.println("</BODY>");
out.println("</HTML>");
}
private static int byteIndexOf(byte[] b, String s, int start) {
return byteIndexOf(b, s.getBytes(), start);
}
private static int byteIndexOf(byte[] b, byte[] s, int start) {
int i;
if (s.length == 0) {
return 0;
}
int max = b.length - s.length;
if (max < 0) {
return -1;
}
if (start > max) {
return -1;
}
if (start < 0) {
start = 0;
}
// 在b中找到s的第一個元素
search: for (i = start; i <= max; i++) {
if (b[i] == s[0]) {
// 找到了s中的第一個元素后，比較剩余的部分是否相等
int k = 1;
while (k < s.length) {
if (b[k + i] != s[k]) {
continue search;
}
k++;
}
return i;
}
}
return -1;
}
private static byte[] subBytes(byte[] b, int from, int end) {
byte[] result = new byte[end - from];
System.arraycopy(b, from, result, 0, end - from);
return result;
}
private static String subBytesString(byte[] b, int from, int end) {
return new String(subBytes(b, from, end));
}
}
瀏覽器 采用了一種編碼方式，即 "multipart/form-data" 的編碼方式，采用這種方式，瀏覽器可以很容易將表單內的數據和文件放在一起發送.這 種編碼方式先定義好一個不可能在數據中出現的字符串作為 分界符，然后用它將各個數據段分開，而對於每個數據段都對應着 HTML 頁面表單 中的一個 Input 區，包括一個 content-disposition 屬性，說明了這個數據段的一些信息，如果這個數據段的內容是一個文件，還會有 Content-Type 屬性，然后就是數據本身. 我們可以用request.getInputStream()或request.getReader()得到 提交的數據.
但想要得到文件內容,需要我們自己解析................
-------------------------------------------------------------------------------------------------
package com.csv.test;
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.io.StringReader;
import java.util.HashMap;
import java.util.Map;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import com.sun.org.apache.xalan.internal.xsltc.runtime.Hashtable;
@SuppressWarnings("serial")
public class CsvTest extends HttpServlet {
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
this.doPost(request, response);
}
public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
response.setContentType("text/html;charset=UTF-8");
PrintWriter out = response.getWriter();
final int NONE = 0; // 狀態碼，表示沒有特殊操作
final int DATAHEADER = 1; // 表示下一行要讀到報頭信息
final int FILEDATA = 2; // 表示下面要讀的是上傳文件和二進制數據
final int FIELDDATA = 3; // 表示下面要讀到表單域的文本值
// 請求消息實體的總長度(請求消息中除消息頭之外的數據長度)
int totalbytes = request.getContentLength();
File f; // 上傳文件儲存在服務器上
// 容納請求消息實體的字節數組
byte[] dataOrigin = new byte[totalbytes];
// 對於post多個文件的表單，b作為原始數據的副本提供提取文件數據的操作
byte[] b = new byte[totalbytes];
// 請求消息類型
String contentType = request.getContentType();
String fieldname = ""; // 表單域的名稱
String fieldvalue = ""; // 表單域的值
String fileFormName = ""; // 上傳的文件再表單中的名稱
String fileRealName = ""; // 上傳文件的真實名字
String boundary = ""; // 分界符字符串
String lastboundary = ""; // 結束分界符字符串
int fileSize = 0; // 文件長度
// 容納表單域的名稱/值的哈希表
Map<String, String> formfieldsTable = new HashMap<String, String>();
// 容納文件域的名稱/文件名的哈希表
Map<String, String> filenameTable = new HashMap<String, String>();
// 在消息頭類型中找到分界符的定義
int pos = contentType.indexOf("boundary=");
int pos2; // position2
if (pos != -1) {
pos += "boundary=".length();
boundary = "--" + contentType.substring(pos); // 解析出分界符
lastboundary = boundary + "--"; // 得到結束分界符
}
int state = NONE; // 起始狀態為NONE
// 得到請求消息的數據輸入流
DataInputStream in = new DataInputStream(request.getInputStream());
in.readFully(dataOrigin); // 根據長度，將消息實體的內容讀入字節數組dataOrigin中
in.close(); // 關閉數據流
String reqcontent = new String(dataOrigin); // 從字節數組中得到表示實體的字符串
// 從字符串中得到輸出緩沖流
BufferedReader reqbuf = new BufferedReader(new StringReader(reqcontent));
// 設置循環標志
boolean flag = true;
// int i = 0;
while (flag == true) {
String s = reqbuf.readLine();
if (s == lastboundary || s == null)
break;
switch (state) {
case NONE:
if (s.startsWith(boundary)) {
// 如果讀到分界符，則表示下一行一個頭信息
state = DATAHEADER;
// i += 1;
}
break;
case DATAHEADER:
pos = s.indexOf("filename=");
// 先判斷出這是一個文本表單域的頭信息，還是一個上傳文件的頭信息
if (pos == -1) {
// 如果是文本表單域的頭信息，解析出表單域的名稱
pos = s.indexOf("name=");
pos += "name=".length() + 1; // 1表示后面的"的占位
s = s.substring(pos);
int l = s.length();
s = s.substring(0, l - 1); // 應該是"
fieldname = s; // 表單域的名稱放入fieldname
out.print("fieldname=" + fieldname);
state = FIELDDATA; // 設置狀態碼，准備讀取表單域的值
} else {
// 如果是文件數據的頭，先存儲這一行，用於在字節數組中定位
String temp = s;
// 先解析出文件名
pos = s.indexOf("name=");
pos += "name=".length() + 1; // 1表示后面的"的占位
pos2 = s.indexOf("filename=");
String s1 = s.substring(pos, pos2 - 3); // 3表示";加上一個空格
fileFormName = s1;
pos2 += "filename=".length() + 1; // 1表示后面的"的占位
s = s.substring(pos2);
int l = s.length();
s = s.substring(0, l - 1);
pos2 = s.lastIndexOf("\"); // 對於IE瀏覽器的設置
s = s.substring(pos2 + 1);
fileRealName = s;
out.print("fileRealName=" + fileRealName + "<br>");
out.print("fileRealName.length()=" + fileRealName.length() + "<br>");
if (fileRealName.length() != 0) { // 確定有文件被上傳
// 下面這一部分從字節數組中取出文件的數據
b = dataOrigin; // 復制原始數據以便提取文件
pos = byteIndexOf(b, temp, 0); // 定位行
// 定位下一行，2 表示一個回車和一個換行占兩個字節
b = subBytes(b, pos + temp.getBytes().length + 2,
b.length);
// 再讀一行信息，是這一部分數據的Content-type
s = reqbuf.readLine();
// 設置文件輸入流，准備寫文件
f = new File("d:" + File.separator +fileRealName);
DataOutputStream fileout = new DataOutputStream(
new FileOutputStream(f));
// 字節數組再往下一行，4表示兩回車換行占4個字節，本行的回車換行2個字節，Content-type的下
// 一行是回車換行表示的空行，占2個字節
// 得到文件數據的起始位置
b = subBytes(b, s.getBytes().length + 4, b.length);
pos = byteIndexOf(b, boundary, 0); // 定位文件數據的結尾
b = subBytes(b, 0, pos - 1); // 取得文件數據
fileout.write(b, 0, b.length - 1); // 將文件數據存盤
fileout.close();
fileSize = b.length - 1; // 文件長度存入fileSize
out.print("fileFormName=" + fileFormName + " filename="
+ fileRealName + " fileSize=" + fileSize
+ "<br>");
filenameTable.put(fileFormName, fileRealName);
state = FILEDATA;
}
}
break;
case FIELDDATA:
// 讀取表單域的值
s = reqbuf.readLine();
fieldvalue = s; // 存入fieldvalue
out.print(" fieldvalue=" + fieldvalue + "<br>");
formfieldsTable.put(fieldname, fieldvalue);
state = NONE;
break;
case FILEDATA:
// 如果是文件數據不進行分析，直接讀過去
while ((!s.startsWith(boundary))
&& (!s.startsWith(lastboundary))) {
s = reqbuf.readLine();
if (s.startsWith(boundary)) {
state = DATAHEADER;
} else {
break;
}
}
break;
}
}
// 指定內容類型，並且可以顯示中文
out.println("<HTML");
out.println("<HEAD><TITLE>文件上傳結果</TITLE></HEAD>");
out.println("<BODY>");
out.println("<H1>文件上傳結果</H1><hr>");
out.println("ID為" + formfieldsTable.get("FileID1") + "的文件"
+ filenameTable.get("FileData1") + "已經上傳!<br>");
out.println("ID為" + formfieldsTable.get("FileID2") + "的文件"
+ filenameTable.get("FileData2") + "已經上傳!<br>");
// out.println("i = " + i + "<br>");
out.println("</BODY>");
out.println("</HTML>");
}
private static int byteIndexOf(byte[] b, String s, int start) {
return byteIndexOf(b, s.getBytes(), start);
}
private static int byteIndexOf(byte[] b, byte[] s, int start) {
int i;
if (s.length == 0) {
return 0;
}
int max = b.length - s.length;
if (max < 0) {
return -1;
}
if (start > max) {
return -1;
}
if (start < 0) {
start = 0;
}
// 在b中找到s的第一個元素
search: for (i = start; i <= max; i++) {
if (b[i] == s[0]) {
// 找到了s中的第一個元素后，比較剩余的部分是否相等
int k = 1;
while (k < s.length) {
if (b[k + i] != s[k]) {
continue search;
}
k++;
}
return i;
}
}
return -1;
}
private static byte[] subBytes(byte[] b, int from, int end) {
byte[] result = new byte[end - from];
System.arraycopy(b, from, result, 0, end - from);
return result;
}
private static String subBytesString(byte[] b, int from, int end) {
return new String(subBytes(b, from, end));
}
}