C＃TCP NetworkStream带有文件流丢失数据

Question

我正在编程一个需要进行文件传输的应用程序。

我应用程序中的大多数通信都是TCP，效果很好。但是，当我尝试进行文件传输时，我似乎在文件的开始和/或结尾失去了一些字节。

这是应该进行文件传输的代码：

Thread sendFile = new Thread(new ThreadStart(() =>
{
    TcpClient tcpClient = new TcpClient(ip, 3);
    tcpClient.Client.DontFragment = true;
    FileStream fileStream = new FileInfo(FilePath).OpenRead();
    Thread.Sleep(1000);
    fileStream.CopyTo(tcpClient.GetStream());
    fileStream.Close();
    tcpClient.Close();
}));
sendFile.SetApartmentState(ApartmentState.STA);
sendFile.Start();
sendFile.Join();

我已经搜索并尝试了通过网络流发送文件流的一系列方法（writeasync，byte [] buffer [buffer，flush the Buffers ,， ...）类似的结果：文件开头的某些字节，每128kb大约消失。

在启动之前，我会以一定的延迟运行传输时，我得到了最好的结果。

客户端代码：

FileStream fileStream = File.Create(path);
Thread receiveFile = new Thread(new ThreadStart(() =>
{
    tcpClient.GetStream().CopyTo(fileStream);
}));
receiveFile.SetApartmentState(ApartmentState.STA);
receiveFile.Start();
receiveFile.Join();
fileStream.Close();

我在与LAN电缆连接的不同计算机和路由器上尝试了它，以确保这些不是问题。

我正在使用.NET Core 5.0

Update

我已经尝试了一些事情，但它使它变得更好，但仍然不完美。

服务器代码：

Thread sendFile = new Thread(new ThreadStart(() =>
{
    TcpClient tcpClient = new TcpClient(ip, 3);
    FileStream fileStream = new FileInfo(FilePath).OpenRead();
    NetworkStream networkStream = tcpClient.GetStream();
    Thread.Sleep(1000);
    byte[] bytes = new byte[1024];
    int read = -1;
    while (read != 0)
    {
        read = fileStream.Read(bytes);
        networkStream.Write(bytes, 0, read);
    }
    filestream.Flush();
    fileStream.Close();
    tcpClient.Close();
}));
sendFile.SetApartmentState(ApartmentState.STA);
sendFile.Start();
sendFile.Join();

客户端代码：

FileStream fileStream = File.Create(path);
BufferedStream networkStream = new BufferedStream(client.GetStream());
Thread receiveFile = new Thread(new ThreadStart(() =>
{
   byte[] bytes = new byte[2048];
   int read = -1;
   while (read != 0)
   {
       read = networkStream.Read(bytes, 0, bytes.Length);
       using (MemoryStream memoryStream = new MemoryStream(bytes))
       {
           using (BinaryReader binaryReader = new BinaryReader(memoryStream))
           {
               fileStream.Write(binaryReader.ReadBytes(read));
           }
       }
   }
fileStream.Flush();
}));
receiveFile.SetApartmentState(ApartmentState.STA);
receiveFile.Start();
receiveFile.Join();
fileStream.Close();

Answer 1

正如我认为问题所在的TCPCLIENT上。使用普通插座时，一切都应该按应有的作用：没有数据丢失。

客户端代码：

Thread receiveFile = new Thread(new ThreadStart(() =>
{
    Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
    socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.DontLinger, true);
    socket.Bind(new IPEndPoint(IPAddress.Any, 33));
    socket.Listen();
    socket = socket.Accept();
    FileStream fileStream = File.Create(path);
    NetworkStream networkStream = new NetworkStream(socket);
    networkStream.CopyTo(fileStream);
    fileStream.Flush();
    fileStream.Close();
    socket.Close();
    socket.Dispose();
}));
receiveFile.SetApartmentState(ApartmentState.STA);
receiveFile.Start();
receiveFile.Join();
GC.Collect();

服务器代码：

Thread sendFile = new Thread(new ThreadStart(() =>
{
    Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
    socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.DontLinger, true);
    socket.Connect(new IPEndPoint(IPAddress.Parse(client.Host), 33));
    FileStream fileStream = new FileInfo(FilePath).OpenRead();
    NetworkStream networkStream = new NetworkStream(socket);
    Thread.Sleep(1000);
    fileStream.CopyTo(networkStream);
    fileStream.Flush();
    fileStream.Close();
    socket.Close();
    socket.Dispose();
}));
sendFile.SetApartmentState(ApartmentState.STA);
sendFile.Start();
sendFile.Join();
GC.Collect();

我强迫收集器确保插座处置，因此可以再次使用它们。