Java学习者论坛

 找回密码
 立即注册

QQ登录

只需一步,快速开始

手机号码,快捷登录

恭喜Java学习者论坛(https://www.javaxxz.com)已经为数万Java学习者服务超过8年了!积累会员资料超过10000G+
成为本站VIP会员,下载本站10000G+会员资源,购买链接:点击进入购买VIP会员
JAVA高级面试进阶视频教程Java架构师系统进阶VIP课程

分布式高可用全栈开发微服务教程

Go语言视频零基础入门到精通

Java架构师3期(课件+源码)

Java开发全终端实战租房项目视频教程

SpringBoot2.X入门到高级使用教程

大数据培训第六期全套视频教程

深度学习(CNN RNN GAN)算法原理

Java亿级流量电商系统视频教程

互联网架构师视频教程

年薪50万Spark2.0从入门到精通

年薪50万!人工智能学习路线教程

年薪50万!大数据从入门到精通学习路线年薪50万!机器学习入门到精通视频教程
仿小米商城类app和小程序视频教程深度学习数据分析基础到实战最新黑马javaEE2.1就业课程从 0到JVM实战高手教程 MySQL入门到精通教程
查看: 665|回复: 0

Java压缩技术-GZIP

[复制链接]

该用户从未签到

发表于 2011-9-12 23:06:05 | 显示全部楼层 |阅读模式
GZIP常常用在linxu环境下,是一种非常简单的压缩算法。在java实现API中,它仅仅包含两个实现类:GZIPInputStream和GZIPOutputStream。
GZIPOutputStream类用于压缩
GZIPInputStream类用于解压缩

先说压缩实现,GZIPOutputStream只有一个方法用于压缩,就是带定长的write方法。简单调用如下文所示:

[pre]    /**     * 数据压缩     *      * @param is     * @param os     * @throws Exception     */    public static void compress(InputStream is, OutputStream os)            throws Exception {        GZIPOutputStream gos = new GZIPOutputStream(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();    }                        [/pre]记得完成操作后,调用finish方法和flush方法!

核心的压缩实现就这么多!

对于解压缩,GZIPInputStream也对应GZIPOutputStream提供了一个带定长的read方法。简单调用如下文所示:

[pre]    /**     * 数据解压缩     *      * @param is     * @param os     * @throws Exception     */    public static void decompress(InputStream is, OutputStream os)            throws Exception {        GZIPInputStream gis = new GZIPInputStream(is);        int count;        byte data[] = new byte[BUFFER];        while ((count = gis.read(data, 0, BUFFER)) != -1) {            os.write(data, 0, count);        }        gis.close();    }                        [/pre]

就这么简单! 核心内容完毕!

顺便补充一下,在liunx下操作gzip命令

gzip file用于压缩,如gzip a.txt将得到文件a.txt.gz,同时删除文件a.txt!
gzip -d file.gz用于解压缩,如gzip -d a.txt.gz将得到文件a.txt,同时删除文件a.txt.gz!

根据这些特性,我补充了相应的文件操作实现,详见下文!

完整实现:

[pre]/** * 2010-4-13 */package org.zlex.commons.io;import java.io.ByteArrayInputStream;import java.io.ByteArrayOutputStream;import java.io.File;import java.io.FileInputStream;import java.io.FileOutputStream;import java.io.InputStream;import java.io.OutputStream;import java.util.zip.GZIPInputStream;import java.util.zip.GZIPOutputStream;/** * GZIP工具 *  * @author <a href="mailto:zlex.dongliang@gmail.com">梁栋</a> * @since 1.0 */public abstract class GZipUtils {    public static final int BUFFER = 1024;    public static final String EXT = ".gz";    /**     * 数据压缩     *      * @param data     * @return     * @throws Exception     */    public static byte[] compress(byte[] data) throws Exception {        ByteArrayInputStream bais = new ByteArrayInputStream(data);        ByteArrayOutputStream baos = new ByteArrayOutputStream();        // 压缩        compress(bais, baos);        byte[] output = baos.toByteArray();        baos.flush();        baos.close();        bais.close();        return output;    }    /**     * 文件压缩     *      * @param file     * @throws Exception     */    public static void compress(File file) throws Exception {        compress(file, true);    }    /**     * 文件压缩     *      * @param file     * @param delete     *            是否删除原始文件     * @throws Exception     */    public static void compress(File file, boolean delete) throws Exception {        FileInputStream fis = new FileInputStream(file);        FileOutputStream fos = new FileOutputStream(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 {        GZIPOutputStream gos = new GZIPOutputStream(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     * @throws Exception     */    public static void compress(String path) throws Exception {        compress(path, true);    }    /**     * 文件压缩     *      * @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 = new ByteArrayInputStream(data);        ByteArrayOutputStream baos = new ByteArrayOutputStream();        // 解压缩        decompress(bais, baos);        data = baos.toByteArray();        baos.flush();        baos.close();        bais.close();        return data;    }    /**     * 文件解压缩     *      * @param file     * @throws Exception     */    public static void decompress(File file) throws Exception {        decompress(file, true);    }    /**     * 文件解压缩     *      * @param file     * @param delete     *            是否删除原始文件     * @throws Exception     */    public static void decompress(File file, boolean delete) throws Exception {        FileInputStream fis = new FileInputStream(file);        FileOutputStream fos = new FileOutputStream(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(InputStream is, OutputStream os)            throws Exception {        GZIPInputStream gis = new GZIPInputStream(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     * @throws Exception     */    public static void decompress(String path) throws Exception {        decompress(path, true);    }    /**     * 文件解压缩     *      * @param path     * @param delete     *            是否删除原始文件     * @throws Exception     */    public static void decompress(String path, boolean delete) throws Exception {        File file = new File(path);        decompress(file, delete);    }}[/pre]

罗嗦了半天,到底行不行?
来个测试用例,测试用例如下所示:

[pre]/** * 2010-4-13 */package org.zlex.commons.compress.compress;import static org.junit.Assert.assertEquals;import java.io.DataInputStream;import java.io.File;import java.io.FileInputStream;import java.io.FileOutputStream;import org.junit.Test;/** * @author <a href="mailto:zlex.dongliang@gmail.com">梁栋</a> * @since 1.0 */public class GZipUtilsTest {    private String inputStr = "zlex@zlex.org,snowolf@zlex.org,zlex.snowolf@zlex.org";    @Test    public final void testDataCompress() throws Exception {        System.err.println("原文:\t" + inputStr);        byte[] input = inputStr.getBytes();        System.err.println("长度:\t" + input.length);        byte[] data = GZipUtils.compress(input);        System.err.println("压缩后:\t");        System.err.println("长度:\t" + data.length);        byte[] output = GZipUtils.decompress(data);        String outputStr = new String(output);        System.err.println("解压缩后:\t" + outputStr);        System.err.println("长度:\t" + output.length);        assertEquals(inputStr, outputStr);    }    @Test    public final void testFileCompress() throws Exception {        FileOutputStream fos = new FileOutputStream("d:/f.txt");        fos.write(inputStr.getBytes());        fos.flush();        fos.close();        GZipUtils.compress("d:/f.txt", false);        GZipUtils.decompress("d:/f.txt.gz", false);        File file = new File("d:/f.txt");        FileInputStream fis = new FileInputStream(file);        DataInputStream dis = new DataInputStream(fis);        byte[] data = new byte[(int) file.length()];        dis.readFully(data);        fis.close();        String outputStr = new String(data);        assertEquals(inputStr, outputStr);    }}[/pre]
结果如何?
先看testDataCompress()方法控制台输出结果。
控制台输出如下:

引用

原文: zlex@zlex.org,snowolf@zlex.org,zlex.snowolf@zlex.org
长度: 52
压缩后:
长度: 45
解压缩后: zlex@zlex.org,snowolf@zlex.org,zlex.snowolf@zlex.org
长度: 52


这里使用英文字符做测试,当输入字符串的字节数大于50左右时,压缩效果明显;如果这里使用中文压缩,可能当压缩上千字节时方能体现出压缩效果!
对于文件操作,朋友们可以自行实验,我代码里的实现是按照gzip命令来的!
举例来说:
压缩时,将文件a.txt压缩为a.txt.gz,同时删除文件a.txt。
解压缩时,将文件a.txt.gz解压缩为a.txt,同时删除文件a.txt.gz。

注意执行testFileCompress方法,查看产生的文件! 你大可以放到linux上去做验证!

commons也提供了GZIP算法的实现,甚至更多种压缩算法(tar、bzip2等)的实现。
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

QQ|手机版|Java学习者论坛 ( 声明:本站资料整理自互联网,用于Java学习者交流学习使用,对资料版权不负任何法律责任,若有侵权请及时联系客服屏蔽删除 )

GMT+8, 2024-5-2 10:11 , Processed in 0.399871 second(s), 46 queries .

Powered by Discuz! X3.4

© 2001-2017 Comsenz Inc.

快速回复 返回顶部 返回列表