4

cでソケットを使用していて、send/recvで成功しました。ただし、問題は、サーバーがクラッシュしたときに、クライアントがサーバーに再接続する必要があることです (サーバーはしばらくすると実行されます)。だからここで私がしたこと：

  1. ソケットを作成する
  2. 接続
  3. 受信/送信
    • recv サイズ == 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);                 
                }

            } 
-----------------------------
4

1 に答える 1

7
  1. ソケットを作成する
  2. 接続
  3. recv size == 0の場合、recv/sendステップ2に進みます。

TCPソケットを再接続することはできません。新しいソケットを作成する必要があります。また、recvまたはsendエラーの場合も処理する必要があります。

したがって、これは次のようにする必要があります。

  1. ソケットを作成する
  2. 接続
  3. recvが<=0を返すか、sendが-1を返す場合（タイムアウトではない場合）、recv / sendソケットを閉じ、ステップ1に進みます。

ただし、コードはステップ2と3を繰り返すだけでなく、これらすべてのステップをすでに実行しているようです。そのため、観察している実際の問題が何であるかは少し不明確です。

さらに、connect（）が失敗した場合、initSocket（）コードはソケットをclose（）しないため、サーバーに障害が発生すると、ソケットが簡単にリークされ、ファイル記述子が1秒以内に不足します。close（）する必要があります。使用しない場合は、作成したばかりのソケット。

于 2012-05-10T13:31:18.403 に答える