调整缓冲区长度以从 NetworkStream 读取小数据

Question

从 TcpClient/NetworkStrem 读取小数据时如何微调 bufferSize？ 如果 bufferSize 很大，例如 1024、4096，则 Read/BeginRead 会阻塞。 如果我将 bufferSize 设置为 16、32，它就不会阻塞。

• 将 bufferSize 设置为 1 是否可以保证不会出现任何块？性能影响会不会很差？

• 看起来将 ReadTimeout 设置为 1000、2000 之类的值有 没有超过阻塞的效果。有没有其他方法可以阻止 矮吗？ （NoDelay = true 不起作用）

  public static IObservable; AsyncReadChunk(此 Stream 流，int bufferSize)
  {
      var buffer = new byte[bufferSize];
  
      返回 Observable.FromAsyncPattern(stream.BeginRead, stream.EndRead)(buffer, 0, bufferSize)
          .Select(cbRead =>
                      {
                          var dataChunk = 新字节[cbRead];
  
                          Buffer.BlockCopy(缓冲区, 0, dataChunk, 0, cbRead);
  
                          返回数据块；
                      });
  }
  
  公共静态 IObservable AsyncRead（此 NetworkStream 流，int bufferSize）
  {
      return Observable.Defer(() => stream.DataAvailable ? AsyncReadChunk(stream, bufferSize) : Observable.Return(new byte[0]))
          。重复（）
          .TakeWhile((dataChunk, index) => dataChunk.Length > 0);
  }
  

Answer 1

看起来像是设置
ReadTimeout 设置为 1000、2000 等值对阻塞没有影响。

Msdn 说，使用异步 BeginRead 方法时，ReadTimeout 不起作用。

将 bufferSize 设置为 1 是否可以保证不会出现任何块？

不，当然不是。当没有通过连接发送单个字节时，无论缓冲区大小如何，Read 调用都会阻塞。

性能影响会很严重吗？

我猜你在这里谈论的是 1 字节缓冲区。
这取决于您接收的数据量和频率以及您在 EndRead 上执行的代码。当处理高带宽的流时，影响可能很大。你必须在接收数据时尝试观察你的CPU。

我不太确定您想要实现什么目标以及您对阻止的担忧是什么。

当您使用 1024 字节的缓冲区启动 Receive（或 Networkstream.Read）时，并且您在套接字上接收 10 字节，Read 调用将在短暂延迟后返回该 10 字节，但在整个缓冲区填满之前不会阻塞。

还有其他方法可以缩短阻塞时间吗？

短是什么意思。正如我所说，即使有很大的缓冲区，读取在接收少量数据时也不会无限阻塞。

（NoDelay = true 不起作用）

完全不同的故事，但在发件人端将其设置为 true 可能会很有趣（如果您也可以控制的话）。

当设置为 false（默认值）时，它将把发送的小数据块组合成大数据块，以减少一个 tcp 数据包（40 字节标头）的开销。

编辑

我的意思是 NetworkStream.BeginRead 在没有数据的情况下立即返回。

使用stream.DataAvailable怎么样？当没有数据时它应该返回 false。

此外，当使用异步模式时，调用会阻塞直到有事情要做，这不是预期的行为吗？否则，您将在繁忙的循环中进行主动轮询。

当缓冲区很大时，有时会等待 60 秒才能返回（当缓冲区未完全填充或填充到一定数量时）

嗯，简直不敢相信。您通过通道发送什么类型的数据？每分钟 1 个字节？每秒 1000 字节？