TCP并发服务器例子出错，使用线程

Gnixfeng

例子是UNP第30章里的例子。源码附在后面。

运行成功是这样子的：运行服务器 $ ./pthread_server 49001和客户：$ ./client localhost 49001 5 10 4000
服务器显示：

客户显示：


错误描述：
               第一种错误情况：运行服务器 $ ./pthread_server 49001和客户：$ ./client localhost 49001 5 10 4000
服务器显示

客户显示

               第二中出错情况：运行服务器 $ ./pthread_server 49001和客户：$ ./client localhost 49001 5 10 4000



               第三中出错情况：运行服务器 $ ./pthread_server 49001和客户：$ ./client localhost 49001 5 10 4000




有时成功，有时错误。我怀疑是不是资源限制的问题。如果把线程换成进程就不会出现这种问题。

想一天了，都没弄清楚。望指教啊！


服务器主程序，包装好的程序都在unp.h中定义了

1. #include "../lib/unp.h"
   
2. 
   
3. int main(int argc, const char *argv[])
   
4. {
   
5.     int     listenfd, connfd;
   
6.     void    sig_int(int);
   
7.     void    *doit(void*);
   
8.     pthread_t   tid;
   
9.     socklen_t   clilen, addrlen;
   
10.     struct sockaddr     *cliaddr;
    
11. 
    
12.     if (argc == 2){
    
13.         listenfd = Tcp_listen(NULL, argv[1], &addrlen);
    
14.     }else if(argc == 3){
    
15.         listenfd = Tcp_listen(argv[1], argv[2], &addrlen);
    
16.     }else
    
17.         err_quit("usage:pthraed_server <Host/IPadrress> <service/#port>");
    
18.     cliaddr = malloc(addrlen);
    
19. 
    
20.     Signal(SIGINT, sig_int);
    
21. 
    
22.     for( ; ;)
    
23.     {
    
24.         clilen = addrlen;
    
25.         connfd = Accept(listenfd, cliaddr, &clilen);
    
26.         printf("Connecting form %s\n",
    
27.                 sock_ntop((SA *)cliaddr, clilen));
    
28.         
    
29.         pthread_create(&tid, NULL, &doit, (void*)connfd);
    
30.     }
    
31.     return 0;
    
32. }
    
33. void *
    
34. doit(void *arg)
    
35. {
    
36.         void        web_child(int);
    
37. 
    
38.         pthread_detach(pthread_self());
    
39.     //printf("connfd: %d\n", (int)arg);
    
40.         web_child((int)arg);
    
41.         Close((int) arg);
    
42.     //printf("close %d\n", (int)arg);
    
43.         return(NULL);
    
44. }
    
45. /* end serv06 */
    
46. 
    
47. void
    
48. sig_int(int signo)
    
49. {
    
50.         void        pr_cpu_time(void);
    
51. 
    
52.         pr_cpu_time();
    
53.         exit(0);
    
54. }

复制代码

web_child函数，MAXLINE等都已经在头文件unp.h中定义

1. #include "unp.h"
   
2. 
   
3. #define MAXN 16384
   
4. 
   
5. void web_child(int connfd)
   
6. {
   
7.     int     ntowrite;
   
8.     ssize_t nread;
   
9.     char    line[MAXLINE], result[MAXN];
   
10. 
    
11.     for ( ; ;){
    
12.         if ((nread = Readline(connfd, line, MAXLINE)) == 0)
    
13.             return;
    
14. 
    
15.         ntowrite = atoi(line);
    
16.         if (ntowrite <= 0 || ntowrite > MAXN)
    
17.             err_quit("client request for %d bytes", ntowrite);
    
18. 
    
19.         Writen(connfd, result, ntowrite);
    
20.     }
    
21. }

复制代码

客户程序：

1. #include "unp.h"
   
2. 
   
3. #define MAXN 16384
   
4. 
   
5. int main(int argc, const char *argv[])
   
6. {
   
7.     int     i, j, fd, nchildren, nconnects, nbytes, status;
   
8.     pid_t   pid;
   
9.     ssize_t n;
   
10.     char    request[MAXLINE], reply[MAXN];
    
11. 
    
12.     if (argc != 6)
    
13.         err_quit("usage: client <Host/IP> <#Port> <#children>"
    
14.                 " <#connect> <#bytes/request>");
    
15. 
    
16.     nchildren = atol(argv[3]);
    
17.     nconnects = atol(argv[4]);
    
18.     nbytes = atol(argv[5]);
    
19.     snprintf(request, sizeof(request), "%d\n", nbytes);
    
20. 
    
21.     printf("nchildren = %d, nconnects = %d\n", nchildren, nconnects);
    
22.     for(i = 0; i < nchildren; i++){
    
23.         if ((pid = fork()) == 0){
    
24.             for(j = 0; j < nconnects; j++)
    
25.             {
    
26.                 fd = tcp_connect(argv[1], argv[2]);
    
27. 
    
28.                 Write(fd, request, strlen(request));
    
29. 
    
30.                 if ((n = readn(fd, reply, nbytes)) != nbytes)
    
31.                     err_quit("server returned %d bytes", n);
    
32. 
    
33.                 Close(fd);
    
34.                 printf("close %d\n", fd);
    
35.             }
    
36.             printf("child %d done\n", i);
    
37.             exit(0);
    
38.         }
    
39.     }
    
40. 
    
41.     for( i = 0; i < nchildren; i++)
    
42.         if (waitpid(-1, &status, 0) < 0)
    
43.             err_sys("waitpid error");
    
44. 
    
45.     return 0;
    
46. }

复制代码

Gnixfeng

第一种错误的图片泡到后面了，倒数2、3张，编辑不了

hellioncu

应该是服务端write之后马上close所致

Gnixfeng

回复 3# hellioncu
在web_child()函数里面是一个循环

    for ( ; {
        if ((nread = Readline(connfd, line, MAXLINE)) == 0)
            return;

        ntowrite = atoi(line);
        if (ntowrite <= 0 || ntowrite > MAXN)
            err_quit("client request for %d bytes", ntowrite);

        Writen(connfd, result, ntowrite);
    }
这也是我所不理解的，看上去web_child()应该会在err_quit()上退出，但是err_quit(）中调用了exit()函数，按理应该整个进程都终止了。但是实际不是这样，doit()中的Close依然会执行。

   

Gnixfeng

回复 3# hellioncu
如果把服务器换成创建进程，就不会出现错误。

1. for( ;  ; )
   
2.     {
   
3.         clilen = addlen;
   
4.         if ((connfd = accept(listenfd, cliaddr, &clilen)) < 0){
   
5.             if (errno == EINTR)
   
6.                 continue;
   
7.             else
   
8.                 err_sys("accept error");
   
9.         }
   
10.         /*
    
11.         printf("Connecting form %s\n",
    
12.                 sock_ntop((SA *)cliaddr, clilen));
    
13.                 */
    
14.         if ((childpid = fork()) == 0){
    
15.             Close(listenfd);
    
16.             web_child(connfd);
    
17.             exit(0);
    
18.         }else if(childpid < 0)
    
19.             err_sys("fork error");
    
20. 
    
21.         Close(connfd);
    
22.     }

复制代码

hellioncu

Gnixfeng 发表于 2014-10-23 16:57
回复 3# hellioncu
如果把服务器换成创建进程，就不会出现错误。

doit中Close((int) arg);之前加个usleep(10000);试试

Gnixfeng

回复 6# hellioncu


    没有用哦，还是那样

Gnixfeng

回复 7# Gnixfeng
哦，可能是我用错readline()的非线程安全的版本了