c# - 通过异步/等待的服务器通信？

Question

我想通过异步/等待创建通过 TAP 发送的套接字消息。

看完this answer和 this one - 我决定创建一个完整的示例:

那么我尝试了什么:

我从 here 中获取了 TAP 扩展方法(一切正常):我在控制台 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();
    }

请注意，我从 main 中删除了 async，因为我在控制台中对其进行了测试。

问题，

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

但是我没有异常(exception)，它只是卡在那条线上:

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

(首先运行接收方，然后运行发送方)

我错过了什么？

Answer 1

问题来自“注意我从 main 中删除了异步，因为我在控制台中对其进行了测试。”。

您需要等待操作完成才能进行下一步。您用作示例的代码在每个 await 处暂停以等待操作完成，您的代码直接通过。

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

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

---

附言你在我发布“这就是为什么我删除异步等待并使用 Task.result”后发表了评论，这样你就知道永远不会曾经¹结合使用 await 的代码和阻止同步竞争的代码(通过使用 Task.Result 或 Task.Wait() 之类的代码，您将可能会导致您的代码死锁并停止运行!

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

^{1:好的，您可以结合使用 await 和阻塞代码，但是您需要遵守一些规则，但是如果您知道的足以反驳我所说的，那么您就知道足够安全做吧。如果您不知道如何安全地这样做，那就避免这样做}