Socket使用异常：间隔2分钟重启后第二次收发数据失败

我帮你梳理下这个问题的核心原因，结合你的代码和表现出来的现象，问题根源主要在Socket连接的生命周期管理上，具体分析和修复方案如下：

问题原因 #

• Receive方法错误地在每次接收后关闭Socket：你的Receive方法在完成数据接收后，无条件调用了NetClient.Shutdown(SocketShutdown.Both)和NetClient.Close()，这意味着第一次接收完成后，整个TCP连接就被彻底关闭了。短时间内重启程序时，服务器可能因为TCP的TIME_WAIT状态（默认约2分钟）还保留着连接资源，偶尔能让第二次操作“侥幸”工作；但间隔2分钟后，TIME_WAIT状态结束，服务器完全释放旧连接，此时客户端Socket已经关闭，自然无法再进行第二次收发。
• TCP连接错误使用SendTo方法：TCP是面向连接的协议，建立连接后应该使用Send方法，而SendTo更多用于UDP无连接场景。虽然某些情况下SendTo在TCP连接下能临时工作，但不符合规范，可能导致不可预期的连接异常。
• 连接状态判断不可靠：直接依赖NetClient.Connected属性判断连接可用性并不准确——它仅反映Socket最后一次操作的状态，即使对方已断开连接，这个属性可能仍返回true，导致后续操作失败。

修复方案 #

1. 调整Receive方法，仅在必要时关闭Socket #

只有在检测到连接异常或主动断开时才关闭Socket，而非每次接收后都关闭：

public override string Receive(int length)
{
    byte[] data = new byte[bufferSize];
    string strbuff = "";
    try
    {
        do
        {
            IAsyncResult result = NetClient.BeginReceive(data, 0, bufferSize, SocketFlags.None, null, null);
            bool success = result.AsyncWaitHandle.WaitOne(connectionDelay, true);
            
            if (!success)
            {
                Log("report.log", "Receive timeout occurred");
                break;
            }

            int receivedBytesCount = NetClient.EndReceive(result);
            if (receivedBytesCount == 0)
            {
                // 收到0字节表示远端已主动关闭连接
                Log("report.log", "Remote connection has been closed");
                Disconnect();
                break;
            }

            strbuff += Encoding.ASCII.GetString(data, 0, receivedBytesCount);
        } while (NetClient.Available > 0);

        return strbuff;
    }
    catch (Exception ex)
    {
        MessageBox.Show(ex.Message);
        Log("report.log", $"Error during receive: {ex.Message}");
        Disconnect();
        return null;
    }
}

2. 修正Send方法，使用TCP专属的Send调用 #

替换SendTo为Send，确保符合TCP连接的使用规范：

public override bool Send(byte[] data)
{
    try
    {
        if (data == null || data.Length == 0) return false;
        
        int sentBytes = NetClient.Send(data);
        Thread.Sleep(transferDelay);
        // 验证是否所有字节都发送成功
        return sentBytes == data.Length;
    }
    catch (Exception e)
    {
        MessageBox.Show(e.Message);
        Log("report.log", $"Error during send: {e.Message}");
        Disconnect();
        return false;
    }
}

3. 优化Connect方法，确保连接清理彻底 #

在建立新连接前先关闭旧连接，避免资源泄漏：

public override bool Connect()
{
    try
    {
        // 先清理旧连接
        Disconnect();
        NetClient = new Socket(ConnectionPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
        
        IAsyncResult result = NetClient.BeginConnect(ConnectionPoint, null, null);
        bool success = result.AsyncWaitHandle.WaitOne(connectionDelay, false);
        
        if (success && NetClient.Connected)
        {
            Log("report.log", "Connection established successfully");
            return true;
        }
        else
        {
            // 连接超时或失败时，及时关闭Socket
            NetClient.Close();
            Log("report.log", "Failed to establish connection");
            return false;
        }
    }
    catch (Exception e)
    {
        MessageBox.Show(e.Message);
        Log("report.log", $"Connection error: {e.Message}");
        if (NetClient != null) NetClient.Close();
        return false;
    }
}

4. 完善Disconnect方法，避免资源残留 #

确保Socket被完全释放，避免后续误操作：

public override void Disconnect()
{
    try
    {
        if (NetClient != null)
        {
            if (NetClient.Connected)
            {
                NetClient.Shutdown(SocketShutdown.Both);
            }
            NetClient.Close();
            NetClient = null; // 置空引用，防止后续操作已关闭的Socket
        }
    }
    catch (Exception e)
    {
        MessageBox.Show(e.Message);
        Log("report.log", $"Disconnect error: {e.Message}");
    }
}

额外建议 #

• 避免使用Thread.Sleep来控制收发延迟，这会阻塞当前线程，建议使用异步等待或更优雅的超时机制。
• 可以添加心跳检测机制，定期验证连接的可用性，避免依赖Connected属性的误判。

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