doc: 更新手动接收示例

Author: ArgoZhang

src/BootstrapBlazor.Server/Components/Samples/Sockets/ManualReceives.razor

@@ -9,31 +9,21 @@
 <DemoBlock Title="@Localizer["NormalTitle"]"
            Introduction="@Localizer["NormalIntro"]"
            Name="Normal" ShowCode="false">
-    <p>本例中连接一个模拟时间同步服务，每间隔 10s 自动发送服务器时间戳，连接后无需发送任何数据即可持续收到时间戳数据</p>
+    <p>本例中连接一个模拟时间同步服务，采用一发一收的方式进行通讯，连接后发送查询电文，接收到服务器端响应时间戳电文数据</p>
     <ul class="ul-demo">
         <li>点击 <b>连接</b> 按钮后通过 <code>ITcpSocketFactory</code> 服务实例创建的 <code>ITcpSocketClient</code> 对象连接到网站模拟 <code>TcpServer</code></li>
         <li>点击 <b>断开</b> 按钮调用 <code>CloseAsync</code> 方法断开 Socket 连接</li>
+        <li>点击 <b>发送</b> 按钮调用 <code>SendAsync</code> 方法发送请求数据</li>
     </ul>
-    <p>使用 <code>ReceivedCallBack</code> 委托获得接收到的数据，可通过 <code>+=</code> 方法支持多个客户端接收数据</p>
-    <Pre>_client.ReceivedCallBack += OnReceivedAsync;</Pre>
-    <p>特别注意页面需要继承 <code>IDisposable</code> 或者 <code>IAsyncDisposable</code> 接口，在 <code>Dispose</code> 或者 <code>DisposeAsync</code> 中移除委托</p>
-    <Pre>private void Dispose(bool disposing)
-{
-    if (disposing)
-    {
-        if (_client is { IsConnected: true })
-        {
-            _client.ReceivedCallBack -= OnReceivedAsync;
-        }
-    }
-}</Pre>
-
+    <p>使用 <code>ReceiveAsync</code> 方法主动接收数据</p>
     <div class="row form-inline g-3">
         <div class="col-12 col-sm-6">
             <Button Text="连接" Icon="fa-solid fa-play"
                     OnClick="OnConnectAsync" IsDisabled="@_client.IsConnected"></Button>
             <Button Text="断开" Icon="fa-solid fa-stop" class="ms-2"
                     OnClick="OnCloseAsync" IsDisabled="@(!_client.IsConnected)"></Button>
+            <Button Text="发送" Icon="fa-solid fa-paper-plane" class="ms-2" IsAsync="true"
+                    OnClick="OnSendAsync" IsDisabled="@(!_client.IsConnected)"></Button>
         </div>
         <div class="col-12">
             <Console Items="@_items" Height="496" HeaderText="接收数据（间隔 10 秒）"

src/BootstrapBlazor.Server/Components/Samples/Sockets/ManualReceives.razor.cs

@@ -10,7 +10,7 @@ namespace BootstrapBlazor.Server.Components.Samples.Sockets;
 /// <summary>
 /// 接收电文示例
 /// </summary>
-public partial class ManualReceives : IDisposable
+public partial class ManualReceives
 {
     [Inject, NotNull]
     private ITcpSocketFactory? TcpSocketFactory { get; set; }
@@ -19,7 +19,7 @@ public partial class ManualReceives : IDisposable
 
     private List<ConsoleMessageItem> _items = [];
 
-    private readonly IPEndPoint _serverEndPoint = new(IPAddress.Loopback, 8800);
+    private readonly IPEndPoint _serverEndPoint = new(IPAddress.Loopback, 8810);
 
     /// <summary>
     /// <inheritdoc/>
@@ -29,11 +29,11 @@ protected override void OnInitialized()
         base.OnInitialized();
 
         // 从服务中获取 Socket 实例
-        _client = TcpSocketFactory.GetOrCreate("demo-receive", options =>
+        _client = TcpSocketFactory.GetOrCreate("demo-manual-receive", options =>
         {
             options.LocalEndPoint = new IPEndPoint(IPAddress.Loopback, 0);
+            options.IsAutoReceive = false;
         });
-        _client.ReceivedCallBack += OnReceivedAsync;
     }
 
     private async Task OnConnectAsync()
@@ -58,40 +58,27 @@ private Task OnClear()
         return Task.CompletedTask;
     }
 
-    private async ValueTask OnReceivedAsync(ReadOnlyMemory<byte> data)
+    private async Task OnSendAsync()
     {
-        // 将数据显示为十六进制字符串
-        var payload = System.Text.Encoding.UTF8.GetString(data.Span);
-        _items.Add(new ConsoleMessageItem
+        if (_client is { IsConnected: true })
         {
-            Message = $"接收到来自站点的数据为 {payload}"
-        });
+            // 准备通讯数据
+            var data = new byte[12];
+            var result = await _client.SendAsync(new byte[2] { 0x01, 0x02 }, CancellationToken.None);
+            var state = result ? "成功" : "失败";
 
-        // 保持队列中最大数量为 50
-        if (_items.Count > 50)
-        {
-            _items.RemoveAt(0);
-        }
-        await InvokeAsync(StateHasChanged);
-    }
+            // 记录日志
+            _items.Add(new ConsoleMessageItem()
+            {
+                Message = $"{DateTime.Now}: 发送数据 {_client.LocalEndPoint} - {_serverEndPoint} Data {BitConverter.ToString(data)} {state}"
+            });
 
-    private void Dispose(bool disposing)
-    {
-        if (disposing)
-        {
-            if (_client is { IsConnected: true })
+            var buffer = await _client.ReceiveAsync(CancellationToken.None);
+            _items.Add(new ConsoleMessageItem()
             {
-                _client.ReceivedCallBack -= OnReceivedAsync;
-            }
+                Message = $"{DateTime.Now}: 接收数据 {_client.LocalEndPoint} - {_serverEndPoint} Data {BitConverter.ToString(buffer.ToArray())} 成功",
+                Color = Color.Success
+            });
         }
     }
-
-    /// <summary>
-    /// <inheritdoc/>
-    /// </summary>
-    public void Dispose()
-    {
-        Dispose(true);
-        GC.SuppressFinalize(this);
-    }
 }