Вот мой клиент-серверный код, который работает только для одного пользователя одновременно, и клиент может отправлять столько сообщений, сколько он хочет.
Я показываю полученное сообщение на сервере и его ответ (который фактически является обратным), а также сообщение «сообщение отправлено».
На стороне клиента я показываю входящее сообщение и ответ сервера: «сообщение получено»
Но есть проблема в моем коде: когда я пытаюсь отправить несколько сообщений, я получаю правильный вывод на стороне сервера, но не на стороне клиента, что является только «сообщением получено», но после этого функция помещается, она не выводит вывод чтобы вывести из строя.
Я перепробовал много вещей, но я не нашел способа сделать это.
Есть ли промывка в стандартный вывод или я что-то упустил?
Пожалуйста, скажите мне.
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]
У вас есть проблема в этом месте в коде на стороне сервера:
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");
В этом коде есть разные недостатки.
Сторона сервера:
client_sock
в цикле, но только закрывайте его в дочернем элементе: у вас есть утечка дескрипторов сокетов -> родитель должен также иметь close(client_sock);
strlen
найти полезную часть и отправить обратно 2000 байтов (то есть вы отправляете мусор).Сторона клиента:
Вы смешиваете размер буфера, длину строки и количество отправленных / полученных байтов. На сервере вы должны использовать количество полученных байтов и никогда не выводить больше его если вы знаете, сообщение теряет силу, никогда не выводите больше, чем его длина. И если вы хотите обменяться более чем одним сообщением, используйте стратегию разграничения (заканчивающуюся нулем (редко) или \n
, отправьте первый или 2 байта, содержащие размер).