c - Linux套接字发送()错误EAGAIN

Question

我正在设计一个使用代理和 HTTP CONNECT 请求的 HTTP 隧道。大约 90% 的时间，当我尝试发送连接请求时 CONNECT 192.168.1.68:3001 HTTP/1.1\r\n\r\n 发送失败，返回 errno = 11 , “再试一次”。

我正在使用非阻塞套接字，套接字在连接尝试之间关闭然后重新打开。我不认为发送缓冲区已满，因为我发送的数据不多。我很困惑为什么它有时连接有时不连接(并且似乎没有模式，有时它会连续连接两次，有时连接之间有 10 次失败)。

我可能会收到此错误的一些原因是什么？

编辑:

(代码)

if (connect(sock, pSockAddr, iSockAddrSize)) {
    ...
    char message[80];
    sprintf(message, "CONNECT 192.168.1.68:3001 HTTP/1.1\r\n\r\n");
    printf("*J* Message loaded.\n"); //*J*
    printf("*J* %s\n", message); //*J*
    if (send(sock, message, strlen(message) + 1, 0) < 0) printf("*J* Send Failed: %d\n", errno); 
    else printf("*J* Data Sent.\n");
    }
...
printf("\n*J* Close Socket (RESET HOST COMMAND)");
closesocket(sock);

(输出)

[SUCCESS]
*J* Starting connect...
*J* Message loaded.
*J* CONNECT 192.168.1.68:3001 HTTP/1.1


*J* Data Sent.
*J* rv = 1
*J* Ending connect...

[FAIL]
*J* Starting connect...
*J* Message loaded.
*J* CONNECT 192.168.1.68:3001 HTTP/1.1


*J* Send Failed: 11
*J* Ending connect...

Answer 1

您的代码中有几个错误:

1. connect() 成功时返回 0，错误时返回 -1。 if 语句对任何非零值的计算结果为真。这意味着当 connect() 因错误而失败时，您的代码正在发送 CONNECT 消息。但是，并非所有错误都是致命的。特别是，由于您使用的是非阻塞套接字，EINPROGRESS/WSAEWOULDBLOCK 错误表示连接仍未决，您需要使用 select() 或 (e)poll() 等待套接字实际完成连接(或失败)。因此，您的代码只有在 connect() 异步连接并且恰好在您有机会调用 send() 之前完全连接到代理时才有效。但这是您不应该依赖的行为。您需要正确处理错误。

2. send() 的返回值指定了实际接受了多少字节，如果出错则为 -1。可能会接受少于请求的字节数(尤其是在非阻塞套接字上)。并且您需要处理非 fatal error ，特别是 (WSA)EWOULDBLOCK(和 EAGAIN，可能还有 EINTR，在非 Windows 上平台)，这意味着在调用 send() 时套接字无法接受新数据，因此请再次调用 send()。您应该在循环中调用 send()，直到发送完所有字节，或者发生 fatal error 。

3. 即使您正确地 send() 发送数据，您在 strlen() 之后使用 + 1 也是错误的。您在要发送的数据中包含空终止符，但这不是 CONNECT 协议(protocol)的一部分。空终止符将被代理视为应用程序数据，并将按原样通过隧道转发到下一个服务器(如果隧道已成功打开)，从而中断与该服务器的通信。

话虽如此，请改为尝试以下内容。您对 closeocket() 的使用表明您正在为 Windows 编程，因此这是特定于 Windows 的:

int ret, err;
...
ret = connect(sock, pSockAddr, iSockAddrSize);
if (ret == -1)
{
    err = WSAGetLastError();

    if (err == WSAEWOULDBLOCK)
    {
        fd_set wfd;
        FD_ZERO(&wfd);
        FD_SET(sock, &wfd);

        fd_set efd;
        FD_ZERO(&efd);
        FD_SET(sock, &efd);

        timeval timeout;
        timeout.tv_sec = ...;
        timeout.tv_usec = ...;

        ret = select(0, NULL, &wfd, &wfd, &timeout);

        if (ret == 0)
        {
            printf("*J* Connect Timeout\n"); 
            // handle timeout as needed ...
            return;
        }

        if ((ret > 0) && FD_ISSET(sock, &efd))
        {
            err = 0;
            getsockopt(sock, SOL_SOCKET, SO_ERROR, (char*)&err, sizeof(err));
            ret = -1;
        }
    }

    if (ret == -1)
    {
        printf("*J* Connect Failed: %d\n", err); 
        // handle fatal error as needed ...
        return;
    }
}

...

char message[80];
sprintf(message, "CONNECT 192.168.1.68:3001 HTTP/1.1\r\n\r\n");
printf("*J* Message loaded.\n"); //*J*
printf("*J* %s\n", message); //*J*

char *pmsg = message;
int len = strlen(message);

do
{
    ret = send(sock, pmsg, len, 0);
    if (ret == -1)
    {
        err = getLastSocketError();    

        if (err == WSAEWOULDBLOCK)
        {
            fd_set wfd;
            FD_ZERO(&wfd);
            FD_SET(sock, &wfd);

            timeval timeout;
            timeout.tv_sec = ...;
            timeout.tv_usec = ...;

            ret = select(0, NULL, &wfd, NULL, &timeout);

            if (ret > 0)
                continue;

            if (ret == 0)
            {
                printf("*J* Send Timeout\n"); 
                // handle timeout as needed ...
                return;
            }

            err = WSAGetLastError();
        }

        printf("*J* Send Failed: %d\n", err); 
        // handle fatal error as needed ...
        return;
    }
    else
    {
        pmsg += ret;
        len += ret;
    }
}
while (len > 0);

printf("*J* Data Sent\n");

...

printf("*J* Close Socket\n");
closesocket(sock);

如果你想要更跨平台的东西，试试这个(或者使用跨平台套接字库):

int getLastSocketError()
{
    #ifdef WINDOWS
    return WSAGetLastError();
    #else
    return errno;
    #endif
};

int ret, err;
...
ret = connect(sock, pSockAddr, iSockAddrSize);
if (ret == -1)
{
    err = getLastSocketError();    

    if (
        #ifdef WINDOWS
        err == WSAEWOULDBLOCK
        #else
        err == EINPROGRESS
        #endif
        )
    {
        #ifndef WINDOWS
        do {
        #endif

        fd_set wfd;
        FD_ZERO(&wfd);
        FD_SET(sock, &wfd);

        #ifdef WINDOWS
        fd_set efd;
        FD_ZERO(&efd);
        FD_SET(sock, &efd);
        #endif

        timeval timeout;
        timeout.tv_sec = ...;
        timeout.tv_usec = ...;

        #ifdef WINDOWS
        ret = select(0, NULL, &wfd, &wfd, &timeout);
        #else
        ret = select(sock+1, NULL, &wfd, NULL, &timeout);
        #endif

        if (ret == 0)
        {
            printf("*J* Connect Timeout\n"); 
            // handle timeout as needed ...
            return;
        }

        #ifdef WINDOWS
        if ((ret > 0) && FD_ISSET(sock, &efd))
        {
            err = 0;
            getsockopt(sock, SOL_SOCKET, SO_ERROR, (char*)&err, sizeof(err));
            ret = -1;
        }
        #endif

        #ifndef WINDOWS
        } while ((ret == -1) && (errno == EINTR));
        #endif
    }

    if (ret == -1)
    {
        printf("*J* Connect Failed: %d\n", err); 
        // handle fatal error as needed ...
        return;
    }
}

...

char message[80];
sprintf(message, "CONNECT 192.168.1.68:3001 HTTP/1.1\r\n\r\n");
printf("*J* Message loaded.\n"); //*J*
printf("*J* %s\n", message); //*J*

char *pmsg = message;
int len = strlen(message);

do
{
    ret = send(sock, pmsg, len, 0);
    if (ret == -1)
    {
        err = getLastSocketError();    

        if (
            #ifdef WINDOWS
            err == WSAEWOULDBLOCK
            #else
            (err == EWOULDBLOCK) || (err == EAGAIN)
            #endif
            )
        {
            fd_set wfd;
            FD_ZERO(&wfd);
            FD_SET(sock, &wfd);

            timeval timeout;
            timeout.tv_sec = ...;
            timeout.tv_usec = ...;

            ret = select(
                #ifdef WINDOWS
                0
                #else
                sock+1
                #endif
                , NULL, &wfd, NULL, &timeout);

            if (ret > 0)
                continue;

            if (ret == 0)
            {
                printf("*J* Send Timeout\n"); 
                // handle timeout as needed ...
                return;
            }

            err = getLastSocketError();
        }

        #ifndef WINDOWS
        if (err != EINTR)
        #endif
        {
            printf("*J* Send Failed: %d\n", err); 
            // handle fatal error as needed ...
            return;
        }
    }
    else
    {
        pmsg += ret;
        len += ret;
    }
}
while (len > 0);

printf("*J* Data Sent\n");

...

printf("*J* Close Socket\n");

#ifdef WINDOWS
closesocket(sock);
#else
close(sock);
#endif