【问题标题】:How to avoid TIME_WAIT for server sockets? [duplicate]如何避免服务器套接字的 TIME_WAIT? [复制]
【发布时间】:2014-05-28 15:05:00
【问题描述】:

我知道您会将其掩盖为重复(question1question2question3),但答案不是我想要的(我认为其他人也是如此)。
所以,我指的是套接字大师(我爱你们):如果我关闭套接字,我怎么能得到绑定错误(地址已经在使用中)?
我将描述我的问题。

我有一个与服务器通信的客户端
在服务器中,我有两个套接字:sockS(监听的主套接字)和 sockTX(客户端)
如果我调用我的程序一次,通信正常,然后我关闭 both 套接字
如果我记得服务器和客户端,我会收到错误消息,我必须等待 TIME_WAIT(在 Ubuntu 32 位上约为 3 分钟秒)

为什么,关闭 两个 套接字后,我仍然遇到绑定错误?
有没有办法让它在没有任何魔法的情况下工作(SO_REUSEADDR)?
我知道我的代码中有问题...

谢谢大家。

这是代码
客户

#include <stdio.h>
#include <stdlib.h>
#include <ctype.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <string.h>
#include <netdb.h>
#include <unistd.h>
#include <arpa/inet.h>

#define PORT 5000
#define SERVER "127.0.0.1"
#define MAXLINE 128

int printMessage(char* str);

int main(){
char buff[MAXLINE+1];

struct sockaddr_in server, client;
struct hostent *host;
int sock, n;
//socklen_t len;

    if((sock = socket(AF_INET,SOCK_STREAM,0)) == -1){
        perror("\nErrore socket()");
        return -1;
    }

    client.sin_family = AF_INET;
    client.sin_port = htons(0); // la porta e' scelta dal sistema operativo
    client.sin_addr.s_addr = htonl(INADDR_ANY);

    if( bind(sock,(struct sockaddr*)&client, sizeof(client)) == -1){
        perror("\nErrore bind()");
        return -1;
    }

    server.sin_family = AF_INET;
    server.sin_port = htons(PORT);

    if((host = gethostbyname(SERVER)) == NULL ){
        perror("\nErrore gethostbyname()");
        return -1;
    }

    server.sin_addr = *((struct in_addr *)host->h_addr);

    if(connect(sock, (struct sockaddr*)&server, sizeof(server)) < 0){
        perror("\nErrore connect");
        return -1;
    }

    // MESSAGGIO

    sprintf(buff, "CTX\nclientTX\nserver\nCiao da client\n");
    if(send(sock, buff, strlen(buff), 0) < 0) {
        perror("\nErrore sendto");
        return -1;
    }
    else {
        printf("\nMessaggio inviato");
    }

    if((n = recv(sock, buff, MAXLINE, 0)) < 0) {
        perror("\nErrore ricezione risposta");
        return -1;
    } else {
        buff[n] = '\0';
        int test = printMessage(buff);
        printf("\nEsito: %s\n", (test == 1 ? "OK" : "FAIL"));
    }

    shutdown(sock, 2); // 2 = RD_WR
    close(sock);
    return 0;
}

int printMessage(char* str){
int i;
char* temp;

    printf("Mittente: ");
    for(i = 0; str[i] != '\n'; i++)
        printf("%c", str[i]);
    printf(" ");
    for(i = i+1; str[i] != '\n'; i++)
        printf("%c", str[i]);
    printf("\nDestinatario: ");
    for(i = i+1; str[i] != '\n'; i++)
        printf("%c", str[i]);

    temp = (char*)malloc(30 * sizeof(char));
    strncpy(temp, str+i+1, 30);
    printf("Messaggio: %s\n", temp);

    if(strcmp(temp, "OK") == 0)
        return 1;
    else
        return 0;
}


服务器:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netdb.h>
#include <unistd.h>
#include <arpa/inet.h>

#define PORT 5000
#define SERVER "127.0.0.1"
#define MAXLINE 128

int printMessage(char* str);

int main() {
char buff[MAXLINE+1];
struct sockaddr_in server; //, client;
int sockS, sockTX, n;

    if((sockS = socket(AF_INET,SOCK_STREAM,0)) == -1)
    {
        perror("\nErrore socket()");
        return -1;
    }

    server.sin_family = AF_INET;
    server.sin_port = htons(PORT);
    server.sin_addr.s_addr = htonl(INADDR_ANY);

    if(bind(sockS, (struct sockaddr *)&server, sizeof(server)) == -1)
    {
        perror("\nErrore bind()");
        return -1;
    }

    if(listen(sockS, 10) == -1)
    {
        perror("\nErrore listen()");
        return -1;
    }
    printf("SERVER\nInizializzazione completata!\n");

    if((sockTX = accept(sockS, (struct sockaddr *)NULL, NULL)) == -1)
    {
        perror("\nErrore accept()");
        return -1; 
    }
    printf("Socket connesso\n");

    // INVIO
    if((n = recv(sockTX, buff, MAXLINE, 0)) < 0) {
        perror("\nErrore recv()");
        return -1; // BREAK??

    } else {
        buff[n] = '\0';
        printMessage(buff);

    }

    sprintf(buff, "S\nserver\nclientTX\nOK\n");
    if(send(sockTX, buff, strlen(buff), 0) < 0){
        perror("\nErrore send()");
        return -1; // BREAK??

    } else {
        printf("Risposta inviata\n");

    }

    shutdown(sockTX, 2);
    close(sockTX);

    shutdown(sockS, 2);
    close(sockS);
    return 0;   
}

int printMessage(char* str){
int i;
char* temp;

    printf("Mittente: ");
    for(i = 0; str[i] != '\n'; i++)
        printf("%c", str[i]);
    printf(" ");
    for(i = i+1; str[i] != '\n'; i++)
        printf("%c", str[i]);
    printf("\nDestinatario: ");
    for(i = i+1; str[i] != '\n'; i++)
        printf("%c", str[i]);

    temp = (char*)malloc(30 * sizeof(char));
    strncpy(temp, str+i+1, 30);
    printf("Messaggio: %s\n", temp);

    if(strcmp(temp, "OK\n") == 0)
        return 1;
    else
        return 0;
}

谢谢大家

编辑 1:可能的解决方案(不是很漂亮,但比 SOCK_REUSEADDR 多一点)
尝试在关闭和关闭两个服务器的套接字之前添加一个 sleep(1)。
客户端将在服务器之前关闭,它会工作
不是很漂亮,我知道。

或者,更好的是,在关闭服务器内部的第一个套接字之前,您可以检查客户端是否关闭了连接(如here

【问题讨论】:

  • SO_REUSEADDR 的魔法。
  • SO_REUSEADDR 不是“魔法”;这是你问题的答案。您不喜欢正确答案的事实不是重复问题的理由;答案不会改变。
  • 另外:将客户端套接字绑定到特定端口确实是个坏主意。让操作系统为你选择一个端口,你不会有任何问题。只有服务器需要众所周知的(固定)端口。
  • @rici 我在第一行写了(链接号 1),以及我决定发布问题的原因,并且我使用了一个固定的端口,因为我有一个服务器..
  • @Duck 我一直在寻找更“优雅”的东西:)

标签: c linux sockets


【解决方案1】:

如果按照 TCP 状态机图,您会看到如果套接字发起发送 FIN,则套接字必须转换到 TIME-WAIT 状态。使用 shutdown(sockTX, 2) 而不等待客户端的 FIN 正是这样做的。

如果您希望服务器等待客户端的 FIN,您可以先阻止 recv() 等待返回值 0。然后,你可以close()

请注意,除非您以某种方式复制了套接字(使用dup*()fork() 调用),否则如果紧跟close(),则无需调用shutdown()。你可以直接调用close()(如果socket已经被复制,只有在最后一个副本关闭时才会发送FIN)。

根本不需要shutdown()接受套接字(sockS)。

因此,我会将您的服务器端更改为如下所示以清理套接字:

while (recv(sockTX,...) > 0) {}
close(sockTX);

close(sockS);

【讨论】:

  • 哦,完美:D 我刚刚在关闭第一个套接字之前添加了一个“recv”,它可以工作:D 我只尝试了发送,但它给了我(显然)一些问题。 (现在)它有效。谢谢:D
  • 只有一点:如果我写 while(recv()
  • while (recv() &lt; 0); 几乎与我的建议相反。您要做的是等待客户端FIN,因此您要测试是否返回0值或错误。如果你保存返回值,你会看到你收到了什么值,如果小于0,你应该检查错误是什么。
  • 是的,很抱歉,这是评论中的印刷错误。我的代码是 while(1) { if(recv(sockTX, buff, MAXLINE, 0)
  • 在那个版本中,如果返回 0,代码会再次调用recv(),这是错误的。返回 0 表示 FIN 已到。
猜你喜欢
  • 1970-01-01
  • 2015-09-15
  • 1970-01-01
  • 2016-05-07
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2020-06-24
相关资源
最近更新 更多