我需要创建一个接受并保持很长时间连接(透视超过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 个客户端后计算变量增量非常慢,而且会出现大量内存使用的问题。我做错了什么以及如何解决这个问题?
内存问题可能是由于未释放非托管资源引起的。TcpClient
和NetworkStream
都实现了 IDisposable,应包装在Using
块中或手动关闭/处置。请参阅如何正确和完全关闭/重置 TcpClient 连接?对于初学者。