在接收命令时通过 TCP 发送字符串

Question

我正在开发一个阅读器程序。它基于 Winorms。

我需要一个代码，winform 将通过 TCP（端口 3573）按需发送一些数据。 （通过需求，我的意思是当程序通过 TCP 接收到命令 GET 时。

我是一个新手，所以这个主题看起来很难将所有这些结合起来：线程、TCPRead TCP 发送、事件处理程序......

所以我在这里需要有关如何实现它的完整代码或示例的帮助。

我尝试了一些来自互联网的示例代码，但没有一个有效（线程、TCPreader 和 TCPsender、TCPreaded 的事件处理）

在 TCP Reader 上，我们收到 GET，然后我们发送一些字符串，让 TCP Sender 说“hello world”

Answer 1

Sockets 真的很难搞定，而且 API 实在是……讨厌。由于这只是要求错误，我将推荐使用“管道”API，它更符合现代async 代码并且更容易正确（并且更好帧处理方面的选项）。所以;这是一个管道示例；

请注意，这需要 Pipelines.Sockets.Unofficial，它位于 nuget via：

<PackageReference Include="Pipelines.Sockets.Unofficial" Version="2.0.22" />

（添加它会自动添加您需要的所有其他部分）

using Pipelines.Sockets.Unofficial;
using System;
using System.IO.Pipelines;
using System.Net;
using System.Text;
using System.Threading.Tasks;

static class Program
{
    static async Task Main()
    {
        var endpoint = new IPEndPoint(IPAddress.Loopback, 9042);
        Console.WriteLine("[server] Starting server...");
        using (var server = new MyServer())
        {
            server.Listen(endpoint);

            Console.WriteLine("[server] Starting client...");
            Task reader;
            using (var client = await SocketConnection.ConnectAsync(endpoint))
            {
                reader = Task.Run(() => ShowIncomingDataAsync(client.Input));

                await WriteAsync(client.Output, "hello");
                await WriteAsync(client.Output, "world");

                Console.WriteLine("press [return]");
                Console.ReadLine();
            }
            await reader;
            server.Stop();
        }
    }

    private static async Task ShowIncomingDataAsync(PipeReader input)
    {
        try
        {
            while (true)
            {
                var read = await input.ReadAsync();
                var buffer = read.Buffer;
                if (buffer.IsEmpty && read.IsCompleted) break; // EOF

                Console.WriteLine($"[client] Received {buffer.Length} bytes; marking consumed");
                foreach (var segment in buffer)
                {   // usually only one segment, but can be more complex
                    Console.WriteLine("[client] " + Program.GetAsciiString(segment.Span));
                }
                input.AdvanceTo(buffer.End); // "we ate it all"
            }
        }
        catch { }
    }

    private static async Task WriteAsync(PipeWriter output, string payload)
    {
        var bytes = Encoding.ASCII.GetBytes(payload);
        await output.WriteAsync(bytes);
    }

    internal static unsafe string GetAsciiString(ReadOnlySpan<byte> span)
    {
        fixed (byte* b = span)
        {
            return Encoding.ASCII.GetString(b, span.Length);
        }
    }
}

class MyServer : SocketServer
{
    protected override Task OnClientConnectedAsync(in ClientConnection client)
        => RunClient(client);
    private async Task RunClient(ClientConnection client)
    {
        Console.WriteLine($"[server] new client: {client.RemoteEndPoint}");
        await ProcessRequests(client.Transport);
        Console.WriteLine($"[server] ended client: {client.RemoteEndPoint}");
    }

    private async Task ProcessRequests(IDuplexPipe transport)
    {
        try
        {
            var input = transport.Input;
            var output = transport.Output;
            while (true)
            {
                var read = await input.ReadAsync();
                var buffer = read.Buffer;
                if (buffer.IsEmpty && read.IsCompleted) break; // EOF

                Console.WriteLine($"[server] Received {buffer.Length} bytes; returning it, and marking consumed");
                foreach (var segment in buffer)
                {   // usually only one segment, but can be more complex
                    Console.WriteLine("[server] " + Program.GetAsciiString(segment.Span));
                    await output.WriteAsync(segment);
                }
                input.AdvanceTo(buffer.End); // "we ate it all"
            }
        }
        catch { }
    }
}

我可以使用原始套接字编写此代码，但需要更多代码来展示最佳实践并避免问题 - 所有这些丑陋都已隐藏在“管道”中。

输出：

[server] Starting server...
[server] Starting client...
[server] new client: 127.0.0.1:63076
press [return]
[server] Received 5 bytes; returning it, and marking consumed
[server] hello
[server] Received 5 bytes; returning it, and marking consumed
[client] Received 5 bytes; marking consumed
[client] hello
[server] world
[client] Received 5 bytes; marking consumed
[client] world