10

我有一个应用程序可以同时建立几百个 TCP 连接，并从它们那里接收到源源不断的数据流。

 private void startReceive()
    {
        SocketAsyncEventArgs e = new SocketAsyncEventArgs();
        e.Completed += receiveCompleted;
        e.SetBuffer(new byte[1024], 0, 1024);
        if (!Socket.ReceiveAsync(e)) { receiveCompleted(this, e); }  
    }

    void receiveCompleted(object sender, SocketAsyncEventArgs e)
    {
        ProcessData(e);

        if (!Socket.ReceiveAsync(e)) { receiveCompleted(this, e); }
    }

我的尝试导致了这样的事情：

private async void StartReceive()
    {
        byte[] Buff = new byte[1024];
        int recv = 0;
        while (Socket.Connected)
        {
            recv = await NetworkStream.ReadAsync(Buff, 0, 1024);
            ProcessData(Buff,recv);
        }
    }

我遇到的问题是方法调用StartReceive()会阻塞，并且无论如何都不会到达随附的StartSend() method called afterStartReceive() . Creating a new task forStartReceive() would just end up with 300-ish threads, and it seems to do so just by callingStartReceive()`。

在使用 a 时在现有代码上实现 newasync和关键字的正确方法是什么，因此它正在使用线程池来避免必须拥有数百个线程/任务？awaitNetworkStreamSocket.SendAsync()Socket.ReceiveAsync()

networkstream以这种方式使用 i/o 完成端口是否有任何性能优势beginreceive？

4

1 回答 1

26

您在这里一次更改了两件事：异步样式（SocketAsyncEventArgsto Task/ async）和抽象级别（Socketto NetworkStream）。

既然您已经习惯了Socket，我建议您只更改异步样式，并继续Socket直接使用该类。

Async CTP 没有提供Socket任何async兼容的方法（这很奇怪；我认为它们被错误地遗漏了，并将在 .NET 4.5 中添加）。

如果您使用我的AsyncEx 库，创建自己的ReceiveAsyncTask扩展方法（以及其他操作的类似包装器）并不难：

public static Task<int> ReceiveAsyncTask(this Socket socket,
    byte[] buffer, int offset, int size)
{
  return AsyncFactory<int>.FromApm(socket.BeginReceive, socket.EndReceive,
      buffer, offset, size, SocketFlags.None);
}

一旦你这样做，你StartReceive可以这样写：

private async Task StartReceive()
{
  try
  {
    var buffer = new byte[1024];
    while (true)
    {
      var bytesReceived = await socket.ReceiveAsyncTask(buffer, 0, 1024)
          .ConfigureAwait(false);
      ProcessData(buffer, bytesReceived);
    }
  }
  catch (Exception ex)
  {
    // Handle errors here
  }
}

现在，要解决许多小问题：

  • await不会产生新线程。我和其他许多人一样，在我的博客上写了一个 async/await 介绍。async/await允许并发，但这并不一定意味着多线程。
  • 数百个线程可能会出现问题。但是，数百个任务根本不是问题。线程池和 BCL 旨在处理很多很多任务。
  • async/await不是一种全新的异步处理形式；这只是表达异步处理的一种更简单的方法。它仍然在下面使用 IOCP。 /比低级方法的性能略低；它的吸引力在于易于编写和组合异步方法。asyncawait
  • async一个非常繁忙的系统在切换到/时会看到一些增加的 GC 压力await。Parallel 团队的 Stephen Toub写了一些示例 socket-specific awaitables可以帮助解决这个问题。（我建议首先使用简单的模式，并且仅在您认为有必要时才使用性能增强的方法；不过，如果您最终需要它，知道它就在那里是件好事）。
  • 异步方法应该返回Task，除非你真的需要它们返回void。Task是等待的，所以你的方法是可组合的（并且更容易测试）；void更像是“一劳永逸”。
  • 您可以调用ConfigureAwait(false)以告诉方法的其余部分async在线程池线程上执行。我在上面的示例中使用它，以便ProcessData在线程池线程中执行，就像使用SocketAsyncEventArgs.
  • Socket.Connected没用。您需要发送数据来检测连接是否仍然有效。
于 2012-03-17T02:43:54.660 回答