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

linux_c_py_php

lonerwolf 发表于 2013-02-25 21:39
回复 173# linux_c_py_php

这可不是一定的, 完全可以做一个半同步半异步的数据库代理服务器在同步层做同步DB访问, 然后指定一个简单的交互协议, 供其他纯异步服务器异步的请求, 就是Proxy的概念

yulihua49

iw1210 发表于 2013-02-25 17:33
你这个做的好了么，别忽悠我啊~
做好了发给我源代码学习下啊

select服务器移植到UNIX啦，在solaris服务器上测试：4核8超线程的服务器：
平均时间:       IFACE   rxpck/s   txpck/s    rxkB/s    txkB/s   rxcmp/s   txcmp/s  rxmcst/s
平均时间:          lo      0.00      0.00      0.00      0.00      0.00      0.00      0.00
平均时间:        eth0 161140.65 160855.88  12272.01  12252.89      0.00      0.00      0.00
平均时间:      virbr0      0.00      0.00      0.00      0.00      0.00      0.00      0.00
平均时间:   virbr0-nic      0.00      0.00      0.00      0.00      0.00      0.00      0.00
这次网络真是饱和啦！qps=16万，流量12.2M。

这个更有意义点，要的是可移植嘛。

100个连接的 nohup.out:

sched:8 Event's active!
sched:11 Event's active!
sched:3 Event's active!
sched:14 Event's active!
sched:6 Event's active!
sched:17 Event's active!
sched:9 Event's active!
sched:15 Event's active!
sched:12 Event's active!
sched:10 Event's active!
sched:10 Event's active!
sched:9 Event's active!
sched:10 Event's active!
sched:10 Event's active!
sched:9 Event's active!
sched:10 Event's active!
sched:10 Event's active!
sched:6 Event's active!
sched:12 Event's active!

UNIX更屌，select不支持非阻塞方式，fd必须在阻塞状态加入select，临使用前设定非阻塞，

select_solaris.tar.gz (1.02 MB, 下载次数: 74)

2013-02-26 15:01 上传

点击文件名下载附件

yulihua49

yulihua49 发表于 2013-02-26 14:50
select服务器移植到UNIX啦，在solaris服务器上测试：4核8超线程的服务器：
平均时间:       IFACE   rxp ...

关于锁非常多的问题，这里是利用锁提高了select的效率。

select必须在调用时设置好fds。它进入后设置的任何状态都是无效的。因此每个线程归还fd后都要煽它一次。
那么许多线程就可能不断的煽它。造成低效。这时需要一个“聚束”的工作，大家设置好fds以后煽一次就行了。

见这一段代码：

1.         pthread_mutex_lock(&beatLock);
   
2.         FD_SET(sock,&rfds);
   
3.         if (conn->woff > 0) FD_SET(sock,&wfds);
   
4. //      FD_SET(sock,&efds);
   
5.         pthread_mutex_unlock(&beatLock);
   
6.         if(!pthread_mutex_trylock(&beatLock)) {
   
7.                 beatc='\n';
   
8.                 write(beat[1],&beatc,1);
   
9.                 pthread_mutex_unlock(&beatLock);
   
10.         }
    

复制代码

第6行，每个线程测试加锁，如果不能获取锁就拉倒。最后的线程获得了锁，煽了select。
这时一个无损聚束的动作，不需要聚束时间，哪怕只有一个线程也不会耽误。
效果嘛，你看看前边1000个连接的，每次都可以激活500-800个fds，虽然每次要遍历1024个fd，但是能够激活那么多fd，平均每个fd开销就不算大了，达到了接近epoll的水平。
前边100个连接的可以聚束到十几个。

iw1210

回复 181# yulihua49
你太牛X了，你的实验证明了我说的用select方案可行了啊~


   

iw1210

yulihua49 发表于 2013-02-26 15:04
关于锁非常多的问题，这里是利用锁提高了select的效率。

select必须在调用时设置好fds。它进入后设置的 ...

不就是用FD_SET设置描述符集合的么

yulihua49

iw1210 发表于 2013-02-26 15:08
不就是用FD_SET设置描述符集合的么

其他线程的FD_SET无效，设完了必需打select一下，要他醒过来重新载入fds。

iw1210

yulihua49 发表于 2013-02-26 15:22
其他线程的FD_SET无效，设完了必需打select一下，要他醒过来重新载入fds。

什么意思？没明白~

yulihua49

iw1210 发表于 2013-02-26 15:26
什么意思？没明白~

一个线程select，其他线程FD_SET是不起作用的。

iw1210

yulihua49 发表于 2013-02-26 15:32
一个线程select，其他线程FD_SET是不起作用的。

一个线程select就行了吧，有必要多线程select么？

yulihua49

iw1210 发表于 2013-02-26 15:38
一个线程select就行了吧，有必要多线程select么？

其他线程干完活，怎么把fd归还到fdset里？