java 压缩解压 zip

package com.test.zipFile;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.zip.ZipEntry;
import java.util.zip.ZipInputStream;
import java.util.zip.ZipOutputStream;

import org.junit.Test;

/**
 * 通过Java的Zip输入输出流实现压缩和解压文件
 * 
 */
public class ZipUtil {

	public ZipUtil() {
		// empty
	}

	/**
	 * 压缩文件
	 * 
	 * @param filePath
	 *            待压缩的文件路径
	 * @return 压缩后的文件
	 * @throws Exception
	 */
	public static File zip(String filePath) throws Exception {
		File target = null;
		File source = new File(filePath);
		if (source.exists()) {
			// 压缩文件名=源文件名.zip
			String zipName = source.getName() + ".zip";
			target = new File(source.getParent(), zipName);
			if (target.exists()) {
				target.delete(); // 删除旧的文件
			}
			FileOutputStream fos = null;
			ZipOutputStream zos = null;
			try {
				fos = new FileOutputStream(target);
				zos = new ZipOutputStream(new BufferedOutputStream(fos));
				// 添加对应的文件Entry
				addEntry("", source, zos);
			} catch (IOException e) {
				throw new RuntimeException(e);
			} finally {
				if (null != zos) {
					zos.close();
				}
				if (null != fos) {
					fos.close();
				}

			}
		}
		return target;
	}

	/**
	 * 扫描添加文件Entry
	 * 
	 * @param base
	 *            基路径
	 * 
	 * @param source
	 *            源文件
	 * @param zos
	 *            Zip文件输出流
	 * @throws IOException
	 */
	@SuppressWarnings("resource")
	private static void addEntry(String base, File source, ZipOutputStream zos) throws Exception {
		// 按目录分级，形如：aaa/bbb.txt
		String entry = base + source.getName();
		if (source.isDirectory()) {
			for (File file : source.listFiles()) {
				// 递归列出目录下的所有文件，添加文件Entry
				addEntry(entry + "/", file, zos);
			}
		} else {
			FileInputStream fis = null;
			BufferedInputStream bis = null;
			byte[] buffer = new byte[1024 * 10];
			fis = new FileInputStream(source);
			bis = new BufferedInputStream(fis, buffer.length);
			int read = 0;
			zos.putNextEntry(new ZipEntry(entry));
			while ((read = bis.read(buffer, 0, buffer.length)) != -1) {
				zos.write(buffer, 0, read);
			}
			zos.closeEntry();
		}
	}

	/**
	 * 解压文件
	 * 
	 * @param filePath
	 *            压缩文件路径
	 * @throws Exception
	 */
	public static void unzip(String filePath) throws Exception {
		File source = new File(filePath);
		if (source.exists()) {
			ZipInputStream zis = null;
			BufferedOutputStream bos = null;
			zis = new ZipInputStream(new FileInputStream(source));
			ZipEntry entry = null;
			while ((entry = zis.getNextEntry()) != null && !entry.isDirectory()) {
				File target = new File(source.getParent(), entry.getName());
				if (!target.getParentFile().exists()) {
					// 创建文件父目录
					target.getParentFile().mkdirs();
				}
				// 写入文件
				bos = new BufferedOutputStream(new FileOutputStream(target));
				int read = 0;
				byte[] buffer = new byte[1024 * 10];
				while ((read = zis.read(buffer, 0, buffer.length)) != -1) {
					bos.write(buffer, 0, read);
				}
				bos.flush();
			}
			zis.closeEntry();
			if (null != zis) {
				zis.close();
			}
			if (null != bos) {
				bos.close();
			}

		}
	}

	public static void main(String[] args) throws Exception {
		String targetPath = "D:/CSVFile";
		File file = ZipUtil.zip(targetPath);
		System.out.println(file);
	}

	@Test
	public void testZipFile() throws Exception {
		File sourceFile = new File("D:/aaabb.docx");
		InputStream inputStream = new FileInputStream(sourceFile);
		OutputStream out = new FileOutputStream("d:/aaabbbccc.zip");
		ZipOutputStream zipOut = new ZipOutputStream(out);

		String entry = sourceFile.getName();
		zipOut.putNextEntry(new ZipEntry(entry)); // 把要压缩的文件put Entry
		int b = -1;
		while ((b = inputStream.read()) != -1) {
			zipOut.write(b);
		}
		zipOut.closeEntry();
		zipOut.close();
		inputStream.close();

	}
	
	@Test
	public void testUnZipFile() throws Exception{
		File zipFile = new File("D:/aaabbbccc.zip");
		ZipInputStream zipInput = new ZipInputStream(new FileInputStream(zipFile));
		ZipEntry nextEntry = zipInput.getNextEntry();
		String name = nextEntry.getName();
		
		File outPutFile = new File("d:/uu/");
		
		if(!outPutFile.exists()){
			outPutFile.mkdirs();
		}
		FileOutputStream out = new FileOutputStream(outPutFile.getAbsolutePath()+"/"+name);
		int b = -1;
		while ( (b = zipInput.read()) != -1 ) {
			out.write(b);
		}
		out.close();
		zipInput.closeEntry();
		zipInput.close();
	}
	
}

 

另一种方式

//==============================================================================

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStream;
import java.util.Enumeration;

import org.apache.tools.ant.Project;
import org.apache.tools.ant.taskdefs.Zip;
import org.apache.tools.ant.types.FileSet;
import org.apache.tools.zip.ZipEntry;
import org.apache.tools.zip.ZipFile;

/**
 * 文件解压缩工具类
 *
 */
public class ZipFileOperateUtil
{
    private String logPath = "";

    public String getLogPath()
    {
        return this.logPath;
    }

    public void setLogPath(String logPath)
    {
        this.logPath = logPath;
    }

    /**
     * 压缩文件
     *
     * @param zipFilePath 压缩的文件完整名称(目录+文件名)
     * @param srcPathName 需要被压缩的文件或文件夹
     */
    public void compressFiles(String zipFilePath, String srcPathName)
    {
        File zipFile = new File(zipFilePath);
        File srcdir = new File(srcPathName);
        if (!srcdir.exists())
        {
            throw new RuntimeException(srcPathName + "不存在！");
        }
        Project prj = new Project();
        FileSet fileSet = new FileSet();
        fileSet.setProject(prj);
        if (srcdir.isDirectory())
        { //是目录
            fileSet.setDir(srcdir);
            fileSet.setIncludes("*.xlsx"); //包括哪些文件或文件夹 eg:zip.setIncludes("*.java");
            fileSet.setIncludes("*.xls");
            fileSet.setIncludes("*.txt");
            //fileSet.setExcludes(...); //排除哪些文件或文件夹
        }
        else
        {
            fileSet.setFile(srcdir);
        }
        Zip zip = new Zip();
        zip.setProject(prj);
        zip.setDestFile(zipFile);
        zip.setEncoding("utf-8"); //以gbk编码进行压缩，注意windows是默认以gbk编码进行压缩的
        zip.addFileset(fileSet);
        zip.execute();
        //        logger.debug("---compress files success---");
    }

    /**
     * 解压文件到指定目录
     *
     * @param //zipFile 目标文件
     * @param //descDir 解压目录
     * @author isDelete 是否删除目标文件
     */
    public void unZipFiles(String zipFilePath, String fileSavePath, boolean isDelete)
    {
        ZipFileOperateUtil fileOperateUtil = new ZipFileOperateUtil();
        boolean isUnZipSuccess = true;
        try
        {
            (new File(fileSavePath)).mkdirs();
            File f = new File(zipFilePath);
            if ((!f.exists()) && (f.length() <= 0))
            {
                throw new RuntimeException("not find " + zipFilePath + "!");
            }
            //一定要加上编码，之前解压另外一个文件，没有加上编码导致不能解压
            ZipFile zipFile = new ZipFile(f, "gbk");
            String gbkPath, strtemp;
            Enumeration<ZipEntry> e = zipFile.getEntries();
            while (e.hasMoreElements())
            {
                org.apache.tools.zip.ZipEntry zipEnt = e.nextElement();
                gbkPath = zipEnt.getName();
                strtemp = fileSavePath + File.separator + gbkPath;
                if (zipEnt.isDirectory())
                { //目录
                    File dir = new File(strtemp);
                    if (!dir.exists())
                    {
                        dir.mkdirs();
                    }
                    continue;
                }
                else
                {
                    // 读写文件
                    InputStream is = zipFile.getInputStream(zipEnt);
                    BufferedInputStream bis = new BufferedInputStream(is);
                    // 建目录
                    String strsubdir = gbkPath;
                    for (int i = 0; i < strsubdir.length(); i++)
                    {
                        if (strsubdir.substring(i, i + 1).equalsIgnoreCase("/"))
                        {
                            String temp = fileSavePath + File.separator + strsubdir.substring(0, i);
                            File subdir = new File(temp);
                            if (!subdir.exists())
                            {
                                subdir.mkdir();
                            }
                        }
                    }
                    FileOutputStream fos = new FileOutputStream(strtemp);
                    BufferedOutputStream bos = new BufferedOutputStream(fos);
                    int len;
                    byte[] buff = new byte[5120];
                    while ((len = bis.read(buff)) != -1)
                    {
                        bos.write(buff, 0, len);
                    }
                    bos.close();
                    fos.close();
                }
            }
            zipFile.close();
        }
        catch (Exception e)
        {
            //            logger.error("解压文件出现异常：", e);
            isUnZipSuccess = false;
            System.out.println("extract file error: " + zipFilePath);
            fileOperateUtil.WriteStringToFile(fileOperateUtil.logPath, "extract file error: " + zipFilePath);
        }
        /**
         * 文件不能删除的原因：
         * 1.看看是否被别的进程引用，手工删除试试(删除不了就是被别的进程占用)
         2.file是文件夹 并且不为空，有别的文件夹或文件，
         3.极有可能有可能自己前面没有关闭此文件的流(我遇到的情况)
         */
        if (isDelete && isUnZipSuccess)
        {
            boolean flag = new File(zipFilePath).delete();
            //            logger.debug("删除源文件结果: " + flag);
            fileOperateUtil.WriteStringToFile(fileOperateUtil.logPath, "delete " + zipFilePath + "result: " + flag);
        }
        //        logger.debug("compress files success");
    }

    /**
     * 删除指定文件夹下所有文件
     * param path 文件夹完整绝对路径
     *
     * @param path
     * @return
     */

    public static boolean delAllFile(String path)
    {
        System.out.println(path);
        boolean flag = false;
        File file = new File(path);
        if (!file.exists())
        {
            return flag;
        }
        if (!file.isDirectory())
        {
            return flag;
        }
        String[] tempList = file.list();
        File temp = null;
        for (int i = 0; i < tempList.length; i++)
        {
            if (path.endsWith(File.separator))
            {
                temp = new File(path + tempList[i]);
            }
            else
            {
                temp = new File(path + File.separator + tempList[i]);
            }
            if (temp.isFile())
            {
                temp.delete();
            }
            if (temp.isDirectory())
            {
                delAllFile(path + "/" + tempList[i]);// 先删除文件夹里面的文件
                boolean success = (new File(path + "/" + tempList[i])).delete();
                flag = success;
            }
        }
        return flag;
    }

    /**
     * 复制单个文件
     *
     * @param oldPath String 原文件路径 如：c:/fqf.txt
     * @param newPath String 复制后路径 如：f:/fqf.txt
     * @return boolean
     */
    public void copyFile(String oldPath, String newPath)
    {
        BufferedInputStream bis = null;
        BufferedOutputStream bos = null;
        try
        {
            (new File(newPath)).mkdirs(); //如果文件夹不存在 则建立新文件夹
            bis = new BufferedInputStream(new FileInputStream(oldPath));
            bos = new BufferedOutputStream(new FileOutputStream(newPath));

            int hasRead = 0;
            byte b[] = new byte[2048];
            while ((hasRead = bis.read(b)) > 0)
            {
                bos.write(b, 0, hasRead);
            }
        }
        catch (FileNotFoundException e)
        {
            e.printStackTrace();
        }
        catch (IOException e)
        {
            e.printStackTrace();
        }
        finally
        {
            if (bos != null)
            {
                try
                {
                    bos.flush();
                    bos.close();
                }
                catch (IOException e)
                {
                    e.printStackTrace();
                }
            }
            if (bis != null)
            {
                try
                {
                    bis.close();
                }
                catch (IOException e)
                {
                    e.printStackTrace();
                }
            }
        }
    }

    /**
     * 复制整个文件夹内容
     * @param oldPath String 原文件路径 如：c:/fqf
     * @param newPath String 复制后路径 如：f:/fqf/ff
     * @return boolean
     */
    public void copyFolder(String oldPath, String newPath)
    {
        System.out.println("copy path: " + oldPath);
        try
        {
            (new File(newPath)).mkdirs(); //如果文件夹不存在 则建立新文件夹
            File a = new File(oldPath);
            String[] file = a.list();
            File temp = null;
            for (int i = 0; i < file.length; i++)
            {
                if (oldPath.endsWith(File.separator))
                {
                    temp = new File(oldPath + file[i]);
                }
                else
                {
                    temp = new File(oldPath + File.separator + file[i]);
                }

                if (temp.isFile())
                {
                    FileInputStream input = new FileInputStream(temp);
                    FileOutputStream output = new FileOutputStream(newPath + "/" + (temp.getName()).toString());
                    byte[] b = new byte[5120];
                    int len;
                    while ((len = input.read(b)) != -1)
                    {
                        output.write(b, 0, len);
                    }
                    output.flush();
                    output.close();
                    input.close();
                }
                if (temp.isDirectory())
                {//如果是子文件夹
                    this.copyFolder(oldPath + "/" + file[i], newPath + "/" + file[i]);
                }
            }
        }
        catch (Exception e)
        {
            System.out.println("复制整个文件夹内容操作出错");
            e.printStackTrace();
        }

    }

    /**
     * 写内容到指定文件
     * @param filePath
     * @param content
     */
    public void WriteStringToFile(String filePath, String content)
    {
        try
        {
            FileWriter fw = new FileWriter(filePath, true);
            BufferedWriter bw = new BufferedWriter(fw);
            bw.write(content + "\r\n");// 往已有的文件上添加字符串
            bw.close();
            fw.close();
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
    }

    public void extractFiles(String strPath)
    {
        ZipFileOperateUtil fileOperateUtil = new ZipFileOperateUtil();
        File dir = new File(strPath);
        File[] files = dir.listFiles(); // 该文件目录下文件全部放入数组
        if (files != null)
        {
            for (int i = 0; i < files.length; i++)
            {
                String fileName = files[i].getName();

                if (!files[i].isDirectory() && (fileName.endsWith(".jar") || fileName.endsWith(".zip")))
                { // 判断文件名是否以.jar结尾
                    String sourceFilePath = files[i].getAbsolutePath();
                    ////////fileOperateUtil.WriteStringToFile(fileOperateUtil.getLogPath(), "extract file: " + sourceFilePath);
                    String dirName = fileName.substring(0, fileName.length() - 4);
                    String resultPath = sourceFilePath.replace(fileName, dirName);

                    fileOperateUtil.unZipFiles(sourceFilePath, resultPath, true);
                }
            }

        }
    }

    public static void main(String[] args) throws Exception
    {
       ZipFileOperateUtil fileutile = new ZipFileOperateUtil();
       fileutile.compressFiles("F:\\Work\\code\\registration-platform\\registration-web\\新建文件夹\\test.zip", "F:\\Work\\code\\registration-platform\\registration-web\\新建文件夹");
       System.out.println("end");
    }
}