[原]Redis源代码分析之六：Redis执行流程

winston

现在我们分析Redis从启动开始的执行流程，从而顺藤摸瓜地理解其事件驱动模型。
首先找到main入口：

1. int main(int argc, char **argv) {
2.     time_t start;
4.     initServerConfig();
5.     if (argc == 2) {
6.         if (strcmp(argv[1], "-v") == 0 ||
7.             strcmp(argv[1], "--version") == 0) version();
8.         if (strcmp(argv[1], "--help") == 0) usage();
9.         resetServerSaveParams();
10.         loadServerConfig(argv[1]);
11.     } else if ((argc > 2)) {
12.         usage();
13.     } else {
14.         redisLog(REDIS_WARNING,"Warning: no config file specified, using the default config. In order to specify a config file use 'redis-server /path/to/redis.conf'");
15.     }
16.     if (server.daemonize) daemonize();
17.     initServer();
18.     if (server.daemonize) createPidFile();
19.     redisLog(REDIS_NOTICE,"Server started, Redis version " REDIS_VERSION);
20. #ifdef __linux__
21.     linuxOvercommitMemoryWarning();
22. #endif
23.     start = time(NULL);
24.     if (server.appendonly) {
25.         if (loadAppendOnlyFile(server.appendfilename) == REDIS_OK)
26.             redisLog(REDIS_NOTICE,"DB loaded from append only file: %ld seconds",time(NULL)-start);
27.     } else {
28.         if (rdbLoad(server.dbfilename) == REDIS_OK) {
29.             redisLog(REDIS_NOTICE,"DB loaded from disk: %ld seconds",
30.                 time(NULL)-start);
31.         } else if (errno != ENOENT) {
32.             redisLog(REDIS_WARNING,"Fatal error loading the DB. Exiting.");
33.             exit(1);
34.         }
35.     }
36.     if (server.ipfd > 0)
37.         redisLog(REDIS_NOTICE,"The server is now ready to accept connections on port %d", server.port);
38.     if (server.sofd > 0)
39.         redisLog(REDIS_NOTICE,"The server is now ready to accept connections at %s", server.unixsocket);
40.     aeSetBeforeSleepProc(server.el,beforeSleep);
41.     aeMain(server.el);
42.     aeDeleteEventLoop(server.el);
43.     return 0;
44. }

复制代码

我们看到，在initServer()中完成了初始化工作：

1. void initServer() {
2.     int j;
4.     signal(SIGHUP, SIG_IGN);
5.     signal(SIGPIPE, SIG_IGN);
6.     setupSignalHandlers();
8.     if (server.syslog_enabled) {
9.         openlog(server.syslog_ident, LOG_PID | LOG_NDELAY | LOG_NOWAIT,
10.             server.syslog_facility);
11.     }
13.     server.mainthread = pthread_self();
14.     server.clients = listCreate();
15.     server.slaves = listCreate();
16.     server.monitors = listCreate();
17.     server.unblocked_clients = listCreate();
18.     createSharedObjects();
19.     server.el = aeCreateEventLoop();
20.     server.db = zmalloc(sizeof(redisDb)*server.dbnum);
22.     if (server.port != 0) {
23.         server.ipfd = anetTcpServer(server.neterr,server.port,server.bindaddr);
24. …… …… ……
25.     aeCreateTimeEvent(server.el, 1, serverCron, NULL, NULL);
26.     if (server.ipfd > 0 && aeCreateFileEvent(server.el,server.ipfd,AE_READABLE,
27.         acceptTcpHandler,NULL) == AE_ERR) oom("creating file event");
28.     if (server.sofd > 0 && aeCreateFileEvent(server.el,server.sofd,AE_READABLE,
29.         acceptUnixHandler,NULL) == AE_ERR) oom("creating file event");
31.     if (server.appendonly) {
32.         server.appendfd = open(server.appendfilename,O_WRONLY|O_APPEND|O_CREAT,0644);
33.         if (server.appendfd == -1) {
34.             redisLog(REDIS_WARNING, "Can't open the append-only file: %s",
35.                 strerror(errno));
36.             exit(1);
37.         }
38.     }
40.     if (server.vm_enabled) vmInit();
41.     slowlogInit();
42.     bioInit();
43.     srand(time(NULL)^getpid());
44. }

复制代码

其中在redisServer结构体中定义了：

aeEventLoop *el;于是我们分析事件驱动模型，就可以从aeEventLoop入手，继续追随aeCreateTimeEvent函数和aeCreateFileEvent创建的事件是如何在事件驱动库下工作的。具体见下节。

作者：Aegeaner 发表于2012-2-27 14:09:40 原文链接