在c中使用套接字重新连接

Question

即时通讯在c中使用socket并在send/recv上获得成功.但问题是当我的服务器崩溃时,客户端必须重新连接服务器(服务器运行一段时间后).所以我在这做了什么:

1. 创建一个套接字
2. 连
3. 的recv /发
   • 如果recv size == 0,请转到步骤2.

这个算法不适合我.有什么想法吗？

码:

int initSocket(char *servIP, unsigned short serverPort)
{
    portNum = serverPort;
    ipAddr = servIP;
                            /* Socket descriptor */
    struct sockaddr_in echoServAddr; /* Echo server address */

    if ((sock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0)
    {
        printf("socket() failed");
        bConnected = -1;
        return -1;
    }

    /* Construct the server address structure */
    memset(&echoServAddr, 0, sizeof(echoServAddr));     /* Zero out structure */
    echoServAddr.sin_family      = AF_INET;             /* Internet address family */
    echoServAddr.sin_addr.s_addr = inet_addr(ipAddr);   /* Server IP address */
    echoServAddr.sin_port        = htons(portNum);      /* Server port */

    struct timeval timeout;
    timeout.tv_sec = 0;
    timeout.tv_usec = 20000;

    if (setsockopt (sock, SOL_SOCKET, SO_RCVTIMEO, (char *)&timeout, sizeof(timeout)) < 0)
        error("setsockopt failed\n");

    /*if (setsockopt (sock, SOL_SOCKET, SO_SNDTIMEO, (char *)&timeout, sizeof(timeout)) < 0)
         error("setsockopt failed\n");
    */
    /* Establish the connection to the echo server */
    if (connect(sock, (struct sockaddr *) &echoServAddr, sizeof(echoServAddr)) < 0)
    {
        printf("connect() failed\n");
        bConnected = -1;
        //close(sock);
        return -1;
    }

    bConnected = 0;
    return 0;
}




--------------- if server crashes ------------
if(recv_size == 0)
            {
            // server crashed
                while(initSocket(ipAddr, portNum) < 0)
                {
                    printf("IP : %s\v", ipAddr);
                    printf("Port : %d\v", portNum);                 
                }

            } 
-----------------------------

Answer 1

1. 创建一个套接字
2. 连
3. recv/send如果recv size == 0转到第2步.

您无法重新连接TCP套接字,您必须创建一个新的套接字.您还需要处理recv或发送错误的情况.

所以这必须是:

1. 创建一个套接字
2. 连
3. recv/send如果recv返回<= 0或send返回-1(并且它不是超时):关闭套接字,转到步骤1

虽然,似乎你的代码已经完成了所有这些步骤,而不仅仅是重复步骤2和3,所以有点不清楚你正在观察的实际问题是什么.

另外,当connect()失败时,你的initSocket()代码不会关闭()套接字,所以一旦服务器出现故障,你很容易在不到一秒的时间内泄漏套接字并耗尽文件描述符,你必须关闭()如果你不打算使用它,你刚刚创建的套接字.