SimpleCompressor

SimpleCompressor.java

package sandbox;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.util.zip.DataFormatException;
import java.util.zip.Deflater;
import java.util.zip.Inflater;

import org.apache.commons.io.IOUtils;

/**
 * SimpleCompressor
 * 
 * @author monzou
 */
final class SimpleCompressor {

    private SimpleCompressor() {
    }

    /**
     * 圧縮
     * 
     * @param bytes バイナリ
     * @return 圧縮されたバイナリ
     */
    static byte[] compress(byte[] bytes) {

        Deflater deflater = new Deflater();
        deflater.setInput(bytes);
        deflater.finish();

        byte[] buf = new byte[1024];
        ByteArrayOutputStream out = new ByteArrayOutputStream();
        do {
            int size = deflater.deflate(buf);
            out.write(buf, 0, size);
        } while (!deflater.finished());

        deflater.end();
        try {
            return out.toByteArray();
        } finally {
            IOUtils.closeQuietly(out);
        }

    }

    /**
     * 解凍
     * 
     * @param bytes バイナリ
     * @return 解凍されたバイナリ
     * @throws IOException I/O 例外
     */
    static byte[] decompress(byte[] bytes) throws IOException {

        byte[] buf = new byte[1024];
        Inflater inflater = new Inflater();
        inflater.setInput(bytes);

        ByteArrayOutputStream out = new ByteArrayOutputStream();
        try {
            do {
                int size;
                size = inflater.inflate(buf);
                out.write(buf, 0, size);
            } while (!inflater.finished());
        } catch (DataFormatException e) {
            throw new IOException(e);
        }

        inflater.end();
        try {
            return out.toByteArray();
        } finally {
            IOUtils.closeQuietly(out);
        }

    }

}