Apache在Commons Compress簡介和簡單應用
Apache在CommonsCompress中提供了眾所周知的tar、cpio、zip等壓縮算法實現,其中最為豐富的當屬zip實現了!
Commons Compress為壓縮(GZip和BZip2)構建了壓縮算法工廠類CompressorStreamFactory。通過這個類可以方便的構建GZip和BZip2的輸入輸出流,關鍵字分別為“gz”和“bzip2”。
GZip
Java代碼 //GzipCompressorInputStream CompressorInputStream gzipIn = newCompressorStreamFactory() .createCompressorInputStream("gz",is); // GzipCompressorOutputStream CompressorOutputStream gzipOut = newCompressorStreamFactory() .createCompressorOutputStream("gz", os); BZip2 Java代碼 // BZip2CompressorInputStream CompressorInputStream bzip2In =new CompressorStreamFactory() .createCompressorInputStream("bzip2", is); //BZip2CompressorOutputStream CompressorOutputStream bzip2Out= new CompressorStreamFactory() .createCompressorOutputStream("bzip2", os); 下面是一個完整的通過apachecommons compress簡單實現bzip2壓縮的樣例。 需要導入的包為:commons-compress-1.9.jar packagetest.ffm83.commons.compress; importjava.io.ByteArrayInputStream; importjava.io.ByteArrayOutputStream; importjava.io.File; importjava.io.FileInputStream; importjava.io.FileOutputStream; importjava.io.InputStream; importjava.io.OutputStream; importorg.apache.commons.compress.compressors.bzip2.BZip2CompressorInputStream; importorg.apache.commons.compress.compressors.bzip2.BZip2CompressorOutputStream; /* 通過apache commons compress簡單實現bzip2壓縮 * 部分代碼來自互聯網 * @author 范芳銘 * */ publicclass BZip2Utils { public static final int BUFFER = 1024; public static final CharSequence EXT =".bz2"; /** * 數據壓縮 * * @param data * @return * @throws Exception */ public static byte[] compress(byte[] data)throws Exception { ByteArrayInputStream bais = newByteArrayInputStream(data); ByteArrayOutputStream baos = newByteArrayOutputStream(); // 壓縮 compress(bais, baos); byte[] output =baos.toByteArray(); baos.flush(); baos.close(); bais.close(); return output; } /** * 文件壓縮 * * @param file * @param delete * 是否刪除原始文件 * @throws Exception */ public static void compress(File file,boolean delete) throws Exception { FileInputStream fis = newFileInputStream(file); FileOutputStream fos = newFileOutputStream(file.getPath() + EXT); compress(fis, fos); fis.close(); fos.flush(); fos.close(); if (delete) { file.delete(); } } /** * 數據壓縮 * * @param is * @param os * @throws Exception */ public static void compress(InputStream is,OutputStream os) throws Exception { BZip2CompressorOutputStream gos = newBZip2CompressorOutputStream(os); int count; byte data[] = new byte[BUFFER]; while ((count = is.read(data, 0, BUFFER)) !=-1) { gos.write(data, 0, count); } gos.finish(); gos.flush(); gos.close(); } /** * 文件壓縮 * * @param path * @param delete * 是否刪除原始文件 * @throws Exception */ public static void compress(String path,boolean delete) throws Exception { File file = new File(path); compress(file, delete); } /** * 數據解壓縮 * * @param data * @return * @throws Exception */ public static byte[] decompress(byte[]data) throws Exception { ByteArrayInputStream bais = newByteArrayInputStream(data); ByteArrayOutputStream baos = newByteArrayOutputStream(); // 解壓縮 decompress(bais, baos); data = baos.toByteArray(); baos.flush(); baos.close(); bais.close(); return data; } /** * 文件解壓縮 * * @param file * @param delete * 是否刪除原始文件 * @throws Exception */ public static void decompress(File file,boolean delete) throws Exception { FileInputStream fis = newFileInputStream(file); FileOutputStream fos = newFileOutputStream(file.getPath().replace(EXT, "")); decompress(fis, fos); fis.close(); fos.flush(); fos.close(); if (delete) { file.delete(); } } /** * 數據解壓縮 * * @param is * @param os * @throws Exception */ public static void decompress(InputStreamis, OutputStream os) throws Exception { BZip2CompressorInputStream gis = newBZip2CompressorInputStream(is); int count; byte data[] = new byte[BUFFER]; while ((count = gis.read(data, 0,BUFFER)) != -1) { os.write(data, 0, count); } gis.close(); } /** * 文件解壓縮 * * @param path * @param delete * 是否刪除原始文件 * @throws Exception */ public static void decompress(String path,boolean delete) throws Exception { File file = new File(path); decompress(file, delete); } public static void main(String[] args)throws Exception{ StringinputStr = "http://blog.csdn.net/ffm83/article/details/42240513"; byte[]input = inputStr.getBytes(); System.out.println("原文:\t" + inputStr); System.out.println("長度:\t" + input.length); byte[] data = compress(input); System.err.println("壓縮后:\t"); System.err.println("長度:\t" + data.length); byte[] output = decompress(data); String outputStr = newString(output); System.err.println("解壓縮后:\t" + outputStr); System.err.println("長度:\t" + output.length); } }
運行結果如下:
原文: http://blog.csdn.net/ffm83/article/details/42240513
長度: 51
壓縮后:
長度: 86
解壓縮后: http://blog.csdn.net/ffm83/article/details/42240513
長度: 51
本文由用戶 pooi 自行上傳分享,僅供網友學習交流。所有權歸原作者,若您的權利被侵害,請聯系管理員。
轉載本站原創文章,請注明出處,并保留原始鏈接、圖片水印。
本站是一個以用戶分享為主的開源技術平臺,歡迎各類分享!