IO流之ZipInputStream和ZipOutputStream的認識及常用使用（轉）及中文亂碼問題

ZipInputStream和ZipOutputStream定義
壓縮流
在日常中經常會使用到zip或rar這樣的壓縮文件，更加便利了我們日常文件的傳輸和使用。當然在java中
也提供了相應的輸入輸出流來壓縮和解壓gzip、zip和rar這樣的文件。
ZipInputStream
“壓縮文件輸入流”，用於讀取磁盤上的壓縮文件
ZipOutputStream
“壓縮文件輸出流”，用於將程序中的壓縮流寫出到磁盤上。
通常需要使用ZipFile ZipInputStream/ZipOutputStream ZipEntry級File完成解壓縮操作。
其他相似流
在JAVA IO中，不僅可以實現ZIP壓縮格式的輸入、輸出，也可以實現JAR及GZIP文件格式的壓縮：
JAR壓縮的支持類保存在java.util.jar包中，常用的類有如下幾個：
JAR壓縮輸出流：JarOutputStream
JAR壓縮輸入流：JarInputStream
JAR文件：JARFile
JAR實體：JAREntry
GZIP是用於UNIX系統的文件壓縮，在Linux中經常會使用到*.gz的文件，就是GZIP格式，GZIP壓縮的支持類保存在java.util.zip包中，常用的類有如下幾個：
GZIP壓縮輸出流：GZIPOutputStream
GZIP壓縮輸入流：GZIPInputStream
使用用例
壓縮
// 壓縮入口1
public static void compress(String srcPath, String destPath,boolean dirFlag) throws Exception {
compress(new File(srcPath), new File(destPath), dirFlag);
}

// 壓縮入口2
public static void compress(String srcPath, String destPath) throws Exception {
compress(new File(srcPath), new File(destPath), DEFAULT_DIR);
}

// 壓縮入口3
public static void compress(File srcFile, File destFile, boolean dirFlag) throws Exception {
compress(srcFile, new ZipOutputStream(new FileOutputStream(destFile)), dirFlag);
}

public static void compress(File srcFile, ZipOutputStream zos, boolean dirFlag) throws Exception {
// 需要解壓的壓縮文件對象
// 壓縮輸出流
// 是否在壓縮文件時創建一個父文件夾后再壓縮
if (srcFile.isDirectory()) {
if (dirFlag) {
doCompress(zos, srcFile, srcFile.getName() + File.separator);
} else {
doCompress(zos, srcFile, "");
}
} else {
doCompress(zos, srcFile, "");
}
zos.close();
}

public static void doCompress(ZipOutputStream zos, File file, String baseDir) throws Exception {
if (file.isDirectory()) {
// 遞歸循環，只壓縮其中所有文件
File[] files = file.listFiles();
for (int i = 0; i < files.length; i++) {
doCompress(zos, files[i], baseDir);
}
} else {
// 進行文件壓縮的操作
byte[] buff = new byte[DEFAULT_BUFF_SIZE];
InputStream in = new FileInputStream(file);
zos.putNextEntry(new ZipEntry(baseDir + File.separator + file.getName()));
int len;
while ((len = in.read(buff,0 ,DEFAULT_BUFF_SIZE)) != -1) {
zos.write(buff, 0, len);
}
in.close();
}
}

解壓
/**
* Default buff byte size
*
*/
private static final int DEFAULT_BUFF_SIZE = 1024;

/**
* Default basedir value
*
*/
private static final boolean DEFAULT_DIR = false;

// 程序入口1
public static void decompress(String srcPath) throws Exception {
decompress(new File(srcPath));
}

// 程序入口2
public static void decompress(File srcFile) throws Exception {
File baseFile = srcFile.getParentFile();
decompress(srcFile, baseFile);
}

// 程序入口3
public static void decompress(String srcPath, String destPath) throws Exception {
decompress(new File(srcPath), new File(destPath));
}

// 程序基本入口
public static void decompress(File srcFile, File destFile) throws Exception {
CheckedInputStream cis = new CheckedInputStream(new FileInputStream(srcFile), new CRC32());
ZipInputStream zis = new ZipInputStream(cis);
// 解壓操作
doDecompress(destFile, zis);
zis.close();
}

private static void doDecompress(File destFile, ZipInputStream zis) throws Exception {
ZipEntry zipEntry = null;
while ((zipEntry = zis.getNextEntry()) != null) {
String dir = destFile.getPath() + File.separator + zipEntry.getName();
File dirFile = new File(dir);
// 如果父文件夾不存在，則遞歸創建其父文件夾
fileProber(dirFile);
if (zipEntry.isDirectory()) {
// 如果zipEntry是目錄，則創建目錄
dirFile.mkdirs();
} else {
// 解壓壓縮文件的其中具體的一個zipEntry對象
doDecompressFile(dirFile, zis);
}
zis.closeEntry();
}
}

// 一般意義上的文件復制操作
private static void doDecompressFile(File destFile, ZipInputStream zis) throws Exception {
BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(destFile));
int len;
byte[] buff = new byte[DEFAULT_BUFF_SIZE];
while ((len = zis.read(buff, 0 ,DEFAULT_BUFF_SIZE)) != -1) {
bos.write(buff, 0, len);
}
bos.close();
}

/**
* 文件探測
*
* When the parent file not exist.Create it.
*
* @param dirFile
* @throws Exception
*/
public static void fileProber(File dirFile) throws Exception {
File parentFile = dirFile.getParentFile();
if (!parentFile.exists()) {
fileProber(parentFile);
parentFile.mkdirs();
}
}

工具類
/**
* Copyright © 2018, LeonKeh
* <p>
* All Rights Reserved.
*/

package cn.cherry.se.l_io_zipoutputinputstream;

import java.io.*;
import java.util.zip.*;

/**
* ZIP 解壓縮工具包
*
* @author Leon
* @version 2018/6/6 23:07
*/
public class ZipUtils {

/**
* Default buff byte size
*
*/
private static final int DEFAULT_BUFF_SIZE = 1024;

/**
* Default basedir value
*
*/
private static final boolean DEFAULT_DIR = false;

public static void decompress(String srcPath) throws Exception {
decompress(new File(srcPath));
}

public static void decompress(File srcFile) throws Exception {
File baseFile = srcFile.getParentFile();
decompress(srcFile, baseFile);
}

public static void decompress(String srcPath, String destPath) throws Exception {
decompress(new File(srcPath), new File(destPath));
}

public static void decompress(File srcFile, File destFile) throws Exception {
CheckedInputStream cis = new CheckedInputStream(new FileInputStream(srcFile), new CRC32());
ZipInputStream zis = new ZipInputStream(cis);
doDecompress(destFile, zis);
zis.close();
}

private static void doDecompress(File destFile, ZipInputStream zis) throws Exception {
ZipEntry zipEntry = null;
while ((zipEntry = zis.getNextEntry()) != null) {
String dir = destFile.getPath() + File.separator + zipEntry.getName();
File dirFile = new File(dir);
fileProber(dirFile);
if (zipEntry.isDirectory()) {
dirFile.mkdirs();
} else {
doDecompressFile(dirFile, zis);
}
zis.closeEntry();
}
}

private static void doDecompressFile(File destFile, ZipInputStream zis) throws Exception {
BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(destFile));
int len;
byte[] buff = new byte[DEFAULT_BUFF_SIZE];
while ((len = zis.read(buff, 0 ,DEFAULT_BUFF_SIZE)) != -1) {
bos.write(buff, 0, len);
}
bos.close();
}

/**
* 文件探測
*
* When the parent file not exist.Create it.
*
* @param dirFile
* @throws Exception
*/
public static void fileProber(File dirFile) throws Exception {
File parentFile = dirFile.getParentFile();
if (!parentFile.exists()) {
fileProber(parentFile);
parentFile.mkdirs();
}
}

public static void compress(String srcPath, String destPath,boolean dirFlag) throws Exception {
compress(new File(srcPath), new File(destPath), dirFlag);
}

public static void compress(String srcPath, String destPath) throws Exception {
compress(new File(srcPath), new File(destPath), DEFAULT_DIR);
}

public static void compress(File srcFile, File destFile, boolean dirFlag) throws Exception {
compress(srcFile, new ZipOutputStream(new FileOutputStream(destFile)), dirFlag);
}

public static void compress(File srcFile, ZipOutputStream zos, boolean dirFlag) throws Exception {
if (srcFile.isDirectory()) {
if (dirFlag) {
doCompress(zos, srcFile, srcFile.getName() + File.separator);
} else {
doCompress(zos, srcFile, "");
}
} else {
doCompress(zos, srcFile, "");
}
zos.close();
}

public static void doCompress(ZipOutputStream zos, File file, String baseDir) throws Exception {
if (file.isDirectory()) {
File[] files = file.listFiles();
for (int i = 0; i < files.length; i++) {
doCompress(zos, files[i], baseDir);
}
} else {
byte[] buff = new byte[DEFAULT_BUFF_SIZE];
InputStream in = new FileInputStream(file);
zos.putNextEntry(new ZipEntry(baseDir + File.separator + file.getName()));
int len;
while ((len = in.read(buff,0 ,DEFAULT_BUFF_SIZE)) != -1) {
zos.write(buff, 0, len);
}
in.close();
}
}

}

總結
壓縮文件中的每個具體的壓縮實體在Java中用ZipEntry來表示，每一個壓縮文件很有可能包含多個ZipEntry
其他兩個gzip和rar壓縮文件的操作類似，在這里就省略
其中壓縮流的來源和目的不一定是磁盤，很有可能是網絡和內存中
ZipFile表示對壓縮文件抽象
具體的項目的開發可以使用Apache的工具包和網上的一些第三方jar工具，但是手寫一筆進一步加深對其了解和java流的認識
————————————————
原文鏈接：https://blog.csdn.net/weixin_39723544/article/details/80611810

 

ZipInputStream 默認utf-8編碼 會存在中文亂碼，解決方式：使用gbk編碼