From 0b8bc52f99c06e5af021a76530b7e1dc4f11d234 Mon Sep 17 00:00:00 2001 From: Yaser Hsueh Date: Tue, 9 Aug 2022 00:11:42 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9EBZip2=E8=A7=A3=E5=8E=8B?= =?UTF-8?q?=E7=BC=A9=E5=B7=A5=E5=85=B7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 7 +- src/main/java/com/simaek/util/BZip2Utils.java | 204 ++++++++++++++++++ .../java/com/simaek/util/BZip2UtilsTest.java | 26 +++ 3 files changed, 236 insertions(+), 1 deletion(-) create mode 100644 src/main/java/com/simaek/util/BZip2Utils.java create mode 100644 src/test/java/com/simaek/util/BZip2UtilsTest.java diff --git a/pom.xml b/pom.xml index 3a357eb..deeaf57 100644 --- a/pom.xml +++ b/pom.xml @@ -12,9 +12,14 @@ org.junit.jupiter junit-jupiter - 5.8.2 + 5.9.0 test + + org.apache.commons + commons-compress + 1.21 + diff --git a/src/main/java/com/simaek/util/BZip2Utils.java b/src/main/java/com/simaek/util/BZip2Utils.java new file mode 100644 index 0000000..a5e8110 --- /dev/null +++ b/src/main/java/com/simaek/util/BZip2Utils.java @@ -0,0 +1,204 @@ +package com.simaek.util; + +import org.apache.commons.compress.compressors.bzip2.BZip2CompressorInputStream; +import org.apache.commons.compress.compressors.bzip2.BZip2CompressorOutputStream; + +import java.io.*; + +/** + * BZip2文件解压缩工具 + * + * @author Yaser Hsueh + */ +@SuppressWarnings({"ResultOfMethodCallIgnored", "unused"}) +public abstract class BZip2Utils { + private static final int BUFFER = 8; + private static final String EXT_SUFFIX = ".bz2"; + + + /** + * 对字节数据进行压缩 + * + * @param data 原始字节数据 + * @return 压缩后的字节数据 + * @throws IOException 数据读写异常 + */ + public static byte[] compress(byte[] data) throws IOException { + ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(data); + ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(); + compress(byteArrayInputStream, byteArrayOutputStream); + byteArrayOutputStream.flush(); + byteArrayOutputStream.close(); + byteArrayInputStream.close(); + return byteArrayOutputStream.toByteArray(); + } + + /** + * 对数据流进行压缩 + * + * @param is 压缩前的数据输入流 + * @param os 压缩后的数据输出流 + * @throws IOException 数据流读写异常 + */ + public static void compress(InputStream is, OutputStream os) throws IOException { + BZip2CompressorOutputStream bzip2OS = new BZip2CompressorOutputStream(os, 8); + int count; + byte[] data = new byte[BUFFER]; + while ((count = is.read(data, 0, data.length)) != -1) { + bzip2OS.write(data, 0, count); + } + bzip2OS.finish(); + bzip2OS.flush(); + bzip2OS.close(); + } + + /** + * 对文件进行压缩 + * + * @param file 待压缩的文件 + * @param delete 压缩完成后删除源文件 + * @throws IOException 文件读写异常 + */ + public static void compress(File file, boolean delete) throws IOException { + if (!file.exists()) { + throw new FileNotFoundException("源文件不存在"); + } + FileInputStream fis = new FileInputStream(file); + FileOutputStream fos = new FileOutputStream(file.getPath() + EXT_SUFFIX); + compress(fis, fos); + fis.close(); + fos.flush(); + fos.close(); + if (delete) { + file.delete(); + } + } + + /** + * 对文件进行压缩，压缩完成后删除源文件 + * + * @param file 待压缩的文件 + * @throws IOException 文件读写异常 + */ + public static void compress(File file) throws IOException { + compress(file, true); + } + + /** + * 对指定路径的文件进行压缩 + * + * @param path 待压缩的文件路径 + * @param delete 压缩完成后删除源文件 + * @throws IOException 文件读写异常 + */ + public static void compress(String path, boolean delete) throws IOException { + File file = new File(path); + compress(file, delete); + } + + /** + * 对指定路径的文件进行压缩，压缩完成后删除源文件 + * + * @param path 待压缩的文件路径 + * @throws IOException 文件读写异常 + */ + public static void compress(String path) throws IOException { + compress(path, true); + } + + /** + * 对字节数据进行解压 + * + * @param data 压缩过的字节数据 + * @return 解压后的字节数据 + * @throws IOException 数据读写异常 + */ + public static byte[] uncompress(byte[] data) throws IOException { + ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(data); + ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(); + uncompress(byteArrayInputStream, byteArrayOutputStream); + byteArrayInputStream.close(); + return byteArrayOutputStream.toByteArray(); + } + + /** + * 对数据流进行解压 + * + * @param is 压缩后的数据输入流 + * @param os 解压后的数据输出流 + * @throws IOException 数据流读写异常 + */ + private static void uncompress(InputStream is, OutputStream os) throws IOException { + /* + * 对于多个合并的bz2输入流 + * BZip2CompressorInputStream decompressConcatenated： + * if true, decompress until the end of the input; + * if false, stop after the first .bz2 stream and + * leave the input position to point to the next + * byte after the .bz2 stream + */ + BZip2CompressorInputStream bzip2IS = new BZip2CompressorInputStream(is, true); + int count; + byte[] data = new byte[BUFFER]; + while ((count = bzip2IS.read(data, 0, data.length)) != -1) { + os.write(data, 0, count); + } + os.flush(); + os.close(); + bzip2IS.close(); + } + + /** + * 对文件进行解压 + * + * @param file 压缩文件 + * @param delete 解压完成后删除源文件 + * @throws IOException 文件读写异常 + */ + public static void uncompress(File file, boolean delete) throws IOException { + if (!file.exists()) { + throw new FileNotFoundException("源文件不存在"); + } + FileInputStream fis = new FileInputStream(file); + FileOutputStream fos = new FileOutputStream(file.getPath().replace(EXT_SUFFIX, "")); + uncompress(fis, fos); + fis.close(); + fos.flush(); + fos.close(); + if (delete) { + file.delete(); + } + } + + /** + * 对文件进行解压，解压完成后删除源文件 + * + * @param file 压缩文件 + * @throws IOException 文件读写异常 + */ + public static void uncompress(File file) throws IOException { + uncompress(file, true); + } + + /** + * 对指定路径的文件进行解压 + * + * @param path 压缩文件路径 + * @param delete 解压完成后删除源文件 + * @throws IOException 文件读写异常 + */ + public static void uncompress(String path, boolean delete) throws IOException { + File file = new File(path); + uncompress(file, delete); + } + + /** + * 对指定路径的文件进行解压，解压完成后删除源文件 + * + * @param path 压缩文件路径 + * @throws IOException 文件读写异常 + */ + public static void uncompress(String path) throws IOException { + uncompress(path, true); + } +} diff --git a/src/test/java/com/simaek/util/BZip2UtilsTest.java b/src/test/java/com/simaek/util/BZip2UtilsTest.java new file mode 100644 index 0000000..e6126af --- /dev/null +++ b/src/test/java/com/simaek/util/BZip2UtilsTest.java @@ -0,0 +1,26 @@ +package com.simaek.util; + +import org.junit.jupiter.api.Test; + +import java.io.File; +import java.io.IOException; + +/** + * 测试BZip2文件解压缩工具 + * + * @author Yaser Hsueh + */ +class BZip2UtilsTest { + + @Test + void compress() throws IOException { + String path = "/data/HS_H08_20210728_0010_B01_FLDK_R10_S0310.DAT"; + BZip2Utils.compress(new File(path)); + } + + @Test + void uncompress() throws IOException { + String path = "/data/HS_H08_20210728_0010_B01_FLDK_R10_S0310.DAT.bz2"; + BZip2Utils.uncompress(new File(path)); + } +} \ No newline at end of file