在 tcp 套接字请求中的线程进程上一段时间后连接被拒绝 (c/linux)

Question

我正在尝试创建每秒处理多个请求的进程，每个请求都会创建新线程。 然后每个线程打开到地址（http 端口）的套接字连接，发送 HEAD 请求，获取响应并关闭套接字。
当我每秒发出超过 3 个请求时，我遇到的问题就出现了，一段时间后，我在函数的 send() 部分遇到错误，我不断收到连接被拒绝的消息。 如果我每秒输入更多请求，我会更早收到错误。 如果我每秒只发出 2 个请求，我根本不会收到错误。 我怀疑我的某些资源用完了，但我找不到哪个资源。

这是代码的基本结构，

//declarations

socketfd = socket(servinfo->ai_family,servinfo->ai_socktype,servinfo->ai_protocol);

arg = fcntl(socketfd, F_GETFL, NULL)) < 0);
arg |= O_NONBLOCK;
fcntl(socketfd, F_SETFL, arg)

if((conn = connect(socketfd, servinfo->ai_addr, servinfo->ai_addrlen)) < 0)
{
    if(errno == EINPROGRESS)
    {
        do
        {
            tv.tv_sec = CONNECT_TIMEOUT;
            tv.tv_usec = 0;
            FD_ZERO(&myset);
            FD_SET(socketfd, &myset);
            if((res = select(socketfd+1, NULL, &myset, NULL, &tv) > 0)) 
            {
                if( (arg = fcntl(socketfd, F_GETFL, NULL)) < 0) { 
                    perror("fcntl get 2");
                } 
                arg &= (~O_NONBLOCK); 
                if( fcntl(socketfd, F_SETFL, arg) < 0) {
                    perror("fcntl set 2");
                }
                char szBuf[4096];

                std::string htmlreq = "HEAD / HTTP/1.1\r\nHost:";
                htmlreq += info->hostName;
                htmlreq += "\r\n\r\n";

                if((conn = send(socketfd,htmlreq.c_str(),htmlreq.size(),0)) == -1 && errno != EINTR)
                {
                    perror("send");
                    close(socketfd);
                    return;
                }

                if((conn = recv(socketfd,szBuf,sizeof(szBuf)+1,0)) < 0 && errno != EINTR)
                {
                    perror("recv");
                    close(socketfd);
                    return ;
                }

                close(socketfd);

                // do stuff with data
                break;
            }
            else
            {
                //timeout
                break;
            }
        }while(1);
    }
    else
    {
        perror("connect");
        close(socketfd);
        return; 
    }
}

我从一开始就删除了一些错误检查，一段时间后我得到的输出是“发送：连接被拒绝”。 我希望能得到一些指示，指出哪些部分可能导致问题，平台是 ubuntu linux。 如果需要的话，我也很乐意发布代码的其他部分。 提前Tnx。

Answer 1

您可能耗尽的资源位于您正在连接的服务器上。 连接被您要连接的计算机拒绝，因为它是：

1. 配置为限制每秒连接数（基于某些条件）
2. 或者您要连接的服务器由于某种原因负载过大，可能会导致 连接失败。不再需要任何连接。

由于您总是在第三个连接上收到错误，因此可能是您要连接的服务器限制了每个 IP 的连接数。

编辑1

您正在尝试进行非阻塞连接吗？ 现在我仔细看看它，听起来你的问题出在 select 上，因为在 select 中返回套接字在实际连接之前是可读的，然后你调用 send。 在非阻塞连接上需要注意的事情之一是套接字在发生错误时变得可读和可写。 这意味着您需要在 select 返回后检查两者，否则您可能会丢失任何实际错误并看到发送错误。

这是史蒂文斯 UNP 的：

FD_ZERO(&rset);
FD_SET(sockfd, &rset);
wset = rset;
tval.tv_sec = nsec;
tval.tv_usec = 0;

if ( (n = Select(sockfd+1, &rset, &wset, NULL,
                 nsec ? &tval : NULL)) == 0) {
    close(sockfd);      /* timeout */
    errno = ETIMEDOUT;
    return(-1);
}

if (FD_ISSET(sockfd, &rset) || FD_ISSET(sockfd, &wset)) {
    len = sizeof(error);
    if (getsockopt(sockfd, SOL_SOCKET, SO_ERROR, &error, &len) < 0)
        return(-1);         /* Solaris pending error */
} else
    err_quit("select error: sockfd not set");

done:
Fcntl(sockfd, F_SETFL, flags);  /* restore file status flags */

if (error) {
    close(sockfd);      /* just in case */
    errno = error;
    return(-1);
}
return(0);

Answer 2

您的代码中有很多问题。

首先，将套接字设置为非阻塞。 我不明白你为什么这样做。 连接函数有一个内部超时，因此不会阻塞。

代码的另一个问题是，如果连接立即成功，第一个 if 语句将跳过指令块！ 这可能会发生。

您显然想首先发送 HEAD 消息。 没有真正需要使其成为非阻塞，除非您预计远程服务器或网络非常慢并且希望超时。 在这种情况下，使用非阻塞套接字进行选择是有意义的。

发送 HEAD 消息后，您期望使用 recv 函数收集一些响应数据。 请注意，此函数调用可能会在接收到发送的全部数据之前返回。 您需要一种独立的方式来确定所有发送的数据都已收到。 服务器会关闭连接吗？ 这将被返回 0 的 recv 函数检测到。

因此，recv 应该被包装到一个循环中，在该循环中将接收到的数据附加到某个缓冲区或文件，并在 recv 返回 0 时退出。如果要添加超时，请使用非阻塞套接字在这个可能确实会阻塞的recv操作上。

但首先尝试不超时，以确保它全速工作而不会像当前版本那样阻塞。

我怀疑初始连接速度很慢，因为名称和 IP 地址解析，并且在后续调用中变得更快，因为数据被缓存。