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

前端之家收集整理的这篇文章主要介绍了Epoll Reactor模型的部分代码[选自gxc]前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。
之前写过的一个Linux下Select模型也是采取类似的方法,在另外的线程里面使用循环来执行update.
文章 经验实在太重要了:epoll的一些补充 提到几个Epoll的关键问题,这里借鉴作者的说法,记录一下,感谢作者的文章

默认使用的是ET模式,即,边沿触发,类似于电平触发,epoll中的边沿触发的意思是只对新到的数据进行通知,而内核缓冲区中如果是旧数据则不进行通知,所以在do_use_fd函数中应该使用如下循环,才能将内核缓冲区中的数据读完。
  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模型关键处理代码如下:
  1. while(_run){
  2. update();
  3. }


  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. }
  11. updateTimerList();
  12. if(epret==0)
  13. {
  14. //debug::send(NETWORK,"EPOLLtimeouted.");
  15. //timeout
  16. }
  17. if(epret>0)
  18. {
  19. for(inti=0;i<epret;++i)
  20. {
  21. CSocket*socket=(CSocket*)(_epollEvents[i].data.ptr);
  22. if(_epollEvents[i].events&(EPOLLERR|EPOLLHUP))
  23. {
  24. debug::send(NETWORK,"EPOLLERRonfd%d.",socket->getHandle());
  25. socket->handleClose();
  26. socket->setReactor(NULL);
  27. socket->close();
  28. continue;
  29. }
  30. intret=0;
  31. if(_epollEvents[i].events&EPOLLIN)
  32. {
  33. debug::send(NETWORK,"EPOLLINonfd%d.",socket->getHandle());
  34. ret=socket->handleRead();
  35. }
  36. if(ret==-1)
  37. {
  38. socket->handleClose();
  39. socket->setReactor(NULL);
  40. socket->close();
  41. continue;
  42. }
  43. if(_epollEvents[i].events&EPOLLOUT)
  44. {
  45. debug::send(NETWORK,"EPOLLOUTonfd%d",socket->getHandle());
  46. ret=socket->handleWrite();
  47. }
  48. if(ret==-1)
  49. {
  50. socket->handleClose();
  51. socket->setReactor(NULL);
  52. socket->close();
  53. continue;
  54. }
  55. }
  56. }
  57. }
很多函数并不存在,但是从代码中我们就可以大致了解该类如何开发,扩展性会比较好!我将尽快完成该类,并在博客放出,希望大家喜欢。

猜你在找的React相关文章