文档章节

java与unity3d通信之数据压缩

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

}

 

© 著作权归作者所有

共有 人打赏支持
节节草
粉丝 48
博文 8
码字总数 4234
作品 0
长沙
后端工程师
Ubuntu 11.10 系统基本设置入门

一般设置(GNOME Shell & Unity) #1,使用GNOME tweak tool 修改系统主题、字体…… Ubuntu 11.10的“系统设置–外观”,只能对系统主题、桌面背景进行调整。我们可以借助Gnome tweak too...

mj4738
2012/01/03
0
2
[Unity3D]Unity+Android交互教程——让手机"动"起来

想要用Unity实现一个二维码扫描的功能,然后网上找插件,找到一个貌似叫EasyCodeScanner,但下载下来用用,真不好使,一导入运行就报错,调好错了再运行发现点按钮没反应,反复试了几遍发现还...

丁小未
2014/04/26
0
0
Unity3D利用Webservice读取数据库

相信大家从事Unity3D开发的,无论是做单机的还是做网游的,特别是稍微大点的项目,都会用到数据库,但是网络上关于Unity3D如何连接数据库的教程少之甚少,搜来搜去无非是那篇Unity3D如何连接...

qq_30279553
04/22
0
0
Unity发布Android版本

先大概说一下我自己的经历吧,总的大概用了10小时吧。刚开始装的是jre和Android stdio,然后发现要装的是JDK和SDK,然后去装JDK和SDK,装JDK很顺利,装SDK失败了,原因未知。后面是用 Androi...

a_clear_chen
05/08
0
0
3D 引擎 Unity 2018.2 正式发布,包含重要优化

5月发布的 Unity 2018.1 标志着新周期的开始,Scriptable Render Pipeline(SRP)和 Shader Graph 共同为艺术家和开发者提供了更多功能,而 C# Job System、Burst Compiler 和 ECS 使得利用多...

王练
07/14
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

Linux下如何查看版本信息

Linux下如何查看版本信息, 包括位数、版本信息以及CPU内核信息、CPU具体型号等等,整个CPU信息一目了然。  1、# uname -a (Linux查看版本当前操作系统内核信息)   Linux localhost.l...

15834278076
28分钟前
0
0
单点登录 SSO 的实现原理

单点登录SSO(Single Sign On)说得简单点就是在一个多系统共存的环境下,用户在一处登录后,就不用在其他系统中登录,也就是用户的一次登录能得到其他所有系统的信任。 单点登录在大型网站里...

明理萝
29分钟前
1
1
虚拟机性能监控工具

前言 JVM调优流行这么一句话“无监控不调优”,因为如果没有监控,就不知道虚拟机的运行状况。更谈不上调优了,所以,学习和了解Java 虚拟机的监控工具很有必要。 概述 在Java虚拟机中经常用...

kukudeku
38分钟前
1
0
一行搞定electron和jquery冲突,electron和jquery最简单和完美的兼容方法

electron和jquery的常见报错: Uncaught ReferenceError: $ is not defined 解决方法:在jquery最末端加上这样一行判断即可. <script src="https://code.jquery.com/jquery-2.2.0.min.js"></s......

xiaogg
48分钟前
1
0
GC和内存管理

1、垃圾回收器需要关注的内容 ava运行时内存区域的各个部分中,程序计数器、虚拟机栈、本地方法栈这三个区域的生命周期和线程相关,栈中的栈帧随着方法的进入和退出执行着进栈和出栈,每一个...

京一
55分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部