[修改]1. 修改消息长度的大小为uint类型

Author: AlianBlank

Runtime/Network/Helper/DefaultPacketReceiveHeaderHandler.cs

@@ -9,7 +9,7 @@ public sealed class DefaultPacketReceiveHeaderHandler : IPacketReceiveHeaderHand
         /// <summary>
         /// 包长度
         /// </summary>
-        public ushort PacketLength { get; private set; }
+        public uint PacketLength { get; private set; }
 
         /// <summary>
         /// 消息ID
@@ -47,15 +47,15 @@ public bool Handler(object source)
 
             // packetLength
             int offset = 0;
-            var packetLength = reader.ReadUShort(ref offset); //4
+            var packetLength = reader.ReadUInt(ref offset); //4
             PacketLength = packetLength;
             // operationType
             OperationType = reader.ReadByte(ref offset); //1
             // zipFlag
             ZipFlag = reader.ReadByte(ref offset); //1
             // uniqueId
             UniqueId = reader.ReadInt(ref offset); //4
-            // MsgId
+            // MessageId
             Id = reader.ReadInt(ref offset); //4
             return true;
         }

Runtime/Network/Helper/DefaultPacketSendHeaderHandler.cs

@@ -55,7 +55,7 @@ public DefaultPacketSendHeaderHandler()
         /// <summary>
         /// 获取网络消息包长度。
         /// </summary>
-        public ushort PacketLength { get; private set; }
+        public uint PacketLength { get; private set; }
 
         /// <summary>
         /// 是否压缩消息内容
@@ -96,9 +96,9 @@ public bool Handler<T>(T messageObject, IMessageCompressHandler messageCompressH
             }
 
             var messageLength = messageBodyBuffer.Length;
-            PacketLength = (ushort)(PacketHeaderLength + messageLength);
+            PacketLength = (uint)(PacketHeaderLength + messageLength);
             // 数据包总大小
-            m_CachedByte.WriteUShort(PacketLength, ref m_Offset);
+            m_CachedByte.WriteUInt(PacketLength, ref m_Offset);
             // 消息操作类型
             m_CachedByte.WriteByte((byte)(ProtoMessageIdHandler.IsHeartbeat(messageType) ? 1 : 4), ref m_Offset);
             // 消息压缩标记

Runtime/Network/Interface/IPacketReceiveHeaderHandler.cs

@@ -13,14 +13,14 @@ namespace GameFrameX.Network.Runtime
     public interface IPacketReceiveHeaderHandler
     {
         /// <summary>
-        /// 消息包头长度
+        /// 获取网络消息包长度。
         /// </summary>
-        ushort PacketHeaderLength { get; }
+        uint PacketLength { get; }
 
         /// <summary>
-        /// 获取网络消息包长度。
+        /// 消息包头长度
         /// </summary>
-        ushort PacketLength { get; }
+        ushort PacketHeaderLength { get; }
 
         /// <summary>
         /// 获取网络消息包协议编号。

Runtime/Network/Interface/IPacketSendHeaderHandler.cs

@@ -20,7 +20,7 @@ public interface IPacketSendHeaderHandler
         /// <summary>
         /// 获取网络消息包长度。
         /// </summary>
-        ushort PacketLength { get; }
+        uint PacketLength { get; }
 
         /// <summary>
         /// 是否压缩消息内容

Runtime/Network/Network/SystemSocket/NetworkManager.SystemTcpNetworkChannel.cs

@@ -81,7 +81,9 @@ private void ReceiveAsync()
             {
                 try
                 {
-                    PSystemNetSocket.BeginReceive(PReceiveState.Stream.GetBuffer(), (int)PReceiveState.Stream.Position, (int)(PReceiveState.Stream.Length - PReceiveState.Stream.Position), SocketFlags.None, ReceiveCallback, PSystemNetSocket);
+                    var position = (int)PReceiveState.Stream.Position;
+                    var length = (int)(PReceiveState.Stream.Length - PReceiveState.Stream.Position);
+                    PSystemNetSocket.BeginReceive(PReceiveState.Stream.GetBuffer(), position, length, SocketFlags.None, ReceiveCallback, PSystemNetSocket);
                 }
                 catch (Exception exception)
                 {
@@ -176,7 +178,8 @@ private bool ProcessPackHeader()
                 var buffer = new byte[headerLength];
                 _ = PReceiveState.Stream.Read(buffer, 0, headerLength);
                 var processSuccess = PNetworkChannelHelper.DeserializePacketHeader(buffer);
-                PReceiveState.Reset(PacketReceiveHeaderHandler.PacketLength - PacketReceiveHeaderHandler.PacketHeaderLength, PacketReceiveHeaderHandler);
+                var bodyLength = (int)(PacketReceiveHeaderHandler.PacketLength - PacketReceiveHeaderHandler.PacketHeaderLength);
+                PReceiveState.Reset(bodyLength, PacketReceiveHeaderHandler);
                 return processSuccess;
             }
 
@@ -186,7 +189,7 @@ private bool ProcessPackHeader()
             /// <returns></returns>
             private bool ProcessPackBody()
             {
-                var bodyLength = PReceiveState.PacketHeader.PacketLength - PReceiveState.PacketHeader.PacketHeaderLength;
+                var bodyLength = (int)(PReceiveState.PacketHeader.PacketLength - PReceiveState.PacketHeader.PacketHeaderLength);
                 var buffer = new byte[bodyLength];
                 _ = PReceiveState.Stream.Read(buffer, 0, bodyLength);
 

Runtime/Network/Network/WebSocket/NetworkManager.WebSocketNetworkChannel.cs

@@ -254,7 +254,7 @@ private void ReceiveCallback(byte[] buffer)
                     var processSuccess = PNetworkChannelHelper.DeserializePacketHeader(buffer);
                     if (processSuccess)
                     {
-                        var bodyLength = PacketReceiveHeaderHandler.PacketLength - PacketReceiveHeaderHandler.PacketHeaderLength;
+                        var bodyLength = (int)(PacketReceiveHeaderHandler.PacketLength - PacketReceiveHeaderHandler.PacketHeaderLength);
                         PReceiveState.Reset(bodyLength, PacketReceiveHeaderHandler);
                         if (buffer.Length < bodyLength)
                         {