c++ - 客户端关闭后 accept() 不阻塞(使用 Ctrl+C)错误 10093

Question

我正在使用 winsock2 开发一个简单的客户端-服务器应用程序，我在其中从客户端发送一个整数值，服务器接收它。
当我发送一个(或多个) ) integer 且客户端正确关闭套接字，服务器知道客户端已关闭连接并转到 accept() 函数等待另一个连接。
但是，当我使用 Ctrl+C 组合停止客户端时，accept() 不会停止并继续主循环每次循环时服务器返回错误 10093(与 WSAStartup() 相关)。
我认为在某种程度上我有管理发送到服务器的信号，例如 Linux 中的 SIPIPE 或类似的东西，但我不知道如何操作。
解决这个问题的最佳方法是什么？

这里是我的接受实现:

bool Network::Accept() {
    caddrlen = sizeof(clientAddr);
    int ret; 
    if ((ret = accept(listeningSocket, (struct sockaddr*)&clientAddr, &caddrlen) ) == INVALID_SOCKET) {
        myFormatMessage(WSAGetLastError());
        closesocket(listeningSocket);
        WSACleanup();
        return false;
    }
    else {
//save client ip address in a string
        getpeername(listeningSocket, (SOCKADDR *)&clientAddr, (int *)sizeof(clientAddr));
        char ip[20];
        inet_ntop(AF_INET, (sockaddr*)&clientAddr.sin_addr, ip, 20);
        clientIPaddr.assign(ip);
        connectedSocket = ret; 
        return true;
    }

}

Answer 1

Winsock 错误 10093 是 WSANOTINITIALISED :

Successful WSAStartup not yet performed.
Either the application has not called WSAStartup or WSAStartup failed. The application may be accessing a socket that the current active task does not own (that is, trying to share a socket between tasks), or WSACleanup has been called too many times.

当 accept() 因任何原因失败时，您的 Network::Accept() 方法正在调用 WSACleanup()。 Network::Accept() 根本不应该这样做。它也不应该关闭监听套接字。从 Network::Accept() 中删除这两行，如果它返回 false，则让你的主循环停止调用 Network::Accept()，然后清理你的根据需要监听套接字。

您的 Network::Accept() 代码还有其他问题:

• accept() 返回一个 SOCKET，而不是一个 int。

• 当 accept() 成功时，您正在使用错误的参数值调用 getpeername()。您传递的是监听套接字而不是已接受的客户端套接字，并且传递的是其 namelen 参数的无效指针(您需要传递指向您的 caddrlen 的指针值，而不是类型转换 sizeof() 的返回值)。就此而言，调用 getpeername() 无论如何都是多余的，因为 accept() 已经为您提供了与 getpeername() 相同的地址.

• 调用 inet_ntop() 时，您将客户端地址的 sin_addr 字段类型转换为 sockaddr*，即错误的。但在这种情况下，编译器会接受它，因为 pAddr 参数是 void*。您根本不需要类型转换。

• 如果 listeningSocket 是一个 AF_INET (IPv4) 套接字，则在调用 inet_ntop() 时硬编码 AF_INET 很好，因为接受的客户端将始终使用 IPv4 地址 (sockaddr_in)。但是，如果您想要/需要支持 IPv6(并且您应该)，那么您应该检查客户端的实际地址族以了解该地址是否使用 sockaddr_in 或 sockaddr_in6 然后将参数相应地传递给 inet_ntop()。

话虽如此，尝试更像这样的事情:

如果您仅支持 IPv4:

bool Network::Accept() {
    // declare clientAddr as sockaddr_in...
    caddrlen = sizeof(clientAddr);
    SOCKET ret = accept(listeningSocket, (struct sockaddr*)&clientAddr, &caddrlen);
    if (ret == INVALID_SOCKET) {
        myFormatMessage(WSAGetLastError());
        return false;
    }

    //save client ip address in a string
    char ip[INET_ADDRSTRLEN] = {0};
    inet_ntop(AF_INET, &(clientAddr.sin_addr), ip, INET_ADDRSTRLEN);
    clientIPaddr.assign(ip);
    // declare connectedSocket as SOCKET...
    connectedSocket = ret; 
    return true;
}

如果您仅支持 IPv6:

bool Network::Accept() {
    // declare clientAddr as sockaddr_in6...
    caddrlen = sizeof(clientAddr);
    SOCKET ret = accept(listeningSocket, (struct sockaddr*)&clientAddr, &caddrlen);
    if (ret == INVALID_SOCKET) {
        myFormatMessage(WSAGetLastError());
        return false;
    }

    //save client ip address in a string
    char ip[INET6_ADDRSTRLEN] = {0};
    inet_ntop(AF_INET6, &(clientAddr.sin6_addr), ip, INET6_ADDRSTRLEN);
    clientIPaddr.assign(ip);
    // declare connectedSocket as SOCKET...
    connectedSocket = ret; 
    return true;
}

如果您同时支持 IPv4 和 IPv6:

bool Network::Accept() {
    // declare clientAddr as SOCKADDR_STORAGE...
    caddrlen = sizeof(clientAddr);
    SOCKET ret = accept(listeningSocket, (struct sockaddr*)&clientAddr, &caddrlen);
    if (ret == INVALID_SOCKET) {
        myFormatMessage(WSAGetLastError());
        return false;
    }

    //save client ip address in a string
    char ip[INET6_ADDRSTRLEN] = {0};
    switch (clientAddr.ss_family)
    {
        case AF_INET:
            inet_ntop(AF_INET, &(((struct sockaddr_in*)&clientAddr)->sin_addr), ip, INET_ADDRSTRLEN);
            break;
        case AF_INET6:
            inet_ntop(AF_INET6, &((struct sockaddr_in6*)&clientAddr)->sin6_addr), ip, INET6_ADDRSTRLEN);
            break;
    }
    clientIPaddr.assign(ip);
    // declare connectedSocket as SOCKET...
    connectedSocket = ret; 
    return true;
}