upgrade(touchsocket):nuget version to 4.0.2 (#10367)

* 优化(MyTcpSessionClientBase): 优化异步逻辑与代码结构

重构MyTcpSessionClientBase类以提升性能与可读性：
- 将Json和Plaintext字段从public改为private
- 优化pipeReader.ReadAsync与pipeWriter.FlushAsync的异步调用逻辑
- 为关键方法添加AggressiveOptimization标记以启用编译优化
- 简化TryReadLine方法的行尾标记处理逻辑
- 优化ParseUrlFast方法的URL解析逻辑，减少冗余代码
- 重构WriteResponseSync方法，使用if-else替代switch语句
- 删除冗余注释与代码，提升代码整洁度

* 优化(project): 升级TouchSocket相关包版本

升级TouchSocket相关包版本以使用最新功能和修复

- 在 `TouchSocketHttp.csproj` 中，将 `TouchSocket.WebApi` 替换为 `TouchSocket.Http`，并将版本更新至 `4.0.2`
- 在 `TouchSocketHttpPlatform.csproj` 中，将 `TouchSocket` 包版本更新至 `4.0.2`
- 在 `TouchSocketWebApi.csproj` 中：
  - 将 `TouchSocket.Hosting` 包版本更新至 `4.0.2`
  - 将 `TouchSocket.WebApi` 包版本更新至 `4.0.2`

Author: RRQM

frameworks/CSharp/touchsocket/src/TouchSocketHttp/TouchSocketHttp.csproj

@@ -8,7 +8,7 @@
 	</PropertyGroup>
 
 	<ItemGroup>
-		<PackageReference Include="TouchSocket.WebApi" Version="4.0.0" />
+		<PackageReference Include="TouchSocket.Http" Version="4.0.2" />
 	</ItemGroup>
 </Project>
 

frameworks/CSharp/touchsocket/src/TouchSocketHttpPlatform/MyTcpSessionClientBase.cs

@@ -41,11 +41,10 @@ internal enum RouteType
 internal sealed class MyTcpSessionClientBase : TcpSessionClient
 {
     #region Paths
-    public static ReadOnlySpan<byte> Json => "/json"u8;
-    public static ReadOnlySpan<byte> Plaintext => "/plaintext"u8;
+    private static ReadOnlySpan<byte> Json => "/json"u8;
+    private static ReadOnlySpan<byte> Plaintext => "/plaintext"u8;
     #endregion
 
-
     private static ReadOnlySpan<byte> PlainTextBody => "Hello, World!"u8;
     private static ReadOnlySpan<byte> JsonBody => "{\"message\":\"Hello, World!\"}"u8;
 
@@ -68,14 +67,30 @@ protected override async Task ReceiveLoopAsync(ITransport transport)
 
         while (true)
         {
-            var readResult = await pipeReader.ReadAsync();
+            ValueTask<ReadResult> readTask = pipeReader.ReadAsync();
+            ReadResult readResult;
+
+            if (readTask.IsCompleted)
+            {
+                readResult = readTask.Result;
+            }
+            else
+            {
+                readResult = await readTask.ConfigureAwait(false);
+            }
+
             var bufferSequence = readResult.Buffer;
 
             var totalConsumed = ProcessRequests(bufferSequence, pipeWriter, out var responseCount);
 
             if (responseCount > 0)
             {
-                await pipeWriter.FlushAsync();
+                ValueTask<FlushResult> flushTask = pipeWriter.FlushAsync();
+                
+                if (!flushTask.IsCompleted)
+                {
+                    await flushTask.ConfigureAwait(false);
+                }
             }
 
             if (totalConsumed > 0)
@@ -94,7 +109,7 @@ protected override async Task ReceiveLoopAsync(ITransport transport)
         }
     }
 
-    [MethodImpl(MethodImplOptions.AggressiveInlining)]
+    [MethodImpl(MethodImplOptions.AggressiveInlining | MethodImplOptions.AggressiveOptimization)]
     private static long ProcessRequests(ReadOnlySequence<byte> buffer, PipeWriter writer, out int responseCount)
     {
         var seqReader = new SequenceReader<byte>(buffer);
@@ -105,23 +120,20 @@ private static long ProcessRequests(ReadOnlySequence<byte> buffer, PipeWriter wr
         {
             var startConsumed = seqReader.Consumed;
 
-            // 请求行
             if (!TryReadLine(ref seqReader, out var requestLineLength))
             {
-                // 请求行不完整，不消费任何数据
                 break;
             }
 
             var requestLineConsumed = requestLineLength + 2;
 
-            // 读取Headers，直到空行；若不完整，回退并等待更多数据
             var headersStartConsumed = seqReader.Consumed;
             bool headersComplete = false;
+            
             while (!seqReader.End)
             {
                 if (!TryReadLine(ref seqReader, out var headerLength))
                 {
-                    // 回退到读取Headers前的位置，等待更多数据
                     var rewind = seqReader.Consumed - headersStartConsumed;
                     if (rewind > 0)
                     {
@@ -134,163 +146,118 @@ private static long ProcessRequests(ReadOnlySequence<byte> buffer, PipeWriter wr
                 if (headerLength == 0)
                 {
                     headersComplete = true;
-                    break; // headers 结束
+                    break;
                 }
             }
 
             if (!headersComplete)
             {
-                // 不完整，等待更多数据
                 break;
             }
 
-            // 解析URL - 直接在原始位置解析，避免Slice
             var routeType = ParseUrlFast(buffer.Slice(startConsumed), requestLineConsumed);
 
-            // 计算本次消费的字节数
             var consumed = seqReader.Consumed - startConsumed;
             totalConsumed += consumed;
 
-            // 写入响应
             WriteResponseSync(writer, routeType);
             responseCount++;
         }
 
         return totalConsumed;
     }
 
-    [MethodImpl(MethodImplOptions.AggressiveInlining)]
+    [MethodImpl(MethodImplOptions.AggressiveInlining | MethodImplOptions.AggressiveOptimization)]
     private static void WriteResponseSync(PipeWriter writer, RouteType routeType)
     {
-        switch (routeType)
+        if (routeType == RouteType.Plaintext)
         {
-            case RouteType.Plaintext:
-                writer.Write(PlaintextPreamble);
-                writer.Write(DateHeader.HeaderBytes);
-                writer.Write(PlainTextBody);
-                break;
-            case RouteType.Json:
-                writer.Write(JsonPreamble);
-                writer.Write(DateHeader.HeaderBytes);
-                writer.Write(JsonBody);
-                break;
+            writer.Write(PlaintextPreamble);
+            writer.Write(DateHeader.HeaderBytes);
+            writer.Write(PlainTextBody);
+        }
+        else if (routeType == RouteType.Json)
+        {
+            writer.Write(JsonPreamble);
+            writer.Write(DateHeader.HeaderBytes);
+            writer.Write(JsonBody);
         }
     }
 
-    [MethodImpl(MethodImplOptions.AggressiveInlining)]
+    [MethodImpl(MethodImplOptions.AggressiveInlining | MethodImplOptions.AggressiveOptimization)]
     private static bool TryReadLine(ref SequenceReader<byte> reader, out long length)
     {
-        var start = reader.Consumed;
-
-        while (!reader.End)
+        if (reader.TryAdvanceTo((byte)'\r', advancePastDelimiter: false))
         {
-            if (reader.TryRead(out var b))
+            var start = reader.Consumed;
+            
+            if (!reader.TryPeek(1, out var next))
             {
-                if (b == '\r')
-                {
-                    // 查看是否有'\n'，若暂不可用则回退并判定不完整
-                    if (!reader.TryPeek(out var next))
-                    {
-                        // 回退已读取的'\r'
-                        reader.Rewind(1);
-                        length = 0;
-                        return false;
-                    }
-                    if (next == '\n')
-                    {
-                        // 消费'\n'并返回本行长度（不含CRLF）
-                        reader.Advance(1);
-                        length = reader.Consumed - start - 2;
-                        return true;
-                    }
-                }
+                length = 0;
+                return false;
             }
+            
+            if (next == '\n')
+            {
+                var lineLength = reader.Consumed;
+                reader.Advance(2);
+                length = lineLength - start;
+                return true;
+            }
+            
+            reader.Advance(1);
+            return TryReadLine(ref reader, out length);
         }
 
         length = 0;
         return false;
     }
 
-    [MethodImpl(MethodImplOptions.AggressiveInlining)]
+    [MethodImpl(MethodImplOptions.AggressiveInlining | MethodImplOptions.AggressiveOptimization)]
     private static RouteType ParseUrlFast(ReadOnlySequence<byte> sequence, long requestLineLength)
     {
         var reader = new SequenceReader<byte>(sequence);
 
-        // 跳过方法
-        var spaceCount = 0;
-        var urlStart = 0L;
-        var urlEnd = 0L;
-
-        while (reader.Consumed < requestLineLength && !reader.End)
+        if (!reader.TryAdvanceTo((byte)' ', advancePastDelimiter: true))
         {
-            if (reader.TryRead(out var b))
-            {
-                if (b == ' ')
-                {
-                    spaceCount++;
-                    if (spaceCount == 1)
-                    {
-                        urlStart = reader.Consumed;
-                    }
-                    else if (spaceCount == 2)
-                    {
-                        urlEnd = reader.Consumed - 1;
-                        break;
-                    }
-                }
-            }
+            return RouteType.Unknown;
         }
 
-        if (spaceCount < 2)
+        var urlStart = reader.Consumed;
+
+        if (!reader.TryAdvanceTo((byte)' ', advancePastDelimiter: false))
         {
             return RouteType.Unknown;
         }
 
-        var urlLength = urlEnd - urlStart;
+        var urlLength = reader.Consumed - urlStart;
 
-        // 截取URL片段
-        var startPos = sequence.GetPosition(urlStart);
-        var urlSlice = sequence.Slice(startPos, urlLength);
-
-        // "/plaintext"
         if (urlLength == Plaintext.Length)
         {
+            var urlSlice = sequence.Slice(urlStart, urlLength);
+            
             if (urlSlice.IsSingleSegment)
             {
-                if (urlSlice.FirstSpan.SequenceEqual(Plaintext))
-                {
-                    return RouteType.Plaintext;
-                }
-            }
-            else
-            {
-                Span<byte> tmp = stackalloc byte[(int)urlLength];
-                urlSlice.CopyTo(tmp);
-                if (tmp.SequenceEqual(Plaintext))
-                {
-                    return RouteType.Plaintext;
-                }
+                return urlSlice.FirstSpan.SequenceEqual(Plaintext) ? RouteType.Plaintext : RouteType.Unknown;
             }
+            
+            Span<byte> tmp = stackalloc byte[(int)urlLength];
+            urlSlice.CopyTo(tmp);
+            return tmp.SequenceEqual(Plaintext) ? RouteType.Plaintext : RouteType.Unknown;
         }
-        // "/json"
-        else if (urlLength == Json.Length)
+        
+        if (urlLength == Json.Length)
         {
+            var urlSlice = sequence.Slice(urlStart, urlLength);
+            
             if (urlSlice.IsSingleSegment)
             {
-                if (urlSlice.FirstSpan.SequenceEqual(Json))
-                {
-                    return RouteType.Json;
-                }
-            }
-            else
-            {
-                Span<byte> tmp = stackalloc byte[(int)urlLength];
-                urlSlice.CopyTo(tmp);
-                if (tmp.SequenceEqual(Json))
-                {
-                    return RouteType.Json;
-                }
+                return urlSlice.FirstSpan.SequenceEqual(Json) ? RouteType.Json : RouteType.Unknown;
             }
+            
+            Span<byte> tmp = stackalloc byte[(int)urlLength];
+            urlSlice.CopyTo(tmp);
+            return tmp.SequenceEqual(Json) ? RouteType.Json : RouteType.Unknown;
         }
 
         return RouteType.Unknown;

frameworks/CSharp/touchsocket/src/TouchSocketHttpPlatform/TouchSocketHttpPlatform.csproj

@@ -8,6 +8,6 @@
 	</PropertyGroup>
 
 	<ItemGroup>
-		<PackageReference Include="TouchSocket" Version="4.0.0" />
+		<PackageReference Include="TouchSocket" Version="4.0.2" />
 	</ItemGroup>
 </Project>

frameworks/CSharp/touchsocket/src/TouchSocketWebApi/TouchSocketWebApi.csproj

@@ -9,7 +9,7 @@
 
 	<ItemGroup>
 		<PackageReference Include="Microsoft.Extensions.Hosting" Version="10.0.0" />
-		<PackageReference Include="TouchSocket.Hosting" Version="4.0.0" />
-		<PackageReference Include="TouchSocket.WebApi" Version="4.0.0" />
+		<PackageReference Include="TouchSocket.Hosting" Version="4.0.2" />
+		<PackageReference Include="TouchSocket.WebApi" Version="4.0.2" />
 	</ItemGroup>
 </Project>