feat(ITcpSocketClient): add TouchSocket extensions

BootstrapBlazor.sln

@@ -78,6 +78,8 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "tools", "tools", "{9BAF50BE
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "UnitTest.Benchmarks", "tools\Benchmarks\UnitTest.Benchmarks.csproj", "{3E6D8D0E-5A36-4CFD-8612-7D64E3FFE7B1}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "BootstrapBlazor.TouchSocket", "..\BootstrapBlazor.Extensions\src\extensions\BootstrapBlazor.TouchSocket\BootstrapBlazor.TouchSocket.csproj", "{8B1D923C-5B6E-6068-BDAE-2752F7FF2D11}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -112,6 +114,10 @@ Global
 		{3E6D8D0E-5A36-4CFD-8612-7D64E3FFE7B1}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{3E6D8D0E-5A36-4CFD-8612-7D64E3FFE7B1}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{3E6D8D0E-5A36-4CFD-8612-7D64E3FFE7B1}.Release|Any CPU.Build.0 = Release|Any CPU
+		{8B1D923C-5B6E-6068-BDAE-2752F7FF2D11}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{8B1D923C-5B6E-6068-BDAE-2752F7FF2D11}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{8B1D923C-5B6E-6068-BDAE-2752F7FF2D11}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{8B1D923C-5B6E-6068-BDAE-2752F7FF2D11}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -128,6 +134,7 @@ Global
 		{D8AEAFE7-10AF-4A5B-BC67-FE740A2CA1DF} = {7C1D79F1-87BC-42C1-BD5A-CDE4044AC1BD}
 		{C075C6C8-B9CB-4AC0-9BDF-B2002B4AB99C} = {EA765165-0542-41C8-93F2-85787FEDEDFF}
 		{3E6D8D0E-5A36-4CFD-8612-7D64E3FFE7B1} = {9BAF50BE-141D-4429-93A9-942F373D1F68}
+		{8B1D923C-5B6E-6068-BDAE-2752F7FF2D11} = {A2182155-43ED-44C1-BF6F-1B70EBD2DFFE}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {0DCB0756-34FA-4FD0-AE1D-D3F08B5B3A6B}

test/UnitTest/Services/TouchSocketTest.cs

@@ -0,0 +1,150 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the Apache 2.0 License
+// See the LICENSE file in the project root for more information.
+// Maintainer: Argo Zhang([email protected]) Website: https://www.blazor.zone
+
+using Microsoft.Extensions.Logging;
+using System.Net;
+using System.Net.Sockets;
+
+namespace UnitTest.Services;
+
+public class TouchSocketTest
+{
+    [Fact]
+    public async Task FixLengthDataPackageHandler_Ok()
+    {
+        var port = 8884;
+        var server = StartTcpServer(port, MockSplitPackageAsync);
+        var client = CreateClient();
+
+        // 测试 ConnectAsync 方法
+        var connect = await client.ConnectAsync("localhost", port);
+        Assert.True(connect);
+        Assert.True(client.IsConnected);
+
+        var tcs = new TaskCompletionSource();
+        ReadOnlyMemory<byte> receivedBuffer = ReadOnlyMemory<byte>.Empty;
+
+        // 增加数据处理适配器
+        client.SetDataHandler(new FixLengthDataPackageHandler(7)
+        {
+            ReceivedCallBack = buffer =>
+            {
+                receivedBuffer = buffer;
+                tcs.SetResult();
+                return ValueTask.CompletedTask;
+            }
+        });
+
+        // 测试 SendAsync 方法
+        var data = new ReadOnlyMemory<byte>([1, 2, 3, 4, 5]);
+        var result = await client.SendAsync(data);
+        Assert.True(result);
+
+        await tcs.Task;
+        Assert.Equal(receivedBuffer.ToArray(), [1, 2, 3, 4, 5, 3, 4]);
+
+        // 模拟延时等待内部继续读取逻辑完成，测试内部 _receiveCancellationTokenSource 取消逻辑
+        await Task.Delay(10);
+
+        // 关闭连接
+        client.Close();
+        StopTcpServer(server);
+    }
+
+    private static async Task MockSplitPackageAsync(TcpClient client)
+    {
+        using var stream = client.GetStream();
+        while (true)
+        {
+            var buffer = new byte[10240];
+            var len = await stream.ReadAsync(buffer);
+            if (len == 0)
+            {
+                break;
+            }
+
+            // 回写数据到客户端
+            var block = new ReadOnlyMemory<byte>(buffer, 0, len);
+            await stream.WriteAsync(block, CancellationToken.None);
+
+            // 模拟延时
+            await Task.Delay(50);
+
+            // 模拟拆包发送第二段数据
+            await stream.WriteAsync(new byte[] { 0x3, 0x4 }, CancellationToken.None);
+        }
+    }
+
+    private static TcpListener StartTcpServer(int port, Func<TcpClient, Task> handler)
+    {
+        var server = new TcpListener(IPAddress.Loopback, port);
+        server.Start();
+        Task.Run(() => AcceptClientsAsync(server, handler));
+        return server;
+    }
+
+    private static async Task AcceptClientsAsync(TcpListener server, Func<TcpClient, Task> handler)
+    {
+        while (true)
+        {
+            var client = await server.AcceptTcpClientAsync();
+            _ = Task.Run(() => handler(client));
+        }
+    }
+
+    private static void StopTcpServer(TcpListener server)
+    {
+        server?.Stop();
+    }
+
+    private static ITcpSocketClient CreateClient()
+    {
+        var sc = new ServiceCollection();
+        sc.AddLogging(builder =>
+        {
+            builder.AddProvider(new MockLoggerProvider());
+        });
+        sc.AddBootstrapBlazorTcpSocketFactory();
+
+        // 增加 TouchSocket 服务
+        sc.AddBootstrapBlazorTouchSocketService();
+
+        var provider = sc.BuildServiceProvider();
+        var factory = provider.GetRequiredService<ITcpSocketFactory>();
+        var client = factory.GetOrCreate("localhost", 0);
+        return client;
+    }
+
+    class MockLoggerProvider : ILoggerProvider
+    {
+        public ILogger CreateLogger(string categoryName)
+        {
+            return new MockLogger();
+        }
+
+        public void Dispose()
+        {
+
+        }
+    }
+
+    class MockLogger : ILogger
+    {
+        public IDisposable? BeginScope<TState>(TState state) where TState : notnull
+        {
+            return null;
+        }
+
+        public bool IsEnabled(LogLevel logLevel)
+        {
+            return true;
+        }
+
+        public void Log<TState>(LogLevel logLevel, EventId eventId, TState state, Exception? exception, Func<TState, Exception?, string> formatter)
+        {
+
+        }
+    }
+}

test/UnitTest/UnitTest.csproj

@@ -36,6 +36,7 @@
   </ItemGroup>
 
   <ItemGroup>
+    <ProjectReference Include="..\..\..\BootstrapBlazor.Extensions\src\extensions\BootstrapBlazor.TouchSocket\BootstrapBlazor.TouchSocket.csproj" />
     <ProjectReference Include="..\..\src\BootstrapBlazor\BootstrapBlazor.csproj" />
   </ItemGroup>