菜鸟问:Linux C Socket编程的问题

fxdfbl

服务器server.c源代码如下:

1. 
   
2. #include <stdio.h>;
   
3. #include <stdlib.h>;
   
4. #include <errno.h>;
   
5. #include <string.h>;
   
6. #include <sys/types.h>;
   
7. #include <netinet/in.h>;
   
8. #include <sys/socket.h>;
   
9. #include <sys/wait.h>;
   
10. #define MYPORT 3490
    
11. #define BACKLOG 50
    
12. 
    
13. main()
    
14. {
    
15.   int sockfd, new_fd;
    
16.   struct sockaddr_in my_addr;
    
17.   struct sockaddr_in their_addr;
    
18.   int sin_size;
    
19. 
    
20.   if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
    
21.   {
    
22.      perror("socket");
    
23.      exit(1);
    
24.   }
    
25. 
    
26.   my_addr.sin_family = AF_INET;
    
27.   my_addr.sin_port = htons(MYPORT);
    
28.   my_addr.sin_addr.s_addr = INADDR_ANY;
    
29.   bzero(&(my_addr.sin_zero),8);
    
30. 
    
31.   if (bind(sockfd, (struct sockaddr *)&my_addr, sizeof(struct sockaddr))== -1)
    
32.   {
    
33.     perror("bind");
    
34.     exit(1);
    
35.   }
    
36.   if (listen(sockfd, BACKLOG) == -1)
    
37.   {
    
38.      perror("listen");
    
39.      exit(1);
    
40.    }
    
41. 
    
42.    while(1)
    
43.    {
    
44.      sin_size = sizeof(struct sockaddr_in);
    
45.      if ((new_fd = accept(sockfd, (struct sockaddr *)&their_addr, &sin_size)) == -1)
    
46.      {
    
47.        perror("accept");
    
48.        continue;
    
49.      }
    
50.      printf("server: got connection from %s\n", inet_ntoa(their_addr.sin_addr));
    
51.      if (!fork())
    
52.      {
    
53.        int numbytes=0,mycount=0;
    
54.        char *buf[50];
    
55. 
    
56.        if (send(new_fd, "Hello, world!\n", 14, 0) == -1)
    
57.          perror("send");
    
58.        while (1)
    
59.        {
    
60.          bzero(buf,sizeof(buf));
    
61.          if ((numbytes=recv(new_fd, buf, 50, 0)) == -1)
    
62.            perror("recv");
    
63.          mycount++;
    
64.          buf[numbytes]='\0';
    
65.          printf("%s\n",buf);
    
66.          break;
    
67.        }
    
68.        close(new_fd);
    
69.        exit(0);
    
70.      }
    
71.      close(new_fd);
    
72.      while(waitpid(-1,NULL,WNOHANG) >; 0);
    
73.    }
    
74. }
    

复制代码

客户端client.c的源代码如下:

1. 
   
2. #include <stdio.h>;
   
3. #include <stdlib.h>;
   
4. #include <errno.h>;
   
5. #include <string.h>;
   
6. #include <sys/types.h>;
   
7. #include <netinet/in.h>;
   
8. #include <sys/socket.h>;
   
9. #include <sys/wait.h>;
   
10. 
    
11. #define PORT 3490
    
12. #define MAXDATASIZE 102400
    
13. 
    
14. int main(int argc, char *argv[])
    
15. {
    
16.    int sockfd, numbytes,i;
    
17.    char buf[MAXDATASIZE];
    
18.    struct sockaddr_in their_addr;
    
19. 
    
20.    if (argc != 2)
    
21.    {
    
22.      fprintf(stderr,"usage: client hostname\n");
    
23.      exit(1);
    
24.    }
    
25. 
    
26.    if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
    
27.    {
    
28.       perror("socket");
    
29.       exit(1);
    
30.    }
    
31. 
    
32.    their_addr.sin_family = AF_INET;
    
33.    their_addr.sin_port = htons(PORT);
    
34.    their_addr.sin_addr.s_addr=inet_addr(argv[1]);
    
35.    bzero(&(their_addr.sin_zero),8);
    
36.    if (connect(sockfd, (struct sockaddr *)&their_addr,sizeof(struct sockaddr)) == -1)
    
37.    {
    
38.       perror("connect");
    
39.       exit(1);
    
40.    }
    
41. 
    
42.    char *msg="register fxdlxf 053124 fxdfbl@sohu.com";
    
43.    send (sockfd,msg,strlen(msg),0);
    
44. 
    
45.    if ((numbytes=recv(sockfd, buf, MAXDATASIZE, 0)) == -1)
    
46.    {
    
47.       perror("recv");
    
48.       exit(1);
    
49.    }
    
50. 
    
51.    buf[numbytes] = '\0';
    
52.    printf("Received: %s",buf);
    
53.    close(sockfd);
    
54.    return 0;
    
55. }
    

复制代码

编译得到server和client执行文件后,我先用./server &运行 服务器程序,然后再用./client 127.0.0.1运行客户端程序,发现有时候得到的结果不尽相同!
下面是运行的结果 :

1. 
   
2. root@fxdlxf:/home/fxdlxf/private/uptu_p2p# ./client 127.0.0.1
   
3. server: got connection from 127.0.0.1
   
4. register fxdlxf 053124 fxdfbl@sohu.com
   
5. Received: Hello, world!
   
6. root@fxdlxf:/home/fxdlxf/private/uptu_p2p# ./client 127.0.0.1
   
7. server: got connection from 127.0.0.1
   
8. register fxdlxf 053124 fxdfbl@sohu.com
   
9. Received: Hello, world!
   
10. root@fxdlxf:/home/fxdlxf/private/uptu_p2p# ./client 127.0.0.1
    
11. server: got connection from 127.0.0.1
    
12. Received: Hello, world!
    
13. register fxdlxf 053124 fxdfbl@sohu.com
    
14. root@fxdlxf:/home/fxdlxf/private/uptu_p2p#
    

复制代码

根据程序的流程,应该结果会是:
root@fxdlxf:/home/fxdlxf/private/uptu_p2p# ./client 127.0.0.1
server: got connection from 127.0.0.1
register fxdlxf 053124 fxdfbl@sohu.com
Received: Hello, world!
才对,可有时候会变成:
server: got connection from 127.0.0.1
Received: Hello, world!
register fxdlxf 053124 fxdfbl@sohu.com
两个是在同一机上同一目录下在的,大家说说是什么原因呢?
是与TCP有关?还是与SHELL进程有关?或是我的代码有问题?
感谢!

saoyu

代码没有问题，TCP发送与接收是有缓冲的，如果要达到你的目的的话应该额外的发送接收一些控制命令来控制顺序。

FH

没看清楚程序的请不要误导

结果很正常嘛！
你的输出来自两个进程，谁先输出谁后输出都由可能，因此顺序不能保证。

saoyu

原帖由 "FH" 发表：
峁?苷?Ｂ铮?
你的输出来自两个进程，谁先输出谁后输出都由可能，因此顺序不能保证。

我好像没说错吧，赫赫，吓我一跳

灰色轨迹

原帖由 "FH" 发表：
峁?苷?Ｂ铮?
你的输出来自两个进程，谁先输出谁后输出都由可能，因此顺序不能保证。

把pid print出来就能说明问题了