模拟客户端与服务端大数据二进制压缩传输

最近项目和其他项目信息交互，因数据量比较大造成效率比较低，我就研究了下数据压缩传输，以下为模拟代码，希望有用的人可以借鉴一下，我写的并非接口调用，为了节约代码，就把原理写了下来，希望你们可以看的明白，如果不明白，可以留言，代码如下：

package com.test.compress;

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.junit.Assert;

public final class CompressionUtil {  
  
    private static final int BUFFER_SIZE = 4 * 1024;  
  
    public static byte[] compress(byte[] data,Level level) throws IOException {  
  
        Assert.assertNotNull(data);  
        Assert.assertNotNull(level);  
  
        Deflater deflater = new Deflater();  
        // set compression level  
        deflater.setLevel(level.getLevel());  
        deflater.setInput(data);  
  
        ByteArrayOutputStream outputStream = new ByteArrayOutputStream(data.length);  
  
        deflater.finish();  
        byte[] buffer = new byte[BUFFER_SIZE];  
        while (!deflater.finished()) {  
            int count = deflater.deflate(buffer); // returns the generated  
                                                  // code... index  
            outputStream.write(buffer,count);  
        }  
        byte[] output = outputStream.toByteArray();  
        outputStream.close();  
        return output;  
    }  
  
    public static byte[] decompress(byte[] data) throws IOException,DataFormatException {  
  
        Assert.assertNotNull(data);  
  
        Inflater inflater = new Inflater();  
        inflater.setInput(data);  
  
        ByteArrayOutputStream outputStream = new ByteArrayOutputStream(data.length);  
        byte[] buffer = new byte[BUFFER_SIZE];  
        while (!inflater.finished()) {  
            int count = inflater.inflate(buffer);  
            outputStream.write(buffer,count);  
        }  
        byte[] output = outputStream.toByteArray();  
        outputStream.close();  
        return output;  
    }  
  
    /** 
     * Compression level 
     */  
    public static enum Level {  
  
        /** 
         * Compression level for no compression. 
         */  
        NO_COMPRESSION(0), 
  
        /** 
         * Compression level for fastest compression. 
         */  
        BEST_SPEED(1), 
  
        /** 
         * Compression level for best compression. 
         */  
        BEST_COMPRESSION(9), 
  
        /** 
         * Default compression level. 
         */  
        DEFAULT_COMPRESSION(-1);  
  
        private int level;  
  
        Level(int level) {  
            this.level = level;  
        }  
        public int getLevel() {  
            return level;  
        }  
    } 
}

package com.test.json;

import java.util.ArrayList; import java.util.List; import com.test.compress.CompressionUtil; import net.sf.json.JSONArray; import net.sf.json.JsonConfig; public class TestCompress { public static JSONArray ListToJSONArray(List<Student> list) {     return JSONArray.fromObject(list);     } @SuppressWarnings("unchecked") public static List<Student> JSONArrayToList(JSONArray jsonArray) {     //参数1为要转换的JSONArray数据，参数2为要转换的目标数据，即List盛装的数据     return JSONArray.toList(jsonArray,new Student(),new JsonConfig());     } public static String toString(String[] strs) {     String str = "[";     for(String s : strs) {     str += '"' + s + '"' + ',';     }     return str.substring(0,str.length()-1) + "]";    } public static void main(String[] args) throws Exception { /*---------------------------- 客户端代码 -----------------------------------*/ //创建JavaBean Student student = null; //创建测试用的List List<Student> list = new ArrayList<Student>(); for(int i = 0; i < 10000; i++) { student = new Student(); student.setId(i); student.setName("张" + i); student.setAge(i); student.setSex("男"); student.setHobby(new String[]{"篮球","上网","跑步","游戏"}); list.add(student); } //List 转 JSONArray JSONArray jsonArray = ListToJSONArray(list); //二进制压缩 byte[] output = CompressionUtil.compress(jsonArray.toString().getBytes(),CompressionUtil.Level.BEST_COMPRESSION); // 接口调用传输数据 参数为 output /*---------------------------- 服务端代码 -----------------------------------*/ // 接收output参数 为客户端传入数据 //二进制解压 byte[] jsonMessage = CompressionUtil.decompress(output); //String 转 JSONArray JSONArray jsonArray2 = JSONArray.fromObject(new String(jsonMessage)); //JSONArray 转 List List<Student> studentList = JSONArrayToList(jsonArray2);  //遍历信息 for(Student stu : studentList) { System.out.println("-----------------------------"); System.out.println("ID:" + stu.getId()); System.out.println("NAME:" + stu.getName()); System.out.println("SEX:" + stu.getSex()); System.out.println("AGE:" + stu.getAge()); System.out.println("HOBBY:" + toString(stu.getHobby())); } } }