使用 Net.Sockets.TcpListener 时,在单独的线程中处理传入连接 (.AcceptSocket) 的最佳方法是什么?
这个想法是在接受新的传入连接时启动一个新线程,而 tcplistener 然后保持可用于进一步的传入连接(并且为每个新传入连接创建一个新线程)。与发起连接的客户端的所有通信和终止都将在线程中处理。
VB.NET 代码的示例 C# 表示赞赏。
使用 Net.Sockets.TcpListener 时,在单独的线程中处理传入连接 (.AcceptSocket) 的最佳方法是什么?
这个想法是在接受新的传入连接时启动一个新线程,而 tcplistener 然后保持可用于进一步的传入连接(并且为每个新传入连接创建一个新线程)。与发起连接的客户端的所有通信和终止都将在线程中处理。
VB.NET 代码的示例 C# 表示赞赏。
我一直在使用的代码如下所示:
class Server
{
private AutoResetEvent connectionWaitHandle = new AutoResetEvent(false);
public void Start()
{
TcpListener listener = new TcpListener(IPAddress.Any, 5555);
listener.Start();
while(true)
{
IAsyncResult result = listener.BeginAcceptTcpClient(HandleAsyncConnection, listener);
connectionWaitHandle.WaitOne(); // Wait until a client has begun handling an event
connectionWaitHandle.Reset(); // Reset wait handle or the loop goes as fast as it can (after first request)
}
}
private void HandleAsyncConnection(IAsyncResult result)
{
TcpListener listener = (TcpListener)result.AsyncState;
TcpClient client = listener.EndAcceptTcpClient(result);
connectionWaitHandle.Set(); //Inform the main thread this connection is now handled
//... Use your TcpClient here
client.Close();
}
}
我相信您的操作方式与 .NET 中的任何其他异步操作相同:您调用该方法的 BeginXxx 版本,在本例中为 BeginAcceptSocket。您的回调将在线程池上执行。
池化线程的扩展性通常比每个连接的线程好得多:一旦超过几十个连接,系统在线程之间切换的工作比完成实际工作要困难得多。此外,每个线程都有自己的堆栈,通常大小为 1MB(尽管它取决于链接标志),必须在 2GB 虚拟地址空间(在 32 位系统上)中找到;实际上,这将您限制为少于 1000 个线程。
我不确定 .NET 的线程池当前是否使用它,但 Windows 有一个称为 I/O 完成端口的内核对象,它有助于可扩展的 I/O。您可以将线程与此对象关联,并且 I/O 请求(包括接受传入连接)可以与它关联。当 I/O 完成(例如连接到达)时,Windows 将释放等待线程,但前提是当前可运行线程的数量(由于其他原因未阻塞)小于为完成端口配置的可伸缩性限制。通常,您会将其设置为内核数量的一小部分。
我想提出一种不同的方法:我的建议只使用两个线程。* 一个线程检查传入的连接。* 当一个新连接打开时,此信息将写入一个共享数据结构,该结构包含所有当前打开的连接。* 第二个线程枚举该数据结构,并为每个打开的连接接收发送的数据并发送回复。
该解决方案在线程方面更具可扩展性,如果正确实施应该具有更好的性能,然后为每个打开的连接打开一个新线程。
O'Reilly C# 3.0 Cookbook 中有一个很好的例子。您可以从以下位置下载随附的源代码http://examples.oreilly.com/9780596516109/CSharp3_0CookbookCodeRTM.zip
我会使用线程池,这样你就不必每次都启动一个新线程(因为这有点贵)。我也不会无限期地等待更多的连接,因为客户端可能不会关闭他们的连接。您打算如何每次将客户端路由到同一个线程?
对不起,没有样品。