文档章节

java与unity3d通信之数据压缩

银杏果果
 银杏果果
发布于 2017/07/04 09:36
字数 1334
阅读 38
收藏 0

最近项目中java、Untiy两端通信用的json,json相对纯字节通信,数据包要大很多,这就涉及到数据压缩了。untiy客户端最早用的C#自带的压缩算法,但在untiy上用就抛出异常。而后我建议他们使用lzma开源压缩算法,原来用过,在此贴出来,记录一下。

package com.kaka.util;

import SevenZip.Compression.LZMA.Decoder;
import SevenZip.Compression.LZMA.Encoder;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 * 7zip的lzma压缩,压缩比高,效率低
 *
 * @author zhoukai
 */
public final class Lzma {

    /**
     * lzma压缩
     *
     * @param is 压缩输入流
     * @param os 压缩后的输出流
     */
    public final static void compress(InputStream is, OutputStream os) {
        Encoder ec = new Encoder();
        try {
            ec.WriteCoderProperties(os);
            os.write(BitConverter.getBytes((long) is.available()));
            ec.Code(is, os, -1, -1, null);
        } catch (IOException ex) {
            Logger.getLogger(Lzma.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    /**
     * lzma压缩
     *
     * @param is 压缩输入流
     * @return 压缩后的输出流
     */
    public final static byte[] compress(InputStream is) {
        ByteArrayOutputStream os = new ByteArrayOutputStream();
        compress(is, os);
        return os.toByteArray();
    }

    /**
     * lzma压缩
     *
     * @param src 压缩输入字节数组
     * @return 压缩后的输出的字节数组
     */
    public final static byte[] compress(byte[] src) {
        return Lzma.compress(new ByteArrayInputStream(src));
    }

    /**
     * lzma压缩
     *
     * @param src 压缩输入字符串
     * @return 压缩后的输出的字节数组
     */
    public final static byte[] compress(String src) {
        return Lzma.compress(src.getBytes(Charset.utf8));
    }

    /**
     * lzma压缩
     *
     * @param src 压缩输入字符串
     * @param charset 字符串转字节的编码
     * @return 压缩后的输出的字节数组
     */
    public final static byte[] compress(String src, String charset) {
        byte[] bytes = null;
        try {
            bytes = src.getBytes(charset);
        } catch (UnsupportedEncodingException ex) {
            Logger.getLogger(Lzma.class.getName()).log(Level.SEVERE, null, ex);
        }
        return Lzma.compress(bytes);
    }

    /**
     * lzma压缩
     *
     * @param src 压缩输入字符串
     * @param charset 字符串转字节的编码
     * @return 压缩后的输出的字节数组
     */
    public final static byte[] compress(String src, java.nio.charset.Charset charset) {
        byte[] bytes = src.getBytes(charset);
        return Lzma.compress(bytes);
    }

    /**
     * lzma解压缩
     *
     * @param is 解压缩输入流
     * @param os 解压缩后的输出流
     */
    public final static void uncompress(InputStream is, OutputStream os) {
        Decoder dc = new Decoder();
        int propertiesSize = 5;
        byte[] properties = new byte[propertiesSize];
        try {
            if (is.read(properties, 0, propertiesSize) != propertiesSize) {
                throw new Exception("input .lzma file is too short");
            }
            if (!dc.SetDecoderProperties(properties)) {
                throw new Exception("Incorrect stream properties");
            }
            byte[] outSizeBytes = new byte[8];
            is.read(outSizeBytes, 0, outSizeBytes.length);
            long outSize = BitConverter.toLong(outSizeBytes, 0);
            dc.Code(is, os, outSize);
        } catch (Exception ex) {
            Logger.getLogger(Lzma.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    /**
     * lzma解压缩
     *
     * @param is 解压缩输入流
     * @return 解压缩后的输出字节数组
     */
    public final static byte[] uncompress(InputStream is) {
        ByteArrayOutputStream os = new ByteArrayOutputStream();
        try {
            uncompress(is, os);
        } catch (Exception ex) {
            Logger.getLogger(Lzma.class.getName()).log(Level.SEVERE, null, ex);
        }
        return os.toByteArray();
    }

    /**
     * lzma解压缩
     *
     * @param src 解压缩输入字节数组
     * @return 解压缩后的输出字节数组
     */
    public final static byte[] uncompress(byte[] src) {
        return Lzma.uncompress(new ByteArrayInputStream(src));
    }
}

C#客户端代码

using System;
using System.IO;
using SevenZip.Compression.LZMA;

public class Lzma {

    private static void Compress(Stream input, Stream output)
    {
        input.Position = 0;
        Encoder ec = new Encoder();
        ec.WriteCoderProperties(output);
        byte[] lenBytes = BitConverter.GetBytes((long)input.Length);
        if(BitConverter.IsLittleEndian)
        {
            Array.Reverse(lenBytes);
        }
        output.Write(lenBytes, 0, lenBytes.Length);
        ec.Code(input, output, -1, -1, null);
    }

    public static byte[] Compress(byte[] src)
    {
        Stream input = new MemoryStream(src);
        Stream output = new MemoryStream();
        Compress(input, output);
        output.Position = 0;
        byte[] bytes = new byte[output.Length];
        output.Read(bytes, 0, bytes.Length);
        input.Close();
        output.Flush();
        output.Close();
        return bytes;
    }

    public static byte[] CompressToUTF8Bytes(string src)
    {
        return Compress(System.Text.Encoding.UTF8.GetBytes(src));
    }

    private static void Uncompress(Stream input, Stream output)
    {
        input.Position = 0;
        Decoder dc = new Decoder();
        int propertiesSize = 5;
        byte[] properties = new byte[propertiesSize];
        if (input.Read(properties, 0, propertiesSize) != propertiesSize)
        {
            throw new Exception("input .lzma file is too short");
        }
        dc.SetDecoderProperties(properties);
        byte[] outSizeBytes = new byte[8];
        input.Read(outSizeBytes, 0, outSizeBytes.Length);
        if (BitConverter.IsLittleEndian)
        {
            Array.Reverse(outSizeBytes);
        }
        long outSize = BitConverter.ToInt64(outSizeBytes, 0);
        dc.Code(input, output, -1, outSize, null);
    }

    public static byte[] Uncompress(byte[] src)
    {
        Stream input = new MemoryStream(src);
        Stream output = new MemoryStream();
        Uncompress(input, output);
        output.Position = 0;
        byte[] bytes = new byte[output.Length];
        output.Read(bytes, 0, bytes.Length);
        input.Close();
        output.Flush();
        output.Close();
        return bytes;
    }

    public static string UncompressToUTF8String(byte[] src)
    {
        return System.Text.Encoding.UTF8.GetString(Uncompress(src));
    }

}

测试的时候,使用Lzma进行数据压缩压测效率不是很好,后面客户端人员发现了ICSharpCode.SharpZipLib这个库,于是又测试了一下gzip算法,还好java有点积累,工具类有现成的

package com.kaka.util;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.util.logging.Level;
import java.util.logging.Logger;
import java.util.zip.GZIPInputStream;
import java.util.zip.GZIPOutputStream;

/**
 * GZIP压缩,压缩比相对lzma较低,但压缩效率高
 *
 * @author zhoukai
 */
public final class GZip {

    /**
     * 压缩数据
     *
     * @param is 数据源
     * @param os 压缩后的数据
     */
    public final static void compress(InputStream is, OutputStream os) {
        try (GZIPOutputStream gos = new GZIPOutputStream(os)) {
            int count;
            byte data[] = new byte[256];
            while ((count = is.read(data, 0, 256)) != -1) {
                gos.write(data, 0, count);
            }
            gos.finish();
            gos.flush();
        } catch (Exception ex) {
            Logger.getLogger(GZip.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    /**
     * 压缩
     *
     * @param src 压缩源
     * @return 压缩后的输出的字节数组
     */
    public final static byte[] compress(byte[] src) {
        if (src == null) {
            return null;
        }
        if (src.length == 0) {
            return src;
        }
        byte[] bytes = null;
        try (ByteArrayOutputStream out = new ByteArrayOutputStream()) {
            try (GZIPOutputStream zip = new GZIPOutputStream(out)) {
                zip.write(src);
                zip.finish();
                zip.flush();
            }
            bytes = out.toByteArray();
        } catch (IOException ex) {
            Logger.getLogger(GZip.class.getName()).log(Level.SEVERE, null, ex);
        }
        return bytes;
    }

    /**
     * gzip压缩
     *
     * @param src 压缩输入字符串
     * @param charset 字符串转字节的编码
     * @return 压缩后的输出的字节数组
     */
    public final static byte[] compress(String src, String charset) {
        byte[] bytes = null;
        try {
            bytes = src.getBytes(charset);
        } catch (UnsupportedEncodingException ex) {
            Logger.getLogger(Lzma.class.getName()).log(Level.SEVERE, null, ex);
        }
        return compress(bytes);
    }

    /**
     * gzip压缩
     *
     * @param src 压缩输入字符串
     * @param charset 字符串转字节的编码
     * @return 压缩后的输出的字节数组
     */
    public final static byte[] compress(String src, java.nio.charset.Charset charset) {
        byte[] bytes = src.getBytes(charset);
        return compress(bytes);
    }

    /**
     * 解压缩
     *
     * @param src
     * @return
     */
    public final static byte[] uncompress(byte[] src) {
        if (src == null) {
            return null;
        }
        if (src.length == 0) {
            return src;
        }
        try (ByteArrayInputStream in = new ByteArrayInputStream(src)) {
            try (GZIPInputStream zip = new GZIPInputStream(in)) {
                byte[] bytes;
                try (ByteArrayOutputStream os = new ByteArrayOutputStream()) {
                    int count;
                    bytes = new byte[256];
                    while ((count = zip.read(bytes, 0, bytes.length)) != -1) {
                        os.write(bytes, 0, count);
                    }
                    bytes = os.toByteArray();
                }
                return bytes;
            }
        } catch (IOException ex) {
            Logger.getLogger(GZip.class.getName()).log(Level.SEVERE, null, ex);
        }
        return null;
    }
}

C# gzip工具类

using System.IO;
using ICSharpCode.SharpZipLib.GZip;


public class GZip {

    public static byte[] Compress(byte[] src)
    {
        MemoryStream ms = new MemoryStream();
        GZipOutputStream gzip = new GZipOutputStream(ms);
        gzip.Write(src, 0, src.Length);
        gzip.Close();
        byte[] bytes =  ms.ToArray();
        ms.Close();
        return bytes;
    }

    public static byte[] Uncompress(byte[] src)
    {
        MemoryStream ms = new MemoryStream(src);
        GZipInputStream gzip = new GZipInputStream(ms);
        MemoryStream re = new MemoryStream();
        int count = 0;
        byte[] data = new byte[2048];
        while ((count = gzip.Read(data, 0, data.Length)) != 0)
        {
            re.Write(data, 0, count);
        }
        byte[] depress = re.ToArray();
        ms.Close();
        re.Close();
        gzip.Close();
        return depress;
    }

    public static byte[] CompressToUTF8Bytes(string src)
    {
        return Compress(System.Text.Encoding.UTF8.GetBytes(src));
    }

    public static string UncompressToUTF8String(byte[] src)
    {
        return System.Text.Encoding.UTF8.GetString(Uncompress(src));
    }

}

 

© 著作权归作者所有

共有 人打赏支持
银杏果果
粉丝 61
博文 8
码字总数 4234
作品 0
长沙
后端工程师
私信 提问
请教,想用C++写一个通信库,用在android的游戏上通过unity3d调用,该怎么做呢?

我还是新手,JAVA、android、网路编程都没接触过。。。 老大给我个任务,让我把现有的jar的通讯库改成用C++写的,提供API给现在的unity3d游戏通信用。 我先大概了解了一些基础知识。现在好像...

哦哈喇
2013/07/26
2.3K
1
.net可以开发Android和iOS了!已经成为事实!

很多初学者误以为Android、IOS开发只能使用Java、ObjectC等语言进行开发,其实借助于Mono技术我们可以使用C#/.Net编写Android、IOS程序。由于C#的高效开发和Mono的完美跨平台,这项技术目前已...

八一戒
2013/06/10
41.3K
19
JavaWeb与VR哪条路更值得走下去?

本人大二学生,从大一学习Java开始,已经学习了1年多Java相关知识了,课余时间自学了一些JavaWeb的基础知识(j2EE,js,mysql,ajax,ssh,springMVC,Mybatis..等),没有很精通,但也算有了初步了...

cchoop
2017/04/15
956
8
unity3d生成安卓apk出错,这个问题已经困扰我2个星期了

本来mac下面也是有同样的问题,后面我在网上找到了解决方法。 现在用同样方法在window不起效果,我的方法是: C:\Users\用户名\.gradle\gradle.properties里添加org.gradle.jvmargs=-Xmx3000...

Richard_x
11/21
28
1
在it行业里,程序员做哪方面开发收入最高?

是用unity3d,还是erlang呢?小弟目前是java程序员,但感觉会java的人太多了,导至php都比java待遇高,哎,很想转行做些其他的开发。

qq734331879
2015/01/27
18.9K
47

没有更多内容

加载失败,请刷新页面

加载更多

一条SQL查询语句是如何执行的

123

writeademo
3分钟前
0
0
hive 集成sentry

环境 apache-hive-2.3.3-bin apache-sentry-2.1.0-bin 1 2 sentry是目前最新的版本,支持hive的最高版本为2.3.3,hive版本如果高于2.3.3,会出一些版本兼容问题[亲测] hive快速安装 wget htt...

hblt-j
3分钟前
0
0
CSS中position属性( absolute | relative | static | fixed )详解

四个属性的特点 static:无特殊定位,对象遵循正常文档流。top,right,bottom,left等属性不会被应用。 relative:对象遵循正常文档流,但将依据top,right,bottom,left等属性在正常文档流...

简心
8分钟前
0
0
个推前端微服务化:突破传统SPA瓶颈

本文作者:个推高级前端开发工程师 沈创 目前的前端领域,单页面应用(SPA)大行其道。而随着时间的推移以及应用功能的丰富,这些应用变得越来越庞大也越来越难以维护。于是“微前端”这一概...

个推
9分钟前
0
0
zero copy零拷贝原理

grace_233
13分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部