使用TcpClient传输大文件失败：文件尾部出现大量零字节

核心问题 #

1. 忽略TCP流式传输特性：Stream.Read()不会保证一次读取到指定的所有字节，它仅返回实际读取的字节数。直接调用一次Read就认为填满缓冲区，会导致部分数据未被读取，缓冲区剩余区域保留初始零值。
2. 标记字节未同步处理：发送端开头写入了0x2A作为传输标记，但接收端完全跳过该字节，导致后续文件名长度、文件名、文件长度及内容的解析全部偏移，这是数据错乱的主要诱因。
3. 潜在字节序风险：BitConverter的字节序依赖系统平台，若发送端与接收端系统字节序不同，解析出的长度值会完全错误。

修复后的代码 #

发送端代码 #

byte[] fileBuffer = File.ReadAllBytes("someFile");
// 统一使用网络字节序（大端），避免跨平台字节序冲突
short nameLengthBigEndian = IPAddress.HostToNetworkOrder((short)Encoding.UTF8.GetByteCount(name));
int fileLengthBigEndian = IPAddress.HostToNetworkOrder(fileBuffer.Length);

stream.Write(new byte[] { 0x2A }); // 传输标记字节
stream.Write(BitConverter.GetBytes(nameLengthBigEndian));
stream.Write(Encoding.UTF8.GetBytes(name)); // 明确转换为UTF8字节数组
stream.Write(BitConverter.GetBytes(fileLengthBigEndian));
stream.Write(fileBuffer);
stream.Flush();

接收端代码 #

// 先读取发送端的标记字节
byte[] marker = new byte[1];
ReadExactly(stream, marker, 0, 1);
if (marker[0] != 0x2A)
{
    throw new InvalidDataException("无效的传输标记");
}

// 读取文件名长度（转换回主机字节序）
byte[] nameSizeBytes = new byte[2];
ReadExactly(stream, nameSizeBytes, 0, 2);
short nameSize = IPAddress.NetworkToHostOrder(BitConverter.ToInt16(nameSizeBytes));

// 读取文件名
byte[] nameBytes = new byte[nameSize];
ReadExactly(stream, nameBytes, 0, nameSize);
string name = Encoding.UTF8.GetString(nameBytes);

// 读取文件长度（转换回主机字节序）
byte[] dataSizeBytes = new byte[4];
ReadExactly(stream, dataSizeBytes, 0, 4);
int dataSize = IPAddress.NetworkToHostOrder(BitConverter.ToInt32(dataSizeBytes));

// 读取文件内容
byte[] dataBuffer = new byte[dataSize];
ReadExactly(stream, dataBuffer, 0, dataSize);

using (FileStream fileStream = new(Path.Combine(directory, name), FileMode.OpenOrCreate))
{
    fileStream.Write(dataBuffer);
}

// 辅助方法：确保读取到指定长度的字节
private static void ReadExactly(Stream stream, byte[] buffer, int offset, int count)
{
    int totalRead = 0;
    while (totalRead < count)
    {
        int read = stream.Read(buffer, offset + totalRead, count - totalRead);
        if (read == 0)
        {
            throw new EndOfStreamException("流提前结束，未读取到足够数据");
        }
        totalRead += read;
    }
}

关键说明 #

• ReadExactly是核心修复：通过循环调用Stream.Read()，确保读取到指定长度的字节，彻底解决TCP流式传输中单次读取不满足需求的问题。
• 统一字节序：借助IPAddress.HostToNetworkOrder和IPAddress.NetworkToHostOrder实现字节序转换，保证跨平台传输时长度解析准确。
• 同步标记字节：接收端必须先读取发送端写入的0x2A标记，否则后续所有数据都会偏移，导致解析错误。

内容的提问来源于stack exchange，提问作者dinikai