java中如何实现文件打包上传以及自动解压

java中如何实现文件打包上传以及自动解压 收藏

我们在开发项目的时候,特别是B/S系统,经常会遇到要批量上传文件的需求,对此需求一般有如下几个解决方案(以B/S为例):

 

 1. 在客户端提供文件上传接口,一次上传一个文件

 

 2. 一次上传多个文件

 

 3. 将需要上传的文件打包,一次上传到服务器,并自动解压到指定目录

 

 1,2方法都有几个很明显的不足,用户工作量大,文件如果过大,在网络环境中,上传的效率低下,另外文件在不同的目录,是无法进行一次选择上传的.所以打包上传就成为了比较流行的批量文件上传的解决方案,下面就来一起讨论一下在java中如何实现:

 

  主要功能需求:

 

    a. 上传文件,将文件保存在服务器

 

    b. 读取服务器上压缩文件,解压到指定目录

 

  下面就这两个需求说说编码实现

 

上传: 使用了smartupload开源程序

 

   1. IUpload.java - (上传接口,需要jsmartupload.jar包)

 

import java.io.IOException;

import java.util.Hashtable;

 

import javax.servlet.ServletException;

 

import com.jspsmart.upload.File;

import com.jspsmart.upload.Files;

import com.jspsmart.upload.Request;

public interface IUpload {

 //只能上传一个文件

    public File getSingleUploadFile() throws MultiFileException,

            UploadFileIsMissingException;

 

    //判断文件是否丢失

    public boolean exists(File file);

 

    //保存文件

    public int save(String targetFileName, int arg1) throws ServletException,

            IOException;

 

    //得到绝对保存路径

    public String getAbsoluteSavePath();

 

    //得到请求

    public Request getRequest();

 

    //得到文件

    public Files getFiles();

 

    //处理所有参数,处理页面提交的其他表单数据

    public Hashtable dealAllPara() throws Exception;

 

    //得到zip文件名，不含后缀

    public String getFilenameNoExt() throws MultiFileException,

            UploadFileIsMissingException;

}

2. SingleUpload.java (本例子特意说明了控制只上传一个文件)

 

import java.io.IOException;

import java.util.Enumeration;

import java.util.Hashtable;

 

import javax.servlet.ServletException;

 

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

 

import com.commonStrut.utils.FileUtils;

import com.jspsmart.upload.File;

import com.jspsmart.upload.Files;

import com.jspsmart.upload.Request;

import com.jspsmart.upload.SmartUpload;

 

public class SingleUpload implements IUpload {

 

    private Log logger = LogFactory.getLog(SingleUpload.class);

 

    private SmartUpload upload = null;

 

    private Request request = null;

 

    private String savePath = "";

  

 

    public SingleUpload(SmartUpload upload) throws ServletException,

            IOException {

        logger.info("SingleUpload:call super(),successed!");

        this.upload = upload;

        this.upload.upload();

        this.request = upload.getRequest();

    }

 

    //只能上传一个文件

    public File getSingleUploadFile() throws MultiFileException,

            UploadFileIsMissingException {

        //产生一个file对象 myFile

        Files files = upload.getFiles();

 

        //必须传入而且只能传入一个文件

        logger.info("|－－－－－－upload file count：" + files.getCount());

        if (files.getCount() == 1) {

            File myFile = upload.getFiles().getFile(0);

            logger.info("|－－－－－－upload file path name:" + myFile.getFilePathName());

            if (myFile.isMissing()) {

                throw new UploadFileIsMissingException("上传文件丢失!");

            }

            return myFile;

        } else {

            throw new MultiFileException("必须上传，而且一次只能上传一个文件!");

        }

    }

 

    //判断文件是否丢失

    public boolean exists(File file) {

        return !file.isMissing();

    }

 

    //保存文件,如果文件不存在,新建目录,文件,(MultiFileException 请自建)

 

    public int save(String targetFilePath, int arg1) throws ServletException,

            IOException {

        try {

            if (logger.isInfoEnabled())

                logger.info("|－－－－－－save upload file to ：" + targetFilePath);

            File uploadFile = getSingleUploadFile();

            String fileName = uploadFile.getFileName();

            this.savePath = targetFilePath + java.io.File.separator + fileName;

            //按绝对路径保存

            FileUtils.createNewFile(savePath);

            uploadFile.saveAs(savePath, arg1);

logger.info("upload file and save is sucessed......!");

            return 1;

        } catch (MultiFileException e) {

            throw new IOException(e.getMessage());

        } catch (UploadFileIsMissingException e) {

            throw new IOException(e.getMessage());

        }

    }

 

    public String getAbsoluteSavePath() {

        return savePath;

    }

 

 

    public Hashtable dealAllPara() throws Exception {

        Hashtable hashtable = new Hashtable();

        Enumeration e = request.getParameterNames();

 

        while (e.hasMoreElements()) {

            String paraname = (String) e.nextElement();

            String para = request.getParameter(paraname);

            if ((paraname != null) && (para != null)) {

                hashtable.put(paraname, para);

            }

            logger.info("UPLOAD/param:name=" + paraname + ",value=" + para);

        }

        logger.info("param length = " + hashtable.size());

        return hashtable;

    }

 

    public String getFilenameNoExt() throws MultiFileException,

            UploadFileIsMissingException {

        File file = getSingleUploadFile();

        String fileName = file.getFileName();

        return fileName.substring(0, fileName.lastIndexOf("."));

    }

 

    public Request getRequest() {

        return upload.getRequest();

    }

 

    public Files getFiles() {

        return upload.getFiles();

    }

}

 

调用上两个类就可以实现文件上传,下面讨论文件解压

 

1. 解压接口

 

package com.commonStrut.utils;

 

 

public interface IZipUtils {

    //File zipFile, String unzipDir

    public String unzip() throws Exception;

}

 

2. 解压

 

package com.commonStrut.utils;

 

import java.io.File;

import java.io.FileOutputStream;

import java.io.InputStream;

import java.io.OutputStream;

import java.util.Enumeration;

import java.util.zip.ZipEntry;

import java.util.zip.ZipFile;

 

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

 

/**

 * @author 魏 剑

 *  

 */

public class ZipUtils implements IZipUtils {

    private Log logger = LogFactory.getLog(ZipUtils.class);

 

    private File zipFile;

 

    private String unzipDir;

 

    public ZipUtils(File zipFile, String unzipDir) {

        this.zipFile = zipFile;

        this.unzipDir = unzipDir;

    }

 

    public String unzip() throws Exception {

        logger.info("zipFile path=" + zipFile.getPath());

        ZipFile zf = new ZipFile(zipFile);

        Enumeration enu = zf.entries();

        String result = "";

 

        while (enu.hasMoreElements()) {

            ZipEntry entry = (ZipEntry) enu.nextElement();

            String name = entry.getName();

 

            //如果解压entry是目录,直接生成目录即可,不用写入,如果是文件,要讲文件写入

            String path = unzipDir + name;

            result = result + path + "<br/>";

            File file = new File(path);

            if (entry.isDirectory()) {

                file.mkdirs();

            } else {

 

//建议使用如下方式创建 流,和读取字节,不然会有乱码(当然要根据具体环境来定),具体原因请听

//下回分解,呵呵

                InputStream is = zf.getInputStream(entry);

                byte[] buf1 = new byte[1024];

                int len;

 

                if (!file.exists()) {

                    file.getParentFile().mkdirs();

                    file.createNewFile();

                }

                OutputStream out = new FileOutputStream(file);

                while ((len = is.read(buf1)) > 0) {

                    String buf = new String(buf1, 0, len);

 

                    out.write(buf1, 0, len);

                }

            }

        }

        result ="文件解压成功,解压文件:<br/>" + result; 

        logger.info("----------------unzip msg = "+result);

        return result;

    }

}

 

为了实现提交后后台一次处理,需要将上传＆解压桥接起来,也写了一个类,有兴趣的朋友可以参考,别打人啊!哎呀,马上就完了

package com.commonStrut.utils.upload;

 

import java.io.File;

import java.io.IOException;

import java.util.Hashtable;

 

import javax.servlet.ServletException;

 

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

 

import com.commonStrut.utils.IZipUtils;

import com.commonStrut.utils.ZipUtils;

import com.commonStrut.utils.ZipUtils;

import com.jspsmart.upload.Files;

import com.jspsmart.upload.Request;

import com.jspsmart.upload.SmartUpload;

 

 

public class ZipUploadAndUnzip implements IZipUtils,IUpload{

 

    private Log logger = LogFactory.getLog(ZipUploadAndUnzip.class);

    private IZipUtils ziputils = null;

    private String uploadTargetFileName = "";

    private String unzipDir = "";

    private SingleUpload upload = null;

    

    public ZipUploadAndUnzip(SingleUpload upload, String saveTargetFilePath,

            String unzipDir) throws ServletException, IOException {

        this.upload = upload;

        this.uploadTargetFileName = saveTargetFilePath;

        this.unzipDir = unzipDir;

    }

 

 

    public String unzip() throws Exception{

        //保存

        upload.save(uploadTargetFileName,SmartUpload.SAVE_PHYSICAL);

        //得到保存后文件

        String savePath = upload.getAbsoluteSavePath();

        logger.info("-------------absolute save path = "+savePath);

        File file = new File(savePath);

        //解压

        ziputils = new ZipUtils(file,unzipDir);

        return ziputils.unzip();

    }

    public String getFilenameNoExt() throws MultiFileException, UploadFileIsMissingException {

        return upload.getFilenameNoExt();

    }

 

 

 

    public com.jspsmart.upload.File getSingleUploadFile() throws MultiFileException, UploadFileIsMissingException {

        return upload.getSingleUploadFile();

    }

 

    

    public boolean exists(com.jspsmart.upload.File file) {

       return upload.exists(file);

    }

 

    public int save(String targetFileName, int arg1) throws ServletException, IOException {

        return upload.save(targetFileName,arg1);

    }

 

    

    public String getAbsoluteSavePath() {

        return upload.getAbsoluteSavePath();

    }

 

    

    public Request getRequest() {

        return upload.getRequest();

    }

 

   

    public Files getFiles() {

        return upload.getFiles();

    }

 

    

    public Hashtable dealAllPara() throws Exception {

       return upload.dealAllPara();

    }

}

 

有朋友说了,你既然这么罗嗦了,干脆把如何调用的也给个例子吧,好好好,盛情难却啊

假如你是用 struts,可以在Action类如下调用

 

public class UploadAction extends Action{

     public ActionForward execute(ActionMapping mapping, ActionForm actionForm,

            HttpServletRequest request, HttpServletResponse response)

            throws Exception {

 

            SmartUpload mySmartUpload = new SmartUpload();

            mySmartUpload.initialize(this.getServlet().getServletConfig(),

                    request, response);

            SingleUpload singleUpload = new SingleUpload(mySmartUpload);

 

            //处理参数

 

             Hashtable allPara = singleUpload.dealAllPara();

 

             //文件上传保存路径,＆解压后保存的目录,这里是定义在配置文件中,具体实现大家写罗

 

            String saveTargetFilePath = InitConfiguration.getInstance()

                        .getCONFIG("uploadPicDir");

            String unzipDir = InitConfiguration.getInstance().getCONFIG(

                        "unzipPicDir");

 

            //upload and unzip.........

            String unzipMsg = uploadAndUnzip(bf, singleUpload, allPara,

                        saveTargetFilePath, unzipDir, true);

 

     }

 

}

 

好了,要吃饭了,写的不好请多多包涵.也请多多指教,可不许骂人