通过 NetworkStream 传输项目会导致某些数据被破坏

Question

我正在发送文件名（字符串）、文件大小（int）和文件（字节[]）。发生的情况是，在某些情况下，根据服务器端处理数据的速度，NetworkStream 读取了我还不需要的数据。

示例：我执行 .Read 来获取文件名，我将获取文件名、文件大小和文件原始数据的数据。我认为发生这种情况是因为服务器只是执行 .Write 并将数据写入流，而第一个 .Read 尚未执行。这最终会破坏我的文件大小。阅读。现在，当我对文件大小执行 .Read 时，我会显示一个巨大的数字，当我去读取文件本身并根据读取的文件大小分配一个新的 byte[] 时，我会收到 OutOfMemory 异常。

如何正确同步读取？我在网上找到的例子都是按照我的方式做的。

一些代码：

   private void ReadandSaveFileFromServer(TcpClient clientATF, NetworkStream currentStream, string locationToSave)
    {
        int fileSize = 0;
        string fileName = "";
        int readPos = 0;
        int bytesRead = -1;

        fileName = ReadStringFromServer(clientATF, currentStream);

        fileSize = ReadIntFromServer(clientATF, currentStream);


        byte[] fileSent = new byte[fileSize];

        while (bytesRead != 0)
        {
            if (currentStream.CanRead && clientATF.Connected)
            {

                bytesRead = currentStream.Read(fileSent, readPos, fileSent.Length);

                readPos += bytesRead;
                if (readPos == bytesRead)
                {
                    break;
                 }

            }
            else
            {
                WriteToConsole("Log Transfer Failed");
                break;
            }
        }
        WriteToConsole("Log Recieved");

        File.WriteAllBytes(locationToSave + "\\" + fileName, fileSent);


    }


 private string ReadStringFromServer(TcpClient clientATF, NetworkStream currentStream)
    {
        int i = -1;
        string builtString = "";
        byte[] stringFromClient = new byte[256];



            if (clientATF.Connected && currentStream.CanRead)
            {

                i = currentStream.Read(stringFromClient, 0, stringFromClient.Length);
                builtString = System.Text.Encoding.ASCII.GetString(stringFromClient, 0, i);

            }

            else
            {
                return "Connection Error";
            }



        return builtString;

    }

    private int ReadIntFromServer(TcpClient clientATF, NetworkStream currentStream)
    {
        int i = -1 ;
        int builtInteger = 0;
        byte[] integerFromClient = new byte[256];
        int offset = 0;


            if (clientATF.Connected && currentStream.CanRead)
            {

                i = currentStream.Read(integerFromClient, offset, integerFromClient.Length);

                builtInteger = BitConverter.ToInt32(integerFromClient, 0);

            }

            else
            {
                return -1;
            }



        return builtInteger;
    }

我尝试使用偏移量......没有麻烦。感谢您的帮助。

我开始了另一个问题，但它与其他事情有关。

提前致谢 肖恩

编辑：这是我的发送字符串代码：

  private void SendToClient( TcpClient clientATF,  NetworkStream currentStream, string messageToSend)
    {
        byte[] messageAsByteArray = new byte[256];

        messageAsByteArray = Encoding.ASCII.GetBytes(messageToSend);

        if (clientATF.Connected && currentStream.CanWrite)
        {
            //send the string to the client

                currentStream.Write(messageAsByteArray, 0, messageAsByteArray.Length);

        }

    }

Answer 1

Read() 你调用它的方式将拉取 256 个字节；这就是 stringFromClient.Length 的设置。

您有两种选择来准确地分割数据流，这两种选择都涉及了解或创建某种确定数据之间边界的方法。它们是定界流和固定长度流。

对于分隔格式，您选择一个不会用作文件名或大小的有效部分的字符（管道、空格、制表符、换行符等），并在文件名和大小之间以及文件名和大小之间插入一个字符。大小和文件内容。然后，一次将一个字节读入数组，直到遇到分隔符。到目前为止，除了分隔符之外，您已读取的字节都是您的数据；提取成可用的形式并返回。这通常会使流变短，但需要一个可能的字符永远不会被使用。

对于固定大小的格式，确定数据的任何合理值都不会超过的字节数。例如，文件名不能超过 256 个字符（更可能不超过 50 个字符；一些较旧/较简单的操作系统仍限制为 8 个字符）。在任何 Windows 环境中，文件大小都不能超过 2^64 字节，并且该数字可以用 4 字节的原始数字数据或 20 个字符串字符来表示。因此，无论您选择什么限制，都应使用适当的缓冲区填充数据；对于原始数字，转换为 Int64 并将其切成字节，而对于字符串，则用空格填充。然后，您知道前 X 个字节将是文件名，接下来的 Y 个字节将是文件大小，之后的任何内容都是内容。这使得流更大，但内容可以是任何内容，因为没有特殊或保留的字节值。

Answer 2

TCP/IP 是流式传输，而不是数据报，因此您想要的行为不存在。您可以通过让流包含足够的信息来解决这个问题。

换句话说，您可以使用分隔符，例如一行文本后的 CR/LF，或者可以给出即将到来的数据片段的长度。您还可以在适当的情况下使用固定大小的字段。

Answer 3

您不能依赖一次从流中读取的字节数，您的 ReadStringFromServer 方法中存在错误，假设字符串具有固定长度（256）。

而不是：

 i = currentStream.Read(stringFromClient, 0, stringFromClient.Length);
 builtString = System.Text.Encoding.ASCII.GetString(stringFromClient, 0, i);

尝试：

 do
 {
    i = currentStream.Read(stringFromClient, 0, 256 - builtString.Length);
    builtString+=(System.Text.Encoding.ASCII.GetString(stringFromClient, 0, i));
 } while(builtString.Length < 256)

Answer 4

更好的解决方案可能是将所有数据序列化（例如，转换为 JSON）并通过网络流传递所有内容。