java web文件上传
什么是文件上传
要将客户端（浏览器）大数据存储到服务器端，不将数据直接存储到数据库中，
而是要将数据存储到服务器所在的磁盘上，这要使用文件上传
为什么使用文件上传
通过文件上传，可以将浏览器端的大数据直接保存到服务器端。
不将数据保存到数据库中，而是保存到服务器磁盘上，这样减少了数据库服务器的压力，
对数据的操作更加灵活
文件上传原理分析
所谓的文件上传就是服务器端通过request对象获取输入流，
将浏览器端上传的数据读取出来，保存到服务器端。
上传文件注意事项
- 1，请求方式必须是post.
- 2,需要使用组件
<input type="file" name="f">组件必须有名称. - 3，表单必须设置encType="multipart/form-data".
服务器端处理
通过request对象，获取InputStream，可以将浏览器提交的所有数据读取到。
例
<form action="${pageContext.request.contextPath }/servlet/upload3"
method="post" enctype="multipart/form-data">
<p>
用户名：<input type="text" name="name">
</p>
<p>
文件：<input type="file" name="photo">
</p>
<input type="submit" value="上传">
</form>
InputStream is = request.getInputStream();
byte[] buffer = new byte[1024];
int len = 0;
while((len =is.read(buffer)) !=-1){
System.out.println(new String(buffer,0,len));
}
is.close();
------WebKitFormBoundaryT3WBozNnn4BoAsmx
Content-Disposition: form-data; name="name"
李浩
------WebKitFormBoundaryT3WBozNnn4BoAsmx
Content-Disposition: form-data; name="photo"; filename="aina_cert.sql"
Content-Type: application/octet-stream
------WebKitFormBoundaryT3WBozNnn4BoAsmx--
fileupload 实现文件上传，接收用户上传的文件
fileupload 是什么
fileupload是由apache的commons组件提供上传组件。它最主要的工作就是帮我们解析
request.getnputStram().
导入commons-fileupload 相关 jar包
* commons-fileupload.jar 核心包
* commons-io.jar 依赖包
fileupload 有什么用
form表单encType="multipart/form-data" 上传文件时帮助我们 处理表单数据。
fileupload 核心类
DiskFileItemFactory ServletFileUpload FileItem
DiskFileItemFactory
- 设置缓存大小
factory.setSizeThreshold(1024*1024) 设置为1m默认是10k - 设置临时文件存储位置
File temp = new File(this.getServletContext().getRealPath("temp"));
//可以指定临时文件存储位置，默认是系统的临时文件存储位置
factory.setRepository(temp);
ServletFileUpload
-
parseRequest方法
//得到所有的上传信息，将每一部分映射成FileItem对象
List<Fileitme> upload.pareRequest(request) -
isMultipartContent 方法
boolean isMultipartContent(request)
这个方法返回值是boolean 它是用于判断当前表单是否是一个上传的表单，简单说
就判断它的encType的值是否是mulipart/form-data。 -
setHeaderEncoding 方法
用于解决上传文件/表单 中文乱码问题 -
设置上传文件大小
//设置单个文件上传大小
void setFileSizeMax(long fileSizeMax)
//设置总文件上传大小
void setSizeMax()
FileItem
-
boolean isFormField() 判断当前表单字段是否为普通文本字段，如果返回false,说明是文件字段；
-
String getFieldName() 获取字段名称：
<input type="text" name="username">是指username. -
String getString("utf-8") 获取字段的内容，如果是文件字段，那么获取的文件内容，当然上传的文件必须是文本文件；
-
String getName():获取文件字段名称（xxx.png）
-
String getContextType():获取上传的文件mime类型，例如 text/plain.
-
int getSize() 获取上传文件的大小
-
InputStream getInputStream() 获取上传文件对应的输入流。
-
void write(File)：把上传的文件保存到指定文件中
-
delete() 删除临时文件
使用步骤
- 1，创建工厂类DiskFileItemFactory 对象：
DiskFileItemFactory factory = new DiskFileItemFactory() - 2，使用工厂创建解析器对象
ServletFileUpload fileUpload = new ServletFileUpload(factory); - 3,使用解析器来解析request对象
List<FileItem> list = fileUpload.parseRequest(request);
例
//判断表单是否支持文件。即enctype="multipart/form-data"
boolean isMultipartContent = ServletFileUpload.isMultipartContent(request);
if(!isMultipartContent) {
throw new RuntimeException("your form is not multipart/form-data");
}
//创建工厂类DiskFileItemFactory 对象
DiskFileItemFactory factory = new DiskFileItemFactory();
//创建一个ServletFileUpload核心对象
ServletFileUpload sfu = new ServletFileUpload(factory);
try {
List<FileItem> fileItems = sfu.parseRequest(request);
for(FileItem item:fileItems) {
if(item.isFormField()) { //true 是普通字段 false 文件字段
processFormField(item);
} else{
processUploadField(item);
}
}
} catch (FileUploadException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
/**
* 上传文件
* @param item
*/
private void processUploadField(FileItem fileitem) {
//得到文件输入流
try {
InputStream is = fileitem.getInputStream();
//项目目录
String directionRealPath = path+File.separator+"upload";
File storeDirectory = new File(directionRealPath);
if(!storeDirectory.exists()) {
storeDirectory.mkdirs();
}
//文件名称
File savefile = new File(storeDirectory,fileitem.getName());
fileitem.write(savefile);
fileitem.delete();
} catch (Exception e) {
e.printStackTrace();
}
}
上传文件时要考虑的问题
1，允许被浏览器端访问：放置在WebRoot 下，但不能是WEB-INF或META-INF下其子目录下
2，不允许被浏览器端访问： 放置在WEB-INF或META-INF
保证服务器的安全
把保存上传文件的目录放在用户直接访问不到的地方（浏览器可以访问到的地方）。
避免文件被覆盖
让文件名唯一即可
`filename = UUID.randomUUID() + "_" + filename; `
避免同一个文件夹中的文件过多
####### 按照日期进行打散存储目录
private File makeChildDirectory(File storeDirectroy) {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
String dateDir = sdf.format(new Date());
File file = new File(storeDirectroy,dateDir);
if(!file.exists()) {
file.mkdirs();
}
return file;
}
####### 用文件名的hashCode计算打算的存储目录：二级目录
private File makeChildDirctory(File storeDirectroy,String fileName) {
int hashCode = fileName.hashCode();
//转换成16进制
String hex = Integer.toHexString(hashCode);
String childDirctory = hex.charAt(0)+File.separator+hex.charAt(1);
File childDirctoryFile = new File(storeDirectroy,childDirctory);
if(!childDirctoryFile.exists()) {
childDirctoryFile.mkdirs();
}
return childDirctoryFile;
}
####### 完整示例
public class Upload3Servlet extends HttpServlet {
private static final long serialVersionUID = 1L;
private String path = "/Users/lihao/Downloads/apache-tomcat-8.0.37/webapps/bookmanager/WebContent";
protected void doGet(HttpServletRequest request,
HttpServletResponse response) throws ServletException, IOException {
boolean isMultipart = ServletFileUpload.isMultipartContent(request);
if (!isMultipart) {
throw new RuntimeException("your form is not multipart/form-data");
}
// 设置文件大小位置等等
DiskFileItemFactory diskfactory = new DiskFileItemFactory();
//指定临时文件的存储目录
// diskfactory.setRepository(new File("/Users/lihao/"));
// 核心类处理上传逻辑
ServletFileUpload fileUpload = new ServletFileUpload(diskfactory);
//解决表单乱码
fileUpload.setHeaderEncoding("utf-8");
//进度条
fileUpload.setProgressListener(new ProgressListener() {
@Override
public void update(long pBytesRead, long pContentLength, int pItems) {
if (pContentLength == -1) {
System.out.println("文件错误");
} else {
float percent = (float) (pBytesRead*1.0/pContentLength*100);
int percents = (int) percent;
System.out.println("已完成: "+percents+"%");
}
}
});
try {
// fileUpload.setFileSizeMax(1024*1024*3); //单个文件不能超过3M
// fileUpload.setSizeMax(1024*1024*6);//总上传文件不能超过6M
List<FileItem> listItem = fileUpload.parseRequest(request);
for (FileItem item : listItem) {
if (item.isFormField()) {
// 普通文本input
processFormField(item);
} else {
// 文件上传
if(item.getName() != null && !item.getName().equals("")){
//扩展名
System.out.println("扩展名："+FilenameUtils.getExtension(item.getName()));
processFileUpload(item);
} else {
System.out.println("没有提交文件");
}
}
}
} catch (FileUploadException e) {
e.printStackTrace();
}
}
//普通input
private void processFormField(FileItem item) {
try {
System.out.println(item.getFieldName() +" "+ item.getString("utf-8"));
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
}
// 上传文件
private void processFileUpload(FileItem item) {
String directory = path + File.separator + "upload";
// upload file name
// f:xxx\sf.png
String filename = item.getName();
if (filename != null) {
filename = FilenameUtils.getName(filename);
}
// 解决重名问题
filename = UUID.randomUUID() + "_" + filename;
File dirctoryFile = new File(directory);
if (!dirctoryFile.exists()) {
dirctoryFile.mkdirs();
}
//按照日期进行打算存储目录
// File newFileDir = makeChildDirectory(dirctoryFile);
//用文件名的hashCode计算打散的存储目录：二级目录
File newFileDir = makeChildDirctory(dirctoryFile,filename);
try {
item.write(new File(newFileDir, filename));
//删除临时文件
item.delete();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/**
* 按照日期打散目录
* @param storeDirectroy
* @return
*/
private File makeChildDirectory(File storeDirectroy) {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
String dateDir = sdf.format(new Date());
File file = new File(storeDirectroy,dateDir);
if(!file.exists()) {
file.mkdirs();
}
return file;
}
/**
* 文件名的hashCode 计算打散的存储目录：二级目录
* @param storeDirectroy
* @param fileName
* @return
*/
private File makeChildDirctory(File storeDirectroy,String fileName) {
int hashCode = fileName.hashCode();
//转换成16进制
String hex = Integer.toHexString(hashCode);
String childDirctory = hex.charAt(0)+File.separator+hex.charAt(1);
File childDirctoryFile = new File(storeDirectroy,childDirctory);
if(!childDirctoryFile.exists()) {
childDirctoryFile.mkdirs();
}
return childDirctoryFile;
}
protected void doPost(HttpServletRequest request,
HttpServletResponse response) throws ServletException, IOException {
doGet(request, response);
}
}
<form action="${pageContext.request.contextPath }/servlet/upload3"
method="post" enctype="multipart/form-data">
<p>
用户名：<input type="text" name="name">
</p>
<p>
文件：<input type="file" name="photo">
</p>
<input type="submit" value="上传">
</form>
2016.11.10
