前言:因自己负责的项目(jetty内嵌启动的SpringMvc)中需要实现文件上传,而自己对java文件上传这一块未接触过,且对 Http 协议较模糊,故这次采用渐进的方式来学习文件上传的原理与实践。该博客重在实践。

一. Http协议原理简介

HTTP是一个属于应用层的面向对象的协议,由于其简捷、快速的方式,适用于分布式超媒体信息系统。它于1990年提出,经过几年的使用与发展,得到不断地完善和扩展。目前在WWW中使用的是HTTP/1.0的第六版,HTTP/1.1的规范化工作正在进行之中,而且HTTP-NG(Next Generation of HTTP)的建议已经提出。

简单来说,就是一个基于应用层的通信规范:双方要进行通信,大家都要遵守一个规范,这个规范就是HTTP协议。

1.特点:

(1)支持客户/服务器模式。

(2)简单快速:客户向服务器请求服务时,只需传送请求方法和路径。请求方法常用的有GET、HEAD、POST。每种方法规定了客户与服务器联系的类型不同。由于HTTP协议简单,使得HTTP服务器的程序规模小,因而通信速度很快。

(3)灵活:HTTP允许传输任意类型的数据对象。正在传输的类型由Content-Type加以标记。

(4)无连接:无连接的含义是限制每次连接只处理一个请求。服务器处理完客户的请求,并收到客户的应答后,即断开连接。采用这种方式可以节省传输时间。

(5)无状态:HTTP协议是无状态协议。无状态是指协议对于事务处理没有记忆能力。缺少状态意味着如果后续处理需要前面的信息,则它必须重传,这样可能导致每次连接传送的数据量增大。另一方面,在服务器不需要先前信息时它的应答就较快。

注意:其中(4)(5)是面试中常用的面试题。虽然HTTP协议(应用层)是无连接,无状态的,但其所依赖的TCP协议(传输层)却是常连接、有状态的,而TCP协议(传输层)又依赖于IP协议(网络层)。

2.HTTP消息的结构

(1)Request 消息分为3部分,第一部分叫请求行, 第二部分叫http header消息头, 第三部分是body正文,header和body之间有个空行, 结构如下图

(2)Response消息的结构, 和Request消息的结构基本一样。 同样也分为三部分,第一部分叫request line状态行, 第二部分叫request header消息体,第三部分是body正文, header和body之间也有个空行,  结构如下图

下面是使用Fiddler捕捉请求baidu的Request消息机构和Response消息机构:

因为没有输入任何表单信息,故request的消息正文为空,大家可以找一个登录的页面试试看。

先到这里,HTTP协议的知识网上很丰富,在这里就不再熬述了。

二. 文件上传的三种实现

1. Jsp/servlet 实现文件上传

这是最常见也是最简单的方式

(1)实现文件上传的Jsp页面

(2)负责接文件的FileUploadServlet

import java.io.File;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStream;

import javax.servlet.ServletException;

import javax.servlet.http.HttpServlet;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import org.apache.log4j.Logger;

// @WebServlet(name = "FileLoadServlet", urlPatterns = {"/fileload"})

public class FileLoadServlet extends HttpServlet {

private static Logger logger = Logger.getLogger(FileLoadServlet.class);

private static final long serialVersionUID = 1302377908285976972L;

@Override

protected void service(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

logger.info("------------ FileLoadServlet ------------");

if (request.getContentLength() > 0) {

InputStream inputStream = null;

FileOutputStream outputStream = null;

try {

inputStream = request.getInputStream();

// 给新文件拼上时间毫秒,防止重名

long now = System.currentTimeMillis();

File file = new File("c:/", "file-" + now + ".txt");

file.createNewFile();

outputStream = new FileOutputStream(file);

byte temp[] = new byte[1024];

int size = -1;

while ((size = inputStream.read(temp)) != -1) { // 每次读取1KB,直至读完

outputStream.write(temp, 0, size);

}

logger.info("File load success.");

} catch (IOException e) {

logger.warn("File load fail.", e);

request.getRequestDispatcher("/fail.jsp").forward(request, response);

} finally {

outputStream.close();

inputStream.close();

}

}

request.getRequestDispatcher("/succ.jsp").forward(request, response);

}

}

FileUploadServlet的配置,推荐采用servlet3.0注解的方式更方便

<servlet>

<servlet-name>FileLoadServlet</servlet-name>

<servlet-class>com.juxinli.servlet.FileLoadServlet</servlet-class>

</servlet>

<servlet-mapping>

<servlet-name>FileLoadServlet</servlet-name>

<url-pattern>/fileload</url-pattern>

</servlet-mapping>

(3)运行效果

点击"submit"

页面转向文件上传成功的页面,再去C盘看看,发现多了一个文件:file-1433417127748.txt,这个就是刚上传的文件

我们打开看看,发现和原来的文本有些不一样

             

结合前面讲的HTTP协议的消息结构,不难发现这些文本就是去掉"请求头"后的"Request消息体"。所以,如果要得到与上传文件一致的文本,还需要一些字符串操作,这些就留给大家了。

另外,大家可以试试一个Jsp页面上传多个文件,会有不一样的精彩哦o(∩_∩)o ,不解释。

2. 模拟Post请求/servlet 实现文件上传

刚才我们是使用Jsp页面来上传文件,假如客户端不是webapp项目呢,显然刚才的那种方式有些捉襟见衬了。

这里我们换种思路,既然页面上通过点击可以实现文件上传,为何不能通过HttpClient来模拟浏览器发送上传文件的请求呢。关于HttpClient ,大家可以自己去了解。

(1)还是这个项目,启动servlet服务

(2)模拟请求的FileLoadClient

import java.io.BufferedReader;

import java.io.File;

import java.io.InputStream;

import java.io.InputStreamReader;

import org.apache.commons.httpclient.HttpClient;

import org.apache.commons.httpclient.HttpStatus;

import org.apache.commons.httpclient.methods.PostMethod;

import org.apache.commons.httpclient.methods.multipart.FilePart;

import org.apache.commons.httpclient.methods.multipart.MultipartRequestEntity;

import org.apache.commons.httpclient.methods.multipart.Part;

import org.apache.log4j.Logger;

public class FileLoadClient {

private static Logger logger = Logger.getLogger(FileLoadClient.class);

public static String fileload(String url, File file) {

String body = "{}";

if (url == null || url.equals("")) {

return "参数不合法";

}

if (!file.exists()) {

return "要上传的文件名不存在";

}

PostMethod postMethod = new PostMethod(url);

try {

// FilePart:用来上传文件的类,file即要上传的文件

FilePart fp = new FilePart("file", file);

Part[] parts = { fp };

// 对于MIME类型的请求,httpclient建议全用MulitPartRequestEntity进行包装

MultipartRequestEntity mre = new MultipartRequestEntity(parts, postMethod.getParams());

postMethod.setRequestEntity(mre);

HttpClient client = new HttpClient();

// 由于要上传的文件可能比较大 , 因此在此设置最大的连接超时时间

client.getHttpConnectionManager().getParams() .setConnectionTimeout(50000);

int status = client.executeMethod(postMethod);

if (status == HttpStatus.SC_OK) {

InputStream inputStream = postMethod.getResponseBodyAsStream();

BufferedReader br = new BufferedReader(new InputStreamReader(inputStream));

StringBuffer stringBuffer = new StringBuffer();

String str = "";

while ((str = br.readLine()) != null) {

stringBuffer.append(str);

}

body = stringBuffer.toString();

} else {

body = "fail";

}

} catch (Exception e) {

logger.warn("上传文件异常", e);

} finally {

// 释放连接

postMethod.releaseConnection();

}

return body;

}

public static void main(String[] args) throws Exception {

String body = fileload("http://localhost:8080/jsp_upload-servlet/fileload", new File("C:/1111.txt"));

System.out.println(body);

}

}

(3)在Eclipse中运行FileLoadClient程序来发送请求,运行结果:

<html><head>  <meta http-equiv="Content-Type" content="text/html; charset=UTF-8" /></head><body><h2>File upload success</h2><a href="index.jsp">return</a></body></html>

打印了:文件上传成功的succ.jsp页面

有没有发现什么,是不是和前面Jsp页面上传的结果类似?对的,还是去掉"请求头"后的"Request消息体"。

这种方式也很简单,负责接收文件的FileUploadServlet没有变,只要在客户端把文件读取到流中,然后模拟请求servlet就行了。

3.模拟Post请求/Controller(SpringMvc)实现文件上传

终于到第三种方式了,主要难点在于搭建maven+jetty+springmvc环境,接收文件的service和模拟请求的客户端 和上面相似。

(1)模拟请求的FileLoadClient未变

import java.io.BufferedReader;

import java.io.File;

import java.io.InputStream;

import java.io.InputStreamReader;

import org.apache.commons.httpclient.HttpClient;

import org.apache.commons.httpclient.HttpStatus;

import org.apache.commons.httpclient.methods.PostMethod;

import org.apache.commons.httpclient.methods.multipart.FilePart;

import org.apache.commons.httpclient.methods.multipart.MultipartRequestEntity;

import org.apache.commons.httpclient.methods.multipart.Part;

import org.apache.log4j.Logger;

public class FileLoadClient {

private static Logger logger = Logger.getLogger(FileLoadClient.class);

public static String fileload(String url, File file) {

String body = "{}";

if (url == null || url.equals("")) {

return "参数不合法";

}

if (!file.exists()) {

return "要上传的文件名不存在";

}

PostMethod postMethod = new PostMethod(url);

try {

// FilePart:用来上传文件的类,file即要上传的文件

FilePart fp = new FilePart("file", file);

Part[] parts = { fp };

// 对于MIME类型的请求,httpclient建议全用MulitPartRequestEntity进行包装

MultipartRequestEntity mre = new MultipartRequestEntity(parts, postMethod.getParams());

postMethod.setRequestEntity(mre);

HttpClient client = new HttpClient();

// 由于要上传的文件可能比较大 , 因此在此设置最大的连接超时时间

client.getHttpConnectionManager().getParams() .setConnectionTimeout(50000);

int status = client.executeMethod(postMethod);

if (status == HttpStatus.SC_OK) {

InputStream inputStream = postMethod.getResponseBodyAsStream();

BufferedReader br = new BufferedReader(new InputStreamReader(inputStream));

StringBuffer stringBuffer = new StringBuffer();

String str = "";

while ((str = br.readLine()) != null) {

stringBuffer.append(str);

}

body = stringBuffer.toString();

} else {

body = "fail";

}

} catch (Exception e) {

logger.warn("上传文件异常", e);

} finally {

// 释放连接

postMethod.releaseConnection();

}

return body;

}

public static void main(String[] args) throws Exception {

String body = fileload("http://localhost:8080/fileupload/upload", new File("C:/1111.txt"));

System.out.println(body);

}

}

(2)servlet换为springMvc中的Controller

import java.io.File;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStream;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import org.apache.log4j.Logger;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

@Controller

@RequestMapping("/fileupload")

public class FileUploadService {

private Logger logger = Logger.getLogger(FileUploadService.class);

@RequestMapping(consumes = "multipart/form-data", value = "/hello", method = RequestMethod.GET)

public void hello(HttpServletRequest request, HttpServletResponse response) throws IOException {

response.getWriter().write("Hello, jetty server start ok.");

}

@RequestMapping(consumes = "multipart/form-data", value = "/upload", method = RequestMethod.POST)

public void uploadFile(HttpServletRequest request, HttpServletResponse response) throws IOException {

String result = "";

if (request.getContentLength() > 0) {

InputStream inputStream = null;

FileOutputStream outputStream = null;

try {

inputStream = request.getInputStream();

// 给新文件拼上时间毫秒,防止重名

long now = System.currentTimeMillis();

File file = new File("c:/", "file-" + now + ".txt");

file.createNewFile();

outputStream = new FileOutputStream(file);

byte temp[] = new byte[1024];

int size = -1;

while ((size = inputStream.read(temp)) != -1) { // 每次读取1KB,直至读完

outputStream.write(temp, 0, size);

}

logger.info("File load success.");

result = "File load success.";

} catch (IOException e) {

logger.warn("File load fail.", e);

result = "File load fail.";

} finally {

outputStream.close();

inputStream.close();

}

}

response.getWriter().write(result);

}

}

(3)启动jetty的核心代码,在Eclipse里面右键可以启动,也可以把项目打成jar报启动

import org.apache.log4j.Logger;

import org.eclipse.jetty.server.Connector;

import org.eclipse.jetty.server.Server;

import org.eclipse.jetty.server.ServerConnector;

import org.eclipse.jetty.webapp.WebAppContext;

public class Launcher

{

private static Logger logger = Logger.getLogger(Launcher.class);

private static final int PORT = 8080;

private static final String WEBAPP = "src/main/webapp";

private static final String CONTEXTPATH = "/";

private static final String DESCRIPTOR = "src/main/webapp/WEB-INF/web.xml";

/*

* 创建 Jetty Server,指定其端口、web目录、根目录、web路径

* @param port

* @param webApp

* @param contextPath

* @param descriptor

* @return Server

*/

public static Server createServer(int port, String webApp, String contextPath, String descriptor) {

Server server = new Server();

//设置在JVM退出时关闭Jetty的钩子

//这样就可以在整个功能测试时启动一次Jetty,然后让它在JVM退出时自动关闭

server.setStopAtShutdown(true);

ServerConnector connector = new ServerConnector(server);

connector.setPort(port);

//解决Windows下重复启动Jetty不报告端口冲突的问题

//在Windows下有个Windows + Sun的connector实现的问题,reuseAddress=true时重复启动同一个端口的Jetty不会报错

//所以必须设为false,代价是若上次退出不干净(比如有TIME_WAIT),会导致新的Jetty不能启动,但权衡之下还是应该设为False

connector.setReuseAddress(false);

server.setConnectors(new Connector[]{connector});

WebAppContext webContext = new WebAppContext(webApp, contextPath);

webContext.setDescriptor(descriptor);

// 设置webapp的位置

webContext.setResourceBase(webApp);

webContext.setClassLoader(Thread.currentThread().getContextClassLoader());

server.setHandler(webContext);

return server;

}

/**

* 启动jetty服务

*/

public void startJetty() {

final Server server = Launcher.createServer(PORT, WEBAPP, CONTEXTPATH, DESCRIPTOR);

try {

server.start();

server.join();

} catch (Exception e) {

logger.warn("启动 jetty server 失败", e);

System.exit(-1);

}

}

public static void main(String[] args) {

(new Launcher()).startJetty();

// jetty 启动后的测试url

// http://localhost:8080/fileupload/hello

}

}

springMvc的配置不贴了,大家可以下载源码下来看。

(4)运行效果

上传包含1W个文件的文件夹,正常

大型文件续传功能正常 。

文件批量上传正常

服务器中已经根据日期+GUID生成了目录

数据库中也有记录

后端代码逻辑大部分是相同的,目前能够支持MySQL,Oracle,SQL。在使用前需要配置一下数据库,可以参考我写的这篇文章: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/

欢迎入群一起讨论:374992201

js+vue分片上传大文件`相关推荐

  1. vue上传大文件/视频前后端(java)代码

    vue上传大文件/视频前后端(java)代码 一.上传组件 二.后端java代码 注意: 一.上传组件 <template><div><!-- 上传组件 -->&l ...

  2. php webuploader大文件,web uploader 上传大文件总结

    由于业务需要,需要上传大文件,已有的版本无法处理IE版本,经过调研,百度的 webuploader 支持 IE 浏览器,而且支持计算MD5值,进而可以实现秒传的功能. 大文件上传主要分为三部分,预上传 ...

  3. 使用webuploader上传大文件

    遇到一个需求,用户想上传超过1.2G的视频文件. 根据这个需求做了一些上传速度对比,ftp上传1G多点的文件用时三分钟左右 1.使用ftp上传 (1) 创建ftp服务站点 在服务器上依次选择控制面板- ...

  4. 利用PLUPLOAD上传大文件

    利用PLUPLOAD上传大文件 大容量文件上传早已不是什么新鲜问题,在.net 2.0时代,HTML5也还没有问世,要实现这样的功能,要么是改web.config,要么是用flash,要么是用一些第三 ...

  5. html5 上传超大文件,HTML5教程 如何拖拽上传大文件

    本篇教程探讨了HTML5教程 如何拖拽上传大文件,希望阅读本篇文章以后大家有所收获,帮助大家HTML5+CSS3从入门到精通 . < 前言: 大文件传输一直是技术上的一大难点.文件过大时,一些性 ...

  6. [转载自简书] ASPNetCore上传大文件碰到的一些问题总结

    上传大文件碰到不少问题,总结一下. 先介绍一下功能:ajax上传文件到NetCore的web api接口, 安装在Linux服务器的服务端通过Nginx接受到后再存到文件服务器上. 如果文件不大,这个 ...

  7. .net上传大文件不成功

    问题描述:js上传大文件(超过30M),后台接收不到 环境描述:vs2012     .net4.5     dojo 使用dojo的Uploader控件上传文件,当文件大小超过30M时,后台不能正常 ...

  8. 前端上传大文件怎么处理

    前端上传大文件怎么处理 - 掘金 背景 当我们在做文件的导入功能的时候,如果导入的文件过大,可能会导所需要的时间够长,且失败后需要重新上传,我们需要前后端结合的方式解决这个问题 思路 我们需要做几件事 ...

  9. Asp.Net 上传大文件专题(4)--利用ajax技术显示上传进度

    ====================================================== 注:本文源代码点此下载 ================================= ...

最新文章

  1. 快看Sample代码,速学Swift语言(3)-运算符
  2. iOS项目架构 小谈
  3. 前端学习(526):等分布局
  4. C++:13---继承(单一继承、多重继承、多级继承、菱形继承、虚继承)
  5. python日历模块_Python日历模块| prmonth()方法与示例
  6. /proc/sys/vm虚拟内存参数
  7. SAP License:雾里看花系列——SAP应用应该更关注业务过程
  8. 《设计模式详解》行为型模式 - 中介者模式
  9. 远程电脑备份与还原数据库
  10. centos7连接华为san存储_centos7配置nfs共享存储服务
  11. order by 影响效率么_如此简单的设计就能将太阳能电池的效率提升25%
  12. Python笔记(21)正则表达式
  13. 航天金税502设置模拟环境步骤
  14. linux网盘客户端,Linux下的百度网盘客户端BaiduPCS-Go
  15. 脑与认知科学基础(期末复习)
  16. Unity3D教程:如何利用Shader实现钻石渲染效果
  17. Java action name=*_* class=com..action.{1}Action method={2} 中*_*意思
  18. 小朋友排队(树状数组)
  19. 熊猫烧香制造者李俊出狱以后的六种出路
  20. css3入门到实战教程-孙琪峥-专题视频课程

热门文章

  1. css怎么调间距,css中字间距怎么调整
  2. Android - Error: quot;java.io.IOException: setDataSource failed.: status=0x80000000quot;
  3. 最简单的JSP-Servlet案例
  4. 影响网站排名的主要因素有哪些
  5. 善用 SPINWAIT 处理 线程空转 以利提升效能
  6. mac安装brew(国内地址,可成功安装!)
  7. Ubuntu16.0配置MPTCP
  8. 【BZOJ3771】Triple
  9. undefined reference to `cvRound'
  10. 使用hbuilder x 把网址打包成app