c++ - 套接字:测量自上一条消息以来耗时

Question

我有多个客户端向服务器发送消息。当超过 5 秒没有新消息时，我正在尝试检测情况。这是我的代码(我删除了很多不相关的行):

listen(sockfd, 5000);
time_t new_msg;
time(&new_msg);

while (true) {
    time_t current;
    time(&current);
    //if more than 5 seconds passed since the last message:
    if (difftime(current, new_msg) > 5) { 
    //do something
    }

    client = accept(sockfd, (struct sockaddr *) &cli_addr, &clilen);
    if (client < 0) {
        cout << "Error on accepting" << endl;
        continue;
    }
    n = read(client, buffer, read_len - 1);
    if (n < 0) cout << "Error on reading from the socket" << endl;
    else if (n == 0) continue;

    time(&new_msg); //save time for the last message
    //if everything is ok, do something with the message
}

问题是在最后一条消息之后(休息开始时)，当前时间和最后一条消息的时间之间的差异只被检查一次并且等于 0 秒。然后服务器似乎只是等待这一行中的消息:

client = accept(sockfd, (struct sockaddr *) &cli_addr, &clilen);

如何再次查看时间？或者有没有更简单的方法来检查服务器空闲了多长时间？

更新:

我在 accept 之前创建了以下循环:

do {
    FD_ZERO(&readfds);
    FD_SET(sockfd, &readfds);
    res = select(maxfd + 1, &readfds, NULL, NULL, &tv);
    tv.tv_sec = 5;
    tv.tv_usec = 0;
    time_t waiting;
    time(&waiting);
    if (difftime(waiting, current) >= 5) {
        //do something
    }
} while (res < 0);

它看起来不是很干净，但至少可以工作。

Answer 1

你能试试这个吗？

fcntl(sockfd, F_SETFL, O_NONBLOCK);
listen(sockfd, 5000);
time_t new_msg;
time(&new_msg);

while (true) {
    time_t current;
    ...

另一种可能性是使用 select() 或 poll() 而不是 accept()。