多线程创建多端口TCP客户端连接失败，求解决方案

核心问题分析 #

你的代码存在三个关键错误导致连接失败或日志异常：

• 循环变量捕获陷阱：线程的lambda表达式直接捕获循环变量i和clientPort，线程启动时循环可能已结束，所有线程会使用变量的最终值，而非创建时的数值。
• TcpClient连接参数混淆：你把本地端口clientPort当成了服务器端口传入Connect方法，实际上Connect的第二个参数是服务器端口，本地端口需要通过绑定终结点来指定。
• 统计时机过早：主线程在启动所有子线程后立刻打印连接数，此时子线程还未完成连接操作，因此显示0个客户端连接。

修正后的完整代码 #

private void BtnConnect_Click(object sender, EventArgs e)
{
    string hostname = txtIP.Text;
    int serverPort;
    int startLocalPort = 30000;
    int totalNumberOfClients = 0;

    // 验证服务器端口输入
    if (!int.TryParse(txtPort.Text, out serverPort) || serverPort <= 0 || serverPort > 65535)
    {
        MessageBox.Show("请输入有效的服务器端口（1-65535）！");
        return;
    }

    // 验证IP地址输入
    if (string.IsNullOrWhiteSpace(hostname))
    {
        MessageBox.Show("请输入服务器IP地址！");
        return;
    }

    // 验证客户端数量输入
    if (!int.TryParse(txtNumberOfDevices.Text, out totalNumberOfClients) || totalNumberOfClients <= 0)
    {
        MessageBox.Show("请输入有效的客户端数量（大于0）！");
        return;
    }

    int connectedCount = 0;
    var threads = new List<Thread>();

    for (int i = 1; i <= totalNumberOfClients; i++)
    {
        // 捕获当前循环的变量快照，避免lambda捕获引用导致的变量值异常
        int clientIndex = i;
        int localPort = startLocalPort + i - 1;

        Thread clientThread = new Thread(() =>
        {
            TcpClient client = null;
            try
            {
                // 创建TcpClient并绑定指定本地端口
                client = new TcpClient();
                client.Client.Bind(new IPEndPoint(IPAddress.Any, localPort));
                
                // 连接到服务器（使用服务器IP和服务器端口）
                client.Connect(hostname, serverPort);

                // 跨线程更新UI日志，需使用Invoke
                this.Invoke((MethodInvoker)delegate
                {
                    WriteLog($"客户端 {clientIndex} 已绑定本地端口 {localPort} 并连接到服务器");
                });

                // 原子操作更新连接计数
                Interlocked.Increment(ref connectedCount);
            }
            catch (Exception ex)
            {
                this.Invoke((MethodInvoker)delegate
                {
                    WriteLog($"客户端 {clientIndex} 绑定本地端口 {localPort} 失败，错误：{ex.Message}");
                });
            }
            finally
            {
                // 检查是否所有线程都已完成，再打印最终连接统计
                if (Interlocked.Decrement(ref totalNumberOfClients) == 0)
                {
                    this.Invoke((MethodInvoker)delegate
                    {
                        WriteLog($"已完成所有连接尝试，成功连接 {connectedCount} 个客户端");
                    });
                }
            }
        });

        threads.Add(clientThread);
        clientThread.IsBackground = true; // 设置为后台线程，避免阻塞程序退出
        clientThread.Start();
    }
}

// 假设WriteLog是更新UI的方法，需要确保线程安全
private void WriteLog(string message)
{
       // 示例实现：追加到日志文本框
    txtLog.AppendText($"{DateTime.Now:HH:mm:ss} - {message}{Environment.NewLine}");
}

关键修正点说明 #

• 循环变量快照：在循环内部创建clientIndex和localPort的局部变量，捕获这些快照值到lambda中，确保每个线程使用当前循环迭代的正确数值。
• 正确绑定本地端口：使用client.Client.Bind(new IPEndPoint(IPAddress.Any, localPort))显式绑定本地端口，Connect方法传入服务器的IP和端口。
• 线程安全的UI更新：WinForm中跨线程更新UI必须使用Invoke，避免线程异常。
• 正确的统计时机：通过Interlocked.Decrement跟踪未完成的线程数，当所有线程执行完毕后再打印最终连接统计。
• 后台线程设置：将客户端线程设为后台线程，防止程序退出时被阻塞。

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