Redis源码设计剖析之事件处理示例详解_Redis_

typedef struct aeFileEvent { // 文件时间类型：AE_NONE，AE_READABLE，AE_WRITABLE int mask; // 可读处理函数 aeFileProc *rfileProc; // 可写处理函数 aeFileProc *wfileProc; // 客户端传入的数据 void *clientData; } aeFileEvent; //文件事件 

typedef void aeFileProc(struct aeEventLoop *eventLoop, int fd, void *clientData, int mask); 

typedef struct aeFiredEvent { // 就绪事件的文件描述符 int fd; // 就绪事件类型：AE_NONE，AE_READABLE，AE_WRITABLE int mask; } aeFiredEvent; //就绪事件 

#define AE_NONE 0 //未设置 #define AE_READABLE 1 //事件可读 #define AE_WRITABLE 2 //事件可写 

typedef struct aeTimeEvent { // 时间事件的id long long id; // 时间事件到达的时间的秒数 long when_sec; /* seconds */ // 时间事件到达的时间的毫秒数 long when_ms; /* milliseconds */ // 时间事件处理函数 aeTimeProc *timeProc; // 时间事件终结函数 aeEventFinalizerProc *finalizerProc; // 客户端传入的数据 void *clientData; // 指向下一个时间事件 struct aeTimeEvent *next; } aeTimeEvent; //时间事件 

typedef int aeTimeProc(struct aeEventLoop *eventLoop, long long id, void *clientData); typedef void aeEventFinalizerProc(struct aeEventLoop *eventLoop, void *clientData); 

typedef struct aeEventLoop { // 当前已注册的最大的文件描述符 int maxfd; /* highest file descriptor currently registered */ // 文件描述符监听集合的大小 int setsize; /* max number of file descriptors tracked */ // 下一个时间事件的ID long long timeEventNextId; // 最后一次执行事件的时间 time_t lastTime; /* Used to detect system clock skew */ // 注册的文件事件表 aeFileEvent *events; /* Registered events */ // 已就绪的文件事件表 aeFiredEvent *fired; /* Fired events */ // 时间事件的头节点指针 aeTimeEvent *timeEventHead; // 事件处理开关 int stop; // 多路复用库的事件状态数据 void *apidata; /* This is used for polling API specific data */ // 执行处理事件之前的函数 aeBeforeSleepProc *beforesleep; } aeEventLoop; //事件轮询的状态结构 

// IO复用的选择，性能依次下降，Linux支持 "ae_epoll.c" 和 "ae_select.c" #ifdef HAVE_EVPORT #include "ae_evport.c" #else #ifdef HAVE_EPOLL #include "ae_epoll.c" #else #ifdef HAVE_KQUEUE #include "ae_kqueue.c" #else #include "ae_select.c" #endif #endif #endif 

typedef struct aeApiState { // epoll事件的文件描述符 int epfd; // 事件表 struct epoll_event *events; } aeApiState; // 事件的状态 

// 创建一个epoll实例，保存到eventLoop中 static int aeApiCreate(aeEventLoop *eventLoop) // 调整事件表的大小 static int aeApiResize(aeEventLoop *eventLoop, int setsize) // 释放epoll实例和事件表空间 static void aeApiFree(aeEventLoop *eventLoop) // 在epfd标识的事件表上注册fd的事件 static int aeApiAddEvent(aeEventLoop *eventLoop, int fd, int mask) // 在epfd标识的事件表上注删除fd的事件 static void aeApiDelEvent(aeEventLoop *eventLoop, int fd, int delmask) // 等待所监听文件描述符上有事件发生 static int aeApiPoll(aeEventLoop *eventLoop, struct timeval *tvp) // 返回正在使用的IO多路复用库的名字 static char *aeApiName(void) 

// 在epfd标识的事件表上注册fd的事件 static int aeApiAddEvent(aeEventLoop *eventLoop, int fd, int mask) { aeApiState *state = eventLoop->apidata; struct epoll_event ee = {0}; // EPOLL_CTL_ADD，向epfd注册fd的上的event // EPOLL_CTL_MOD，修改fd已注册的event // #define AE_NONE 0 //未设置 // #define AE_READABLE 1 //事件可读 // #define AE_WRITABLE 2 //事件可写 // 判断fd事件的操作，如果没有设置事件，则进行关联mask类型事件，否则进行修改 int op = eventLoop->events[fd].mask == AE_NONE ? EPOLL_CTL_ADD : EPOLL_CTL_MOD; // struct epoll_event { // uint32_t events; /* Epoll events */ // epoll_data_t data; /* User data variable */ // }; ee.events = 0; // 如果是修改事件，合并之前的事件类型 mask |= eventLoop->events[fd].mask; /* Merge old events */ // 根据mask映射epoll的事件类型 if (mask & AE_READABLE) ee.events |= EPOLLIN; //读事件 if (mask & AE_WRITABLE) ee.events |= EPOLLOUT; //写事件 ee.data.fd = fd; //设置事件所从属的目标文件描述符 // 将ee事件注册到epoll中 if (epoll_ctl(state->epfd,op,fd,&ee) == -1) return -1; return 0; } 

// 等待所监听文件描述符上有事件发生 static int aeApiPoll(aeEventLoop *eventLoop, struct timeval *tvp) { aeApiState *state = eventLoop->apidata; int retval, numevents = 0; // 监听事件表上是否有事件发生 retval = epoll_wait(state->epfd,state->events,eventLoop->setsize, tvp ? (tvp->tv_sec*1000 + tvp->tv_usec/1000) : -1); // 至少有一个就绪的事件 if (retval > 0) { int j; numevents = retval; // 遍历就绪的事件表，将其加入到eventLoop的就绪事件表中 for (j = 0; j < numevents; j++) { int mask = 0; struct epoll_event *e = state->events+j; // 根据就绪的事件类型，设置mask if (e->events & EPOLLIN) mask |= AE_READABLE; if (e->events & EPOLLOUT) mask |= AE_WRITABLE; if (e->events & EPOLLERR) mask |= AE_WRITABLE; if (e->events & EPOLLHUP) mask |= AE_WRITABLE; // 添加到就绪事件表中 eventLoop->fired[j].fd = e->data.fd; eventLoop->fired[j].mask = mask; } } // 返回就绪的事件个数 return numevents; } 

// 事件轮询的主函数 void aeMain(aeEventLoop *eventLoop) { eventLoop->stop = 0; // 一直处理事件 while (!eventLoop->stop) { // 执行处理事件之前的函数 if (eventLoop->beforesleep != NULL) eventLoop->beforesleep(eventLoop); //处理到时的时间事件和就绪的文件事件 aeProcessEvents(eventLoop, AE_ALL_EVENTS); } } 

#define AE_FILE_EVENTS 1 //文件事件 #define AE_TIME_EVENTS 2 //时间事件 #define AE_ALL_EVENTS (AE_FILE_EVENTS|AE_TIME_EVENTS) //文件和时间事件 #define AE_DONT_WAIT 4 

// 处理到时的时间事件和就绪的文件事件 // 如果flags = 0，函数什么都不做，直接返回 // 如果flags设置了 AE_ALL_EVENTS ，则执行所有类型的事件 // 如果flags设置了 AE_FILE_EVENTS ，则执行文件事件 // 如果flags设置了 AE_TIME_EVENTS ，则执行时间事件 // 如果flags设置了 AE_DONT_WAIT ，那么函数处理完事件后直接返回，不阻塞等待 // 函数返回执行的事件个数 int aeProcessEvents(aeEventLoop *eventLoop, int flags) { int processed = 0, numevents; // 如果什么事件都没有设置则直接返回 if (!(flags & AE_TIME_EVENTS) && !(flags & AE_FILE_EVENTS)) return 0; // 请注意，既然我们要处理时间事件，即使没有要处理的文件事件，我们仍要调用select（），以便在下一次事件准备启动之前进行休眠 // 当前还没有要处理的文件事件，或者设置了时间事件但是没有设置不阻塞标识 if (eventLoop->maxfd != -1 || ((flags & AE_TIME_EVENTS) && !(flags & AE_DONT_WAIT))) { int j; aeTimeEvent *shortest = NULL; struct timeval tv, *tvp; // 如果设置了时间事件而没有设置不阻塞标识 if (flags & AE_TIME_EVENTS && !(flags & AE_DONT_WAIT)) // 获取最近到时的时间事件 shortest = aeSearchNearestTimer(eventLoop); // 获取到了最早到时的时间事件 if (shortest) { long now_sec, now_ms; // 获取当前时间 aeGetTime(&now_sec, &now_ms); tvp = &tv; // 等待该
                
提示：
                    本文由神整理自网络，如有侵权请联系本站删除！
                    

                    本站声明： 

                    1、本站所有资源均来源于互联网，不保证100%完整、不提供任何技术支持； 

                    2、本站所发布的文章以及附件仅限用于学习和研究目的;不得将用于商业或者非法用途；否则由此产生的法律后果，本站概不负责！
                
                

                

                                            
上一篇：Redis源码与设计剖析之网络连接库_Redis_
                                                                
下一篇：Spring Boot 整合Redis 实现优惠卷秒杀 一人一单功能_Redis_