recv() 不阻塞

Question

recv() 不阻塞

3

我有两台机器运行一个我为测试目的编写的简单的C TCP服务器，一台是Fedora 16，另一台是Ubuntu 11.10。我的Fedora机器完美地工作，但在Ubuntu机器上，recv()不会阻塞。请记住这些机器正在运行完全相同的代码。有人见过这种情况吗？谢谢。

int TcpSocket::ReadFromClient(int socket, char* buf, int len)
{
    char *request = buf;
    int slen = len;

    int c = recv(socket, request, slen, 0);
    while((c > 0) && (request[c-1] != '\n'))
    {
        request += c;
        slen -= c;
        c = recv(socket, request, slen, 0);
    }

    if (c < 0)
    {
        return c;
    }
    else if(c == 0)
    {
        //Sending back an empty string
        buf[0] = '\0';
    }

    return len-slen;
}

- tier1

听起来你的套接字处于非阻塞模式。 - Keith Randall

第一次返回1（当实际发送数据时），在循环时返回0。为什么它会在我的Fedora机器上阻塞？ - tier1

2

@tkcsam，recv返回0表示另一端关闭了连接，或者可能是您传递给recv的slen参数为0。 - nos

我仍然不明白为什么 recv 第二次不会阻塞。 - tier1

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Remy Lebeau · Accepted Answer

看起来你的代码意图是在读取到一个 '\n' 字节时停止读取。如果是这样的话，那么你需要逐字节从套接字中读取，而不是使用整个可用缓冲区大小，特别是因为你只检查了缓冲区的最后一个字节，而不是检查每个接收到的字节。

你还应该改变循环逻辑，只在一个地方调用 recv()，而不是两个地方。你当前的实现方式在缓冲区耗尽时使用 slen=0 调用 recv()，这将设置 c=0 并使缓冲区的第一个字节无效。

尝试使用以下代码替代：

int TcpSocket::ReadFromClient(int socket, char* buf, int len)
{ 
    int slen = len;
    char ch;

    while (len > 0)
    {
        int ret = recv(socket, &ch, 1, 0); 
        if (ret > 0)
        {
            *buf = ch; 
            ++buf; 
            --len; 

            if (ch == '\n')
                break;
        }
        else
        {
            if ((ret == 0) || (errno != EAGAIN))
                return ret;

            fd_set readfd;
            FD_ZERO(&readfd);
            FD_SET(socket, &readfd);

            timeval tv;
            tv.tv_sec = 5;
            tv.tv_usec = 0;

            ret = select(socket+1, &readfd, NULL, NULL, &tv);
            if (ret < 0)
                return ret;

            if (ret == 0)
            {
                // timeout elapsed while waiting for data
                // do something if desired...
            }
        } 
    } 

    return slen - len;
}