2012-10-22 6 views
0

소켓 프로그래밍을 사용하여 간단한 채팅 프로그램 코드를 수정했습니다. 내 문제는 서버 또는 클라이언트에서 두 라인을 입력해야만 한 라인 만 수신하는 것입니다. . 더 많은 것을 설명하기 위해 이미지를 업로드했습니다. 도움을 주신 경우C 소켓 프로그래밍, 라인 수신 오류.

SERVER 
#include <stdio.h> 
#include <sys/types.h> 
#include<sys/socket.h> 
#include<netinet/in.h> 
#include<stdlib.h> 
#include<strings.h> 
#include<unistd.h> 
#define SERVER_TCP_PORT 3000 
#define BUFLEN 256 

int main (int argc,char **argv) 
{ 
    int n,bytes_to_read; 
    int sd,new_sd,client_len,port; 
    struct sockaddr_in server,client; 
    char *bp,buf[BUFLEN]; 

    switch (argc) { 
     case 1: 
      port = SERVER_TCP_PORT; 
      break; 
     case 2: 
      port = atoi (argv[1]); 
      break; 
     default: 
      fprintf (stderr,"Usage: %s[port]\n",argv[0]); 
      exit(1); 
      } 
    /*Create a system socket */ 

     if ((sd = socket(AF_INET,SOCK_STREAM,0))==-1){ 
      fprintf(stderr,"Can't create a socket\n"); 
      exit(1); 
      } 

    /*Bind an address to the socket*/ 

    bzero ((char*)&server,sizeof(struct sockaddr_in)); 
    server.sin_family = AF_INET; 
    server.sin_port = htons(port); 
    server.sin_addr.s_addr = htonl(INADDR_ANY); 
    if(bind(sd,(struct sockaddr *)&server,sizeof(server))==-1){ 
     fprintf(stderr,"can't bind name to socket\n"); 
     exit(1); 
    } 
    /*queue up to 5 connect requests*/ 

    listen(sd,5); 
    while(1){ 
     client_len = sizeof(client); 
    if((new_sd = accept(sd,(struct sockaddr *)&client,&client_len))==-1){ 
     fprintf(stderr,"can't accept client \n"); 
     exit(1); 
     } 

if(fork()) 
{ 
printf("\n Server listening to clients on port 2000"); 
printf("\n Server got request from%s",inet_ntoa(client.sin_addr)); 
printf("\n SEND DATA<q or Q to quit> :%s",buf); 
scanf("%s",buf); 
while((strcmp(buf,"q")!=0)&&(strcmp(buf,"Q")!=0)) 
{ 
send(new_sd,buf,30,0); 
scanf("%s",buf); 

} 
send(new_sd,"q",5,0); 
} 
else{ 
n = recv(new_sd,buf,30,0); 
while((strcmp(buf,"q")!=0)&&(strcmp(buf,"Q")!=0)) 
{ 
printf("\nRECEIVED DATA =%s",buf); 
n = recv(new_sd,buf,30,0); 

} 
printf("\n Bye"); 
send(new_sd,"EOF",4,0); 
close(sd); 
close(new_sd); 
} 
} 
return 0; 
} 



Client 
#include <stdio.h> 
#include <sys/types.h> 
#include<sys/socket.h> 
#include <netdb.h> 
#include<stdlib.h> 
#include<strings.h> 
#include <netinet/in.h> 

#define SERVER_TCP_PORT 3000 
#define BUFLEN 256 
int main(int argc,char **argv) 
{ 

int n,bytes_to_read; 
int sd,port; 
struct hostent *hp; 
struct sockaddr_in server; 
char *host,*bp,rbuf[BUFLEN],sbuf[BUFLEN]; 
switch(argc) { 
    case 2: 
     host = argv[1]; 
     port = SERVER_TCP_PORT; 
     break; 
    case 3: 
     host = argv[1]; 
     port = atoi(argv[2]); 
     break; 
    default: 
     fprintf(stderr,"Usage: %s host[port] \n",argv[0]); 
     exit(1); 
     } 

/*Create a stream socket*/ 

if ((sd=socket(AF_INET,SOCK_STREAM,0))==-1){ 
    fprintf(stderr,"Can't create a socket\n"); 
    exit(1); 
    } 
bzero ((char *)&server,sizeof(struct sockaddr_in)); 
server.sin_family = AF_INET; 
server.sin_port = htons(port); 
if((hp = gethostbyname(host))==NULL){ 
    fprintf (stderr,"Can't get server's address\n"); 
    exit(1); 
    } 
bcopy(hp->h_addr,(char *)&server.sin_addr,hp->h_length); 
/*connecting to the server*/ 

if (connect (sd,(struct sockaddr *)&server,sizeof(server))==-1){ 
    fprintf(stderr,"Can't connect \n"); 
    exit(1); 
    } 
printf("Connected:server's address is %s\n",hp->h_name); 

if(fork()) 
{ 
bzero(rbuf,30); 
printf("\n SEND DATA<q or Q to quit> :%s",rbuf); 
scanf("%s",rbuf); 
while((strcmp(rbuf,"q")!=0)&&(strcmp(rbuf,"Q")!=0)) 
{ 
send(sd,rbuf,30,0); 
scanf("%s",rbuf); 

} 
send(sd,"q",5,0); 
} 

else{ 
n = recv(sd,rbuf,30,0); 
while((strcmp(rbuf,"q")!=0)&&(strcmp(rbuf,"Q")!=0)) 
{ 
printf("\nRECEIVED DATA =%s",rbuf); 
n = recv(sd,rbuf,30,0); 

} 
printf("\n Bye"); 
send(sd,"EOF",4,0); 
close(sd); 
} 

return 0; 
} 
+1

RECV() 함수는 네트워크 스트림의 "일부"데이터를 판독한다. 문자열을 하나씩 가져 오려면 문자열의 크기가 필요합니다. 따라서 문자 수를 포함하는 헤더로 행 (문자열)을 캡슐화해야합니다. – Alican

+0

내 무지를 용서하지만, 나는 당신을 따라하지 않았어, 조금 더 설명해 주시겠습니까 – abbas

+0

코드를 올바르게 포맷하십시오. 이것은 읽기 쉽습니다. – alk

답변

1

매번 30 바이트 만 보내거나받는 중입니다. BUFLEN이되어야할까요? 메시지 앞에 strlen을 포함하는 고정 크기 블록을 메시지 앞에 추가하는 것이 좋습니다. 예를 들어

:

int size = htonl(strlen(buf)+1); 
send(new_sd, size, sizeof(size), 0); 
send(new_sd, buf, size, 0); 

클라이언트 :

int size; 
recv(sd, size, sizeof(size),0); 
size = ntohl(size); 
recv(sd, buf, size, 0); 

오류 검사가 명확성을 위해 생략되었다.

+0

BUFLEN을 30으로 변경했습니다. 불행히도 여전히 같은 문제가 있습니다. – abbas

+0

아니요, 30을 변경하지 말고 변경하십시오. BUFLEN! – cdarke

1

내가 이해하는 한, 줄을 하나씩 읽고 싶다. 그러나 recv() 함수는 메시지 스트림에서 특정 양의 데이터 만 읽기 때문에 메시지를 하나씩 전달하지 않습니다. 메시지를 구별하기 위해 두 가지 방법이 있습니다.

먼저 고정 크기 메시지 (이 경우 30 바이트)를 보내고 항상 네트워크의 다른 쪽에서 30 바이트를 읽습니다.

둘째, 다양한 크기의 메시지를 제공 할 수 있도록 데이터 길이가 포함 된 구조로 데이터를 캡슐화합니다. 1024 바이트 길이의 문자열을 보내려는 경우 otherside가이를 알고 1024 바이트를 읽게되므로이 방법이 더 좋습니다.

0

나는 틀린 일을해야만한다. 나는 헤더 메시지에 크기를 추가했는데, 이제는 클라이언트와 서버에서 어떤 데이터도받지 못하고있다. 그것을 올바르게 사용하고 있습니다. 여기에 크기가 삽입 된 코드의 일부입니다.

SERVER

if(fork()) 
{ 
printf("\n Server listening to clients on port 2000"); 
printf("\n Server got request from%s",inet_ntoa(client.sin_addr)); 
bzero(buf,256); 
printf("\n SEND DATA<q or Q to quit> :%s",buf); 
scanf("%s",buf); 
while((strcmp(buf,"q")!=0)&&(strcmp(buf,"Q")!=0)) 
{ 
int size = htonl(strlen(buf)+1); 
send(new_sd,size,sizeof(size),0); 
send(new_sd,buf,size,0); 
scanf("%s",buf); 

} 
send(new_sd,"q",5,0); 
} 
else{ 

int size; 
recv(new_sd,size,sizeof(size),0); 
size=ntohl(size); 
n=recv(new_sd,buf,size,0); 
while((strcmp(buf,"q")!=0)&&(strcmp(buf,"Q")!=0)) 
{ 
printf("\nRECEIVED DATA =%s",buf); 
n = recv(new_sd,buf,size,0); 
} 
printf("\n Bye"); 
send(new_sd,"EOF",BUFLEN,0); 
close(sd); 
close(new_sd); 
} 
} 
return 0; 
} 

CLIENT

if(fork()) 
{ 
printf("\n SEND DATA<q or Q to quit> :%s",rbuf); 
scanf("%s",rbuf); 
while((strcmp(rbuf,"q")!=0)&&(strcmp(rbuf,"Q")!=0)) 
{ 
int size = htonl(strlen(sbuf)+1); 
send(sd,size,sizeof(size),0); 
send(sd,sbuf,size,0); 
scanf("%s",sbuf); 

} 
send(sd,"q",5,0); 
} 

else{ 
int size; 
recv(sd,size,sizeof(size),0); 
size = ntohl(size); 
recv(sd,rbuf,size,0); 
while((strcmp(rbuf,"q")!=0)&&(strcmp(rbuf,"Q")!=0)) 
{ 
printf("\nRECEIVED DATA =%s",rbuf); 
//n = recv(sd,rbuf,bytes_to_read,0); 

} 
printf("\n Bye"); 
send(sd,"EOF",4,0); 
close(sd); 
} 

return 0; 
}