文档章节

java与unity3d通信之数据压缩

kakai
 kakai
发布于 2017/07/04 09:36
字数 1334
阅读 131
收藏 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));
    }

}

 

© 著作权归作者所有

kakai

kakai

粉丝 97
博文 13
码字总数 12842
作品 1
长沙
后端工程师
私信 提问
加载中

评论(0)

Unity与Android的通信

Unity与Android的通信 Android 下载eclipse,连接https://pan.baidu.com/s/1Bc2xZGgXr8cC6NMN1QK0iQ 下载Java的JDK,从Java官网上下载或用我在压缩包中提供的jdk1.7也行 配置java JDK的运行环境...

GA博客
03/31
0
0
Unity加入Android广告小结

在Unity游戏加入广告大致有以下几种方式: 导入Android Jar包 导出游戏为Android项目(在Build时选中Google Android Project,这种方法可以参考将Unity3D游戏移植到Android平台上) 使用Uni...

andong777
2019/09/29
0
0
请教,想用C++写一个通信库,用在android的游戏上通过unity3d调用,该怎么做呢?

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

哦哈喇
2013/07/26
2.4K
1
让不懂编程的人爱上Unity3d AR/VR开发-Cha1初识神兵01 - 知乎

本系列内容选编自本人的《Unity AR/VR开发-从新手到专家》一书,即将再版,当前版本建议大家不要再购买。 这里放出来的内容是再版的修改内容,请大家多批评指正。 对AR/VR感兴趣的童鞋可以加...

笨猫快乐学编程
2019/10/21
0
0
.net可以开发Android和iOS了!已经成为事实!

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

八一戒
2013/06/10
4.2W
19

没有更多内容

加载失败,请刷新页面

加载更多

提起集体诉讼 瑞幸咖啡股东为何可能赢了官司却赔了钱?

4月对瑞幸咖啡来说是困难的一个月。由于内部调查发现2019年后三个季度营收存在很大水分,4月2日瑞幸咖啡股价遭遇暴跌。目前,瑞幸咖啡股价与4月1日相比跌幅超过80%。 丑闻曝光后,瑞幸 咖啡还...

osc_b67rw1ne
9分钟前
16
0
爱奇艺被美机构做空:“该报告远不如针对瑞幸的扎实”

十年来一直亏损的爱奇艺(Nasdaq: IQ)被美国做空机构Wolfpack Research盯上了。4月7日晚间,爱奇艺遭Wolfpack Research做空。Wolfpack Research在其网站发布的报告称,爱奇艺早在IPO之前便存...

osc_rt7omcc0
10分钟前
15
0
宝马:电动车“双肾”进气格栅不仅保留 还要更大更亮

当下车企在设计电动车外观时,都会刻意减小前进气格栅的尺寸,主要原因是电动机不需要进气和通过空气散热,一般小尺寸的进气格栅都能满足车辆使用。也有更激进的车企,直接采用了全封闭式进气...

osc_qroejco7
12分钟前
19
0
华为发布5G CPE Pro 2最快路由:支持WiFi 6+、下行3.6Gbps

4月8日晚,华为还发布了两款路由产品,其中AX3智能路由首发华为WiFi 6+技术,速率3000Mbps,而5G CPE Pro 2路由则是5G+WiFi 6+路由,下行速度可达3.6Gbps。华为5G CPE Pro 2路由搭载华为十大...

osc_veyfyz58
13分钟前
18
0
华为P40正式发布:业界最大底、无死角领先

4月8日晚间,华为举办春季新品发布会,正式面向国内市场发布新旗舰P40系列,首批上市的是P40、P40 Pro两款机型,最顶级的P40 Pro+稍后跟进。华为P40系列在外观设计方面采用了创新的四曲满溢屏...

osc_d8v3gwtb
14分钟前
15
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部