基于wxWidgets的Windows客户端closesocket后端口未释放问题求助

问题复现步骤 #

• 客户端主线程响应按钮事件，通过异步队列调用DLL A的接口，接口内创建线程1监听8888端口，执行netstat -ano|grep 8888确认端口已成功监听。
• 客户端主线程休眠5000毫秒（仅用于提高复现概率，主线程阻塞时问题更易触发）。
• 客户端主线程调用DLL A的关闭接口，该接口调用closesocket()关闭8888端口的监听Socket，closesocket()返回值为0，但执行netstat -ano|grep 8888显示端口未释放。

疑问 #

1. 为何调用closesocket()后8888端口未释放？这会导致accept()持续阻塞，while循环无法退出。
2. 客户端主线程被Sleep()阻塞时问题出现概率更高的原因是什么？客户端主线程与DLL中Socket的创建和释放有何关联？

已尝试的解决手段 #

已尝试设置SO_LINGER(1,0)、SO_LINGER(0,0)及SO_REUSEPORT选项，但问题仍存在。

代码示例 #

void APP::main()
{
    onButton();
}

void APP::onButton(wxCommandEvent & evt)
{
    // Sleep(5000); 若在此处（或主线程其他位置）执行阻塞操作，后续Socket将无法关闭
    if (evt.GetId() == open)
    {
        _tasks->async([this]()
        {
            openSocket();
        });
    }
    else if(evt.GetId() == close)
    {
        _tasks->async([this]()
        {
            closeSocket();
        });
    }

}

void DLL::closeSocket()
{
    closesocket(serverSocket);
}

void DLL::openSocket()
{
    thread t1(myFunction);
    t1.detach();
}

void myFunction()
{
    //仅列出简化步骤
    serverSocket = socket(AF_INET, SOCK_STREAM, 0);
    struct sockaddr_in serverAddress;
    serverAddress.sin_port = htons(8888);
    bind(serverSocket, (struct sockaddr*)&serverAddress, sizeof(serverAddress));
    listen(serverSocket, 5);
    while(true)
    {
        int clientSocket = accept(serverSocket, (struct sockaddr*)&clientAddress, &clientAddressSize);
        if (clientSocket == -1) {
            std::cerr << "Failed to accept client connection." << std::endl;
            break;
        }
        // 将建立连接的Socket传递给外部使用
        new transportThread(endpoint, clientSocket);
    }

}

疑问1：closesocket()调用成功但端口未释放、accept()无法退出的原因 #

核心问题出在Socket引用计数未归零和阻塞的accept()未被打断：

1. Windows中Socket是内核对象，closesocket()只是减少其引用计数，只有当引用计数为0时，内核才会真正释放Socket资源并关闭端口。如果代码中存在其他持有该Socket句柄的副本（比如未正确清理的变量），会导致引用计数不为0，端口无法释放。
2. 当accept()处于阻塞状态时，直接调用closesocket()不会主动唤醒该阻塞调用，accept()会一直阻塞，监听线程持续持有Socket句柄，间接维持了引用计数，导致端口无法释放。

疑问2：主线程阻塞时问题概率更高的原因 #

wxWidgets的UI主线程依赖消息循环处理事件，主线程被Sleep()阻塞时：

1. 消息循环无法正常运行，会导致异步任务队列的调度延迟。关闭Socket的异步任务如果被延迟执行，监听线程的accept()会持续阻塞，此时Socket句柄的释放逻辑可能因线程调度时序问题，出现引用计数未正确归零的情况。
2. 如果DLL中的serverSocket是全局变量，主线程阻塞可能引发线程间对该变量的竞态条件——比如关闭Socket的操作和accept()操作同时进行，导致closesocket()调用后，监听线程仍持有无效句柄继续阻塞，维持端口占用状态。

具体修复方案 #

1. 打断阻塞的accept() #

在调用closesocket()前，先执行shutdown(serverSocket, SD_BOTH)关闭Socket的读写通道，此时accept()会返回错误（WSAENOTSOCK或WSAESHUTDOWN），从而退出while循环。也可以向监听端口发送一个空连接，主动唤醒accept()。

2. 确保Socket句柄引用计数正确归零 #

• 避免使用全局Socket句柄，改用线程安全的方式管理（比如原子变量、智能指针）。
• 监听线程退出前，确保所有持有Socket句柄的地方都已释放，避免悬空句柄。

3. 优化线程调度与同步 #

• 不要在wxWidgets UI主线程中执行长时间阻塞操作，改用wxThread或wxPostEvent等异步机制处理耗时任务，保证消息循环正常运行。
• 关闭Socket时，等待监听线程退出后再完成关闭操作：比如用join()代替detach()管理监听线程，或用事件通知机制让监听线程主动退出。

修改后的关键代码示例 #

// DLL中新增线程与Socket的线程安全管理变量
std::thread* g_listenThread = nullptr;
std::atomic<int> g_serverSocket = INVALID_SOCKET;

void DLL::openSocket()
{
    if (g_listenThread == nullptr) {
        g_listenThread = new std::thread(myFunction);
    }
}

void DLL::closeSocket()
{
    if (g_serverSocket != INVALID_SOCKET) {
        // 先shutdown打断阻塞的accept()
        shutdown(g_serverSocket, SD_BOTH);
        // 等待监听线程退出
        if (g_listenThread != nullptr) {
            g_listenThread->join();
            delete g_listenThread;
            g_listenThread = nullptr;
        }
        // 最后关闭Socket并重置句柄
        closesocket(g_serverSocket);
        g_serverSocket = INVALID_SOCKET;
    }
}

void myFunction()
{
    g_serverSocket = socket(AF_INET, SOCK_STREAM, 0);
    struct sockaddr_in serverAddress;
    memset(&serverAddress, 0, sizeof(serverAddress));
    serverAddress.sin_family = AF_INET;
    serverAddress.sin_addr.s_addr = INADDR_ANY;
    serverAddress.sin_port = htons(8888);
    
    bind(g_serverSocket, (struct sockaddr*)&serverAddress, sizeof(serverAddress));
    listen(g_serverSocket, 5);
    
    while(true)
    {
        int clientSocket = accept(g_serverSocket, nullptr, nullptr);
        if (clientSocket == -1) {
            // 检查错误码，若为shutdown导致的错误则退出循环
            int err = WSAGetLastError();
            if (err == WSAENOTSOCK || err == WSAESHUTDOWN) {
                break;
            }
            std::cerr << "Failed to accept client connection." << std::endl;
            continue;
        }
        // 处理客户端连接...
        closesocket(clientSocket);
    }
}

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