[基于Epoll内置Leader-Follower服务端实现, 已可达50万echo qps（全新支持Lua啦）]

linux_c_py_php

starwing83 发表于 2013-02-21 18:11
另外，LF模式主要是为了应对惊群问题吧？现在没有这个问题了吧？还需要用这个模式么？

LF+ONESHOT做的, LF测试比ET效率要高, 不知道是否是用法有误.

linux_c_py_php

starwing83 发表于 2013-02-21 18:10
回复 112# linux_c_py_php

我再试试啊, 我就这么用的, 活生生没Move过去., 汗

starwing83

回复 111# iw1210


    本地lo，虽然也过了协议栈但是还是和网络延迟不能同日而语……

当然这代表服务器本身不会是瓶颈了

实际应用的时候肯定不会这么高的啦

yulihua49

iw1210 发表于 2013-02-21 16:49
连接多少个？不会这么脆弱吧！
怎么死掉一部分？什么现象？

10个连接，每个发10000包，最后有4、5个退不出来。丢事件了。

你弄的啥样？你不是一直坚持用select的吗？
楼主给我说的办法是多线程的，不是线程池，依然是同步IO不是异步的。

yulihua49

linux_c_py_php 发表于 2013-02-21 20:00
LF+ONESHOT做的, LF测试比ET效率要高, 不知道是否是用法有误.

LT吧？我认为网络饱和看不出二者区别，CPU饱和才能看出来。

linux_c_py_php

yulihua49 发表于 2013-02-22 10:24
LT吧？我认为网络饱和看不出二者区别，CPU饱和才能看出来。

额, 让我先来重新试试为什么xmove挪不动吧, HOHO.

iw1210

yulihua49 发表于 2013-02-22 10:22
10个连接，每个发10000包，最后有4、5个退不出来。丢事件了。

你弄的啥样？你不是一直坚持用select的吗？
楼主给我说的办法是多线程的，不是线程池，依然是同步IO不是异步的。 ...

才10个连接就不行了，不会吧，几个线程用select？

linux_c_py_php

starwing83 发表于 2013-02-22 08:36
回复 111# iw1210

嗯, 过网卡的话得看网卡性能, 公司网卡都优化了网卡对队列和CPU亲缘性, 能跑20万左右就极限了.

yulihua49

iw1210 发表于 2013-02-22 10:53
才10个连接就不行了，不会吧，几个线程用select？

一个专用线程进行select和任务分派。

1. void *sched(void *arg)
   
2. {
   
3. int stat,i;
   
4. char beatbuff[CONN_MAXFD+1];
   
5. fd_set rf,wf,ef;
   
6. 
   
7. fprintf(stderr,"sched:start!\n");
   
8.         FD_ZERO(&rfds);
   
9.         FD_ZERO(&wfds);
   
10.         FD_ZERO(&efds);
    
11.         stat=pipe2(beat,O_NONBLOCK);
    
12.         if(stat<0) {
    
13.                 fprintf(stderr,"create pipe beat err=%d:%s\n",
    
14.                                 errno,strerror(errno));
    
15.                 return NULL;
    
16.         }
    
17.         while(1) {
    
18.                 rf=rfds;
    
19.                 wf=wfds;
    
20.                 ef=efds;
    
21.                 FD_SET(beat[0],&rf);
    
22.                 stat=select(CONN_MAXFD+1,&rf,&wf,&ef,NULL);
    
23.                 if(stat<0) break;
    
24. //              pthread_mutex_lock(&beatLock);
    
25.                 beatc=0;
    
26. //              pthread_mutex_unlock(&beatLock);
    
27. fprintf(stderr,"sched:stat=%d\n",stat);
    
28.                 for(i=0;i<CONN_MAXFD;i++) {
    
29.                         stat=0;
    
30.                         if(FD_ISSET(i,&rf)) {
    
31.                                 if(i==beat[0]) {
    
32.                                         read(beat[0],beatbuff,sizeof(beatbuff));
    
33.                                         continue;
    
34.                                 }
    
35.                                 stat |= EV_IN;
    
36.                                 FD_CLR(i,&rfds);
    
37.                         }
    
38.                         if(FD_ISSET(i,&wf)) {
    
39.                                 stat |= EV_OUT;
    
40.                                 FD_CLR(i,&wfds);
    
41.                         }
    
42.                         if(FD_ISSET(i,&ef)) {
    
43.                                 stat |= EV_ERR;
    
44.                                 FD_CLR(i,&efds);
    
45.                         }
    
46.                         if(stat) {
    
47.                                 g_conn_table[i].events=stat;
    
48.                                 pthread_mutex_lock(&rdyLock);
    
49.                                 q_add(i,&rdy_q);//加入就绪队列
    
50.                                 pthread_mutex_unlock(&rdyLock);
    
51.                                 pthread_cond_signal(&rdyCond);
    
52.                         }
    
53.                 }
    
54.         }
    
55.         shut_server=1;
    
56.         close(beat[0]);
    
57.         close(beat[1]);
    
58. }
    

复制代码

iw1210

yulihua49 发表于 2013-02-22 10:22
10个连接，每个发10000包，最后有4、5个退不出来。丢事件了。

你弄的啥样？你不是一直坚持用select的吗 ...

4、5个退不出来，什么意思？