feat: 支持多次粘包处理功能

Author: ArgoZhang

src/BootstrapBlazor/Services/TcpSocket/DataPackage/FixLengthDataPackageHandler.cs

@@ -28,28 +28,40 @@ public override async Task ReceiveAsync(Memory<byte> data)
         // 处理上次粘包数据
         data = ConcatBuffer(data);
 
-        // 拷贝数据
-        var len = length - _receivedLength;
-        var segment = data.Length > len ? data[..len] : data;
-        segment.CopyTo(_data[_receivedLength..]);
-
-        if (data.Length > len)
+        while (data.Length > 0)
         {
-            SlicePackage(data, data.Length - len);
-        }
+            // 拷贝数据
+            var len = length - _receivedLength;
+            var segment = data.Length > len ? data[..len] : data;
+            segment.CopyTo(_data[_receivedLength..]);
 
-        // 更新已接收长度
-        _receivedLength += segment.Length;
+            // 更新已接收长度
+            _receivedLength += segment.Length;
 
-        // 如果已接收长度等于总长度则触发回调
-        if (_receivedLength == length)
-        {
-            // 重置已接收长度
-            _receivedLength = 0;
-            if (ReceivedCallBack != null)
+            // 如果已接收长度等于总长度则触发回调
+            if (_receivedLength == length)
+            {
+                // 重置已接收长度
+                _receivedLength = 0;
+                if (ReceivedCallBack != null)
+                {
+                    await ReceivedCallBack(_data);
+                }
+            }
+
+            // 检查剩余长度是否大于总长度
+            if (data.Length >= segment.Length + length)
+            {
+                data = data[segment.Length..];
+                continue;
+            }
+
+            // 缓存剩余数据
+            if (data.Length > len)
             {
-                await ReceivedCallBack(_data);
+                SlicePackage(data, data.Length - len);
             }
+            break;
         }
     }
 }