多线程服务器，发现个问题，请高人解惑

samlumengjun

回复 10# yulihua49


    虽然可能性很小,但是是存在的.这也解释了为什么你usleep以后情况会有所好转.最好的办法是在主线程里malloc一个Conn结构传给线程函数,然后在线程函数结束时free掉.另外,像这样的原形如果事先没有设置线程detach的话要在线程处理函数里加上pthread_detach(pthread_self());这么一句,要不然随着连接数的上升.会资源耗尽.

yulihua49

Conn里的内容在创建线程的时候会被共用.比如你要创建两个线程,线程1里的Conn内容会被主线程改变.简单点说主 ...
samlumengjun 发表于 2010-07-05 13:45

   感谢哦，找到了。修改如下：
子线程：

1. 
   
2. static void * thread_work(void *param)
   
3. {
   
4. T_Connect Conn=*(T_Connect *)param;
   
5. T_NetHead Head;
   
6. int ret,logined=0;
   
7. T_SRV_Var ctx;
   
8. srvfunc *fp;
   
9. int svcnum=0;
   
10. 
    
11. #ifdef __GNUC__
    
12. char gda[Conn.SendLen+1];//本线程的全局数据区必须在此分配。
    
13. #else
    
14. char *gda=alloca(Conn.SendLen+1);
    
15. #endif
    
16. 
    
17.         if(Conn.SendLen>0) ctx.var=gda;
    
18.         else ctx.var=0;
    
19.         Conn.SendLen=0;
    
20.         ctx.tid=pthread_self();//标志多线程服务
    
21.         ctx.poolno=0;
    
22.         ___SQL_Init_SQL_Connect(&ctx.SQL_Connect);
    
23.         Conn.Var=&ctx;
    
24.         Conn.only_do=0;
    
25. //借用only_do存放函数地址 conn_init
    
26.         if(((T_Connect *)param)->only_do) ((T_Connect *)param)->only_do(&Conn,&Head);
    
27.         ((T_Connect *)param)->Socket=-1;//通知主线程，param可以重用了。
    

复制代码

主线程：

1.   ret=pthread_create(&pthread_id,&attr,thread_work,&Conn);
   
2.                 if(ret) {
   
3.                         ShowLog(1,"%s:pthread_create:%s",__FUNCTION__,strerror(ret));
   
4.                         close(s);
   
5.                         if(ret==EAGAIN||ret==ENOMEM) {  //线程数用完了，休息一会，等一些线程退出
   
6.                                 sleep(30);
   
7.                         }
   
8.                         continue;
   
9.                 }
   
10.                 while(Conn.Socket != -1) usleep(1000);//等子线程通知。
    

复制代码

chenzhanyiczy

当然乱了，

s=accept(sock,(struct sockaddr *)&cin,&leng);

这个s都是每个线程公用的

                Conn.Socket=s;

                Conn.only_do=conn_init; //借用一下

                Conn.SendLen=sizeof_gda;

                ret=pthread_create(&pthread_id,&attr,thread_work,&Conn);、

可以改为

              int fd=s;

                Conn.Socket=fd;

                Conn.only_do=conn_init; //借用一下

                Conn.SendLen=sizeof_gda;

                ret=pthread_create(&pthread_id,&attr,thread_work,&Conn);、

yulihua49

当然乱了，

s=accept(sock,(struct sockaddr *)&cin,&leng);

这个s都是每个线程公用的

           ...
chenzhanyiczy 发表于 2010-07-05 15:11

  谢谢，如上贴，每个线程用完了Conn，通知主线程，主线程收到通知再进行下一轮accept，就没问题了。
关键不是s共用，而是Conn共用了。s放到Conn里边跟你放到fd里边是一个意思。
s这个地址不会交给子线程，所以没必要fd，只是把s的值放到Conn，而Conn的地址交到子线程，就出现问题了，这个地址里的内容在一个时间里只能由一个线程使用。

yulihua49

回复  yulihua49


    虽然可能性很小,但是是存在的.这也解释了为什么你usleep以后情况会有所好转.最好 ...
samlumengjun 发表于 2010-07-05 14:41

    感谢支持。当初用你这办法也可能不错，现在Conn的使用串行化了，每收到一个连接都得等等，也能解决问题。就是需要等等，你的办法可能不需要等。
注意我子线程函数，发通知的时候，服务还未开始，只进行了初始化。线程还是并行的，只接受连接串行了。

ssuclinux

传值 和 传址

yulihua49

回复  yulihua49


    虽然可能性很小,但是是存在的.这也解释了为什么你usleep以后情况会有所好转.最好 ...
samlumengjun 发表于 2010-07-05 14:41

    又出现新问题：
大量客户端同时传送数据时，个别线程会出现：
1 thrsrv:8942 07/05 16:17'07 thread_work:tid=46914753890624,接收结束,status=84,Invalid or incomplete multibyte or wide character
此时服务器端关闭连接，退出线程。服务器出现内存泄漏（占用内存增加，服务器不会死掉），客户端进程死等。大约500个链接里出现3-5个。

每出现一个这样的错误就会挂住一个客户端进程。

客户端的状态是，成功连接，与服务器协商密钥完成，发出登录包，等回答。
服务器未收到登录包。84号错误返回。

samlumengjun

回复 17# yulihua49


    为什么不看清楚我的回复?都和你说了像这样的原形如果事先没有设置线程detach的话要在线程处理函数里加上pthread_detach(pthread_self());这么一句,要不然随着连接数的上升.会资源耗尽.

samlumengjun

另外你的情况应该有两个问题,第一个问题就是我说的你没有设置线程属性,自行释放资源.还有一个问题是在客户端上,server这里close socket的话,客户端那里read到-1,应该也自己close socket.你客户端代码是怎么处理的?

yulihua49

回复  yulihua49


    为什么不看清楚我的回复?都和你说了像这样的原形如果事先没有设置线程detach的话 ...
samlumengjun 发表于 2010-07-05 18:28

    哦，对不住，关注点没在这。
程序的前半部分没给，现在补上：

1.         ret= pthread_attr_init(&attr);
   
2.         if(ret) {
   
3.                 ShowLog(1,"can not init pthread attr %s",strerror(ret));
   
4.                 return ;
   
5.         }
   
6. //设置分离线程
   
7.         ret=pthread_attr_setdetachstate(&attr,PTHREAD_CREATE_DETACHED);
   
8.         if(ret) {
   
9.                 ShowLog(1,"can't set pthread attr:%s",strerror(ret));
   
10.                 return ;
    
11.         }
    
12. //设置线程堆栈保护区 256K
    
13.         ret=pthread_attr_setguardsize(&attr,(size_t)(1024 * 256));
    
14. 
    

复制代码

create_thread用的这个attr。