ggd543/IO.java

## IO.java
package com.travelsky.esb.emd.utils;

import org.mule.util.IOUtils;

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

/**
 * Created by IntelliJ IDEA.
 * User: Administrator
 * Date: 11-9-20
 * Time: 下午4:16
 * To change this template use File | Settings | File Templates.
 */
public class IO {
    private static String DEFAULT_CHARSET = "utf-8";

    public static byte[] gZipCompress(String source) throws IOException {
        return gZipCompress(source, DEFAULT_CHARSET);
    }

    public static byte[] gZipCompress(String source, String charset) throws IOException {
        return gZipCompress(source.getBytes(charset));
    }

    public static byte[] gZipCompress(byte[] bytes) throws IOException {
        return gZipCompress(new ByteArrayInputStream(bytes));
    }


    public static byte[] gZipCompress(InputStream is) throws IOException {
        ByteArrayOutputStream bos = new ByteArrayOutputStream();
        GZIPOutputStream gzip_os = new GZIPOutputStream(bos);
//        IOUtils.copy(is, gzip_os);
        copy(is, gzip_os);
        byte[] compressedBytes = bos.toByteArray();
        is.close();
        gzip_os.close();
        return compressedBytes;
    }


    public static byte[] gZipUncompress(String s) throws IOException {
        return gZipUncompress(s, DEFAULT_CHARSET);
    }

    public static byte[] gZipUncompress(String s, String charset) throws IOException {
        return gZipUncompress(s.getBytes(charset));
    }

    public static byte[] gZipUncompress(byte[] bytes) throws IOException {
        return gZipUncompress(new ByteArrayInputStream(bytes));
    }


    public static byte[] gZipUncompress(InputStream is) throws IOException {
        ByteArrayOutputStream bos = new ByteArrayOutputStream();
        InputStream gzip_is = new GZIPInputStream(is);
       // IOUtils.copy(gzip_is, bos);  // Refer to http://hi.baidu.com/bobylou/blog/item/1f8600e91de9ee3cb90e2de6.html
        copy(gzip_is,bos);
        byte[] bytes = bos.toByteArray();
        gzip_is.close();
        bos.close();
        return bytes;
    }

    private static final int BYTE_BLOCK_LENGTH = 1024;
    /**
     * The input and output stream won't be closed after the method invocation
     *
     * @param is
     * @param os
     */
    public static void copy(InputStream is, OutputStream os) throws IOException {
        byte[] buf = new byte[BYTE_BLOCK_LENGTH];
        int len = -1;
        while ((len = is.read(buf, 0, buf.length)) != -1) {
            os.write(buf, 0, len);
        }
    }

    public static String read(InputStream is, String encoding) throws IOException {
        ByteArrayOutputStream baos = new ByteArrayOutputStream(BYTE_BLOCK_LENGTH);
        copy(is, baos);
        String res = new String(baos.toByteArray(), encoding);
        is.close();;
        baos.close();
        return res;

    }


}

## IOTest.java
package com.travelsky.esb.emd.utils

import java.lang.String
import org.junit.{Ignore, Assert, Test}

/**
 * Created by IntelliJ IDEA.
 * User: ggd543
 * Date: 11-9-22
 * Time: 下午3:48
 * To change this template use File | Settings | File Templates.
 */

class IOTest {


  @Ignore
  @Test
  def testGZipCompressAndUncompress() {
    try {
      val str = "I want to go home";
      println("compress this string : " + str)
      val bytes = str.getBytes();
      val compressedBytes = IO.gZipCompress(bytes)
      val compressedStr = new String(compressedBytes)
      println("The length of original byte array : " + bytes.length)
      println("The length of compressed byte array : " + compressedBytes.length)
      println("The length of original string : " + str.length)
      println("The length of compressed string : " + compressedStr.length)
      Assert.assertTrue(bytes.length >= compressedBytes.length)

      val uncompressedBytes = IO.gZipUncompress(compressedBytes);
      val uncompressedStr = new String(uncompressedBytes);
      println("The length of uncompress byte array : " + uncompressedBytes.length)
      println("The uncompress string : " + uncompressedStr)
      Assert.assertTrue(compressedBytes.length <= uncompressedBytes.length)
      Assert.assertEquals(str, uncompressedStr)
    } catch {
      case e: Exception => e.printStackTrace(); Assert.fail();
    }
  }

}
	package com.travelsky.esb.emd.utils;

	import org.mule.util.IOUtils;

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

	/**
	* Created by IntelliJ IDEA.
	* User: Administrator
	* Date: 11-9-20
	* Time: 下午4:16
	* To change this template use File \| Settings \| File Templates.
	*/
	public class IO {
	private static String DEFAULT_CHARSET = "utf-8";

	public static byte[] gZipCompress(String source) throws IOException {
	return gZipCompress(source, DEFAULT_CHARSET);
	}

	public static byte[] gZipCompress(String source, String charset) throws IOException {
	return gZipCompress(source.getBytes(charset));
	}

	public static byte[] gZipCompress(byte[] bytes) throws IOException {
	return gZipCompress(new ByteArrayInputStream(bytes));
	}


	public static byte[] gZipCompress(InputStream is) throws IOException {
	ByteArrayOutputStream bos = new ByteArrayOutputStream();
	GZIPOutputStream gzip_os = new GZIPOutputStream(bos);
	// IOUtils.copy(is, gzip_os);
	copy(is, gzip_os);
	byte[] compressedBytes = bos.toByteArray();
	is.close();
	gzip_os.close();
	return compressedBytes;
	}


	public static byte[] gZipUncompress(String s) throws IOException {
	return gZipUncompress(s, DEFAULT_CHARSET);
	}

	public static byte[] gZipUncompress(String s, String charset) throws IOException {
	return gZipUncompress(s.getBytes(charset));
	}

	public static byte[] gZipUncompress(byte[] bytes) throws IOException {
	return gZipUncompress(new ByteArrayInputStream(bytes));
	}


	public static byte[] gZipUncompress(InputStream is) throws IOException {
	ByteArrayOutputStream bos = new ByteArrayOutputStream();
	InputStream gzip_is = new GZIPInputStream(is);
	// IOUtils.copy(gzip_is, bos); // Refer to http://hi.baidu.com/bobylou/blog/item/1f8600e91de9ee3cb90e2de6.html
	copy(gzip_is,bos);
	byte[] bytes = bos.toByteArray();
	gzip_is.close();
	bos.close();
	return bytes;
	}

	private static final int BYTE_BLOCK_LENGTH = 1024;
	/**
	* The input and output stream won't be closed after the method invocation
	*
	* @param is
	* @param os
	*/
	public static void copy(InputStream is, OutputStream os) throws IOException {
	byte[] buf = new byte[BYTE_BLOCK_LENGTH];
	int len = -1;
	while ((len = is.read(buf, 0, buf.length)) != -1) {
	os.write(buf, 0, len);
	}
	}

	public static String read(InputStream is, String encoding) throws IOException {
	ByteArrayOutputStream baos = new ByteArrayOutputStream(BYTE_BLOCK_LENGTH);
	copy(is, baos);
	String res = new String(baos.toByteArray(), encoding);
	is.close();;
	baos.close();
	return res;

	}



	}
	package com.travelsky.esb.emd.utils

	import java.lang.String
	import org.junit.{Ignore, Assert, Test}

	/**
	* Created by IntelliJ IDEA.
	* User: ggd543
	* Date: 11-9-22
	* Time: 下午3:48
	* To change this template use File \| Settings \| File Templates.
	*/

	class IOTest {


	@Ignore
	@Test
	def testGZipCompressAndUncompress() {
	try {
	val str = "I want to go home";
	println("compress this string : " + str)
	val bytes = str.getBytes();
	val compressedBytes = IO.gZipCompress(bytes)
	val compressedStr = new String(compressedBytes)
	println("The length of original byte array : " + bytes.length)
	println("The length of compressed byte array : " + compressedBytes.length)
	println("The length of original string : " + str.length)
	println("The length of compressed string : " + compressedStr.length)
	Assert.assertTrue(bytes.length >= compressedBytes.length)

	val uncompressedBytes = IO.gZipUncompress(compressedBytes);
	val uncompressedStr = new String(uncompressedBytes);
	println("The length of uncompress byte array : " + uncompressedBytes.length)
	println("The uncompress string : " + uncompressedStr)
	Assert.assertTrue(compressedBytes.length <= uncompressedBytes.length)
	Assert.assertEquals(str, uncompressedStr)
	} catch {
	case e: Exception => e.printStackTrace(); Assert.fail();
	}
	}

	}