<dependency>
	<groupId>org.apache.commons</groupId>
	<artifactId>commons-compress</artifactId>
	<version>1.19</version>
</dependency>
<dependency>
 <groupId>log4j</groupId>
 <artifactId>log4j</artifactId>
 <version>1.2.17</version>
</dependency>

package com.arhorchin.securitit.compress.gzip;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

import org.apache.commons.compress.archivers.tar.TarArchiveEntry;
import org.apache.commons.compress.archivers.tar.TarArchiveInputStream;
import org.apache.commons.compress.archivers.tar.TarArchiveOutputStream;
import org.apache.commons.compress.compressors.gzip.GzipCompressorInputStream;
import org.apache.commons.compress.compressors.gzip.GzipCompressorOutputStream;
import org.apache.commons.io.IOUtils;

/**
 * @author Securitit.
 * @note 基于內(nèi)存以ZIP算法進(jìn)行壓縮和解壓工具類(lèi).
 */
public class GZipRamUtil {

 /**
 * 使用TAR算法進(jìn)行壓縮.
 * @param sourceFileBytesMap 待壓縮文件的Map集合.
 * @return 壓縮后的TAR文件字節(jié)數(shù)組.
 * @throws Exception 壓縮過(guò)程中可能發(fā)生的異常，若發(fā)生異常，則返回的字節(jié)數(shù)組長(zhǎng)度為0.
 */
 public static byte[] compressByTar(Map<String, byte[]> tarFileBytesMap) throws Exception {
 // 變量定義.
 ByteArrayOutputStream tarBaos = null;
 TarArchiveOutputStream tarTaos = null;
 TarArchiveEntry tarTae = null;

 try {
  // 壓縮變量初始化.
  tarBaos = new ByteArrayOutputStream();
  tarTaos = new TarArchiveOutputStream(tarBaos);
  // // 將文件添加到TAR條目中.
  for (Map.Entry<String, byte[]> fileEntry : tarFileBytesMap.entrySet()) {
  tarTae = new TarArchiveEntry(fileEntry.getKey());
  tarTae.setName(fileEntry.getKey());
  tarTae.setSize(fileEntry.getValue().length);
  tarTaos.putArchiveEntry(tarTae);
  tarTaos.write(fileEntry.getValue());
  tarTaos.closeArchiveEntry();
  }
 } finally {
  if (tarTaos != null) {
  tarTaos.close();
  }
  if (null == tarBaos) {
  tarBaos = new ByteArrayOutputStream();
  }
 }
 return tarBaos.toByteArray();
 }

 /**
 * 使用TAR算法進(jìn)行解壓.
 * @param sourceZipFileBytes TAR文件字節(jié)數(shù)組.
 * @return 解壓后的文件Map集合.
 * @throws Exception 解壓過(guò)程中可能發(fā)生的異常，若發(fā)生異常，返回Map集合長(zhǎng)度為0.
 */
 public static Map<String, byte[]> decompressByTar(byte[] sourceTarFileBytes) throws Exception {
 // 變量定義.
 TarArchiveEntry sourceTarTae = null;
 ByteArrayInputStream sourceTarBais = null;
 TarArchiveInputStream sourceTarTais = null;
 Map<String, byte[]> targetFilesFolderMap = null;

 try {
  // 解壓變量初始化.
  targetFilesFolderMap = new HashMap<String, byte[]>();
  sourceTarBais = new ByteArrayInputStream(sourceTarFileBytes);
  sourceTarTais = new TarArchiveInputStream(sourceTarBais);
  // 條目解壓縮至Map中.
  while ((sourceTarTae = sourceTarTais.getNextTarEntry()) != null) {
  targetFilesFolderMap.put(sourceTarTae.getName(), IOUtils.toByteArray(sourceTarTais));
  }
 } finally {
  if (sourceTarTais != null)
  sourceTarTais.close();
 }
 return targetFilesFolderMap;
 }

 /**
 * 使用GZIP算法進(jìn)行壓縮.
 * @param sourceFileBytesMap 待壓縮文件的Map集合.
 * @return 壓縮后的GZIP文件字節(jié)數(shù)組.
 * @throws Exception 壓縮過(guò)程中可能發(fā)生的異常，若發(fā)生異常，則返回的字節(jié)數(shù)組長(zhǎng)度為0.
 */
 public static byte[] compressByGZip(byte[] sourceFileBytes) throws IOException {
 // 變量定義.
 ByteArrayOutputStream gzipBaos = null;
 GzipCompressorOutputStream gzipGcos = null;

 try {
  // 壓縮變量初始化.
  gzipBaos = new ByteArrayOutputStream();
  gzipGcos = new GzipCompressorOutputStream(gzipBaos);
  // 采用commons-compress提供的方式進(jìn)行壓縮.
  gzipGcos.write(sourceFileBytes);
 } finally {
  if (gzipGcos != null) {
  gzipGcos.close();
  }
  if (null == gzipBaos) {
  gzipBaos = new ByteArrayOutputStream();
  }
 }
 return gzipBaos.toByteArray();
 }

 /**
 * 使用GZIP算法進(jìn)行解壓.
 * @param sourceGZipFileBytes GZIP文件字節(jié)數(shù)組.
 * @return 解壓后的文件Map集合.
 * @throws Exception 解壓過(guò)程中可能發(fā)生的異常，若發(fā)生異常，則返回的字節(jié)數(shù)組長(zhǎng)度為0.
 */
 public static byte[] decompressByGZip(byte[] sourceGZipFileBytes) throws IOException {
 // 變量定義.
 ByteArrayOutputStream gzipBaos = null;
 ByteArrayInputStream sourceGZipBais = null;
 GzipCompressorInputStream sourceGZipGcis = null;

 try {
  // 解壓變量初始化.
  gzipBaos = new ByteArrayOutputStream();
  sourceGZipBais = new ByteArrayInputStream(sourceGZipFileBytes);
  sourceGZipGcis = new GzipCompressorInputStream(sourceGZipBais);
  // 采用commons-compress提供的方式進(jìn)行解壓.
  gzipBaos.write(IOUtils.toByteArray(sourceGZipGcis));
 } finally {
  if (sourceGZipGcis != null)
  sourceGZipGcis.close();
 }
 return gzipBaos.toByteArray();
 }

}

package com.arhorchin.securitit.compress.gzip;

import java.io.File;
import java.util.HashMap;
import java.util.Map;

import org.apache.commons.io.FileUtils;

import com.arhorchin.securitit.compress.gzip.GZipRamUtil;

/**
 * @author Securitit.
 * @note GZipRamUtil工具類(lèi)測(cè)試.
 */
public class GZipRamUtilTester {

 public static void main(String[] args) throws Exception {
 Map<String, byte[]> fileBytesMap = null;

 fileBytesMap = new HashMap<String, byte[]>();
 // 設(shè)置文件列表.
 File dirFile = new File("C:/Users/Administrator/Downloads/個(gè)人文件/2020-07-13/files");
 for (File file : dirFile.listFiles()) {
  fileBytesMap.put(file.getName(), FileUtils.readFileToByteArray(file));
 }

 byte[] ramBytes = GZipRamUtil.compressByTar(fileBytesMap);
 ramBytes = GZipRamUtil.compressByGZip(ramBytes);
 FileUtils.writeByteArrayToFile(new File("C:/Users/Administrator/Downloads/個(gè)人文件/2020-07-13/ram.tar.gz"), ramBytes);
 
 ramBytes = GZipRamUtil.decompressByGZip(ramBytes);
 fileBytesMap = GZipRamUtil.decompressByTar(ramBytes);
 System.out.println(fileBytesMap.size());
 }

}