文件上传小工具

UploadUtils

　　使用该工具类只需要在上传的Servlet中调用upload方法，传递要上传到的路径和request对象，该工具类返回一个list集合，list集合中是一个一个Map。如果是多值会用&连接，比如[{name=xxx},{hobby=xxx&xxx},{fileName=xxx}…]，文件项会保存它的上传名fileName，要插入数据库的名字saveName，存储文件的路径savePath，上传时间time等。在上传的Servlet中遍历取出值就可以做接下来的操作。工具类用到了年月两级目录打散，文件重命名的CommonUtils.uuid)是UUID.randomUUID).toString).replace”-“, “”).toUpperCase);就不把文件贴出来了，后面是项目中用到该工具类的例子。

package hui.zhang.upload;

import hui.zhang.commons.CommonUtils;

import java.io.File;
import java.text.NumberFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import javax.servlet.http.HttpServletRequest;
import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.ProgressListener;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;

/**
 * 上传小工具
 * 传递一个要上传到的磁盘路径和HttpServletRequest对象，返回一个list集合
 * 集合中存放着map，通过key得到value进行后续操作
 * key：fileName、saveName、savePath、time
 * @author hui.zhang
 * @date 2017-10-14 上午8:32:18
 */
@SuppressWarnings"all")
public class UploadUtils {
    private static final int CACHE = 1024*1024*3; //设置缓存区大小3M
    private static final int FILEMAX = 1024*1024*100; //设置上传文件最大100M
    /**
     * 给本方法传递一个要上传到的路径 如 G://upload
     * 本方法会返回一个list集合，包含普通文件项的name和value
     * 复选框多值返回用&拼接 如 hobby=a&b&c
     * 上传文件项在集合中有上传文件名fileName,存储文件名saveName
     * 存储路径savePath和上传时间time
     * @param path
     * @param request
     * @return
     * @throws Exception
     */
    public static List uploadString path, final HttpServletRequest request) throws Exception {
        //创建工厂
        DiskFileItemFactory factory = new DiskFileItemFactory);
        //设置缓冲区大小，默认10K
        factory.setSizeThresholdCACHE);
        //通过工厂得到核心解析器
        ServletFileUpload sfu = new ServletFileUploadfactory);
        //设置文件上传最大限制
        sfu.setSizeMaxFILEMAX);
        //处理上传文件中文乱码
        sfu.setHeaderEncoding"UTF-8");
        /**
         * 设置上传进度，存到session域中
         * 可以通过异步请求从session中实时取出上传进度
         */
        sfu.setProgressListenernew ProgressListener) {
            //参数1：已上传文件大小
            //参数2：文件总大小
            @Override
            public void updatelong pBytesRead, long pContentLength, int pItems) {
                double progress= Double.parseDoublepBytesRead+"")/Double.parseDoublepContentLength+"");
                //获取百分比格式化对象
                NumberFormat format = NumberFormat.getPercentInstance);
                //保留两位小数
                format.setMinimumFractionDigits2);
                String progress_str = format.formatprogress);
                //保存在session域中，匿名内部类 需要将request用final修饰】
                request.getSession).setAttribute"progress", progress_str);
            }
        });
        //解析请求，得到FileItem对象
        List<FileItem> list = sfu.parseRequestrequest);
        //创建一个list集合，将普通文件项和上传文件项的信息封装之，返回
        List<Map> l = new LinkedList);
        //创建一个map，把每个文件项信息映射一份，可以修改复选框一对多单独存储问题
        Map m = new LinkedHashMap<>);
        //定义要返回的list结合的索引
        int i = -1;
        
        for FileItem fileItem : list) {
            //创建局部map，封装每个文件项，最后添加到集合中
            Map map = new HashMap);
            if fileItem.isFormField)) {
                //得到普通文件项名称
                String fieldName = fileItem.getFieldName);
                //值
                String value = fileItem.getString"UTF-8");
                //如果是空不添加
                if value.equals"") || value == null || value.trim).isEmpty)) {
                    continue;
                }
                //从映射map中取出相同文件项名称 例如 复选框又有相同的名称 hobby
                if m.containsKeyfieldName)) {
                    //让list集合移除掉刚才添加的
                    l.removei);
                    //hobby=a&b 覆盖之
                    map.putfieldName, m.getfieldName)+"&"+value);
                    m = map; //映射
                } else {
                    i++; //索引加1
                    map.putfieldName, value); //把控件名和值添加到局部map hobby=a
                    m = map; //映射
                }
            } else {
                if fileItem.getSize) > FILEMAX) {
                    System.out.println"文件大于设定的100M了！");
                    request.getSession).setAttribute"info", "文件过大，不能大于100M！");
                }
                String filename = fileItem.getName); // a.jpg
                if filename.equals"") || filename.trim).isEmpty) || filename == null) {
                    continue;
                }
                String dir = MakeDir.getDir); //  "/2017/10/"
                // G://upload  +  /2017/10/
                String root = path + dir;
                File file = new Filepath, dir);
                if !file.exists)) {
                    file.mkdirs);
                }
                // xxxxxxxxx_a.jpg
                String savename = CommonUtils.uuid)+"_"+filename;
                // G://upload/2017/10/xxxxxxxx_a.jpg
                File savepath = new Filefile, savename);
                fileItem.writesavepath);
                fileItem.delete);
                map.put"fileName", filename);
                map.put"saveName", savename);
                map.put"savePath", root+savename);
                map.put"time", new Date));
            }
            l.addmap);
        }
        return l;
    }

}

MakeDir

package hui.zhang.upload;

import java.util.Calendar;

/**
 * 返回当前的年月组成二级目录
 * @return "/2017/10/"
 * @author hui.zhang
 * @date 2017-10-14 上午8:46:39
 */
@SuppressWarnings"all")
public class MakeDir {
    public static String getDir) {
        Calendar calendar = Calendar.getInstance);
        int year = calendar.getCalendar.YEAR);
        int month = calendar.getcalendar.MONTH)+1;
        return "/"+year+"/"+month+"/";
    }

}

举个栗子

public class AdminProductUploadServlet extends HttpServlet {
    protected void doPostHttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        try {
            List<Map> list = UploadUtils.upload"D:/tomcat/apache-tomcat-7.0.81/webapps/day08_store/products", request);
            System.out.printlnlist);
            Product product = new Product);
            product.setPidCommonUtils.uuid));
            product.setPdatenew Date));
            product.setPflag0);
            for Map<String,String> map : list) {
                BeanUtils.populateproduct, map);
                Set<String> set = map.keySet);
                for String key : set) {
                    if "savePath".equalsIgnoreCasekey)) {
                        String path = map.getkey);
                        String[] split = path.split"day08_store/");
                        product.setPimagesplit[1]);
                    } else if"cid".equalskey)) {
                        ProductService productService = ProductService) BeanFactory.getBean"productService");
                        Category category = productService.findCategorymap.getkey));
                        product.setCategorycategory);
                    }
                }
            }
            AdminProductDao adminProductDao = new AdminProductDao);
            System.out.printlnproduct.toString));
            adminProductDao.addproduct);
            response.sendRedirectrequest.getContextPath)+"/AdminProductServlet?method=findAllByPage&currPage=1");
        } catch Exception e) {
            throw new RuntimeExceptione);
        }
    }

}

Published by

风君子

独自遨游何稽首 揭天掀地慰生平