如何在C#中实现多客户端TCP连接状态检测？

问题背景 #

我正在开发服务器与多客户端的一对多网络程序，每次客户端连接时执行clientList.Add(client);将其加入客户端列表。已实现单客户端的心跳检测逻辑，用于判断连接状态并更新toolStripStatusLabel1控件状态，单客户端场景运行良好；同时在发送数据的异常处理中加入了cleanup()调用以覆盖更多异常场景。现在需要解决如何检测多个客户端的连接状态的问题。

核心问题分析 #

当前的checkConnection和IsConnected方法依赖全局client变量，无法区分不同客户端，导致多客户端场景下检测逻辑失效。需要修改为针对每个客户端实例独立执行检测逻辑。

修改后的实现代码 #

1. 启动监听线程时绑定对应客户端

修改StartListen方法中的检测线程启动代码，将当前连接的TcpClient实例传入检测方法：

private void StartListen()
{
    //Creating a TCP Connection and listening to the port
    tcpListener = new TcpListener(System.Net.IPAddress.Any, 6666);
    tcpListener.Start();
    
    toolStripStatusLabel1.Text = "Listening on port 6666 ...";
    int counter = 0;
    appStatus = 0;

    while (true)
    {
        try
        {
            TcpClient client = tcpListener.AcceptTcpClient();
            counter++;
            // 多线程操作集合必须加锁
            lock (clientList)
            {
                clientList.Add(client);
            }
            
            IPEndPoint ipend = (IPEndPoint)client.Client.RemoteEndPoint;
            //Updating status of connection
            UpdateStatusLabel();
            appStatus = 1;
            
            th_outPutStream = new Thread(delegate () { outPutStream(client); });
            th_outPutStream.Start();
            th_inPutStream = new Thread(delegate () { inPutStream(client); });
            th_inPutStream.Start();
            // 将当前客户端传入检测线程
            th_checkConnection = new Thread(() => checkConnection(client));
            th_checkConnection.Start();
        }
        catch (Exception err)
        {
            // 全局异常清理，可根据需求细化
            Cleanup(null);
        }
    }
}

2. 修改连接检测方法，接收指定客户端实例

private void checkConnection(TcpClient targetClient)
{
    bool status = true;
    while (status)
    {
        status = IsConnected(targetClient);
        if (status)
        {
            System.Threading.Thread.Sleep(3000); //Wait 3 seconds then try again
        }
        else
        {
            Cleanup(targetClient);
            break;
        }
    }
}

3. 修改连接状态判断方法，针对指定客户端

private bool IsConnected(TcpClient targetClient)
{
    // 先判断客户端是否已标记为断开
    if (targetClient == null || !targetClient.Connected)
        return false;

    try
    {
        return !(targetClient.Client.Poll(1, SelectMode.SelectRead) && targetClient.Client.Available == 0);
    }
    catch (SocketException) 
    { 
        Cleanup(targetClient); 
        return false; 
    }
}

4. 实现针对特定客户端的清理逻辑

private void Cleanup(TcpClient targetClient)
{
    if (targetClient == null)
        return;

    // 从客户端列表移除，必须加锁保证线程安全
    lock (clientList)
    {
        if (clientList.Contains(targetClient))
            clientList.Remove(targetClient);
    }

    // 安全关闭连接资源
    try
    {
        targetClient.Client.Shutdown(SocketShutdown.Both);
        targetClient.Close();
    }
    catch (Exception ex)
    {
        // 可添加日志记录异常信息
        // Logger.Error($"清理客户端连接失败：{ex.Message}");
    }

    // 更新状态栏，显示当前在线客户端数量
    UpdateStatusLabel();
}

// 跨线程安全更新状态栏控件
private void UpdateStatusLabel()
{
    if (toolStripStatusLabel1.InvokeRequired)
    {
        toolStripStatusLabel1.Invoke(new Action(UpdateStatusLabel));
        return;
    }
    toolStripStatusLabel1.Text = $"当前在线客户端：{clientList.Count}";
}

额外优化建议 #

• 线程安全保障：所有对clientList的操作（添加、移除、遍历）都必须加锁，避免多线程并发访问导致的集合异常
• 主动心跳机制：仅被动检测连接状态可能存在误判（如客户端正常但长时间无数据传输），建议主动向客户端发送心跳包，客户端收到后回复确认，以此更准确判断连接有效性
• 线程资源优化：手动创建大量线程会消耗系统资源，建议使用ThreadPool或Task替代，或者直接使用异步IO（async/await）处理客户端连接和数据读写，提升性能和代码简洁性
• 异常日志记录：在所有catch块中添加日志记录，方便后续排查连接异常问题，避免空catch块

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