时间戳

首页 > 解决方案 > C# TcpClient 从流中读取或获取不完整的数据

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

问题描述

我有一个模拟视频流的 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();

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

标签： c#tcpclientnetworkstream

解决方案

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

您与 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 仍然非常低级。

推荐阅读