GameGate:ProtoBuf测试

Author: mirbeta

src/GameGate/ClientSession.cs

@@ -1,11 +1,7 @@
 using System;
 using System.Collections.Generic;
-using System.Diagnostics;
-using System.Runtime.InteropServices;
-using System.Threading.Tasks;
 using SystemModule;
 using SystemModule.Packages;
-using SystemModule.ProtobuffPacket;
 
 namespace GameGate
 {

src/GameGate/Services/ClientThread.cs

@@ -1,7 +1,6 @@
 using System;
 using SystemModule;
 using SystemModule.Packages;
-using SystemModule.ProtobuffPacket;
 using SystemModule.Sockets;
 
 namespace GameGate
@@ -408,16 +407,6 @@ public void SendBuffer(byte[] sendBuffer)
             ClientSocket.SendBuff(sendBuffer);
         }
 
-        public void SendBuffer(IProtoBuff protoBuff)
-        {
-            if (!ClientSocket.IsConnected) {
-                return;
-            }
-            var bodyBuffer = ProtobuffHelp.Serialize(protoBuff);
-            SendBytes += bodyBuffer.Length;
-            ClientSocket.SendBuff(bodyBuffer);
-        }
-
         public void CheckServerIsTimeOut()
         {
             if ((HUtil32.GetTickCount() - _checkServerTick) > GateShare.dwCheckServerTimeOutTime && CheckServerFailCount <= 20)

src/GameGate/TimedService.cs

@@ -3,8 +3,6 @@
 using System.Threading;
 using System.Threading.Tasks;
 using SystemModule;
-using SystemModule.Packages;
-using SystemModule.ProtobuffPacket;
 
 namespace GameGate
 {

src/SystemModule/ProtobuffPacket/ProtobuffHelp.cs

@@ -0,0 +1,61 @@
+using System;
+using System.IO;
+
+namespace SystemModule.ProtobuffPacket
+{
+    public class ProtobuffHelp
+    {
+        /// <summary>
+        /// 将消息序列化为二进制的方法
+        /// </summary>
+        /// <typeparam name="T"></typeparam>
+        /// <param name="model"></param>
+        /// <returns></returns>
+        public static byte[] Serialize<T>(T model)
+        {
+            try
+            {
+                //涉及格式转换，需要用到流，将二进制序列化到流中
+                using MemoryStream ms = new MemoryStream();
+                //使用ProtoBuf工具的序列化方法
+                ProtoBuf.Serializer.Serialize<T>(ms, model);
+                //定义二级制数组，保存序列化后的结果
+                byte[] result = new byte[ms.Length];
+                //将流的位置设为0，起始点
+                ms.Position = 0;
+                //将流中的内容读取到二进制数组中
+                ms.Read(result, 0, result.Length);
+                return result;
+            }
+            catch (Exception ex)
+            {
+                return null;
+            }
+        }
+
+        /// <summary>
+        /// 将收到的消息反序列化成对象
+        /// </summary>
+        /// <typeparam name="T"></typeparam>
+        /// <param name="msg"></param>
+        /// <returns></returns>
+        public static T DeSerialize<T>(byte[] msg)
+        {
+            try
+            {
+                using MemoryStream ms = new MemoryStream();
+                //将消息写入流中
+                ms.Write(msg, 0, msg.Length);
+                //将流的位置归0
+                ms.Position = 0;
+                //使用工具反序列化对象
+                T result = ProtoBuf.Serializer.Deserialize<T>(ms);
+                return result;
+            }
+            catch (Exception ex)
+            {
+                return default(T);
+            }
+        }
+    }
+}

src/SystemModule/SystemModule.csproj

@@ -20,6 +20,7 @@
       <None Remove="System.Data.SQLite.Core" />
     </ItemGroup>
     <ItemGroup>
+      <PackageReference Include="protobuf-net" Version="3.0.101" />
       <PackageReference Include="System.Text.Encoding.CodePages" Version="6.0.0" />
     </ItemGroup>
 </Project>