异步 TCP 服务器持有套接字但停止侦听

Question

我有以下异步 TCP 服务器，用于接受来自想要上传文件的客户端的传入请求。大约 1-4 小时后，服务器会停止接受任何新连接。这一直让我感到困惑，因为我无法确定地重现错误。我程序中的其余线程继续正常运行。没有任何异常抛出。关于可能发生的事情有什么建议吗？

在服务器死机之前，我所看到的只是它设法完成待处理的请求然后停止。我有一种预感，服务器正在经历频繁的网络断开连接。如何使这段代码对失败更加健壮？我已经在可能失败的两段代码中添加了 try-catch，但我觉得我仍然缺少一些东西。

我设置了另一个线程来检查此服务器是否释放了套接字，但即使它停止处理客户端请求，它似乎仍在使用该套接字。我使用netstat -a验证了这一点

internal class TCPServer
{
    private readonly int _listeningPort;
    private TcpListener listener;

    public TCPServer(int port)
    {
        _listeningPort = port;
        listener = new TcpListener(IPAddress.Any, _listeningPort);
        listener.Start(int.MaxValue);
    }

    public async void Start()
    {
        while (true)
        {
            Log.Verbose("Waiting for connections...");
            try
            {
                var tcpClient = await listener.AcceptTcpClientAsync();
                Task t = HandleConnectionAsync(tcpClient);
                await t;
            }
            catch (Exception exp)
            {
                Log.Fatal(exp.ToString());
            }
        }
    }

    private async Task HandleConnectionAsync(TcpClient tcpClient)
    {
        try
        {
            string outputFile = ""; // get a random string

            using (var stream = tcpClient.GetStream())
            using (var output = File.Create(outputFile))
            {
                //...

                while ((bytesRead = await stream.ReadAsync(buffer, 0, buffer.Length)) > 0)
                {
                    // ...
                    await output.WriteAsync(buffer, 0, bytesRead);
                }
            }

            tcpClient.Close();
        }
        catch (Exception exp)
        {
            Log(exp.Message);
        }
    }

Answer 1

存在三个问题：

1. 您一个一个地处理连接。一个故障/挂起的连接会阻塞整个服务器。只需删除await t;。您已经在工作函数中记录了所有错误，这很好。
2. 使 HandleConnectionAsync 快速返回，以便可以快速恢复接受新连接。我会牺牲一点效率，只说Task.Run(() => HandleConnectionAsync(tcpClient)) 以确保处理可以立即继续。现在所有文件打开的东西都是同步的，并阻碍了接受工作流。
3. 通过包装确定性地关闭tcpClient：using (tcpClient) ...。这样可以防止僵尸客户端在发生错误时闲逛。

Answer 2

你应该检查一下，如果你仍然连接。

也许这很有用： How to test for a broken connection of TCPClient after being connected?