插座-客户端双打印

Question

我正在使用套接字开发一个简单的聊天应用程序。它是客户机-服务器驱动的。除了这个我找不到的bug，一切都很完美：如果我是第一个连接到服务器的客户机，我收到的每一条消息都会在屏幕上打印一次（就像它应该的那样）。然而，如果我是第二个连接的客户，我收到的每条消息都会打印两次，第三个客户会看到他的消息三次，以此类推

当我通过插座收到东西时，我像这样打印它：

printf (" >%s \n", received);

因此，如果我收到用户“charles”发送的消息hello，我会打印消息“

我将感激任何帮助。以下是从socket接收的部分代码:

while (1) {
    recv(newsockfd, recibido, 255, 0);
    printf (">%s \n",recibido);
}

此代码由线程执行。

谢谢伙计们。

这是客户端的完整代码：

void *Atender(void *estructura){
   DATOS *info;
   info = (DATOS *)estructura;
   int newsockfd=info->socket;
   char recibido[255];
   memset(recibido,1,255);
   while (1){
       recv(newsockfd, recibido, 255, 0);
       printf (">%s \n",recibido);
       memset(recibido,0,255);
   }
}

main(int argc, char *argv[]) {
    int sockfd;
    struct sockaddr_in serveraddr;
    char *server;
    Hilos = malloc((200)*sizeof(pthread_t));

    /* Remember the program name for error messages. */
    programname = argv[0];

    //Realizo lectura e imprimo para chequear que se leyo todo bien.
    lectura(argv,argc);

    /* Who's the server? */
    server=host;


    /* Get the address of the server. */
    bzero(&serveraddr, sizeof(serveraddr));
    serveraddr.sin_family = AF_INET;
    serveraddr.sin_addr.s_addr = inet_addr(server);
    serveraddr.sin_port = htons(atoi(puerto));

    /* Open a socket. */
    sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (sockfd < 0)
        fatalerror("can't open socket");

    /* Connect to the server. */
    if (connect(sockfd, (struct sockaddr *) &serveraddr,
        sizeof(serveraddr)) < 0)
        fatalerror("can't connect to server");

    enviarInfoInicial(sockfd,nombre,"Actual");

    char buff[200];
    memset(buff,1,200);


    //Creacion del hilo que se quedara siempre escuchando
    DATOS d;
    d.socket=sockfd;
    pthread_create(&Hilos[iterador_hilos],NULL,Atender,(void *)&d);
    iterador_hilos++;

    //El que no es un hilo se queda siempre esperando por si se quiere
    //introducir un comando
    while (1) {
        fgets(buff, sizeof buff, stdin);
        mandarInstruccion(sockfd,buff);
        if ((buff[0] == 'f') & (buff[1] == 'u') & (buff[2] == 'e')){
            printf("Cchat se ha cerrado. \n");
            close(sockfd);
            exit(0);
        }

        memset(buff,1,200);
    }
}

代码是西班牙文的，但大意是可以理解的。DATOS结构只是我传递给创建线程的结构，并且只包含该线程将从中读取的套接字（while（1）之前发布）。“ATENDER”是线程将执行的过程。

以下是来自服务器的相关代码：

void EjecutarInstruccion(char tipo[],char argumento[],char usuario[]) {
    if (!strcmp(tipo,"men")) {
        char sala[20];
        char total[300];
        memset(total,0,300);
        strcpy(sala,ObtenerSalaUsuario(usuario));
        int i=0;
        for (i;i<200;i++) {
            if (!strcmp((lusuarios[i].sala),sala)) {
                strcat(total,usuario);
                strcat(total,": ");
                strcat(total,argumento);
                send (lusuarios[i].socket, total, strlen(total)+1, 0 );
            }
        }
    }
}

在服务器端，我有一个用户数组，每个用户都包含他的用户名、他所在的聊天室和他的套接字（fd）。当服务器需要发送消息时，我会浏览用户数组，并仅在该用户位于同一聊天室时才将消息发送给该用户。谢谢。

Answer 1

你不用检查返回了多少字节。它不必读取所有未完成的数据。您可能需要循环读取，直到接收到所有字节。