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

没本

4080个连接时进程使用了多少个fd看了没？可以调整小一点栈空间，能多支持一些线程。

yulihua49

4080个连接时进程使用了多少个fd看了没？可以调整小一点栈空间，能多支持一些线程。
没本 发表于 2010-07-16 22:28

共4096个fd，数据库池还要用，先前系统还用了好几个。超了一点，但没问题，超额的可以等前边的退出再进。
我对listen（sock，1000），有1000个都可以等着。

yulihua49

4080个连接时进程使用了多少个fd看了没？可以调整小一点栈空间，能多支持一些线程。
没本 发表于 2010-07-16 22:28

    解决了，线程池成功了，超稳定，超高效。释放连接时必须互斥锁。
不知为什么，线程池比多线程快许多。接入16300个链接很轻松。

没本

回复 73# yulihua49


    呵呵，恭喜你搞定服务器开发了。

yulihua49

回复  yulihua49


    呵呵，恭喜你搞定服务器开发了。
没本 发表于 2010-07-20 18:20

    同喜，可能将来细节上还有许多问题。
现在就有一个问题，C语言，一个线程fault，整个进程就down了。
我看JAVA，线程fault，进程不down，只down线程，C能做到吗？

yulihua49

回复  yulihua49


    呵呵，恭喜你搞定服务器开发了。
没本 发表于 2010-07-20 18:20

    已经进行16000多连接，稳定。

超额的等待，等不起的挂断，服务器是不会死的。

不会发生当用户蜂拥而至时，服务器自杀的情况。

连上的进行协议验证，不符合协议（对不上黑话）的推出午门斩首，绝不会让这些反贼坏了江山。

只是在写服务时一定要注意线程安全，内存严谨，这个堡垒只能由内部攻破。

看看服务器框架的运用：

1. #include <unistd.h>
   
2. #include <ctype.h>
   
3. #include <sys/resource.h>
   
4. #include "../thread/thrsrv.h"
   
5. 
   
6. extern int tpool_main(void (*conn_init)(T_Connect *,T_NetHead *),void (*quit)(int),void (*poolchk)(void),int sizeof_gda);
   
7. extern void tpool_free(void);
   
8. 
   
9. //定义服务函数
   
10. srvfunc Function[]={
    
11.         {login,"login"},        /*0 login.c */
    
12.         {Echo,"Echo"},                  /*1*/
    
13.         {Rexec, "Rexec"},
    
14.         {GetFile,"GetFile"},
    
15.         {PutFile,"PutFile"},
    
16.         {Pwd,"Pwd"},        
    
17.         {filels,"filels"},
    
18.         {SQL_Select,"SQL_Select"},
    
19.         {page_select,"page_select"},
    
20.         {dui_svc,"dui_svc"},
    
21.         {SQL_RPC,"SQL_RPC"},
    
22.         {net_showlog,"net_showlog"},
    
23.         {0,0}
    
24. };
    
25. 
    
26. void quit(int n)
    
27. {
    
28.         free_DB_pool();
    
29.                 tpool_free();
    
30.         ShowLog(0,"quit by %d",n);
    
31.         exit(n);
    
32. }
    
33. //连接已收到，初始化连接器。
    
34. void sc_init(T_Connect *conn,T_NetHead *head)
    
35. {
    
36. char *env;
    
37. char cp[21];
    
38. T_SRV_Var *sp;
    
39. GDA *gp;
    
40.         sp=(T_SRV_Var *) conn->Var;
    
41.         gp=(GDA *)sp->var;
    
42.         if(gp) *gp->ShowID=0;
    
43.         env=getenv("SENDSIZE");
    
44.         if(env && *env) {
    
45.                 conn->MTU=atoi(env);
    
46.         }
    
47.         peeraddr(conn->Socket,cp);;
    
48.         ShowLog(0,"tid %lu 连接:%s ",pthread_self(),cp);
    
49. /* 在此设置事件处理 */
    
50. //      connect->Event_proc=事件设置函数;
    
51. 
    
52. }
    
53. 
    
54. void FreeVar(void *data)
    
55. {
    
56. }
    
57. 
    
58. static char my_showid[200];
    
59. 
    
60. int main(int argc,char *argv[])
    
61. {
    
62. int ret;
    
63. struct rlimit sLimit;
    
64. char *p;
    
65. 
    
66. //设置可以core dumpped
    
67.         sLimit.rlim_cur = -1;
    
68.         sLimit.rlim_max = -1;
    
69.         ret=setrlimit(RLIMIT_CORE,(const struct rlimit *)&sLimit);
    
70. 
    
71.         if(argc>1) ret=envcfg(argv[1]);
    
72. 
    
73.         p=getenv("COL_TO_LOWER");
    
74.         if(p && isdigit(*p)) col_to_lower=atoi(p);
    
75. 
    
76.         sprintf(my_showid,"%s:%d",sc_basename(argv[0]),getpid());
    
77.         Showid=my_showid;
    
78.         ret=init_DB_pool();
    
79.         if(ret) {
    
80.                 ShowLog(1,"init_DB_pool:fail");
    
81.                 return 1;
    
82.         }
    
83. //调用线程池服务器框架。它将根据客户请求的服务号调用服务函数。
    
84.         tpool_main(sc_init,quit,dbpool_check,sizeof(GDA));//GDA用户自定义的上下文,告它一个尺寸，内部自己分配
    
85.         quit(0);
    
86. }
    

复制代码

服务函数的例子在4页31楼。

要想定义一个服务，只需;
按照框架规定的格式接受自变量和提供返回值，按照与客户端约定的流程处理业务。
函数原型加入公共头文件（../thread/thrsrv.h）。
加入服务器函数表。
Makefile里增加一个模块。

yulihua49

已经进行16000多连接，稳定。

超额的等待，等不起的挂断，服务器是不会死的。

不会发生当用 ...
yulihua49 发表于 2010-07-22 10:10

关于数据库的服务，比较冗长，给一个简单点的例子。从客户端接收一个语句，（检查语句合法性），访问数据库，返回结果集。

1. SQL_Select(T_Connect *connect,T_NetHead *NetHead)
   
2. {
   
3. char *rec=0;
   
4. register int i;
   
5. T_SRV_Var *srvp;
   
6. T_SQL_Connect *SQL_Connect;
   
7. int event;
   
8.      srvp=(T_SRV_Var *)connect->Var;
   
9.      SQL_Connect=&srvp->SQL_Connect;
   
10.         event=NetHead->PROTO_NUM;
    
11.         if(NetHead->data[strlen(NetHead->data)-1]=='|') {
    
12.                 NetHead->data[strlen(NetHead->data)-1]=0;
    
13.         }
    
14.      ShowLog(5,"SQL Select:%s",NetHead->data);
    
15.      i=SQL_Check_Stmt(NetHead->data);
    
16.      if(i!=0){
    
17.         sprintf(SQL_Connect->ErrMsg,"%s:invalid statment",NetHead->data);
    
18.         ShowLog(1,"SQL_Select fail:%s",SQL_Connect->ErrMsg);
    
19.              NetHead->PROTO_NUM=PutEvent(connect,NetHead->PROTO_NUM);
    
20.         NetHead->ERRNO1=201;
    
21.         NetHead->ERRNO2=0;
    
22.         NetHead->O_NODE=ntohl(LocalAddr(0,0));
    
23.         NetHead->PKG_REC_NUM=0;
    
24.         NetHead->data=SQL_Connect->ErrMsg;
    
25.         NetHead->PKG_LEN=strlen(NetHead->data);
    
26.         i=SendPack(connect,NetHead);
    
27.         return 0;
    
28.      }
    
29.         if(srvp->tid) {
    
30.                 i=get_DB_connect(SQL_Connect,srvp->poolno);
    
31.                 if(i) {
    
32.                         sprintf(SQL_Connect->ErrMsg,"取连接池失败！,pool[%d],ret=%d",srvp->poolno,i);
    
33.                         ShowLog(1,"%s:%s",__FUNCTION__,SQL_Connect->ErrMsg);
    
34.                         NetHead->data=SQL_Connect->ErrMsg;
    
35.                         NetHead->PKG_REC_NUM=0;
    
36.                         NetHead->PKG_LEN=strlen(NetHead->data);
    
37.                         NetHead->PROTO_NUM=PutEvent(connect,event);
    
38.                         NetHead->ERRNO1=SQL_Connect->Errno;
    
39.                         NetHead->ERRNO2=i;
    
40.                         NetHead->O_NODE=ntohl(LocalAddr(connect->Socket,
    
41.                                 SQL_Connect->ErrMsg+sizeof(SQL_Connect->ErrMsg)-20));
    
42.                         SendPack(connect,NetHead);
    
43.                         return 0;
    
44.                 }
    
45.         }
    
46. 
    
47.      i=___SQL_Select__(SQL_Connect,NetHead->data,&rec,NetHead->PKG_REC_NUM);
    
48.      if(i<=0) {
    
49.              ShowLog(1,"SQL Select error: %d,%s",
    
50.                 SQL_Connect->Errno,
    
51.                 SQL_Connect->ErrMsg);
    
52.         ___SQL_SendError(connect,NetHead->PROTO_NUM);
    
53.         if(rec) free(rec);
    
54.         return 0;
    
55.      }
    
56.         if(srvp->tid) release_DB_connect(SQL_Connect,srvp->poolno);
    
57.      ShowLog(5,"SQL Select Success nROWS=%d",i);
    
58.              NetHead->PROTO_NUM=PutEvent(connect,NetHead->PROTO_NUM);
    
59.              NetHead->O_NODE=0;
    
60.              NetHead->D_NODE=SQL_Connect->NativeError;
    
61.              NetHead->ERRNO2=0;
    
62.         NetHead->ERRNO1=0;
    
63.              NetHead->PKG_REC_NUM=i;
    
64.         NetHead->data=rec;
    
65.              NetHead->PKG_LEN=strlen(NetHead->data);
    
66.         SendPack(connect,NetHead);
    
67.         if(rec) free(rec);
    
68.         return 0;
    
69. }

复制代码