C10K问题

港控/mmm° 2022-08-06 13:08 65阅读 0赞

<table style="color:rgb(68,68,68); font-size:16px; line-height:24px"> 
 <tbody> 
 <tr> 
 <td style="position:relative"> <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> 所谓c10k问题，指的是服务器同时支持成千上万个客户端的问题，也就是concurrent 10 000 connection（这也是c10k这个名字的由来）。由于硬件成本的大幅度降低和硬件技术的进步，如果一台服务器同时能够服务更多的客户端，那么也就意味着服务每一个客户端的成本大幅度降低，从这个角度来看，c10k问题显得非常有意义。 <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> 为了解决C10K问题，有各种各样的IO策略，它们的分歧或者说不同之处大概如下： <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:-0.25in"> ·&nbsp;&nbsp;&nbsp;&nbsp;是否在一个线程当中处理多个IO调用 <p style="margin-top:0px; margin-bottom:5px; margin-left:1in; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:-0.25in"> o&nbsp;&nbsp;&nbsp;单线程处理多个IO调用不靠谱，还是使用阻塞的，同步的调用方法。在这种情况下利用多线程或者多进程来达到并发 <p style="margin-top:0px; margin-bottom:5px; margin-left:1in; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:-0.25in"> o&nbsp;&nbsp;&nbsp;使用非阻塞的IO（比如被设置成O_NONBLOCK模式的socket的write方法）来启动IO，利用IO的就绪通知（比如poll（）方法或者/dev/poll）来确认什么时候可以在同一个通道上启动一轮新的IO。通常这种方法只是适合网络IO，对于磁盘IO这种方法并不合适。 <p style="margin-top:0px; margin-bottom:5px; margin-left:1in; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:-0.25in"> o&nbsp;&nbsp;&nbsp;使用异步IO调用（比如aio_write()）来启动IO&nbsp;，当IO完成时，会有通知（比如信号量或者完成端口）告诉你什么时候IO操作结束了。这种方法对于网络IO和磁盘IO都很适合。 <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:-0.25in"> ·&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;如何控制服务于每个客户端的代码。 <p style="margin-top:0px; margin-bottom:5px; margin-left:1in; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:-0.25in"> o&nbsp;&nbsp;&nbsp;一个进程服务一个客户端。（这是Unix采用的经典的方法，从80年代采用直到现在一直在使用） <p style="margin-top:0px; margin-bottom:5px; margin-left:1in; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:-0.25in"> o&nbsp;&nbsp;&nbsp;一个OS-Level的线程来同时处理很多客户端，每个客户端的控制是通过： <p style="margin-top:0px; margin-bottom:5px; margin-left:1.5in; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:-0.25in"> §&nbsp;&nbsp;一个用户态的线程（比如GNU状态线程，经典的java绿色线程） <p style="margin-top:0px; margin-bottom:5px; margin-left:1.5in; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:-0.25in"> §&nbsp;&nbsp;一个状态机 <p style="margin-top:0px; margin-bottom:5px; margin-left:1.5in; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:-0.25in"> §&nbsp;&nbsp;线程延伸 <p style="margin-top:0px; margin-bottom:5px; margin-left:1in; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:-0.25in"> o&nbsp;&nbsp;&nbsp;为每个客户端分配一个OS Level的线程 <p style="margin-top:0px; margin-bottom:5px; margin-left:1in; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:-0.25in"> o&nbsp;&nbsp;&nbsp;为每个活跃的客户端分配一个OS Level的线程 <p style="margin-top:0px; margin-bottom:5px; margin-left:1in; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:-0.25in"> 是否使用标准的OS 服务，更直接的方法是把部分代码放入内核中。 &nbsp;&nbsp;&nbsp;&nbsp;下面就来看看5种最流行的IO策略： <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:-0.25in"> 1． &nbsp;&nbsp;&nbsp;&nbsp;1 用一个线程来同时为很多的客户端来服务，非阻塞IO以及水平触发方式的就绪通知 <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> 这种方式很简单，它将所有的网络文件句柄的工作模式都设置成NON-BLOCKING，通过调用select（）方法或者poll（）方法来告诉应用层哪些个网络句柄有正在等待着并需要被处理的数据。这是一种非常传统的方法。通过这种机制，内核能够告诉应用层一个文件描述符是否准备好了（这里的准备好有着明确的含义，对于读描述符，准备好了意味着此时该描述符的缓冲区内数据已经准备好，读取该描述符的数据不会发生阻塞，而对于写描述符而言，准备好了意味着另外一层含义，它意味着写缓冲区已经准备好了，此时对该操作符的写操作也将不会导致任何阻塞发生），以及你是否已经利用该文件描述符作了相应的事情。因为这里的就绪通知方式是水平触发，也就说如果内核通知应用层某一个文件描述符已经就绪，而如果应用层此后一直没有完整的处理该描述符（没有读取完相应的数据或者没有写入任何数据），那么内核会不断地通知应用层该文件描述符已经就绪。这就是所谓的水平触发：只要条件满足，那内核就会触发一个事件（只要文件描述符对应的数据没有被读取或者写入，那内核就不断地通知你）。 <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> 需要注意的是：内核的就绪通知只是一个提示，提示也就意味着这个通知消息未必是100%准确的，当你读取一个就绪的读文件描述符时，实际上你有可能会发现这个描述符对应的数据并没有准备好。这就是为什么如果使用就绪通知的话一定要将文件描述符的模式设置成NOBLOCK的，因为NOBLOCK模式的读取或者写入在文件描述符没有就绪的时候会直接返回，而不是引起阻塞。如果这里发生了阻塞，那将是非常致命的，因为我们只有一个线程，唯一的线程被阻塞了的话，那我们就玩完了。 <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> 这种方式的一个缺陷就是不适用磁盘文件的IO操作。将磁盘文件的操作句柄的工作模式设置成NOBLOCK是无效的，此时对该磁盘文件进行读写依然有可能导致阻塞。对于缺乏AIO（异步IO）支持的系统，将磁盘IO操作委托给worker线程或者进程是一个好方法来绕过这个问题。一个可行的方法是使用memory mapped file，然后调用mincore（），mincore会返回一个向量来表示相应的page是否在ram缓存中，如果page不在ram缓存中，则意味着读取该页面会导致page falut，从而引起阻塞，那么就需要通过委托的worker线程来进行IO操作。这种方式的实现方法在Linux上就是select，poll这样的系统调用。 <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:-0.25in"> 2．&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;2&nbsp;&nbsp;使用一个线程同时服务很多个客户端，采用noblock的IO模式以及边沿触发的就绪通知。 <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> 所谓边沿触发是相对水平触发而言的，也就是说内核只是在文件描述符的状态发生变换的时候才进行通知。这就意味着在大多数情况下，当内核通知某个读描述符就绪后，除非该读描述符内部缓冲区的所有数据已经完全被读取从而使得就绪状态发生了变化，否则内核不会发出任何新的通知，会永远沉默下去。如果该文件描述符的receive操作返回EWOULDBLOCK错误码，这就意味着该描述符的就绪状态已经被打破，你需要等待下一次的边沿触发通知。 <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> 除了上面所说的问题，一旦使用了边沿触发，另外一个随之而来的问题就是，你需要注意一个常见的“意外事件”的问题。因为os实现边沿触发的一个常见的实现bug就是在某些情况下内核一旦收到新数据包就会通知就绪，不管你上一次的就绪通知是否被用户处理。因此你必须小心组织你的代码，你需要处理好每一个就绪通知，如果某一次就绪通知的数据没有被正确得完整得处理你就急急忙忙得开始等待下一次通知，那么下一次的就绪通知就会覆盖掉前面的数据，那么你就会永远不会恢复了。 <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> 相比之下，这种方式对于程序员编码的要求可能会更高一些，一旦应用程序错过了一次通知，那么与之对应的客户端就永远崩溃了（意外事件）或者沉默（没有读取完上一次事件产生的数据）。而方式1则会不断提醒用户缓冲区内还有数据。因此，对于边沿触发方式的就绪通知，应用层必须在每次就绪通知后读取数据，一直读到EWOULDBLOCK为止。 <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> 这种方式在Linux中主要通过epoll实现。实际上java nio采用的也是这种IO策略。Epoll和poll有一些共同之处，epoll在默认情况下也是水平触发的，此时你可以认为epoll是一个增强版的poll，它的效率更高，这是因为epoll采用了一些优化，比如只关心活跃的连接，通过共享内存空间避免了内存拷贝等等。 <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> &nbsp; <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:-0.25in"> 3．&nbsp;&nbsp;&nbsp;&nbsp;3&nbsp;&nbsp;用一个线程同时服务很多个客户端，采用异步IO。 <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> 这种IO策略实际上Linux并没有原生支持，尽管POSIX定义了它。相比之下windows就提供了很好的支持。异步IO也有内核通知，只不过这种通知不是就绪通知，而是完成通知，这就意味着一旦获得内核通知，那么IO操作就已经完成了，用户无需再调用任何操作来获取数据或者发送数据，此时数据已经好端端得放在用户定义的buffer中或者数据已经妥妥得发送出去了。与前两种方式相比，实际上aio是由内核线程或者底层线程异步地，默默得完成了IO操作，而方式1，方式2还得由用户线程来自己读取数据。相比之下，内核线程自然要高效很多。因此从IO模型的效率上来讲，windows是要优于Linux的。另外题外话再插一句，实际上微软的windows在很多概念上还是比较先进的，比如windows是微内核的，又比如这里的AIO，所以微软其实没有大家所想象的那么不堪，还是挺牛的。如果专业一点来讲，1和2这种方式一般被称之为reactor模式，3这种模式被称之为proactor模式。 <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> &nbsp; <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:-0.25in"> 4．&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;4 为每个客户端分配一个线程来进行IO操作 <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> 这种IO策略就比较老土了，也就是我们最常用的的一种IO模型，而且这种IO模型已经存在了几十年了。这种策略下，read和write调用都是阻塞的。它最大的问题就是每个线程都需要占据一个完整的栈帧，这个对内存的考验还是比较大的。而且过多的线程对OS也有很大的压力，很多OS如果有过多的线程其性能会有指数级别的下降。来算一下吧，假设栈帧的空间为2M，那么1G的内存最多服务512个线程，显然和我们的要求10K有不小的差距。当然，由于硬件的资源会越来越便宜，线程的内存开销可能不太会成为瓶颈。但多线程带来的进程切换的开销却有可能会长期存在。 <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> 这种IO策略的关键在于OS的线程要足够强大，高效。 <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:-0.25in"> 5．&nbsp;&nbsp;&nbsp;&nbsp;5 把应用层代码装进内核里 <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> 这种方式比较疯狂，如果你的team有足够的人手，而且服务器的需求量也比较大，你其实可以考虑这种方式。用专有的方法来解决问题其实也并非不可以，比如有的公司会把常用的核心算法放到FPGA或者ASIC芯片上去来解决问题，这两者的思路其实是如出一辙。对于Linux来讲，其实社区的意见还是不倾向于这么做，原因也很好理解，在内核中为应用开一个口子怎么看都不像一个好主意，一个更好的思路还是尽可能让用户空间的程序更快吧，别动不动就塞进内核里来。 <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> &nbsp; <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> 好了，这就是目前为止关于解决C10K问题的一些思路，实际上思路2还是解决问题的主流方式。关于这个问题更多的资料大家可以参阅<a href="http://www.kegel.com/c10k.html#threaded" style="color:rgb(165,110,0); text-decoration:none" rel="nofollow">http://www.kegel.com/c10k.html#threaded</a>，这个页面上对于C10K问题有着比较全面的分析和总结，本文实际上也只不过这个页面主要内容的一个摘要以及评注。 <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> <p style="margin-top:0px; margin-bottom:5px; padding-top:0px; padding-bottom:0px; border:0px; list-style:none; word-wrap:normal; word-break:normal; line-height:21px; color:rgb(50,62,50); font-family:simsun; font-size:14px; text-indent:28px"> </td> 
 </tr> 
 </tbody> 
</table>

C10K problem是指如何让服务器能够支持10k并发，当然你可以买昂贵的服务器，但是还有更便宜的办法。  
这是最著名的讲C10K问题的网页[《The C10K Problem][The C10K Problem]》  
  
在Linux下面，解决这个问题的技术首选当然是epoll啦,不过2.6以上kernel才支持...2.4的兄弟们打个patch吧。  
  
epoll的接口非常简单，一共就三个函数：  
1. int epoll\_create(int size);  
2. int epoll\_ctl(int epfd, int op, int fd, struct epoll\_event \*event);  
3. int epoll\_wait(int epfd, struct epoll\_event \* events, int maxevents, int timeout);  
大家看看man就知道具体参数意思。  
  
需要注意的是epoll有两个触发方式，类似于中断的两种触发方式：

*  边缘触发(ET)：只有fd的状态有变化才会触发event，唤醒epoll\_wait，比如新数据到来
 *  水平触发(LT)：类似传统的poll，只要有数据，epoll\_wait就会成功

但是在epoll出现之前，大家都习惯于LT的模式，而据说epoll最开始设计的时候只有ET模式，而且第一版的实现也只有ET模式，ET虽然快，但是比较容易出错，epoll的man page给出如下的死锁情况：  
假定A,B通讯，A给B发送了一个2K的message，B的epoll\_wait将会成功返回，B开始读数据，但是只读1k的时候调用epoll\_wait,这时epoll\_wait将进入等待状态（因为fd没有新状态变化）。如果此时A还在等待B的response，那么AB将会进入死锁状态。  
后来在大家的强烈要求下，才加入了LT模式...  
  
在这之前大家做异步I/O，大部分使用select/poll，在内核里面slect和poll的实现都差不多的，都是用VFS的poll函数实现的(fs/select.c)。select最多只能同时处理1024个fd,poll的问题是每次调用都要拷贝pollfd，同时处理的fd越多，效率越低。而epoll避免了这个问题，只有有状态变化的fd才有通知。  
  
其实有很多lib和framework已经帮大家做了很好的封装，比如ACE, ASIO, libevent等，大家看哪个顺手就拿来用吧，至于windows下，当仁不让的选择是完成端口。  
  
下面是一个各种异步I/O方法的性能比较图,来自libevent：  
![libevent-benchmark.jpg][]

编写连接数巨大的高负载服务器程序时，经典的多线程模式和select模式都不再适用。 
应当抛弃它们，采用epoll/kqueue/dev\_poll来捕获I/O事件。最后简要介绍了AIO。 
 
 
由来 
 
 
网络服务在处理数以万计的客户端连接时，往往出现效率低下甚至完全瘫痪，这被称为 
C10K问题。随着互联网的迅速发展，越来越多的网络服务开始面临C10K问题，作为大型 
网站的开发人员有必要对C10K问题有一定的了解。本文的主要参考文献是 
<[http://www.kegel.com/c10k.html][The C10K Problem]> [http://www.kegel.com/c10k.htmls][http_www.kegel.com_c10k.htmls]。 
 
C10K问题的最大特点是：设计不够良好的程序，其性能和连接数及机器性能的关系往往 
是非线性的。举个例子：如果没有考虑过C10K问题，一个经典的基于select的程序能在 
旧服务器上很好处理1000并发的吞吐量，它在2倍性能新服务器上往往处理不了并发 
2000的吞吐量。 
 
这是因为在策略不当时，大量操作的消耗和当前连接数n成线性相关。会导致单个任务 
的资源消耗和当前连接数的关系会是O(n)。而服务程序需要同时对数以万计的socket进 
行I/O处理，积累下来的资源消耗会相当可观，这显然会导致系统吞吐量不能和机器性 
能匹配。为解决这个问题，必须改变对连接提供服务的策略。 
 
 
基本策略 
 
 
主要有两方面的策略：1.应用软件以何种方式和操作系统合作，获取I/O事件并调度多 
个socket上的I/O操作；2. 应用软件以何种方式处理任务和线程/进程的关系。前者主 
要有阻塞I/O、非阻塞I/O、异步I/O这3种方案，后者主要有每任务1进程、每任务1线 
程、单线程、多任务共享线程池以及一些更复杂的变种方案。常用的经典策略如下： 
 
1. Serve one client with each thread/process, and use blocking I/O 
这是小程序和java常用的策略，对于交互式的长连接应用也是常见的选择(比如BBS)。 
这种策略很能难足高性能程序的需求，好处是实现极其简单，容易嵌入复杂的交互逻 
辑。Apache、ftpd等都是这种工作模式。 
 
2. Serve many clients with single thread, and use nonblocking I/O 
and readiness notification 
这是经典模型，datapipe等程序都是如此实现的。优点在于实现较简单，方便移植，也 
能提供足够的性能；缺点在于无法充分利用多CPU的机器。尤其是程序本身没有复杂的 
业务逻辑时。 
 
3. Serve many clients with each thread, and use nonblocking I/O and 
readiness notification 
对经典模型2的简单改进，缺点是容易在多线程并发上出bug，甚至某些OS不支持多线程 
操作readiness notification。 
 
4. Serve many clients with each thread, and use asynchronous I/O 
在有AI/O支持的OS上，能提供相当高的性能。不过AI/O编程模型和经典模型差别相当 
大，基本上很难写出一个框架同时支持AI/O和经典模型，降低了程序的可移植性。在 
Windows上，这基本上是唯一的可选方案。 
 
本文主要讨论模型2的细节，也就是在模型2下应用软件如何处理Socket I/O。 
 
 
select 与 poll 
 
 
最原始的同步阻塞 I/O 模型的典型流程如下： 
 
同步阻塞 I/O 模型的典型流程 
 
从应用程序的角度来说，read 调用会延续很长时间，应用程序需要相当多线程来解决 
并发访问问题。同步非阻塞I/O对此有所改进： 
 
经典的单线程服务器程序结构往往如下： 
 
 
do \{ 
 
Get Readiness Notification of all sockets 
 
Dispatch ready handles to corresponding handlers 
 
If (readable) \{ 
read the socket 
 
If (read done) 
 
Handler process the request 
\} 
 
if (writable) 
 
write response 
 
if (nothing to do) 
 
close socket 
 
\} while(True) 
 
非阻塞 I/O 模型的典型流程: 
 
异步阻塞 I/O 模型的典型流程 
 
其中关键的部分是readiness notification，找出哪一个socket上面发生了I/O事件。 
一般从教科书和例子程序中首先学到的是用select来实现。Select定义如下： 
 
 
int select(int n, fd\_set \*rd\_fds, fd\_set \*wr\_fds, fd\_set \*ex\_fds, struct 
timeval \*timeout); 
 
 
 
在ACE环境中，ACE\_Select\_Reactor针对这一点特别作了保护措施，但是还是有recv\_n 
这样的函数间接的使用了select，这需要大家注意。 
 
针对fd\_set的问题，\*nix提供了poll函数作为select的一个替代品。Poll的接口如下： 
 
 
int poll(struct pollfd \*ufds, unsigned int nfds, int timeout); 
 
第1个参数ufds是用户提供的一个pollfd数组，数组大小由用户自行决定，因此避免了 
FD\_SETSIZE带来的麻烦。Ufds是fd\_set的一个完全替代品，从select到poll的移植很方 
便。到此为止，至少我们面对C10K，可以写出一个能work的程序了。 
 
然而Select和Poll在连接数增加时，性能急剧下降。这有两方面的原因：首先操作系统 
面对每次的select/poll操作，都需要重新建立一个当前线程的关心事件列表，并把线 
程挂在这个复杂的等待队列上，这是相当耗时的。其次，应用软件在select/poll返回 
后也需要对传入的句柄列表做一次扫描来dispatch，这也是很耗时的。这两件事都是和 
并发数相关，而I/O事件的密度也和并发数相关，导致CPU占用率和并发数近似成O(n2) 
的关系。 
 
 
epoll, kqueue, /dev/poll 
 
 
因为以上的原因，\*nix的hacker们开发了epoll, kqueue, /dev/poll这3套利器来帮助 
大家，让我们跪拜三分钟来感谢这些大神。其中epoll是linux的方案，kqueue是 
freebsd的方案，/dev/poll是最古老的Solaris的方案，使用难度依次递增。 
 
简单的说，这些api做了两件事：1.避免了每次调用select/poll时kernel分析参数建立 
事件等待结构的开销，kernel维护一个长期的事件关注列表，应用程序通过句柄修改这 
个列表和捕获I/O事件。2.避免了select/poll返回后，应用程序扫描整个句柄表的开 
销，Kernel直接返回具体的事件列表给应用程序。 
 
在接触具体api之前，先了解一下边缘触发(edge trigger)和条件触发(level trigger) 
的概念。边缘触发是指每当状态变化时发生一个io事件，条件触发是只要满足条件就发 
生一个io事件。举个读socket的例子，假定经过长时间的沉默后，现在来了100个字 
节，这时无论边缘触发和条件触发都会产生一个read ready notification通知应用程 
序可读。应用程序读了50个字节，然后重新调用api等待io事件。这时条件触发的api会 
因为还有50个字节可读从而立即返回用户一个read ready notification。而边缘触发 
的api会因为可读这个状态没有发生变化而陷入长期等待。 
 
因此在使用边缘触发的api时，要注意每次都要读到socket返回EWOULDBLOCK为止，否则 
这个socket就算废了。而使用条件触发的api时，如果应用程序不需要写就不要关注 
socket可写的事件，否则就会无限次的立即返回一个write ready notification。大家 
常用的select就是属于条件触发这一类，以前本人就犯过长期关注socket写事件从而 
CPU 100%的毛病。 
 
epoll的相关调用如下： 
 
 
int epoll\_create(int size) 
 
 
int epoll\_ctl(int epfd, int op, int fd, struct epoll\_event \*event) 
 
 
int epoll\_wait(int epfd, struct epoll\_event \* events, int maxevents, int 
timeout) 
 
epoll\_create创建kernel中的关注事件表，相当于创建fd\_set。 
 
epoll\_ctl修改这个表，相当于FD\_SET等操作 
 
epoll\_wait等待I/O事件发生，相当于select/poll函数 
 
epoll完全是select/poll的升级版，支持的事件完全一致。并且epoll同时支持边缘触 
发和条件触发，一般来讲边缘触发的性能要好一些。这里有个简单的例子： 
 
 
struct epoll\_event ev, \*events; 
 
int kdpfd = epoll\_create(100); 
 
ev.events = EPOLLIN | EPOLLET; // 注意这个EPOLLET，指定了边缘触发 
 
ev.data.fd =listener; 
 
epoll\_ctl(kdpfd, EPOLL\_CTL\_ADD, listener, &ev); 
 
for(;;) \{ 
 
nfds = epoll\_wait(kdpfd, events, maxevents, -1); 
 
 
 
for(n = 0; n < nfds; ++n) \{ 
 
if(events\[n\].data.fd == listener) \{ 
 
client = accept(listener, (struct sockaddr \*) &local, 
 
&addrlen); 
 
if(client < 0)\{ 
 
perror("accept"); 
 
continue; 
 
\} 
 
setnonblocking(client); 
 
ev.events = EPOLLIN | EPOLLET; 
 
ev.data.fd = client; 
 
if (epoll\_ctl(kdpfd, EPOLL\_CTL\_ADD, client, &ev) < 0) \{ 
 
fprintf(stderr, "epoll set insertion error: fd=%d0, 
 
client); 
 
return -1; 
 
\} 
 
\} 
 
else 
 
do\_use\_fd(events\[n\].data.fd); 
 
\} 
 
\} 
 
简单介绍一下kqueue和/dev/poll 
 
kqueue是freebsd的宠儿，kqueue实际上是一个功能相当丰富的kernel事件队列，它不 
仅仅是select/poll的升级，而且可以处理signal、目录结构变化、进程等多种事件。 
Kqueue是边缘触发的 
 
/dev/poll是Solaris的产物，是这一系列高性能API中最早出现的。Kernel提供一个特 
殊的设备文件/dev/poll。应用程序打开这个文件得到操纵fd\_set的句柄，通过写入 
pollfd来修改它，一个特殊ioctl调用用来替换select。由于出现的年代比较早，所以 
/dev/poll的接口现在看上去比较笨拙可笑。 
 
C++开发：ACE 5.5以上版本提供了ACE\_Dev\_Poll\_Reactor封装了epoll和/dev/poll两种 
api，需要分别在config.h中定义ACE\_HAS\_EPOLL和ACE\_HAS\_DEV\_POLL来启用。 
 
Java开发： JDK 1.6的Selector提供了对epoll的支持，JDK1.4提供了对/dev/poll的支 
持。只要选择足够高的JDK版本就行了。 
 
 
异步I/O以及Windows 
 
 
和经典模型不同，异步I/O提供了另一种思路。和传统的同步I/O不同，异步I/O允许进 
程发起很多 I/O 操作，而不用阻塞或等待任何操作完成。稍后或在接收到 I/O 操作完 
成的通知时，进程就可以检索 I/O 操作的结果。 
 
异步非阻塞 I/O 模型是一种处理与 I/O 重叠进行的模型。读请求会立即返回，说明 
read 请求已经成功发起了。在后台完成读操作时，应用程序然后会执行其他处理操 
作。当 read 的响应到达时，就会产生一个信号或执行一个基于线程的回调函数来完成 
这次 I/O 处理过程。异步I/O 模型的典型流程： 
 
异步非阻塞 I/O 模型的典型流程 
 
对于文件操作而言，AIO有一个附带的好处：应用程序将多个细碎的磁盘请求并发的提 
交给操作系统后，操作系统有机会对这些请求进行合并和重新排序，这对同步调用而言 
是不可能的——除非创建和请求数目同样多的线程。 
 
Linux Kernel 2.6提供了对AIO的有限支持——仅支持文件系统。libc也许能通过来线 
程来模拟socket的AIO，不过这对性能没意义。总的来说Linux的aio还不成熟 
 
Windows对AIO的支持很好，有IOCP队列和IPCP回调两种方式，甚至提供了用户级异步调 
用APC功能。Windows下AIO是唯一可用的高性能方案，详情请参考MSDN。

C10K问题：

网络服务在处理数以万计的客户端连接时，往往出现效率底下甚至完全瘫痪，这被成为C10K问题。

(C10K = connection 10 kilo 问题)。k 表示 kilo，即 1000 比如：kilometer(千米), kilogram(千克)。

非阻塞I/O，最关键的部分是readiness notification(when ready, then notify!)和找出哪一个socket上面发生了I/O事件。

一般我们首先会想到用select来实现。  
int select(int n, fd\_set \*rd\_fds; fd\_set \*wr\_fds, fd\_set \*ex\_fds, struct timeval \* timeout);

其中用到了fd\_set结构，而fd\_set不能大于FD\_SETSIZE,默认是1024，很容易导致数组越界。

针对fd\_set的问题，\*nix提供了poll函数作为select的一个替代品：

int poll(struct pollfd \*ufds, unsigned int nfds, int timeout)

第一个参数ufds是用户提供的一个pollfd数组，大小由用户自行决定，因此避免了FD\_SETSIZE带来的麻烦。

然而select和poll在连接数增加时，性能急剧下降。这有两方面的原因：

《1》首先操作系统面对每次的select/poll操作，都需要重新建立一个当前线程的关心事件链表，并把线程挂在这个复杂的等待队列上，这是相当耗时的。

《2》其次，应用软件在select/poll返回后也需要对传入的句柄链表做一次循环扫描来dispatch，这也是很耗时的。这两件事都是和并发数相关，而I/O事件的密度也和并发数相关，导致CPU占用率和并发数近似成O(n2)的关系。

基于以上原因，\*nix的hacker们开发了epoll, kqueue, /dev/poll这3套利器。epoll是Linux的方案，kqueue是freebsd的方案，/dev/poll是solaris的方案。

简单的说，这些api做了两件事：

《1》避免了每次调用select/poll时kernel分析参素建立事件等结构的开销，kernel维护一个长期的时间关注列表，应用程序通过句柄修改这个链表和捕获I/P事件

《2》避免了select/poll返回后，应用程序扫描整个句柄表的开销，kernel直接返回具体的链表给应用程序。

在接触具体api之前，先了解一下边缘触发(edge trigger)和条件触发(level trigger)的概念。边缘触发是指每当状态变化时发生一个io事件，假定经过长时间的沉默后，现在来了100个字节，这是无论边缘触发和条件触发都会产生一个read ready notification通知应用程序可读。应用程序在读完来的50个字节，然后重新调用api等待io事件。这时条件触发的api会因为还有50个字节可读从而立即返回用户一个read ready notification。而边缘触发的api会因为可读这个状态没有发生变化而陷入长期等待。

因此在使用边缘触发的api时，要注意每次都要读到socket返回**EWOULDBLOCK**为止，否则这个socket就算废了。而使用条件触发的api时，如果应用程序不需要写就不要关注socket可写的事件，否则会无限次的立即返回一个write ready nitification. 大家常用的select就是属于条件触发这一类，以前本人翻过长期关注socket写事件从而CPU 100%的毛病。

epoll相关调用：

int epoll\_create(int size);  
int epoll\_ctl(int epfd, int op, int fd, struct epoll\_event \*event);  
int epoll\_wait(int epfd, struct epoll\_event \*events, int maxevents, int timeout);

epoll\_create 创建kernel中的关注事件表，相当于创建fd\_set.  
epoll\_ctl 修改这个表，相当与FD\_SET等操作。  
epoll\_wait 完全是select/poll的升级版，支持的事件完全一致。并且epoll同时支持边缘触发和条件触发，一般来讲边缘触发的性能要好一些。

简单的例子：

**\[cpp\]** [view plain][] [copy][view plain]

1. strut epoll\_event ev, \*events; 
2. 
3. **int** kdpfd = epoll\_create(100); //创建kernel中的关注事件表，返回一个kernel事件表的句柄
4. 
5. 
6. 
7. ev.events = EPOLLIN | EPOLLET; //边缘触发
8. 
9. ev.data.fd = listener; 
10. 
11. epoll\_ctl(kdpfd, EPOLL\_CTL\_ADD, listener, &ev); //将事件ev加入到kernel关注的事件表中
12. 
13. 
14. 
15. **for**(;;)\{ 
16. 
17. nfds = epoll\_wait(kdpfd, events, maxevents, -1); //等待被通知 
18. 
19. **for**(n = 0; n < nfds; n++)\{ 
20. 
21. 
22. 
23. **if**(events\[n\].data.fd == listener)\{ 
24. 
25. client = accept(listener, (**struct** sockaddr\*)&local, &addrlen); 
26. 
27. **if**(client < 0)\{ 
28. 
29. peror("accept"); 
30. 
31. **continue**; 
32. 
33. \} 
34. 
35. setnonblocking(client); 
36. 
37. ev.events = EPOLLIN | EPOLLET; 
38. 
39. ev.data.fd = client; 
40. 
41. **if**(epoll\_ctl(kdpfd, EPOLL\_CTL\_ADD, client, &ev) < 0)\{ 
42. 
43. fprintf(stderr, "epoll set insertion error: fd = %d, client); 
44. 
45. **return** \-1; 
46. \} 
47. \}**else**
48. do\_use\_fd(events\[n\].data.fd); 
49. \} 
50. \}

[The C10K Problem]: http://www.kegel.com/c10k.html
[libevent-benchmark.jpg]: /images/20220806/38b575c07c064441bf15037a2260bbce.png
[http_www.kegel.com_c10k.htmls]: http://www.kegel.com/c10k.htmls
[view plain]: http://blog.csdn.net/jysg9/article/details/7901321#