Epoll Reactor模型的部分代码[选自gxc]

之前写过的一个Linux下Select模型也是采取类似的方法，在另外的线程里面使用循环来执行update.
文章 经验实在太重要了：epoll的一些补充 提到几个Epoll的关键问题，这里借鉴作者的说法，记录一下，感谢作者的文章。

默认使用的是ET模式，即，边沿触发，类似于电平触发，epoll中的边沿触发的意思是只对新到的数据进行通知，而内核缓冲区中如果是旧数据则不进行通知，所以在do_use_fd函数中应该使用如下循环，才能将内核缓冲区中的数据读完。

view plain print ?

1. while(1){
2. len=recv(*******);
3. if(len==-1){
4. if(errno==EAGAIN)
5. break;
6. perror("recv");
7. break;
8. }
9. dosomethingwiththerecveddata........
10. }

在上面例子中没有说明对于listen socket fd该如何处理，有的时候会使用两个线程， 一个用来监听accept另一个用来监听epoll_wait，如果是这样使用的话，则listen socket fd使用默认的阻塞方式就行了，而如果epoll_wait和accept处于一个线程中，即，全部由epoll_wait进行监听，则，需将listen socket fd也设置成非阻塞的，这样，对accept也应该使用while包起来（类似于上面的recv），因为，epoll_wait返回时只是说有连接到来了，并没有说有几个连接，而且在ET模式下epoll_wait不会再因为上一次的连接还没读完而返回，这种情况确实存在，我因为这个问题而耗费了一天多的时间，这里需要说明的是，每调用一次accept将从内核中的已连接队列中的队头读取一个连接，因为在并发访问的环境下，有可能有多个连接“同时”到达，而epoll_wait只返回了一次。

Reactor模型关键处理代码如下：

view plain print ?

1. while(_run){
2. update();
3. }

view plain print ?

1. voidCEpollReactor::update()
2. {
3. intepret=epoll_wait(_epollHandle,_epollEvents,EVENT_COUNT,200);
4. if(epret==-1)
5. {
6. debug::send(NETWORK,"epoll_waiterrorerrno=%d.",errno);
7. debug::send(NETWORK,"%s.",strerror(errno));
8. //break;
9. return;
10. }
12. updateTimerList();
14. if(epret==0)
15. {
16. //debug::send(NETWORK,"EPOLLtimeouted.");
17. //timeout
18. }
20. if(epret>0)
21. {
22. for(inti=0;i<epret;++i)
23. {
24. CSocket*socket=(CSocket*)(_epollEvents[i].data.ptr);
26. if(_epollEvents[i].events&(EPOLLERR|EPOLLHUP))
27. {
28. debug::send(NETWORK,"EPOLLERRonfd%d.",socket->getHandle());
29. socket->handleClose();
30. socket->setReactor(NULL);
31. socket->close();
32. continue;
33. }
35. intret=0;
36. if(_epollEvents[i].events&EPOLLIN)
37. {
38. debug::send(NETWORK,"EPOLLINonfd%d.",socket->getHandle());
39. ret=socket->handleRead();
40. }
41. if(ret==-1)
42. {
43. socket->handleClose();
44. socket->setReactor(NULL);
45. socket->close();
46. continue;
47. }
49. if(_epollEvents[i].events&EPOLLOUT)
50. {
51. debug::send(NETWORK,"EPOLLOUTonfd%d",socket->getHandle());
52. ret=socket->handleWrite();
53. }
54. if(ret==-1)
55. {
56. socket->handleClose();
57. socket->setReactor(NULL);
58. socket->close();
59. continue;
60. }
61. }
62. }
63. }

很多函数并不存在，但是从代码中我们就可以大致了解该类如何开发，扩展性会比较好！我将尽快完成该类，并在博客放出，希望大家喜欢。