什么是文件上传
要将客户端(浏览器)大数据存储到服务器端,不将数据直接存储到数据库中,
而是要将数据存储到服务器所在的磁盘上,这要使用文件上传
为什么使用文件上传
通过文件上传,可以将浏览器端的大数据直接保存到服务器端。
不将数据保存到数据库中,而是保存到服务器磁盘上,这样减少了数据库服务器的压力,
对数据的操作更加灵活
文件上传原理分析
所谓的文件上传就是服务器端通过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