C# 中的多线程 TCP 侦听器（服务器）

Question

简介： 我开发了一个用 C# 开发的服务器（TCP 侦听器）程序，它在特定（恒定）端口的特定（恒定）IP 上运行。该服务器程序接收客户端程序发送的数据包，对其进行处理并将数据包发送回同一个套接字。虽然此服务器的客户端程序数量可能有数百个：

代码示例

while(true)
{
    socket = Host.AcceptSocket();
    int len = socket.Receive(msgA);

    performActivities(msgA); // May take up-to 5 seconds

    socket.Send(msgB);
    socket.Close();
}

问题： 由于一些关键的业务需求，处理可能需要长达 5 秒的时间，因此在此期间的其他请求会排队，我需要避免这种情况，以便每个请求必须在不超过 5 秒的时间内得到处理。

查询： 我可以让它成为多线程的，但是（如果你发现我是新手，请原谅我）：

如果一个套接字仍然被前一个线程打开，它如何接收来自不同客户端的另一个数据包？

在处理多个请求的情况下，如何确保将响应发送回各自的客户端？

Answer 1

构建高效的多线程套接字服务器需要在该领域拥有丰富的知识和技能。我的建议不是尝试从头开始构建自己的 TCP 服务器，而是使用已经解决了这个问题的现有库之一。我想到的很少是：

• DotNetty 用于 Azure IoT 服务。
• System.IO.Pipelines 这是实验性的，但已经非常快了。
• Akka.Streams TCP stream。

每个库都涵盖以下内容：

• TCP 连接生命周期的管理。
• 字节缓冲区的有效管理。为每个包分配新的byte[] 效率非常低，并且会造成很大的 GC 压力。
• 安全访问套接字 API（默认情况下，套接字不是线程安全的）。
• 传入数据包的缓冲。
• 处理程序/管道/阶段形式的抽象，允许您组合和操作二进制有效负载以进行进一步处理。这特别有用，即当您想根据消息对传入数据进行操作时 - 默认情况下，TCP 是二进制流，它不知道管道内的一条消息何时结束而另一条消息何时开始。

编写生产就绪 TCP 服务器是一项艰巨的工作。除非您是具有非常具体要求的网络编程专家，否则您永远不应该从头开始编写。