socket을 이용한 데이터 전송 문제

소켓을 이용한 데이터 전송 문제 입니다.

클라이언트가 데이터를 보내고 읽기를 준비하는데요

서버에서 데이터를 받고 받는 구문을 마치지 못하고 계속 받을려고 하네요

무엇이 문제인가요?

클라이언트 소스

20 int main(int argc, char *argv[]) {
     21     struct sockaddr_in servaddr;
     22     int  s, nbyte;
     23
     24     char *buf1 = (char *)malloc(sizeof(char)*512);
     25     char *buf = (char *)malloc(sizeof(char)*1024);
     26
     27
     28     sprintf(buf1,
     29             "<?xml version=\"1.0\" ?>\n"
     30             "<transaction type =\"event\" txid=\"%s\">\n"
     31             "\t<to>homeserver</to>\n"
     32             "\t<from>door1</from>\n"
     33             "\t<command>visit</command>\n"
     34             "\t<arg>\n"
     35             "\t\t<name>authorized_id</name>\n"
     36             "\t\t<value>0001</value>\n"
     37             "\t</arg>\n"
     38             "</transaction>\n"
     39             ,"8091");
     40
     41     sprintf(buf,
     42             "POST /message.cgi HTTP/1.0"
     43             CRLF
     44             "Content-Type: application/x-isas-message"
     45             CRLF
     46             "Content-length:%d"
     47             CRLF
     48             CRLF
     49             "%s"
     50             ,strlen(buf1),buf1);
     51 
     53     if((s = socket(PF_INET, SOCK_STREAM, 0)) < 0) {
     54         perror("socket fail");
     55         exit(0);
     56     }
     57     // 에코 서버의 소켓주소 구조체 작성
     58     bzero((char *)&servaddr, sizeof(servaddr));
     59     servaddr.sin_family = AF_INET;
     60     inet_pton(AF_INET,"127.0.0.1" , &servaddr.sin_addr);
     61     servaddr.sin_port = htons(8080);
     62
     63     printf("2\n");
     64     // 연결요청
     65     if(connect(s, (struct sockaddr *)&servaddr, sizeof(servaddr))
     66         < 0) {
     67         perror("connect fail");
     68             exit(0);
     69     }
     70
     71     nbyte = strlen(buf);
     72
     73     printf("send message is %d \n %s\n",nbyte,buf);
     74
     75     // 에코 서버로 메시지 송신
     76     if (write(s, buf, nbyte) < 0) {
     77         printf("write error\n");
     78         exit(0);
     79     }
     80
     81     printf("\nwrite end\n ");
     82     // 수신된 에코 데이터 화면출력
     83     printf("receive : ");
     84
     85     if( (nbyte=read(s, buf, MAXLINE)) <0) {
     86         perror("read fail");
     87         exit(0);
     88     }
     89     buf[nbyte]=0;
     90     printf("%s\n", buf);
     91
     92     close(s);
     93     free(buf);
     94     free(buf1);
     95     return 0;
     96 }

서버 쪽 프로그램 소스 입니다. 쓰레드로 돌아갑니다.

 42 /* network module*/
     43 void *network_module(void *data)
     44 {
     45     int sock;
     46     int state;
     47     int client_sockfd;
     48     struct sockaddr_in cliaddr,seraddr;
     49
     50     int addrlen = sizeof(cliaddr);
     51
     52     int pid;
     53
     54     /* create listen socket and listen */
     55     sock = socket(AF_INET,SOCK_STREAM,0);
     56
     57     if (sock == -1) {
     58         perror("don't create socket ");
     59         exit_isas();
     60     }
     61
     62     bzero((char *)&seraddr, sizeof(seraddr));
     63     seraddr.sin_family = AF_INET;
     64     seraddr.sin_addr.s_addr = htonl(INADDR_ANY);
     65     seraddr.sin_port = htons(port);
     66
     67     if (bind(sock,(struct sockaddr *)&seraddr, sizeof(seraddr)) < 0) {
     68         perror("bind fail");
     69         exit_isas();
     70        
     71
     72     state = listen(sock,10);
     73
     74     if (state == -1)
     75     {
     76         perror("listen error : ");
     77         exit_isas();
     78     }
     79
     80     signal(SIGCHLD,SIG_IGN);
     81
     82
     83     while (1)
     84     {
     85         client_sockfd = accept(sock,(struct sockaddr *)&cliaddr,&addrlen);     86
     87         pid = fork();
     88
     89         if (pid == 0)
     90         {
     91             int nbyte;
     92             char *buf = (char *)malloc(sizeof(char)*1024);
     93
     94             printf("[pid:%ld]child process \n",(long)getpid());
     95
     96             if (client_sockfd == -1)
     97             {
     98                 perror("Accept error : ");
     99                 exit(0);
    100             }
    101
    102             while (1)
    103             {
    104
    105                 memset(buf,0x00,1024);
    106
    107                 printf("\nread message \n");
    108
    109                 while ((nbyte = read(client_sockfd,buf,1024)) > 0)
    110                 {
    111                     printf("%s",buf);
    112                     fflush(stdout);
    113                     memset(buf,0x00,1024);
    114                     break;
    115                 }
    116
    117                 printf("\nreading end \n");
    118
    119                 write(client_sockfd,"OK",2);
    120
    121                 printf("\nwriting end \n");
    122
    123                 
    124             }
    125
    126
    127             sleep(10);
    128             free(buf);
    129             close(client_sockfd);
    130             break;
    131         }
    132
    133         if (pid > 0){
    134             printf("parent process \n");
    135             fflush(stdout);
    136         }
    137
    138         if (pid == -1)
    139         {
    140             perror("fork error : ");
    141         }
    142     }
    143
    144     close(sock);
    145
    146     printf("this is network module\n");
    147
    148     return 0;
    149 };

서버를 실행하고 클라이언틀를 실행하면
클라이언트에서 xml 메시지를 서버에게 보냅니다.
서버는 이 메지리르 제대로 받고 다른 메시지를 기다리고 있습니다.
그런데 클라이언트에서는 메시지를 보내고 다시 서버에서 보낸 메시지를 받기를 대기 하고 있습니다.

왜 서버에서 메시지가 끝났다는 것을 알지 못하는 걸까요?
종료문자를 같이 넣어서 보내줘야 하나요?
'\0' 넣어서 보내봤지만 결과는 똑같더라고요.

그리고 위 서버 프로그램에서 문제가 생길만 한게 머가 있을까요?