socket服务端如何连续接收客户端发来的数据？

harold

我写了socket服务端以及客户端程序，因是demo，一切errorcheck都省了！

1. 
   
2. /*
   
3. ** srvdemo.c - a stream socket server demo
   
4. */
   
5. #include <stdio.h>
   
6. #include <string.h>
   
7. #include <sys/types.h>
   
8. #include <sys/socket.h>
   
9. #include <arpa/inet.h>
   
10. 
    
11. #define PORT 1234   
    
12. #define BACKLOG 10   
    
13. 
    
14. int main(void)
    
15. {
    
16.   int sockfd, new_fd;
    
17.   struct sockaddr_in my_addr;   
    
18.   struct sockaddr_in their_addr;
    
19.   int sin_size;
    
20.   char buf[15];
    
21. 
    
22.   sockfd = socket(AF_INET, SOCK_STREAM, 0);
    
23. 
    
24.   my_addr.sin_family = AF_INET;        
    
25.   my_addr.sin_port = htons(PORT);   
    
26.   my_addr.sin_addr.s_addr = INADDR_ANY;
    
27. 
    
28.   memset(&(my_addr.sin_zero), '\0', 8);
    
29. 
    
30.   bind(sockfd, (struct sockaddr *)&my_addr,
    
31.        sizeof(struct sockaddr));
    
32. 
    
33.   listen(sockfd, BACKLOG);
    
34. 
    
35.   while(1)
    
36.     {
    
37.     sin_size = sizeof(struct sockaddr_in);
    
38.    
    
39.     new_fd = accept(sockfd, (struct sockaddr *)&their_addr,
    
40.                          &sin_size);
    
41. 
    
42.     printf("server: got connection from %s\n",
    
43.            inet_ntoa(their_addr.sin_addr));
    
44. 
    
45.     recv(new_fd, buf, 11, 0);
    
46.     printf("server: %s\n", buf);
    
47.     }
    
48.   return 0;
    
49. }
    

复制代码

这应该是一个典型的socket服务端程序。
下面是客户端demo。

1. 
   
2. /*
   
3. ** clientdemo.c - a stream socket client demo
   
4. */
   
5. #include <stdio.h>
   
6. #include <unistd.h>
   
7. #include <string.h>
   
8. #include <netdb.h>
   
9. #include <sys/types.h>
   
10. #include <sys/socket.h>
    
11. 
    
12. #define PORT 1234
    
13. #define MAXDATASIZE 100
    
14. 
    
15. int main(int argc, char *argv[])
    
16. {
    
17.   int sockfd, numbytes;
    
18.   char buf[MAXDATASIZE];
    
19.   struct hostent *he;
    
20.   struct sockaddr_in their_addr;
    
21. 
    
22.   he = gethostbyname(argv[1]);
    
23. 
    
24.   sockfd = socket(AF_INET, SOCK_STREAM, 0);
    
25. 
    
26.   their_addr.sin_family = AF_INET;   
    
27.   their_addr.sin_port = htons(PORT);
    
28.   their_addr.sin_addr = *((struct in_addr *)he->h_addr);
    
29. 
    
30.   memset(&(their_addr.sin_zero), '\0', 8);
    
31. 
    
32.   connect(sockfd, (struct sockaddr *)&their_addr,
    
33.               sizeof(struct sockaddr));
    
34. 
    
35.   sprintf(buf, "Hello,World");
    
36. 
    
37.   send(sockfd, buf, 11, 0);
    
38.   send(sockfd, buf, 5, 0);
    
39.   close(sockfd);
    
40.   return 0;
    
41. }
    

复制代码

编译测试如下：
gcc -Wall srvdemo.c -o srvdemo
gcc -Wall clientdemo.c -o clientdemo

在一个终端输入启动srvdemo。在另一个终端运行客户端clientdemo localhost，结果如下
server: got connection from 127.0.0.1
server: Hello,World

我的问题是：我在客户端连续发送了两次数据，为什么服务端却只接收了一次呢？
如果我要服务端连续两次都接收到，要怎么样做？

doubleelec

这是一个典型的问题程序

（1）第二次循环 accept 阻塞了，当然不会再收到 “hello world”，除非你再运行 client；

（2）如果把 accept 改对了，recv 不检查返回值，当客户端不再发送时，服务器仍会不停的打出 buf 内容。

harold

我初学socket编程，还望大哥们多多指点。
这些细节问题，我还没仔细测试过。因为临时写的，比较随便。
但是主要是为了要有一个思路。
可是大哥还是没有给出提示，关于如何解决这个问题呀？
阻塞掉了，我也想是，可是如何觉解决呢？

doubleelec

socket 编程推荐看 《用TCP/IP实现网际互连，第三卷》和《UNIX网络编程》。

写代码之前先理清思路，服务器可以是循环的（非并发的）或者并发的，非并发服务器要求一次服务在较短时间内结束，否则会使其它客户端无法连接；并发服务器可以是多路IO的、多线程的、或者多进程的。

如果你是要实现一个非并发服务器。你的服务器程序中的 while 是要循环接受多个客户端的连接，接受连接以后，对每个客户端，你要接收若干数据，对于TCP协议而言，这些数据要 recv 多少次是不一定的，于是你要循环地 recv，并在每次 recv 后判断是否需要退出循环。

如果你要实现一个并发服务器，你需要（1）用 select 来管理 accept 及与各个客户端的数据收发；或者（2）在 accept 后为新连接建立一个线程或进程。当然，对每个连接，你还是要循环的 recv。

一定要理解 accept 和 recv 是对不同的 socket_fd，把这两个任务线性地放在同一个循环中，有概念不清之嫌。

如果不考虑错误处理，可以把 recv 那一句改成，while (recv(new_fd, buf, 11, 0) > 0) printf("server: %s\n", buf);

harold

谢谢大哥的指点，我现在明白了一些问题。
首先，我知道我需要一个非并发的服务器。而且打算采用多线程。
我看我的问题就在于没有想到循环接收。
关于accept 和 recv 是对不同的 socket_fd，这个我是知道的。
最后多谢大哥！