基于socket的一个小的服务器回射程序

wangjc_strive

小弟最近用socket写了一个c/s的小程序，客户端发一段字符给服务器，服务器收到该段字符后，将其再发回给客户端，我二者链接建立好后，我用客户端发字符的时候，服务器端总是会收到额外的字符，下面是问题的截图，以及我的代码，希望哪位高手给点指点，我知道应该是read跟write的地方有问题。
首先server端监听到了client端的链接，打印now receive a new connect!!   然后我在client端输入first line input，为什么server却收到了“first line input”，后面还跟了个“0”

1. #include"unp.h"
   
2. //server
   
3. /*
   
4. #include<sys/socket.h>//socket()
   
5. #include<netinet/in.h>//sockaddr_in
   
6. #include<stdio.h>//perror()
   
7. #include<unistd.h>//fork()
   
8. #include<stdlib.h>
   
9. #include<errno.h>//errno, EINTR
   
10. #include<string.h>//strlen()
    
11. 
    
12. #define PORT 7788
    
13. #define MAX_BUF 1000
    
14. */
    
15. 
    
16. void server_read(int sockfd);
    
17. 
    
18. int main(int argc, char *argv[])
    
19. {
    
20.     int listenfd, connfd;
    
21.     struct sockaddr_in cliaddr, servaddr;
    
22.     pid_t childpid;
    
23.     socklen_t clilen;
    
24. 
    
25.     if( (listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
    
26.     {
    
27.         perror("socket error");
    
28.     }
    
29.     bzero(&servaddr, sizeof(servaddr));
    
30.     servaddr.sin_family = AF_INET;
    
31.     servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
    
32.     servaddr.sin_port = htons(PORT);
    
33.     if( bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) == -1)
    
34.     {
    
35.         perror("bind error");
    
36.         exit(EXIT_FAILURE);
    
37.     }
    
38.     printf("bind OK\n");
    
39.     if( listen(listenfd, 5) == -1)
    
40.     {
    
41.         perror("listen error");
    
42.     }
    
43.     printf("now listening \n");
    
44.     for(;;)
    
45.     {
    
46.         clilen = sizeof(cliaddr);
    
47.         connfd = accept(listenfd, (struct sockaddr *)&cliaddr, &clilen);
    
48.         if(connfd == -1)
    
49.         {
    
50.             perror("accept error");
    
51.         }
    
52.         printf("now receive a new connect!!\n");
    
53.         if( (childpid = fork()) == -1 )
    
54.         {
    
55.             perror("fork error");
    
56.         }
    
57.         else if(childpid == 0)//child
    
58.         {
    
59.             close(listenfd);
    
60.             server_read(connfd);
    
61.             exit(0);
    
62.         }
    
63.     }
    
64.     close(connfd);
    
65. }
    
66. 
    
67. void
    
68. server_read(int sockfd)
    
69. {
    
70.     unsigned int n;
    
71.     char recebuf[MAX_LINE];
    
72.    
    
73.     bzero(recebuf, MAX_LINE);
    
74. again:
    
75.     while((n = read(sockfd, recebuf, MAX_LINE-1)) >0)
    
76.     {
    
77.         //fputs(recebuf, stdout);
    
78.         recebuf[n] = '/0';
    
79.         printf("server receive: %s\n",recebuf);
    
80.         write(sockfd, recebuf, strlen(recebuf));
    
81.         printf("server write: %s\n", recebuf);
    
82.     }
    
83.     if(n<0 && errno == EINTR)
    
84.     {
    
85.         goto again;   
    
86.     }
    
87.     else if(n<0)
    
88.     {
    
89.         perror("read or write error");
    
90.     }
    
91. }

复制代码

1. #include"unp.h"
   
2. //client
   
3. /*
   
4. #include<sys/socket.h>//socket() bind()...
   
5. #include<stdio.h>//perror
   
6. #include<arpa/inet.h>//inet_pton()
   
7. #include<string.h>//bzero()
   
8. #include<stdlib.h>//exit()
   
9. 
   
10. 
    
11. #define port 7788
    
12. #define MAX_LINE 1000
    
13. */
    
14. 
    
15. void client_read(FILE *fp, int sockfd);
    
16. 
    
17. int
    
18. main(int argc, char **argv)
    
19. {
    
20.     int sockfd;
    
21.     char *str;
    
22.     struct sockaddr_in cliaddr;
    
23. 
    
24.     if(argc != 2)
    
25.     {
    
26.         printf("input right canshu");
    
27.         exit(1);
    
28.     }
    
29.     if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
    
30.     {
    
31.         perror("socket error");
    
32.     }
    
33.     bzero(&cliaddr, sizeof(cliaddr));
    
34.     cliaddr.sin_family = AF_INET;
    
35.     cliaddr.sin_port = htons(port);
    
36.     if( inet_pton(AF_INET, argv[1], &cliaddr.sin_addr) !=1 )
    
37.     {
    
38.         printf("inet_pton error");
    
39.     }
    
40.     if((connect(sockfd, (struct sockaddr *)&cliaddr, sizeof(cliaddr))) == -1)
    
41.     {
    
42.         perror("connect error!!!");
    
43.         exit(0);
    
44.     }
    
45.     client_read(stdin, sockfd);
    
46. }
    
47. void
    
48. client_read(FILE *fp, int sockfd)
    
49. {
    
50.     char writebuf[MAX_LINE], recvbuf[MAX_LINE];
    
51.    
    
52.     bzero(writebuf, MAX_LINE);
    
53.     bzero(recvbuf, MAX_LINE);
    
54.     while( (fgets(writebuf, MAX_LINE, fp)) != NULL )
    
55.     {
    
56.         
    
57.         printf("your input is: %s\n", writebuf);
    
58.         write(sockfd, writebuf, strlen(writebuf));
    
59.         printf("client write: %s\n",writebuf);
    
60.         if((read(sockfd, recvbuf, MAX_LINE)) ==0 )
    
61.         {
    
62.             printf("read zero\n");   
    
63.         }
    
64.         //fputs(recvbuf, stdout);
    
65.         printf("client receive: %s\n", recvbuf);
    
66.     }
    
67. }
    

复制代码

井蛙夏虫

server的78行'/0'应为'\0'