通过异步/等待进行服务器通信？

我想创建通过 async/await 通过 TAP 发送的 Socket 消息。

看完之后这个答案 and this one- 我决定创建一个完全工作的示例：

那么我尝试了什么：

我从以下位置获取了 TAP 扩展方法here（一切正常）：我在控制台cmd中测试它：

接收者代码

public static class SocketExtensions
{
    public static Task<int> ReceiveTaskAsync(this Socket socket, byte[] buffer, int offset, int count)
    {
        return Task.Factory.FromAsync<int>(
                         socket.BeginReceive(buffer, offset, count, SocketFlags.None, null, socket),
                         socket.EndReceive);
    }

    public static async Task<byte[]> ReceiveExactTaskAsync(this Socket socket, int len)
    {
        byte[] buf = new byte[len];
        int totalRead = 0;
        do{
            int read = await ReceiveTaskAsync(socket, buf, totalRead, buf.Length - totalRead);
            if (read <= 0) throw new SocketException();
            totalRead += read;
        }while (totalRead != buf.Length);
        return buf;
    }

    public static Task ConnectTaskAsync(this Socket socket, string host, int port)
    {
        return Task.Factory.FromAsync(
                         socket.BeginConnect(host, port, null, null),
                         socket.EndConnect);
    }

    public static Task SendTaskAsync(this Socket socket, byte[] buffer)
    {
        return Task.Factory.FromAsync<int>(
                         socket.BeginSend(buffer, 0, buffer.Length, SocketFlags.None, null, socket),
                         socket.EndSend);
    }
}
static   void  Main()
{
      Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
      s.ConnectTaskAsync("127.0.0.1", 443);


      var buf1 =    s.ReceiveExactTaskAsync(100); //read exactly 100 bytes
      Console.Write(Encoding.UTF8.GetString(buf1.Result)); 

      var buf2 =   s.ReceiveExactTaskAsync(100); //read exactly 100 bytes
      Console.Write(Encoding.UTF8.GetString(buf2.Result));

      Console.ReadLine();
}

发件人代码：

// use same extension method class like above ....^

   void  Main()
    {
     Socket s = new Socket(SocketType.Stream    , ProtocolType.Tcp);
     s.ConnectTaskAsync( "127.0.0.1" , 443);
     s.SendTaskAsync(Encoding.UTF8.GetBytes("hello"));

     s.Close();
     Console.ReadLine();
    }

请注意我删除了async从 main 开始，因为我在控制台中测试它。

问题 ，

根据上面的链接，代码应该可以工作

然而我没有得到任何例外，它只是挂在那条线上：

Console.Write(Encoding.UTF8.GetString(buf1.Result));

（首先我运行接收者，然后运行发送者）

我缺少什么？

问题来自于“请注意，自从我在控制台中测试它以来，我从 main 中删除了异步。".

您需要等待操作完成才能进行下一步。您用作示例的代码在每次暂停await为了完成操作，您的代码将直接执行。

您可以通过放置来解决此问题.Wait()每次操作后都会有一个await或者通过在线程池线程内运行此函数Task.Run(, however我认为最好知道什么时候应该使用异步，什么时候不应该使用异步。

当您有其他工作可以让线程执行时，应该使用异步，很常见的是，“其他工作”是处理 WinForms 项目上的 UI 消息或接受 ASP.NET 站点上的新连接。在控制台应用程序中，程序在等待时无法执行其他工作，因此在这种情况下，使用函数的同步版本会更合适。

P.S. You made the comment after I posted "that's why I remove the async awaits and used Task.result", just so you know never ever¹ combine code that uses await and code that blocks the synchronization contest (by using things like Task.Result or Task.Wait(), you will likely cause your code to deadlock and stop functioning!

对于您当前的示例来说，这不是问题，因为控制台应用程序没有同步上下文，但如果您将此代码复制并粘贴到具有同步上下文的内容中，您可以轻松锁定您的程序。

^{1: Ok, you could combine await and blocking code but there are rules you need to follow, but if you know enough to dispute my what I am saying you know enough to safely do it. If you don't know how to safely do it just avoid doing it}