JavaEE精选-FileUpload-阿里云开发者社区

准备工作

1.需要form表单，input type=file 组件

2.form表单方法post

3.form表单必须要设置enctype=multipart/form-data，可以上传除了表单数据（文本）以外的数据

4.如果要使用JavaBean来封装的话，那么这个file属性的组件的name要和封装的对象中的属性相同

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>
<form action="/servlet/upload" enctype="multipart/form-data" method="post">
    <input type="text" name="username"><br>
    <input type="password" name="password"><br>
    <input type="file" name="image"><br>
    <input type="submit">
</form>
 </body>
</html>

此时注意，由于设置了enctype=multipart/form-data导致请求体报文的格式改变，那么就不能使用普通的读取方式了，否则会导致在二进制文件中写入字符而报错

------WebKitFormBoundaryrYApx85v3VoXeztu
Content-Disposition: form-data; name="username"
admin
------WebKitFormBoundaryrYApx85v3VoXeztu
Content-Disposition: form-data; name="password"
admin123
------WebKitFormBoundaryrYApx85v3VoXeztu
Content-Disposition: form-data; name="image"; filename="1.txt"
Content-Type: text/plain
hello  你好
------WebKitFormBoundaryrYApx85v3VoXeztu--

必须要剔除分隔符的部分，需要引入第三方组件来解决

使用组件完成文件上传

使用组件整体的思路：

首先需要判断请求是否包含上传的文件，否则使用该组件没有意义

boolean multipartContent = ServletFileUpload.isMultipartContent(request);

创建工厂，设置文件缓存，获取upload对象

DiskFileItemFactory factory = new DiskFileItemFactory();//创建工厂
ServletContext servletContext = getServletContext();//获取Context域，用于缓存
File repository = (File)servletContext.getAttribute("javax.servlet.context.tempdir");//创建一个缓存的中转站
factory.setRepository(repository);
ServletFileUpload upload = new ServletFileUpload(factory);//利用工厂创建一个upload对象，功能是帮我们处理请求报文中上传的部分
upload.setHeaderEncoding("utf-8");

使用upload对象对请求报文进行解析，将每一个input框中的内容解析成FileItem，得到的是一个List
item实际上就是input中上传的文本参数或者是文件，根据不同的文件来实现具体的业务逻辑，分发给不同的方法来进行处理

try {
    List<FileItem> items = upload.parseRequest(request);//处理请求报文对象
    for (FileItem item : items) {
        //item本质上是页面上的input框中包含的文本、文件
        if (item.isFormField()){
            //如果是普通的表单数据，作出表单数据的处理
            processFormField(item);
        }else {
            //处理上传文件
            processUploadFile(item);
        }
    }
} catch (FileUploadException e) {
    e.printStackTrace();
}

处理表单数据的方法

private void processFormField(FileItem item) {
    //具体处理表单数据的方法
    String fieldName = item.getFieldName();//相当于获取请求参数中的key
    String value = null; //获取value
    try {
        value = item.getString("utf-8");//处理表单数据的中文乱码
    } catch (UnsupportedEncodingException e) {
        e.printStackTrace();
    }
    System.out.println(fieldName+":"+value);
}

处理上传数据

private void processUploadFile(FileItem item) {
        String fieldName = item.getFieldName();//文件属性名
        String fileName = item.getName();//文件名
//        String contentType = item.getContentType();//获取文件类型名mni
//        long size = item.getSize();//文件大小
//        boolean inMemory = item.isInMemory();//是否在内存中
        String realPath = getServletContext().getRealPath("image/" + fileName);//获取该文件要存放在服务器硬盘上的绝对路径
        File file = new File(realPath);
        if (!file.getParentFile().exists()){
            //如果该文件的父路径不存在，那么需要进行创建
            file.getParentFile().mkdirs();
        }
        try {
            item.write(file); //直接将该item写入硬盘
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

中文乱码

表单中文乱码

//表单中文乱码的解决方案
value = item.getString("utf-8");

setEncoding失效，因为此时文件的格式已经变了，之前都是key=value

上传的文件名中文乱码

//设置上传的文件名中文乱码
upload.setHeaderEncoding("utf-8");

将数据保存到Java Bean

思路：在具体分发的处理方法中，传入一个map对象，用于保存键值对，键可以设置为JAVA Bean中的属性名，值设置为一个object，用于保存具体的参数类型；最后在所有的Item处理完毕后，将map使用BeanUtils进行处理，就完成了封装

package com.fh.upload;
import org.apache.commons.beanutils.BeanUtils;
import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.FileUploadException;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import javax.servlet.ServletContext;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.File;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.lang.reflect.InvocationTargetException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@WebServlet("/upload2")
public class UploadServlet2 extends HttpServlet {
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        response.setContentType("text/html;charset=utf-8");
//        request.setCharacterEncoding("utf-8");
        boolean multipartContent = ServletFileUpload.isMultipartContent(request);//判断是否有上传的文件
        if (!multipartContent){
            //如果不存在该文件，那就直接返回
            System.out.println("你没有上传文件！");
            return;
        }
        DiskFileItemFactory factory = new DiskFileItemFactory();//创建工厂
        ServletContext servletContext = getServletContext();//获取Context域，用于缓存
        File repository = (File)servletContext.getAttribute("javax.servlet.context.tempdir");//创建一个缓存的中转站
        factory.setRepository(repository);
        ServletFileUpload upload = new ServletFileUpload(factory);//利用工厂创建一个upload对象，功能是帮我们处理请求报文中上传的部分
        upload.setHeaderEncoding("utf-8"); //解决上传文件名的中文乱码
        Map<String,Object> map = new HashMap<>();
        User user = new User();
        try {
            List<FileItem> items = upload.parseRequest(request);//处理请求报文对象
            for (FileItem item : items) {
                //item本质上是页面上的input框中包含的文本、文件
                if (item.isFormField()){
                    //如果是普通的表单数据，作出表单数据的处理
                    processFormField(item,map);
                }else {
                    //处理上传文件
                       processUploadFile(item,map);
                }
            }
        } catch (FileUploadException e) {
            e.printStackTrace();
        }
        try {
            BeanUtils.populate(user,map);
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        } catch (InvocationTargetException e) {
            e.printStackTrace();
        }
        getServletContext().setAttribute("user",user);//将user传到共享域
        response.setHeader("refresh","6;url="+request.getContextPath()+"/view");
    }
    private void processUploadFile(FileItem item, Map<String, Object> map) {
        String fieldName = item.getFieldName();//文件属性名
        String fileName = item.getName();//文件名
//        String contentType = item.getContentType();//获取文件类型名mni
//        long size = item.getSize();//文件大小
//        boolean inMemory = item.isInMemory();//是否在内存中
        String relativePath  = "image/"+fileName;
        String realPath = getServletContext().getRealPath(relativePath);//获取该文件要存放在服务器硬盘上的绝对路径
        File file = new File(realPath);
        if (!file.getParentFile().exists()){
            //如果该文件的父路径不存在，那么需要进行创建
            file.getParentFile().mkdirs();
        }
        try {
            item.write(file); //直接将该item写入硬盘
            map.put("img",relativePath);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    private void processFormField(FileItem item, Map<String, Object> map) {
        //具体处理表单数据的方法
        String fieldName = item.getFieldName();//相当于获取请求参数中的key
        String value = null; //获取value
        try {
            value = item.getString("utf-8");//处理表单数据的中文乱码
        } catch (UnsupportedEncodingException e)    {
            e.printStackTrace();
        }
        map.put(fieldName,value);
    }
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
    }
}

工具类

package com.fh.upload;
import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.FileUploadException;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import javax.servlet.ServletContext;
import javax.servlet.http.HttpServletRequest;
import java.io.File;
import java.io.UnsupportedEncodingException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;
public class FileUploadUtil {
    public static Map<String, Object> parseRequest(HttpServletRequest request){
        //解析请求报文，终极目标是返回一个该请求报文中所有参数的列表，并完成文件上传的工作
        DiskFileItemFactory factory = new DiskFileItemFactory();//创建工厂
        ServletContext servletContext = request.getServletContext();//获取Context域，用于缓存
        File repository = (File)servletContext.getAttribute("javax.servlet.context.tempdir");//创建一个缓存的中转站
        factory.setRepository(repository);
        ServletFileUpload upload = new ServletFileUpload(factory);//利用工厂创建一个upload对象，功能是帮我们处理请求报文中上传的部分
        upload.setHeaderEncoding("utf-8"); //解决上传文件名的中文乱码
        Map<String,Object> map = new HashMap<>();
        try {
            List<FileItem> items = upload.parseRequest(request);//处理请求报文对象
            for (FileItem item : items) {
                //item本质上是页面上的input框中包含的文本、文件
                if (item.isFormField()){
                    //如果是普通的表单数据，作出表单数据的处理
                    processFormField(item,map);
                }else {
                    //处理上传文件
                    processUploadFile(item,map,request);
                }
            }
        } catch (FileUploadException e) {
            e.printStackTrace();
        }
        return map;
    }
    private static void processUploadFile(FileItem item, Map<String, Object> map, HttpServletRequest request) {
        String fieldName = item.getFieldName();//文件属性名
        String fileName = item.getName();//文件名
        fileName = UUID.randomUUID().toString() + "-" + fileName; //随机生成一个文件名，防止重复
        //对文件上传进行散列
        int hashCode = fileName.hashCode();
        String hexString = Integer.toHexString(hashCode); //生成一个16进制的哈希值，每一位都分别创建子目录，完成散列
        char[] chars = hexString.toCharArray();
        String basePath = fieldName; //总的一个父路径，所有下属的文件夹都放在这个父路径里，根据不同的文件类型生成
        for (char aChar : chars) {
            basePath = basePath + "/" + aChar;
        }
        String relativePath = basePath + "/" + fileName; //最终用文件总的父路径拼接文件名，那么就得到了文件要存放在硬盘上的相对路径
        //需要根据相对路径获取存储到服务器磁盘的绝对路径，显然需要一个request对象
        String realPath = request.getServletContext().getRealPath(relativePath);
        File file = new File(realPath);
        if (!file.getParentFile().exists()){
            //父路径不存在，那就创建
            file.getParentFile().mkdirs();
        }
        try {
            item.write(file);
            map.put(fieldName,relativePath);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    private static void processFormField(FileItem item, Map<String, Object> map) {
        String name = item.getFieldName();
        String value = null;
        try {
            //表单中文乱码的解决方案
            value = item.getString("utf-8");
            map.put(name, value);
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }
    }
}

JavaEE精选-FileUpload

准备工作

使用组件完成文件上传

中文乱码

将数据保存到Java Bean

工具类

热门文章

最新文章

相关电子书

热门

活动广场

任务中心

开发者评测

高校计划

乘风者计划

训练营

阿里云MVP

话题

直播

下载

镜像站

技术资料

插件

JavaEE精选-FileUpload

准备工作

使用组件完成文件上传

中文乱码

将数据保存到Java Bean

工具类

热门文章

最新文章

相关电子书