从 .NET 中的 NetworkStream 读取的正确方法是什么

我一直在努力解决这个问题，但找不到我的代码无法从我也编写的 TCP 服务器正确读取的原因。我正在使用TcpClient类及其GetStream()方法，但有些东西没有按预期工作。要么操作无限期地阻塞（最后一个读取操作没有按预期超时），要么数据被裁剪（由于某种原因读取操作返回 0 并退出循环，也许服务器响应速度不够快）。这是实现此功能的三种尝试：

// this will break from the loop without getting the entire 4804 bytes from the server 
string SendCmd(string cmd, string ip, int port)
{
    var client = new TcpClient(ip, port);
    var data = Encoding.GetEncoding(1252).GetBytes(cmd);
    var stm = client.GetStream();
    stm.Write(data, 0, data.Length);
    byte[] resp = new byte[2048];
    var memStream = new MemoryStream();
    int bytes = stm.Read(resp, 0, resp.Length);
    while (bytes > 0)
    {
        memStream.Write(resp, 0, bytes);
        bytes = 0;
        if (stm.DataAvailable)
            bytes = stm.Read(resp, 0, resp.Length);
    }
    return Encoding.GetEncoding(1252).GetString(memStream.ToArray());
}

// this will block forever. It reads everything but freezes when data is exhausted
string SendCmd(string cmd, string ip, int port)
{
    var client = new TcpClient(ip, port);
    var data = Encoding.GetEncoding(1252).GetBytes(cmd);
    var stm = client.GetStream();
    stm.Write(data, 0, data.Length);
    byte[] resp = new byte[2048];
    var memStream = new MemoryStream();
    int bytes = stm.Read(resp, 0, resp.Length);
    while (bytes > 0)
    {
        memStream.Write(resp, 0, bytes);
        bytes = stm.Read(resp, 0, resp.Length);
    }
    return Encoding.GetEncoding(1252).GetString(memStream.ToArray());
}

// inserting a sleep inside the loop will make everything work perfectly
string SendCmd(string cmd, string ip, int port)
{
    var client = new TcpClient(ip, port);
    var data = Encoding.GetEncoding(1252).GetBytes(cmd);
    var stm = client.GetStream();
    stm.Write(data, 0, data.Length);
    byte[] resp = new byte[2048];
    var memStream = new MemoryStream();
    int bytes = stm.Read(resp, 0, resp.Length);
    while (bytes > 0)
    {
        memStream.Write(resp, 0, bytes);
        Thread.Sleep(20);
        bytes = 0;
        if (stm.DataAvailable)
            bytes = stm.Read(resp, 0, resp.Length);
    }
    return Encoding.GetEncoding(1252).GetString(memStream.ToArray());
}

最后一个“有效”，但考虑到套接字已经支持读取超时，将硬编码的睡眠放入循环中确实看起来很难看！我是否需要在TcpClient of the NetworkStream？问题是否出在服务器上？服务器不会关闭连接，这取决于客户端。上面的内容也在UI线程上下文（测试程序）内运行，也许与此有关......

有人知道如何正确使用吗NetworkStream.Read读取数据直到没有更多数据可用？我想我想要的是旧的 Win32winsock 超时属性之类的东西......ReadTimeout等等。它尝试读取直到达到超时，然后返回0...但有时当数据应该可用时它似乎返回0（或者在途中..如果可用的话可以读取返回0吗？）并且它然后，当数据不可用时，在最后一次读取时无限期地阻塞...

是的，我很茫然！

众所周知，网络代码很难编写、测试和调试。

您经常需要考虑很多事情，例如：

• 您将使用什么“字节序”来交换数据（Intel x86/x64 基于小字节序） - 使用大字节序的系统仍然可以读取小字节序的数据（反之亦然），但它们必须重新排列数据。在记录您的“协议”时，只需明确您正在使用哪一个即可。

• 套接字上是否设置了任何可能影响“流”行为方式的“设置”（例如 SO_LINGER） - 如果您的代码非常敏感，您可能需要打开或关闭某些设置

• 现实世界中导致流延迟的拥塞如何影响您的读/写逻辑

如果客户端和服务器之间（任一方向）交换的“消息”大小可能不同，那么您通常需要使用某种策略，以便以可靠的方式（也称为协议）交换该“消息”。

以下是处理交换的几种不同方法：

• 将消息大小编码在数据之前的标头中 - 这可能只是发送的前 2/4/8 字节中的“数字”（取决于您的最大消息大小），或者可能是更奇特的“标头”

• 使用特殊的“消息结束”标记（哨兵），如果实际数据可能与“标记结束”混淆，则对实际数据进行编码/转义

• 使用超时......即在一定时间内没有接收到字节意味着该消息没有更多数据 - 但是，如果超时很短，这可能很容易出错，这很容易在拥塞的流上遇到。

• 在单独的“连接”上有一个“命令”和“数据”通道......这是 FTP 协议使用的方法（优点是数据与命令清晰分离......以第二个连接为代价）

每种方法对于“正确性”都有其优点和缺点。

下面的代码使用“超时”方法，因为这似乎就是您想要的方法。

See http://msdn.microsoft.com/en-us/library/bk6w7hs8.aspx。您可以访问NetworkStream on the TCPClient所以你可以改变ReadTimeout.

string SendCmd(string cmd, string ip, int port)
{
  var client = new TcpClient(ip, port);
  var data = Encoding.GetEncoding(1252).GetBytes(cmd);
  var stm = client.GetStream();
  // Set a 250 millisecond timeout for reading (instead of Infinite the default)
  stm.ReadTimeout = 250;
  stm.Write(data, 0, data.Length);
  byte[] resp = new byte[2048];
  var memStream = new MemoryStream();
  int bytesread = stm.Read(resp, 0, resp.Length);
  while (bytesread > 0)
  {
      memStream.Write(resp, 0, bytesread);
      bytesread = stm.Read(resp, 0, resp.Length);
  }
  return Encoding.GetEncoding(1252).GetString(memStream.ToArray());
}

作为编写网络代码的其他变体的脚注......当做一个Read如果您想避免“阻塞”，您可以检查DataAvailable标志，然后只读取缓冲区中的内容检查.Length财产例如stm.Read(resp, 0, stm.Length);