multithreading - 複数のクライアントとサーバーの通信

Question

私はクライアントサーバープログラミングの初心者ですが、特定のことを理解し、クライアントとサーバーの間で通信しようとしている方法の一部です。私のコードはバグがあり、文字列全体を表示していません。クライアントからサーバーに文字列全体 (スペースを含む) を送信する方法を教えてください。

出力:
RHU>> confgiure CM ポート (これは私の文字列全体です) server reply=configure
RHU>> server reply=CM RHU>> server reply=port

上記のすべてが1つの文字列構成CMポートに対して出力されます

もう1つ、上記のケースでargv []でこれらの引数をキャッチする方法があります。これが私のサーバーコードです。

//Create socket
socket_desc = socket(AF_INET , SOCK_STREAM , 0);
if (socket_desc == -1)
{
    printf("Could not create socket");
}
puts("Socket created");

//Prepare the sockaddr_in structure
server.sin_family = AF_INET;
server.sin_addr.s_addr = INADDR_ANY;
server.sin_port = htons( 8888 );

//Bind
if( bind(socket_desc,(struct sockaddr *)&server , sizeof(server)) < 0)
{
    //print the error message
    perror("bind failed. Error");
    return 1;
}
puts("bind done");

//Listen
listen(socket_desc , 3);

//Accept and incoming connection
puts("Waiting for incoming connections...");
c = sizeof(struct sockaddr_in);


//Accept and incoming connection
puts("Waiting for incoming connections...");
c = sizeof(struct sockaddr_in);
pthread_t thread_id;

while( (client_sock = accept(socket_desc, (struct sockaddr *)&client, (socklen_t*)&c)) )
{
    puts("Connection accepted");

    if( pthread_create( &thread_id , NULL ,  connection_handler , (void*) &client_sock) < 0)
    {
        perror("could not create thread");
        return 1;
    }

    //Now join the thread , so that we dont terminate before the thread
    //pthread_join( thread_id , NULL);
    puts("Handler assigned");
}

if (client_sock < 0)
{
    perror("accept failed");
    return 1;
}

return 0;

}

//void connectionhandler(void *sock_desc)
{
//write(sock , message , strlen(message));

//message = "Now type something and i shall repeat what you type \n";
//write(sock , message , strlen(message));

//Receive a message from client
while( (read_size = recv(sock , client_message , 2000, 0)) > 0)
{
    client_message[read_size] = '\0';
    write(sock, client_message, strlen(client_message));
    memset(client_message, 0, 2000);
}

if(read_size == 0)
{
    puts("Client disconnected");
    fflush(stdout);
}
else if(read_size == -1)
{
    perror("recv failed");
}


return 0;

私
のクライアントコード

//Create socket
sock = socket(AF_INET , SOCK_STREAM , 0);
if (sock == -1)
{
    printf("Could not create socket");
}
//puts("Socket created");

server.sin_addr.s_addr = inet_addr("127.0.0.1");
server.sin_family = AF_INET;
server.sin_port = htons( 8888 );

//Connect to remote server
if (connect(sock , (struct sockaddr *)&server , sizeof(server)) < 0)
{
    perror("connect failed. Error");
    return 1;
}

//puts("Connected\n");
printf("!!Welcome to RHU CLI!!\n"); 
//keep communicating with server
while(1)
{
    fflush(stdout);
    printf("RHU>> : ");  
    scanf("%s" , message);

    //Send some data
    if( send(sock , message , strlen(message) , 0) < 0)
    {
        puts("Send failed");
        return 1;
    }
    //Receive a reply from the server
   if( recv(sock , server_reply , 2000 , 0) < 0)
    {
        puts("recv failed");
        break;
    }
    printf("server reply=%s\n", server_reply);
    //if(strcmp(server_reply, "?") == 0)
    //puts("confgiure");
    parse_init(server_reply);
    memset(server_reply, 0, 2000);
    fflush(stdout);
}

close(sock);
return 0;

}