许多TcpListener传入连接

Question

我需要制作一个服务器，它可以接受，并在很长一段时间内保持的许多连接(前瞻性地超过100 K)。

我的代码如下：

public delegate Task ClientConnectedEventHandler(Stream stream);

public class Listener
{
    public event ClientConnectedEventHandler OnClientConnected;

    private readonly TcpListener _tcpListener;

    public Listener()
    {
        _tcpListener = new TcpListener(new IPEndPoint(IPAddress.Any, 8082));
    }

    public void Start()
    {
        _tcpListener.Start();
        _tcpListener.BeginAcceptTcpClient(Accept, null);
    }

    private void Accept(IAsyncResult asyncResult)
    {
        _tcpListener.BeginAcceptTcpClient(Accept, null);
        var client = _tcpListener.EndAcceptTcpClient(asyncResult);
        var stream = client.GetStream();
        OnClientConnected?.Invoke(stream).ContinueWith(_ => client.Close());
    }
}

class Program
{
    static void Main(string[] args)
    {
        var listener = new Listener();
        var count = 0;
        var infoLock = new object();

        listener.OnClientConnected += async stream =>
        {
            lock (infoLock)
            {
                count++;
                Console.Title = count.ToString();
            }
            while (true)
            {
                // Some logic
                await Task.Delay(100);
            }
        };

        listener.Start();
        while (true)
        {
            Thread.Sleep(100);
        }
    }
}

当逻辑占用300-400毫秒时，没有问题。但是，如果我想长时间保持传入连接，那么count变量在接受8个客户端后增长非常缓慢，而且出现了大量内存占用的问题。我做错了什么以及如何解决这个问题？

Answer 1

内存问题可能是由于未处理非托管资源造成的。TcpClient和NetworkStream都实现了IDisposable，并且应该包装在Using块中，或者手动关闭/释放。首先，请参阅How to properly and completely close/reset a TcpClient connection?。