许多 TcpListener 传入连接



我需要创建一个接受并保持很长时间连接(透视超过100k)的服务器。

我的代码如下:

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 毫秒时,没有问题。但是,如果我想长时间保持传入连接,在接受 8 个客户端后计算变量增量非常慢,而且会出现大量内存使用的问题。我做错了什么以及如何解决这个问题?

内存问题可能是由于未释放非托管资源引起的。TcpClientNetworkStream都实现了 IDisposable,应包装在Using块中或手动关闭/处置。请参阅如何正确和完全关闭/重置 TcpClient 连接?对于初学者。

相关内容

  • 没有找到相关文章

最新更新