redis7.2源码解析

[toc]

背景

学习redis7.2源码并分析redis的IO模型，基本的数据结构。

分析

epoll模型

// 以下只是一个demo
// 创建监听 socket
int listenfd = socket(AF_INET, SOCK_STREAM, 0);
bind(listenfd, ...);
listen(listenfd, 128);

// 创建 epoll 实例
// 一棵红黑树（存储所有被监控的 FD）。
// 一个就绪链表（存储已经发生事件的 FD）
// 一个等待队列（用于阻塞 epoll_wait 的进程）
int epfd = epoll_create(1024);
// 把监听 socket 加入 epoll
struct epoll_event event;
event.events = EPOLLIN | EPOLLET; // 边缘触发
event.data.fd = listenfd;

epoll_ctl(epfd, EPOLL_CTL_ADD, listenfd, &event);

//进入事件循环
while (1) {
    int n = epoll_wait(epfd, events, MAX_EVENTS, -1);
    for (i=0; i<n; i++) {

        if (events[i].data.fd == listenfd) {
            // 新连接建立后epoll_ctl将conn_fd添加到epoll中
            accept()
        } else {
            // 客户端数据
            read()
            // 处理
            write()
        }
    }
}

整体架构