doc: 增加一发一收的模拟服务

Author: ArgoZhang

src/BootstrapBlazor.Server/Extensions/ServiceCollectionExtensions.cs

@@ -46,6 +46,7 @@ void Invoke(BootstrapBlazorOptions option)
         services.AddHostedService<ClearTempFilesService>();
         services.AddHostedService<MockOnlineContributor>();
         services.AddHostedService<MockReceiveSocketServerService>();
+        services.AddHostedService<MockSendReceiveSocketServerService>();
         services.AddHostedService<MockCustomProtocolSocketServerService>();
 
         // 增加通用服务

src/BootstrapBlazor.Server/Services/MockSendReceiveSocketServerService.cs

@@ -0,0 +1,67 @@
+// 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 System.Net;
+using System.Net.Sockets;
+
+namespace Longbow.Tasks.Services;
+
+/// <summary>
+/// 模拟 Socket 服务端服务类
+/// </summary>
+class MockSendReceiveSocketServerService(ILogger<MockReceiveSocketServerService> logger) : BackgroundService
+{
+    /// <summary>
+    /// 运行任务
+    /// </summary>
+    /// <param name="stoppingToken"></param>
+    /// <returns></returns>
+    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
+    {
+        var server = new TcpListener(IPAddress.Loopback, 8810);
+        server.Start();
+        while (stoppingToken is { IsCancellationRequested: false })
+        {
+            try
+            {
+                var client = await server.AcceptTcpClientAsync(stoppingToken);
+                _ = Task.Run(() => MockSendAsync(client, stoppingToken), stoppingToken);
+            }
+            catch { }
+        }
+    }
+
+    private async Task MockSendAsync(TcpClient client, CancellationToken stoppingToken)
+    {
+        // 方法目的:
+        // 接收到数据后会送当前时间戳数据包到客户端
+        await using var stream = client.GetStream();
+        while (stoppingToken is { IsCancellationRequested: false })
+        {
+            try
+            {
+                // 接收数据
+                var len = await stream.ReadAsync(new byte[1024], stoppingToken);
+                if (len == 0)
+                {
+                    // 断开连接
+                    break;
+                }
+                // 模拟服务，对接收到的消息未做处理
+                // 模拟一发一收的通讯方法
+                var data = System.Text.Encoding.UTF8.GetBytes(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
+                await stream.WriteAsync(data, stoppingToken);
+            }
+            catch (OperationCanceledException) { break; }
+            catch (IOException) { break; }
+            catch (SocketException) { break; }
+            catch (Exception ex)
+            {
+                logger.LogError(ex, "MockSendReceiveSocketServerService encountered an error while sending data.");
+                break;
+            }
+        }
+    }
+}