Почему функция put () не печатает многократный вывод в коде сокета клиент-сервер?

Вот мой клиент-серверный код, который работает только для одного пользователя одновременно, и клиент может отправлять столько сообщений, сколько он хочет.

Я показываю полученное сообщение на сервере и его ответ (который фактически является обратным), а также сообщение «сообщение отправлено».

На стороне клиента я показываю входящее сообщение и ответ сервера: «сообщение получено»

Но есть проблема в моем коде: когда я пытаюсь отправить несколько сообщений, я получаю правильный вывод на стороне сервера, но не на стороне клиента, что является только «сообщением получено», но после этого функция помещается, она не выводит вывод чтобы вывести из строя.

Я перепробовал много вещей, но я не нашел способа сделать это.

Есть ли промывка в стандартный вывод или я что-то упустил?
Пожалуйста, скажите мне.

server code::::::
#include <stdio.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <stdlib.h>
int main(int argc , char *argv[])
{
int socket_desc , client_sock , c , read_size;
struct sockaddr_in server , client;
char client_message[2000];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( 42969 );

//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);
while(1)
{
//accept connection from an incoming client
client_sock = accept(socket_desc, (struct sockaddr *)&client, (socklen_t*)&c);
if (client_sock < 0)
{
perror("accept failed");
return 1;
}
puts("Connection accepted");
pid_t p=fork();
if(p==0)
{
close(socket_desc);
//Receive a message from client
while( (read_size = recv(client_sock , client_message , sizeof(client_message) , 0)) > 0 )
{
puts(client_message);
char message[20000];
int i,j=0;
for(i=strlen(client_message)-1;i>=0;i--)
message[j++]=client_message[i];
message[j]='\0';
puts(message);
//Send the message back to client
if( send(client_sock , message , sizeof(message),0)>0)
puts("message sent");
// memset(client_message,'\0',sizeof(client_message));
//memset(message,'\0',sizeof(message));
}

if(read_size == 0)
{
puts("Client disconnected");
fflush(stdout);
}
else if(read_size == -1)
{
perror("recv failed");
}
close(client_sock);
exit(1);
}
}
close(socket_desc);
return 0;
}client code::::

#include<stdio.h>
#include<string.h>
#include<sys/socket.h>
#include<arpa/inet.h>
#include<stdlib.h>

int main(int argc , char *argv[])
{
int sock;
struct sockaddr_in server;
// char message[1000] ,
char server_reply[2000];

//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 (42969 );

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

puts("Connected\n");

//keep communicating with server
while(1)
{
printf("Enter message : ");
char message[1000];
scanf("%s" , message);
//Send some data
if( send(sock , message , sizeof(message) , 0) < 0)
{
puts("Send failed");
return 1;
}

//Receive a reply from the server
if( recv(sock , server_reply , sizeof(server_reply) , 0) > 0)
{
puts("message got");

}

puts("Server reply :");
puts(server_reply);
fflush(stdout);
//memset(server_reply,'\0',sizeof(server_reply));
// memset(message,'\0',sizeof(message));
}

close(sock);
return 0;
}

[/ NOEDIT]

0

Решение

У вас есть проблема в этом месте в коде на стороне сервера:

   if( send(client_sock , message , sizeof(message),0)>0)
puts("message sent");

Вы должны заменить:

   if( send(client_sock , message , strlen(message) + 1,0)>0)
puts("message sent");
0

Другие решения

В этом коде есть разные недостатки.

Сторона сервера:

  • вы принимаете сокет client_sock в цикле, но только закрывайте его в дочернем элементе: у вас есть утечка дескрипторов сокетов -> родитель должен также иметь close(client_sock);
  • клиент отправляет сообщение максимального размера 1000, который сервер читает в буфере размера 2000. Хорошо до здесь. Но вы используете strlen найти полезную часть и отправить обратно 2000 байтов (то есть вы отправляете мусор).

Сторона клиента:

  • Вы читаете строку из stdin с помощью scanf в буфер или размер 1000. Хорошо. Но затем вы отправляете 1000 байт, сообщение и мусор.
  • у вас нет разграничения сообщений. Поэтому первое сообщение может потребовать много чтения (на самом деле, если нужно как минимум 2, так как вы в настоящее время отправляете 2000 байтов и читаете его кусками по 1000!)

Вы смешиваете размер буфера, длину строки и количество отправленных / полученных байтов. На сервере вы должны использовать количество полученных байтов и никогда не выводить больше его если вы знаете, сообщение теряет силу, никогда не выводите больше, чем его длина. И если вы хотите обменяться более чем одним сообщением, используйте стратегию разграничения (заканчивающуюся нулем (редко) или \n, отправьте первый или 2 байта, содержащие размер).

1

По вопросам рекламы [email protected]