使用TCPClient传文件时NetworkStream.Write阻塞，设WriteTimeout后该如何处理？

阿华AIGC实验室

2026-5-22

我来帮你拆解下这个TCP文件传输的阻塞问题，以及超时后的处理方案——毕竟在.NET里搞TCP传输，这种缓冲区阻塞的坑我踩过不止一次。

问题根源分析

你遇到的NetworkStream.Write阻塞，大概率是TCP发送缓冲区已满导致的。TCP是可靠的流式协议，发送端的套接字会先把要发送的数据放到自身的发送缓冲区，等接收端确认收到数据后，才会腾出缓冲区空间继续接收新的写入请求。如果你的接收端（标记为"client"的TCPListener侧）没有及时读取数据，发送缓冲区很快就会被填满，这时候Write就会一直阻塞，直到缓冲区有空间或者连接出问题。

另外要明确：NetworkStream确实没有Flush方法——因为TCP本身不会像文件流那样存在“缓存待刷”的概念，数据要么已经被发送到网络，要么在套接字缓冲区里等待发送。

解决阻塞的核心方案

1. 确保接收端持续读取数据

这是最关键的一点！如果接收端代码只调用了一次Read，或者读取速度远慢于发送端的写入速度，必然会导致发送缓冲区溢出。正确的接收逻辑应该是循环读取，直到整个文件传输完成：

// 接收端（TCPListener侧）示例代码
using (var client = listener.AcceptTcpClient())
using (var stream = client.GetStream())
using (var fileStream = new FileStream("received_file.bin", FileMode.Create))
{
    byte[] buffer = new byte[1000];
    int bytesRead;
    // 循环读取，直到stream返回0（表示连接正常关闭）
    while ((bytesRead = stream.Read(buffer, 0, buffer.Length)) > 0)
    {
        fileStream.Write(buffer, 0, bytesRead);
        // 可添加进度日志，确保读取操作一直在执行
    }
}

2. 禁用Nagle算法（本地传输更友好）

默认情况下TCP会启用Nagle算法，它会合并小数据包后再发送以减少网络开销，但在本地传输场景下这个优化意义不大，反而可能导致小数据块的发送延迟，间接加剧缓冲区阻塞问题。你可以在发送端的TCPClient上禁用它：

var tcpClient = new TcpClient();
tcpClient.NoDelay = true; // 禁用Nagle算法，数据立即发送
tcpClient.Connect("localhost", 你的端口号);

Write超时后的处理方案

你设置了WriteTimeout = 3000，当Write超时后会抛出IOException（内部通常是SocketException，错误码为WSAETIMEDOUT）。处理这个异常时，需要分情况应对：

1. 捕获超时异常并判断连接状态

先捕获异常，确认是否为超时导致，再验证套接字是否还可用：

try
{
    stream.Write(buffer, 0, buffer.Length);
}
catch (IOException ex)
{
    // 检查是否是超时异常
    var socketEx = ex.InnerException as SocketException;
    if (socketEx != null && socketEx.SocketErrorCode == SocketError.TimedOut)
    {
        // 检查套接字是否还可写
        bool canWrite = tcpClient.Client.Poll(1000, SelectMode.SelectWrite);
        if (canWrite)
        {
            // 连接仍正常，可能是接收端暂时卡顿，可限制次数重试
            int retryCount = 0;
            while (retryCount < 3)
            {
                try
                {
                    stream.Write(buffer, 0, buffer.Length);
                    break;
                }
                catch (IOException)
                {
                    retryCount++;
                    Thread.Sleep(500); // 短暂等待后重试
                }
            }
            if (retryCount >= 3)
            {
                Console.WriteLine("多次重试写入失败，传输终止");
                tcpClient.Close();
            }
        }
        else
        {
            // 套接字不可写，说明连接已断开
            Console.WriteLine("连接已断开，无法继续写入");
            tcpClient.Close();
        }
    }
    else
    {
        // 其他IO异常，直接关闭连接并处理
        Console.WriteLine($"写入失败：{ex.Message}");
        tcpClient.Close();
    }
}