建立多个连接时如何在C中设置套接字超时？

Question

我正在编写一个简单的程序，它可以与不同的服务器建立多个连接以进行状态检查。所有这些连接都是按需构建的；最多可以同时创建 10 个连接。我不喜欢每个套接字一个线程的想法，所以我将所有这些客户端套接字设为非阻塞，并将它们放入 select() 池中。

效果很好，直到我的客户抱怨目标服务器停止响应时等待时间太长才能得到错误报告。

我检查了论坛中的几个主题。有人建议可以使用 alarm() 信号或在 select() 函数调用中设置超时。但我正在处理多个连接，而不是一个。当一个进程范围的超时信号发生时，我无法区分所有其他连接之间的超时连接。

有没有办法改变系统默认的超时时间？

Answer 1

您可以使用 SO_RCVTIMEO 和 SO_SNDTIMEO 套接字选项为任何套接字操作设置超时，如下所示：

    struct timeval timeout;      
    timeout.tv_sec = 10;
    timeout.tv_usec = 0;
    
    if (setsockopt (sockfd, SOL_SOCKET, SO_RCVTIMEO, &timeout,
                sizeof timeout) < 0)
        error("setsockopt failed\n");

    if (setsockopt (sockfd, SOL_SOCKET, SO_SNDTIMEO, &timeout,
                sizeof timeout) < 0)
        error("setsockopt failed\n");
    

编辑：来自setsockoptman page：

SO_SNDTIMEO 是为输出操作设置超时值的选项。它接受一个 struct timeval 参数，其中包含用于限制等待输出操作完成的秒数和微秒数。如果发送操作阻塞了这么长时间，它会返回部分计数，如果没有发送数据，则会返回错误 EWOULDBLOCK。在当前的实现中，每次向协议传递附加数据时都会重新启动此计时器，这意味着该限制适用于输出部分的大小范围从输出的低水位线到高水位线。

SO_RCVTIMEO 是为输入操作设置超时值的选项。它接受一个 struct timeval 参数，其中包含用于限制等待输入操作完成的秒数和微秒数。在当前实现中，每次协议接收到附加数据时都会重新启动该计时器，因此该限制实际上是一个不活动计时器。如果一个接收操作被阻塞了这么长时间而没有接收到额外的数据，它会返回一个短计数或如果没有接收到数据则返回错误 EWOULDBLOCK。 struct timeval 参数必须代表一个正的时间间隔；否则，setsockopt() 返回错误 EDOM。

Answer 2

我不确定我是否完全理解这个问题，但猜想它与我的问题有关，我正在使用带有 TCP 套接字通信的 Qt，Windows 和 Linux 都是非阻塞的。..

希望在已连接的客户端失败或完全消失时获得快速通知，而不是等待默认的 900 多秒直到断开信号发出。实现这项工作的技巧是将 SOL_TCP 层的 TCP_USER_TIMEOUT 套接字选项设置为所需的值，以毫秒为单位。

这是一个相当新的选项，请参阅https://www.rfc-editor.org/rfc/rfc5482，但显然它工作正常，在 WinXP、Win7/x64 和 Kubuntu 12.04/x64 上尝试过，我选择的 10 秒结果有点长，但是比我之前尝试过的任何东西都要好;-)

我遇到的唯一问题是找到正确的包含，因为显然这没有添加到标准套接字包含中（还......），所以最后我自己定义它们如下：

#ifdef WIN32
    #include <winsock2.h>
#else
    #include <sys/socket.h>
#endif

#ifndef SOL_TCP
    #define SOL_TCP 6  // socket options TCP level
#endif
#ifndef TCP_USER_TIMEOUT
    #define TCP_USER_TIMEOUT 18  // how long for loss retry before timeout [ms]
#endif

设置此套接字选项仅在客户端已连接时有效，代码行如下所示：

int timeout = 10000;  // user timeout in milliseconds [ms]
setsockopt (fd, SOL_TCP, TCP_USER_TIMEOUT, (char*) &timeout, sizeof (timeout));

并且初始连接的失败被调用connect()时启动的计时器捕获，因为不会有Qt的信号，连接信号不会被引发，因为没有连接，并且也不会发出断开信号，因为还没有连接..

Answer 3

你不能实现自己的超时系统吗？

保留超时事件的排序列表，或者更好的是 Heath 建议的优先级堆。在您的 select 或 poll 调用中，使用超时列表顶部的超时值。当该超时到达时，执行附加到该超时的操作。

该操作可能是关闭尚未连接的套接字。

Answer 4

connect 超时必须使用非阻塞套接字来处理（GNU LibC documentation on connect）。您让connect 立即返回，然后使用select 等待连接完成超时。

这里也有解释：Operation now in progress error on connect( function) error。

int wait_on_sock(int sock, long timeout, int r, int w)
{
    struct timeval tv = {0,0};
    fd_set fdset;
    fd_set *rfds, *wfds;
    int n, so_error;
    unsigned so_len;

    FD_ZERO (&fdset);
    FD_SET  (sock, &fdset);
    tv.tv_sec = timeout;
    tv.tv_usec = 0;

    TRACES ("wait in progress tv={%ld,%ld} ...\n",
            tv.tv_sec, tv.tv_usec);

    if (r) rfds = &fdset; else rfds = NULL;
    if (w) wfds = &fdset; else wfds = NULL;

    TEMP_FAILURE_RETRY (n = select (sock+1, rfds, wfds, NULL, &tv));
    switch (n) {
    case 0:
        ERROR ("wait timed out\n");
        return -errno;
    case -1:
        ERROR_SYS ("error during wait\n");
        return -errno;
    default:
        // select tell us that sock is ready, test it
        so_len = sizeof(so_error);
        so_error = 0;
        getsockopt (sock, SOL_SOCKET, SO_ERROR, &so_error, &so_len);
        if (so_error == 0)
            return 0;
        errno = so_error;
        ERROR_SYS ("wait failed\n");
        return -errno;
    }
}