java中getinputstream_解析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 formfieldsTable = new HashMap();
// 容纳文件域的名称/文件名的哈希表
Map filenameTable = new HashMap();
// 在消息头类型中找到分界符的定义
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 + "
");
out.print("fileRealName.length()=" + fileRealName.length() + "
");
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
+ "
");
filenameTable.put(fileFormName, fileRealName);
state = FILEDATA;
}
}
break;
case FIELDDATA:
// 读取表单域的值
s = reqbuf.readLine();
fieldvalue = s; // 存入fieldvalue
out.print(" fieldvalue=" + fieldvalue + "
");
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("
out.println("
文件上传结果");
out.println("
");
out.println("
文件上传结果
");
out.println("ID为" + formfieldsTable.get("FileID1") + "的文件"
+ filenameTable.get("FileData1") + "已经上传!
");
out.println("ID为" + formfieldsTable.get("FileID2") + "的文件"
+ filenameTable.get("FileData2") + "已经上传!
");
// out.println("i = " + i + "
");
out.println("");
out.println("");
}
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));
}
}
java中getinputstream_解析request.getInputStream()得到的流相关推荐
- shapefile java_有人知道Java中可以解析ESRI Shapefile的库吗?
有人知道Java中可以解析ESRI Shapefile的库吗? 我对编写2009 Tiger / Line Shapefile中道路数据的可视化程序感兴趣. 我想绘制线数据以显示我县的所有道路. ES ...
- 一文读懂Java中File类、字节流、字符流、转换流
一文读懂Java中File类.字节流.字符流.转换流 第一章 递归:File类: 1.1:概述 java.io.File 类是文件和目录路径名的抽象表示,主要用于文件和目录的创建.查找和删除等操作. ...
- 第八节:详细讲解Java中的异常处理情况与I/O流的介绍以及类集合框架
前言 大家好,给大家带来详细讲解Java中的异常处理情况与I/O流的介绍以及类集合框架的概述,希望你们喜欢 JAVA 异常 try...catch...finally结构的使用方法 class Tes ...
- Java中DOM4J解析xml文件浅析
DOM4J解析它是JDOM的一种智能分支.它合并了许多超出基本XML文档表示的功能,包括集成的XPath支持.XML Schema支持以及用于大文档或流化文档的基于事件的处理.它还提供了构建文档表 ...
- java中http解析url,java url 编码(解析http请求汉语言地址 )
java url 编码(解析http请求中文地址 ) 在近在做项目的过程中,由于客户那边服务器上提供的有很多中文结构目录.请求要的地址不能正常运行显示出来.下面来分享一下我对http协议处理请求中文的 ...
- Java中如何解析SQL语句、格式化SQL语句、生成SQL语句?
昨天在群里看到有小伙伴问,Java里如何解析SQL语句然后格式化SQL,是否有现成类库可以使用? 之前TJ没有做过这类需求,所以去研究了一下,并找到了一个不过的解决方案,今天推荐给大家,如果您正要做类 ...
- java中的setattribute_JSP request.setAttribute()详解及实例
javascript request.setAttribute()详解 request.setAttribute()怎么用的? JSP1代码 String [] test=new String[2]; ...
- 【转帖】map,set,list,等JAVA中集合解析 - Java - cjw的资料
导读: JavaTM 2 Platform Standard Ed. 5.0 在JAVA的util包中有两个所有集合的父接口Collection和Map,它们的父子关系: java.util ...
- Java中使用try-with-resource优雅的关闭io流
前言 最近看到一篇关于串流的关闭方法,通过编译器自动生成关闭串流源码,行之有效. 转载自博主: Java劝退师. https://blog.csdn.net/qq_41389354/article/d ...
最新文章
- Finding iPhone Memory Leaks: A “Leaks” Tool Tutorial[转]
- QT发布中遇到的问题 - wufan的专栏 - 博客频道 - CSDN.NET
- Delphi调用REST
- flowable 配置自定义表单_Flowable用代码自定义流程
- 仅靠一杯奶茶钱8.8元,你就能转到人工智能专业?
- hiho图的联通性(自留)
- mysql获取一个表的数据作为值插入_请问如何在mysql中得到一个即将插入数据表中的那条数据的id值(id自增长)?...
- 墙裂推荐 | 漫画解读Elasticsearch原理,看完你就懂
- 性能测试--jmeter中http的请求默认值【6】
- 第五章 Spark-SQL进阶(一)之Dataset用法
- 计算机基础试题及答案 完整版,大学计算机基础试题及答案(完整版)
- 基于stm32智能门锁系统
- 中宠股份第三季度营收7.55亿元:增速环比持续下滑,净利润转降
- 2011年中国科学院院士增选初步候选…
- 笔记本独显无输出_双显卡笔记本独显消失怎么回事|笔记本双显卡独显没了怎么解决|笔记本双显卡切换独显方法...
- Wireshark基础知识(一)
- IBM:金融的话语权仍掌握在银行手中
- 调用微信接口上传图片总结
- 在坦桑尼亚如何打国际长途,打给你中国的朋友?
- Redis的ZSET的实现及结合源码的跳跃表结构分析
热门文章
- 微服务的接入层设计与动静资源隔离
- 开发小程序商城必看:社交电商的销售玩法
- 我们准备在网关中支持GrahpQL了
- 分布式概念-分布式事务,并发处理协议
- c# BinaryFormatter 更换了命名空间反序列化遇到的问题
- JVM运行时数据区---方法区(内部结构)
- java中application后缀_编译JavaApplication源程序文件将产生相应的字节码文件,这些字节码文件的扩展名为...
- 基于TransformerFusion的单目场景重构
- ICCV 2021 | 基于稀疏多视角彩色相机的多人人体全身捕捉
- 3D视觉工坊中秋国庆贺礼!