void *zmalloc(size_t size) {

    // 多申请的一部分内存用于存储当前分配了多少自己的内存

    void *ptr = malloc(size+PREFIX_SIZE);

    if (!ptr) zmalloc_oom_handler(size);

#ifdef HAVE_MALLOC_SIZE

    update_zmalloc_stat_alloc(zmalloc_size(ptr));

    return ptr;

#else

    *((size_t*)ptr) = size;

    // 内存分配统计

    update_zmalloc_stat_alloc(size+PREFIX_SIZE);

    return (char*)ptr+PREFIX_SIZE;

#endif

}

Redis的事件类型分为时间事件和文件事件，文件事件也就是网络连接事件。时间事件的处理是在epoll_wait返回处理文件事件后处理的，每次epoll_wait的超时时间都是Redis最近的一个定时器时间。

 

Redis在进行事件处理前，首先会进行初始化，初始化的主要逻辑在main/initServer函数中。初始化流程主要做的工作如下：

void initServer(void) {

    int j;

    // 设置信号对应的处理函数

    signal(SIGHUP, SIG_IGN);

    signal(SIGPIPE, SIG_IGN);

    setupSignalHandlers();

    ...

    createSharedObjects();

    adjustOpenFilesLimit();

    // 创建事件循环机制，及调用epoll_create创建epollfd用于事件监听

    server.el = aeCreateEventLoop(server.maxclients+CONFIG_FDSET_INCR);

    server.db = zmalloc(sizeof(redisDb)*server.dbnum);

    /* Open the TCP listening socket for the user commands. */

    // 创建监听服务端口，socket/bind/listen

    if (server.port !=  &&

        listenToPort(server.port,server.ipfd,&server.ipfd_count) == C_ERR)

        exit();

    ...

    /* Create the Redis databases, and initialize other internal state. */

    for (j = ; j < server.dbnum; j++) {

        server.db[j].dict = dictCreate(&dbDictType,NULL);

        server.db[j].expires = dictCreate(&keyptrDictType,NULL);

        server.db[j].blocking_keys = dictCreate(&keylistDictType,NULL);

        server.db[j].ready_keys = dictCreate(&setDictType,NULL);

        server.db[j].watched_keys = dictCreate(&keylistDictType,NULL);

        server.db[j].eviction_pool = evictionPoolAlloc();

        server.db[j].id = j;

        server.db[j].avg_ttl = ;

    }

    ...

    /* Create the serverCron() time event, that's our main way to process

     * background operations. 创建定时事件 */

    if(aeCreateTimeEvent(server.el, , serverCron, NULL, NULL) == AE_ERR) {

        serverPanic("Can't create the serverCron time event.");

        exit();

    }

    /* Create an event handler for accepting new connections in TCP and Unix

     * domain sockets. */

    for (j = ; j < server.ipfd_count; j++) {

        if (aeCreateFileEvent(server.el, server.ipfd[j], AE_READABLE,

            acceptTcpHandler,NULL) == AE_ERR)

            {

                serverPanic(

                    "Unrecoverable error creating server.ipfd file event.");

            }

    }

    // 将事件加入到事件机制中，调用链为 aeCreateFileEvent/aeApiAddEvent/epoll_ctl

    if (server.sofd >  && aeCreateFileEvent(server.el,server.sofd,AE_READABLE,

        acceptUnixHandler,NULL) == AE_ERR) serverPanic("Unrecoverable error creating server.sofd file event.");

    /* Open the AOF file if needed. */

    if (server.aof_state == AOF_ON) {

        server.aof_fd = open(server.aof_filename,

                               O_WRONLY|O_APPEND|O_CREAT,);

        if (server.aof_fd == -) {

            serverLog(LL_WARNING, "Can't open the append-only file: %s",

                strerror(errno));

            exit();

        }

    }

    ...

}

事件处理函数链：aeMain / aeProcessEvents / aeApiPoll / epoll_wait。

 

常见的事件机制处理流程是：调用epoll_wait等待事件来临，然后遍历每一个epoll_event，提取epoll_event中的events和data域，data域常用来存储fd或者指针，不过一般的做法是提取出events和data.fd，然后根据fd找到对应的回调函数，fd与对应回调函数之间的映射关系可以存储在特定的数据结构中，比如数组或者哈希表，然后调用事件回调函数来处理。

 

Redis中用了一个数组来保存fd与回调函数的映射关系，使用数组的优点就是简单高效，但是数组一般使用在建立的连接不太多情况，而Redis正好符合这个情况，一般Redis的文件事件大都是客户端建立的连接，而客户端的连接个数是一定的，该数量通过配置项maxclients来指定。

Redis监听端口的事件回调函数链是：acceptTcpHandler / acceptCommonHandler / createClient / aeCreateFileEvent / aeApiAddEvent / epoll_ctl。 

在Reids监听事件处理流程中，会将客户端的连接fd添加到事件机制中，并设置其回调函数为readQueryFromClient，该函数负责处理客户端的命令请求。

 

命令处理流程链是：readQueryFromClient / processInputBuffer / processCommand / call / 对应命令的回调函数(c->cmd->proc)，比如get key命令的处理回调函数为getCommand。getCommand的执行流程是先到client对应的数据库字典中根据key来查找数据，然后根据响应消息格式将查询结果填充到响应消息中。

 

3 如何添加自定义命令