Skip to content

Commit 7b7a5c5

Browse files
committed
[修改]1. 修改压缩和解压缩的实现方式为调用主框架库的函数
GameFrameX/GameFrameX.Unity#28
1 parent 6384b4e commit 7b7a5c5

File tree

2 files changed

+4
-59
lines changed

2 files changed

+4
-59
lines changed
Lines changed: 2 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
1-
using System.IO;
2-
using ICSharpCode.SharpZipLib.GZip;
1+
using GameFrameX.Runtime;
32

43
namespace GameFrameX.Network.Runtime
54
{
@@ -16,25 +15,7 @@ public sealed class DefaultMessageCompressHandler : IMessageCompressHandler, IPa
1615
/// <returns></returns>
1716
public byte[] Handler(byte[] message)
1817
{
19-
return Compress(message);
20-
}
21-
22-
/// <summary>
23-
/// 压缩数据。
24-
/// </summary>
25-
/// <param name="inputBytes"></param>
26-
/// <returns></returns>
27-
static byte[] Compress(byte[] inputBytes)
28-
{
29-
using (var compressStream = new MemoryStream())
30-
{
31-
using (var gZipOutputStream = new GZipOutputStream(compressStream))
32-
{
33-
gZipOutputStream.Write(inputBytes, 0, inputBytes.Length);
34-
var press = compressStream.ToArray();
35-
return press;
36-
}
37-
}
18+
return ZipHelper.Compress(message);
3819
}
3920
}
4021
}
Lines changed: 2 additions & 38 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,4 @@
1-
using System.Buffers;
2-
using System.IO;
3-
using ICSharpCode.SharpZipLib.GZip;
1+
using GameFrameX.Runtime;
42

53
namespace GameFrameX.Network.Runtime
64
{
@@ -17,41 +15,7 @@ public sealed class DefaultMessageDecompressHandler : IMessageDecompressHandler,
1715
/// <returns></returns>
1816
public byte[] Handler(byte[] message)
1917
{
20-
return Decompress(message);
21-
}
22-
23-
/// <summary>
24-
/// 解压数据。
25-
/// </summary>
26-
/// <param name="bytes"></param>
27-
/// <returns></returns>
28-
static byte[] Decompress(byte[] bytes)
29-
{
30-
using (var compressedStream = new MemoryStream(bytes))
31-
{
32-
using (var gZipInputStream = new GZipInputStream(compressedStream))
33-
{
34-
using (var decompressedStream = new MemoryStream())
35-
{
36-
var buffer = ArrayPool<byte>.Shared.Rent(8192);
37-
try
38-
{
39-
int count;
40-
while ((count = gZipInputStream.Read(buffer, 0, buffer.Length)) != 0)
41-
{
42-
decompressedStream.Write(buffer, 0, count);
43-
}
44-
}
45-
finally
46-
{
47-
ArrayPool<byte>.Shared.Return(buffer);
48-
}
49-
50-
var array = decompressedStream.ToArray();
51-
return array;
52-
}
53-
}
54-
}
18+
return ZipHelper.Decompress(message);
5519
}
5620
}
5721
}

0 commit comments

Comments
 (0)