即使没有新数据，FD_ISSET 也始终为真？

Question

我正在尝试检查客户端是否发送了一些新数据。这实际上告诉我，我总是有新数据：

bool ClientHandle::hasData()
{
    fd_set temp;
    FD_ZERO(&temp);
    FD_SET(m_sock, &temp);

    //setup the timeout to 1000ms
    struct timeval tv;
    tv.tv_sec = 0;
    tv.tv_usec = 1000;
    //temp.fd_count possible?
    if (select(m_sock+1, &temp, nullptr, nullptr, &tv) == -1)
    {
        return false;
    }

    if (FD_ISSET(m_sock, &temp)) 
        return true;

    return false;
}

我正在与一个 java 客户端连接并发送一条我在 ctor 内部读取的“连接”消息：

ClientHandle::ClientHandle(SOCKET s) : m_sock(s)
{
    while (!hasData())
    {
    }
    char buffer[5];
    recv(m_sock, buffer, 4, NULL);
    auto i = atoi(buffer);
    LOG_INFO << "Byte to receive: " << i;
    auto dataBuffer = new char[i + 1]{'\0'};
    recv(m_sock, dataBuffer, i, NULL);
    LOG_INFO << dataBuffer;
    //clean up
    delete[] dataBuffer;
}

这似乎工作正常。之后，我会继续检查是否有新数据，即使 java 客户端没有发送任何新数据。

这里是java客户端。不要评判我，这只是为了检查连接。将大小信息作为 char[] 发送不会一直这样。

public static void main(String[] args) throws UnknownHostException,
        IOException {
    Socket soc = null;

    soc = new Socket("localhost", 6060);
    PrintWriter out = new PrintWriter(soc.getOutputStream(), true);
    BufferedReader in = new BufferedReader(new InputStreamReader(
            soc.getInputStream()));

    if (soc != null)
        System.out.println("Connected");
    out.write("10\0");
    out.flush();
    out.write("newCon\0");
    out.flush();    
    out.close();
    in.close();
    soc.close();
}

那么 hasData FD_ISSET 方法有什么问题呢？

Answer 1

那么 hasData FD_ISSET 方法有什么问题呢？

其实没有。你使用recv()有问题。

recv() 将在客户端断开连接时返回 0 并将返回此直到您 close 套接字（服务器端）。您可以找到此信息in the manual。 即使recv() 返回0，它也会“触发”select()。

知道了这一点，就很容易找出问题所在：您从不检查recv() 的返回值，因此您无法判断客户端是否仍处于连接状态。不过，你还是用FD_SET!

#include <sys/types.h> // for ssize_t
#include <stdio.h> // for perror()
ClientHandle::ClientHandle(SOCKET s) : m_sock(s)
{
    while (!hasData())
    {
    }
    char buffer[5];
    ssize_t ret = recv(m_sock, buffer, 4, NULL);
    if (ret == -1) // error
    {
        perror("recv");
        return ;
    }
    else if (ret == 0) // m_sock disconnects
    {
       close(m_sock);
       // DO NOT FD_SET m_sock since the socket is now closed 
    }
    else
    {
        auto i = atoi(buffer);
        LOG_INFO << "Byte to receive: " << i;
        auto dataBuffer = new char[i + 1]{'\0'};
        recv(m_sock, dataBuffer, i, NULL);
        LOG_INFO << dataBuffer;
        //clean up
        delete[] dataBuffer;
    }
}

Answer 2

来自 Steven 的书 UNIX Networking Programming：

如果以下四个条件中的任何一个为真，则套接字已准备好读取：

• 套接字接收缓冲区中的数据字节数大于或等于套接字接收缓冲区的低水位标记的当前大小。套接字上的读取操作不会阻塞，并且会返回一个大于 0 的值（即准备好读取的数据）。我们可以使用 SO_RCVLOWAT 套接字选项设置这个低水位线。 TCP 和 UDP 套接字默认为 1。

• 连接的读取部分已关闭（即，已收到 FIN 的 TCP 连接）。对套接字的读操作不会阻塞，会返回 0（即 EOF）。

• 套接字是侦听套接字，已完成的连接数非零。监听套接字上的接受通常不会阻塞，尽管我们将在第 16.6 节中描述接受可以阻塞的时间条件。

• 一个套接字错误未决。套接字上的读取操作不会阻塞，并将返回错误 (–1)，并将 errno 设置为特定的错误条件。也可以通过调用 getsockopt 并指定 SO_ERROR 套接字选项来获取和清除这些未决错误。

ISSET 在上述所有情况下都将返回 true。在您的 Java 客户端关闭连接后，套接字将准备好在服务器中读取。

在 ClientHandle::ClientHandle 中，您没有检查 recv 的返回值以及是否返回任何数据。

在第二次调用 recv 时是否阻塞？

Answer 3

您没有检查recv 的返回值，并且您没有处理接收的字节数比您要求的少。那么当连接关闭时，您期望会发生什么？