带有等待和异步的 C#5.0 异步 TCP/IP 服务器

Question

我已经写了以下 Tcp Server 应用程序。问题是它没有并行执行单个客户端。也就是说，如果连接了一个客户端，则服务器不接受与其他客户端的连接。请帮我修复代码：

void Run()
{
    tcpListener.Start();           

    while (true)
    {
        Console.WriteLine("Waiting for a connection...");

        try
        { 
            var client = await tcpListener.AcceptTcpClientAsync();
            await Accept(client);
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.Message);
        }
    }
}

private async Task Accept(TcpClient client)
{
    //get client information 
    string clientEndPoint = GetClientIPAddress(client);            
    Console.WriteLine("Client connected at " + clientEndPoint);
    log.Info("Client connected at " + clientEndPoint);

    await Task.Yield (); 

    try 
    {              
        using (client) 
            using (NetworkStream stream = client.GetStream ()) 
            { 
                byte[] dataReceived = new byte [50];                  
                while (await stream.ReadAsync(dataReceived, 0, dataReceived.Length) != 0) //read input stream                
                {                    
                    //process data here                        
                    await ProcessData(dataReceived);                      
                }                   
            }
    } //end try
    catch (Exception ex) 
    {
        Console.WriteLine(ex.Message);                
        if (client.Connected)
            client.Close();
    }
} //end Accept(TcpClient client)

Answer 1

问题是这样的：

await Accept(client);

您正在等待Accept 的结果，因此您无法接受新连接（因为您没有执行AcceptTcpClientAsync 而Accept 处于“运行中”）。

这是一个如何正确完成的示例：https://stackoverflow.com/a/21018042/1768303。