推荐一个 零声学院 免费公开课程，个人觉得老师讲得不错，分享给大家：[Linux，Nginx，ZeroMQ，MySQL，Redis，fastdfs，MongoDB，ZK，流媒体，CDN，P2P，K8S，Docker，TCP/IP，协程，DPDK等技术内容，立即学习]
后台服务器：https://course.0voice.com/v1/course/intro?courseId=5&agentId=0

即时通信：先判断listenfd有数据可读就读出来，通过协议判断出目标，再转发给目标。
reactor反应堆模型：一个事件对应一个回调函数。readable–readcb。

epoll_wait在返回一瞬间既可读又可写有没有可能？
回答是有的！一次处理一个事件就是写一个回调函数。

struct item{int fd;int events;#if 1int (*callback)(int fd,int event,void *arg);#elseint (*readcb)(int fd,int event,void *arg);int (*writecb)(int fd,int event,void *arg);#endifint sbuffer[1024];int slength;int rbuffer[1024];int rlength;};int read_callback(int fd,int event,void *arg){epoll_ctl(epfd,EPOLL_CTL_MOD,event,ev);}struct itemblock{struct itemblock *next;struct nitem *items;};struct reactor{int epfd;struct nitemnlock *head;struct nitemnlock **last;};

引入单例模式

struct reator *instance=NULL;struct reactor *getinstance(void *){if(instance==NULL){instance=malloc(sizeof(struct reactor));if(instance == NULL ) return NULL;memset(instance,0,sizeof(struct reactor));if(0>init_reactor(instance)){return NULL;}}return instance;}

对于一个新的连接而言，会先处理acceptcb，再去处理其他的。

总结

引入reactor，将对io的管理改为对事件的管理，我们对事件的管理。