C# TcpClient 从流中读取或获取不完整的数据答案

【问题标题】：C# TcpClient reading or getting incomplete data from streamC# TcpClient 从流中读取或获取不完整的数据
【发布时间】：2020-02-07 17:14:38
【问题描述】：

我有一个模拟视频流的 exe。我连接到它并偶尔读取预期的数据，但通常我只得到前 28 个字节，然后是 65508 个字节的零。假设视频流正常工作。

TcpClient tcpClient = new TcpClient ();

int port = 13000;
myIP = IPAddress.Loopback.ToString();

tcpClient.Connect (myIP, port);
NetworkStream netStream = tcpClient.GetStream ();

byte[] bytes = new byte[tcpClient.ReceiveBufferSize];

netStream.Read (bytes, 0, (int)tcpClient.ReceiveBufferSize);

string dataString = Encoding.ASCII.GetString (bytes);

Console.WriteLine("\ndataString: "+dataString.Substring(0,1000));
Console.WriteLine("\nnumber of bytes read: "+bytes.Length); 

tcpClient.Close ();
// Closing the tcpClient instance does not close the network stream.
netStream.Close();

我怎样才能做到每次都能得到预期的输出？

【问题讨论】：

您的代码不正确。应该是var readCount = netStream.Read(bytes, 0, bytes.Length); […] Console.WriteLine("Number of bytes read: “ + readCount);。另外为什么要将二进制数据转换为文本字符串？在您显示的代码中，您从哪里获得 28 和 65508 号码？
扩展ckun的评论：NetworkStream.Read返回读取的字节数。超出此范围的缓冲区 (bytes) 中的任何内容都不适合消费。 TCP 只保证发送的字节按顺序到达，不重复。不能保证，例如，发送的 64 个字节不会以 3 个一组的形式到达，并且在最后一次读取时不会到达一个字节。
ckuri - 我将其转换为字符串，以便将其打印到控制台。我需要操作二进制文件，我认为它可以帮助我想象我需要做什么。

标签： c# tcpclient networkstream

【解决方案1】：

TCP 表示（双向）数据流。您应该循环读取它，并根据需要解析数据。它没有 messages 的概念 - 一侧的十次写入可以导致另一侧的一次读取，就像一侧的一次写入可以导致另一侧的十次读取一样容易.

您与 TCP 的合同如下：

如果接收缓冲区中有数据，Read 会立即返回，用您提供的尽可能多的数据填充缓冲区，直到缓冲区的长度。读取的字节数为Read的返回值。
如果接收缓冲区中没有数据，Read 将阻塞直到至少有一个字节的数据。然后就像第一种情况一样。
如果另一方关闭套接字，Read 将返回零。

所以要让 TCP 工作，你需要一个循环。你如何形成循环取决于你想要做什么。如果您真的在处理逻辑上是流的数据（例如音频数据），请尽可能快地阅读并处理收到的任何数据。如果您需要发送消息，则需要实现消息协议。如果您需要一次性消息，您可以继续阅读，直到 Read 返回零。

您的情况可以使用第一种方法处理 - 继续阅读直到流关闭，然后将接收到的数据向前推送。假设数据实际上是 UTF8 文本流，基本接收器看起来像这样：

using (var client = new TcpClient())
{
  tcpClient.Connect(myIP, port);

  var stream = client.GetStream();
  var buffer = new byte[4096]; // Adapt the size based on what you want to do with the data
  var charBuffer = new char[4096];
  var decoder = Encoding.UTF8.GetDecoder();

  int bytesRead;
  while ((bytesRead = stream.Read(buffer, 0, buffer.Length)) != 0)
  {
    var expectedChars = decoder.GetCharCount(buffer, 0, bytesRead);
    if (charBuffer.Length < expectedChars) charBuffer = new char[expectedChars];

    var charCount = decoder.GetChars(buffer, 0, bytesRead, charBuffer, 0);
    Console.Write(new string(charBuffer, 0, charCount));
  }

  client.Close();
}

请注意，这不会进行错误处理，因此不要在任何生产代码中使用它。如果您期望有多个同时连接，您可能还想使用Async 方法。这只是为了说明处理通过 TCP 接收的数据流的基本方式。

如果您想更深入地了解如何处理 TCP，我在https://github.com/Luaancz/Networking 提供了一些非常简单的示例。我还没有找到任何好的 C# 教程或代码示例，所以如果这还不够，您可能需要深入研究有关套接字、TCP 等的文档。

或者只是使用现有的网络库，而不是尝试编写自己的 :) TCP 仍然非常低级。

【讨论】：