GzipCompression

GzipCompression.java

package pw.navo.compression;

import java.io.*;
import java.util.zip.GZIPInputStream;
import java.util.zip.GZIPOutputStream;

public class GzipCompression {

	public static byte[] compress(byte[] bytes) throws IOException {
		ByteArrayOutputStream byteStream = new ByteArrayOutputStream(bytes.length);
		try {
			GZIPOutputStream gzipInputStream = new GZIPOutputStream(byteStream);
			try {
				gzipInputStream.write(bytes);
			} finally {
				gzipInputStream.close();
			}
		} finally {
			byteStream.close();
		}

		return byteStream.toByteArray();
	}

	public static byte[] deflate(byte[] bytes) throws IOException {
		GZIPInputStream gzipInputStream = new GZIPInputStream(new ByteArrayInputStream(bytes));

		ByteArrayOutputStream byteBuffer = new ByteArrayOutputStream();

		int bufferSize = 1024;
		byte[] buffer = new byte[bufferSize];

		int length = 0;
		while ((length = gzipInputStream.read(buffer)) != -1) {
			byteBuffer.write(buffer, 0, length);
		}

		return byteBuffer.toByteArray();
	}

}