阻塞模式下socket connect()遇服务器未运行的实现与疑问

阻塞模式下connect()的行为是否正常？ #

是的，这完全符合阻塞connect()的预期逻辑：

• 当目标服务器未启动（对应端口无监听进程），TCP协议发送SYN包后会立刻收到对方的RST响应，此时connect()会马上返回失败，错误码为ECONNREFUSED（也就是你看到的errno=111）。
• 只有当目标主机可达但服务器暂时无响应（比如网络延迟、服务器忙但端口处于监听状态），阻塞connect()才会等待系统默认的超时时间（通常几十秒）后再返回失败。

能否配置connect()使其等待服务器启动后再返回？ #

直接修改阻塞connect()的原生行为做不到，但可以通过「非阻塞Socket + IO多路复用」的方式实现类似效果，让程序持续等待直到服务器启动、连接成功再返回：

实现思路 #

1. 将Socket设置为非阻塞模式，调用connect()时会立即返回EINPROGRESS（表示连接正在异步进行中）。
2. 使用select()/poll()/epoll()监听该Socket的可写事件，可设置短轮询间隔（比如1秒），或持续等待直到事件触发。
3. 事件触发后，通过getsockopt()获取连接状态：如果成功则恢复Socket模式并返回；如果失败（比如仍为ECONNREFUSED），则重复上述流程直到连接成功。

修改后的示例代码 #

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <errno.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
#include <fcntl.h>
#include <sys/select.h>

int socket_connect(const char *host, int port)
{
    struct sockaddr_in sa;
    struct hostent *hp;
    int sockfd;
    int flags;
    int ret;
    fd_set writefds;
    struct timeval tv;

    hp = gethostbyname(host);
    if (hp == NULL)
    {
        return -1;
    }

    memset(&sa, 0, sizeof(sa));
    sa.sin_family = AF_INET;
    sa.sin_port = htons(port);
    memcpy(&sa.sin_addr, hp->h_addr, hp->h_length);

    while (1)
    {
        sockfd = socket(AF_INET, SOCK_STREAM, 0);
        if (sockfd < 0)
        {
            perror("socket failed");
            sleep(1);
            continue;
        }

        // 将Socket设为非阻塞模式
        flags = fcntl(sockfd, F_GETFL, 0);
        if (fcntl(sockfd, F_SETFL, flags | O_NONBLOCK) < 0)
        {
            perror("fcntl failed");
            close(sockfd);
            sleep(1);
            continue;
        }

        // 发起非阻塞连接
        ret = connect(sockfd, (struct sockaddr *)&sa, sizeof(sa));
        if (ret == 0)
        {
            // 意外的立即成功，恢复阻塞模式后返回
            fcntl(sockfd, F_SETFL, flags);
            return sockfd;
        }
        else if (errno != EINPROGRESS)
        {
            // 连接直接失败，关闭Socket后重试
            close(sockfd);
            printf("connect failed, errno=%d, retrying...\n", errno);
            sleep(1);
            continue;
        }

        // 用select等待连接完成
        FD_ZERO(&writefds);
        FD_SET(sockfd, &writefds);
        tv.tv_sec = 1; // 每次等待1秒，可按需调整
        tv.tv_usec = 0;

        ret = select(sockfd + 1, NULL, &writefds, NULL, &tv);
        if (ret < 0)
        {
            perror("select failed");
            close(sockfd);
            sleep(1);
            continue;
        }
        else if (ret == 0)
        {
            // 超时，继续等待
            continue;
        }
        else
        {
            // 检查连接是否成功
            int err;
            socklen_t err_len = sizeof(err);
            if (getsockopt(sockfd, SOL_SOCKET, SO_ERROR, &err, &err_len) == 0)
            {
                if (err == 0)
                {
                    // 连接成功，恢复阻塞模式后返回
                    fcntl(sockfd, F_SETFL, flags);
                    return sockfd;
                }
                else
                {
                    printf("connect failed after select, errno=%d, retrying...\n", err);
                    close(sockfd);
                    sleep(1);
                    continue;
                }
            }
            else
            {
                perror("getsockopt failed");
                close(sockfd);
                sleep(1);
                continue;
            }
        }
    }
}

注意事项 #

• 上述代码会无限重试直到连接成功，你可以根据需求添加最大重试次数限制。
• 恢复Socket的阻塞模式是为了适配后续依赖阻塞IO的逻辑，若不需要可跳过该步骤。
• 相比你原有的循环方案，这种方式更高效，等待时不会占用CPU资源（select是阻塞等待事件触发）。

内容的提问来源于stack exchange，提问作者Epsilon