远程主机终止后 Recv() 调用挂起

我的问题是我有一个线程处于 recv() 调用中。远程主机突然终止（没有 close() 套接字调用）并且 receive() 调用继续阻塞。这显然不好，因为当我加入线程以关闭进程（本地）时，该线程永远不会退出，因为它正在等待永远不会到来的接收。

所以我的问题是人们通常认为什么方法是处理这个问题的最佳方法？在回答之前还应该了解一些其他注意事项：

• 我无法确保远程主机在退出之前关闭套接字。

• 该解决方案无法使用外部库（例如boost）。它必须使用 C++/C 的标准库/功能（最好不是 C++0x 特定的）。

我知道过去可能有人问过这个问题，但我想让别人了解如何正确纠正这个问题（而不需要做一些我过去会做的超级黑客行为）。

Thanks!

假设您想继续使用阻塞套接字，您可以使用SO_RCVTIMEO插座选项 http://linux.die.net/man/7/socket:

   SO_RCVTIMEO and SO_SNDTIMEO
          Specify the receiving or sending  timeouts  until  reporting  an
          error.   The parameter is a struct timeval.  If an input or out-
          put function blocks for this period of time, and data  has  been
          sent  or received, the return value of that function will be the
          amount of data transferred; if no data has been transferred  and
          the  timeout has been reached then -1 is returned with errno set
          to EAGAIN or EWOULDBLOCK just as if the socket was specified  to
          be  nonblocking.   If  the  timeout is set to zero (the default)
          then the operation will never timeout.

因此，在您开始接收之前：

struct timeval timeout = { timo_sec, timo_usec };
int r = setsockopt(s, SOL_SOCKET, SO_RCVTIMEO, &timeout, sizeof(timeout));
assert(r == 0); /* or something more user friendly */

如果你愿意使用非阻塞 I/O，那么你可以使用poll(), select(), epoll(), kqueue()，或者任何适合您的系统的事件调度机制。需要使用非阻塞 I/O 的原因是您需要允许系统调用recv()返回以通知您套接字的输入队列中没有数据。使用的示例有点复杂：

for (;;) {
    ssize_t bytes = recv(s, buf, sizeof(buf), MSG_DONTWAIT);
    if (bytes > 0) { /* ... */ continue; }
    if (bytes < 0) {
        if (errno == EWOULDBLOCK) {
            struct pollfd p = { s, POLLIN, 0 };
            int r = poll(&p, 1, timo_msec);
            if (r == 1) continue;
            if (r == 0) {
                /*...handle timeout */
                /* either continue or break, depending on policy */
            }
        }
        /* ...handle errors */
        break;
    }
    /* connection is closed */
    break;
}