.NET 异步 TcpListener / TcpClient 问题

Question

对于如何正确实现 TcpListner 和 TcpClient int .NET 的异步方法，我有点不知所措。我已经阅读了很多关于hear 的帖子，我相信我有代码可以在服务器上接受新客户端。下面是接受新连接的代码：

Public Sub Start()
    m_oListener = New TcpListener(m_oIpAddress, m_iPort)

    m_oListener.Start()
    m_oListener.BeginAcceptTcpClient(New AsyncCallback(AddressOf OnAcceptClient), m_oListener)
End Sub

Public Sub OnAcceptClient(ByVal ar As IAsyncResult)
    Dim listener As TcpListener = CType(ar.AsyncState, TcpListener)
    Dim client As TcpClient = listener.EndAcceptTcpClient(ar)

    If listener.Server.IsBound Then
        ThreadPool.QueueUserWorkItem(New WaitCallback(AddressOf OnHandleClient), client)
        listener.BeginAcceptTcpClient(New AsyncCallback(AddressOf OnAcceptClient), listener)
    End If
End Sub

我不确定的是，一旦建立连接，客户端该怎么做。据我所知，通常人们会为每个连接的客户端创建一个新线程，以防止 IO 读取阻塞应用程序。

我的应用程序将在任何给定时间连接多达 100 个客户端。如果我为每个客户分拆一个新线程，那么我将拥有 100 个左右的线程。那是对的吗？我想我只是缺少 .NET 框架中的异步方法。

我看到的大多数示例都让服务器接受连接，读入一条短消息（例如“hello server”），然后关闭客户端并关闭服务器。这并不能帮助我理解在很长一段时间内保持大量活跃客户的正确方法。

提前感谢您的帮助。

Answer 1

一旦您在OnAcceptClient 回调中提取了对TcpClient 的引用，您将希望通过GetStream 获取NetworkStream，然后立即调用BeginRead（或BeginWrite）以启动异步手术。在您从回调中调用EndRead 之后，您将链接下一个BeginRead，就像您对TcpListener 所做的那样。

Answer 2

您可以有 100 个线程，每个线程都处理一个客户端，这很好。您还可以有一个线程循环遍历所有客户端并异步处理 I/O。

通过使这种异步方式，您不必担心单线程处理每个连接需要很长时间。

如果您要扩展的规模远高于您所说的，那么每个线程处理多个客户端将是必要的。

伪代码：

foreach TcpClient
    if DataAvailable
        BeginRead()