c# – 将流写入文件无法正常工作

2023年12月27日 171次阅读

我正在制作一个程序,通过TCP传输文件块.现在,每次我在最后传输一个文件似乎都没有写入,所以如果我尝试传输图片 at the bottom right there are glitches.

现在,我的第一个想法是,当我读取,传输和写入比缓冲区长度更小的最终块时,我也写了很多零.所以我试着相应地改变最后的缓冲区大小.然后我尝试使用一个只写有HELLO WORLD的小文本文件,但是当我将其写入,然后打开文件时,它是空的.

这是读取和发送代码,其中范围[0]是第一部分,范围[1]是最后一部分：

byte[] buffer = new byte[DATA_BUFF_SIZE];
using (Stream input = File.OpenRead(file.Path))
{
    Console.WriteLine("SENT PARTS # ");
    for (int i = range[0]; i <= range[1]; i++)
    {
        Console.Write("PART " + i + ", ");

        if (i == range[1])
        {
            buffer = new byte[input.Length - input.Position];
        }

        input.Position = i * DATA_BUFF_SIZE;
        input.Read(buffer, 0, buffer.Length);

        netStream.Write(buffer, 0, buffer.Length);

    }
    Console.WriteLine("LENGTH = " + input.Length);
}

这是接收和编写代码：

int bytesReceived = 0;
int index = partRange.First;
int partNum = 0;
byte[] receiveBuffer = new byte[BUFF_SIZE];

if (index == partRange.Last)
{
    receiveBuffer = new byte[fileToDownload.Length - index * BUFF_SIZE];
}

while ((bytesReceived = netStream.Read(receiveBuffer, 0, receiveBuffer.Length)) > 0)
{
    Console.Write("INDEX:" + index + ", ");
    output.Position = index * BUFF_SIZE;
    output.Write(receiveBuffer, 0, receiveBuffer.Length);
    index++;
    partNum++;

    if (partNum > (partRange.Last - partRange.First))
    {
        break;
    }

    if (index == partRange.Last)
    {
        receiveBuffer = new byte[fileToDownload.Length - index * BUFF_SIZE];
    }
}
Console.WriteLine();

我错过了什么？我甚至在客户端和服务器上打印出缓冲区,它是相同的.

任何帮助将不胜感激,谢谢.

最佳答案 试试netStream.Flush();

我怀疑正在发生的事情是在写完成之前流正在关闭.有时输出流将继续异步写入.在处理文件流时也会发现这一点.在继续执行之前,使用Flush()强制流完成它正在执行的任何写操作.

点赞