【Redis源码分析】Server启动过程
toyiye 2024-09-16 06:12 8 浏览 0 评论
背景
- 我们通过源码来看看redis的server启动的时候会初始化哪些参数或者对象,以及都做了哪些工作?
说明
源码分析基于redis的6.2版本源码分析主要是在server.h和server.c本次主要是分析启动过程的流程,一些细节等后续分章节分析
流程图
源码解析
预备知识
redisServer
- server.h中定义了一个redisServer全局变量,存储 Redis 服务器信.包括服务器配置项和运行时数据:
- 网络连接信息
- 数据库
- redisDb
- 命令表
- 客户端信息
- 从服务器信息
- 统计信息等数据
代码启动入口
- Redis的Server实例启动是从server.c这个文件的main开始执行的
int main(int argc, char **argv) {
struct timeval tv;
int j;
char config_from_stdin = 0;
// 删除了代码中的#ifdef
// 设置时区
setlocale(LC_COLLATE,"");
tzset(); /* Populates 'timezone' global. */
//Redis中对内存的管理功能由 zmalloc 完成,表示在内存不足(out of memory,缩写oom)的时候所采取的操作
zmalloc_set_oom_handler(redisOutOfMemoryHandler);
//以getpid()为随机序列的种子,即将系统返回的进程ID作为随机序列的种子
srand(time(NULL)^getpid());
srandom(time(NULL)^getpid());
gettimeofday(&tv,NULL);
init_genrand64(((long long) tv.tv_sec * 1000000 + tv.tv_usec) ^ getpid());
crc64_init();
umask(server.umask = umask(0777));
// 设置随机种子
uint8_t hashseed[16];
getRandomBytes(hashseed,sizeof(hashseed));
dictSetHashFunctionSeed(hashseed);
// 检查是否是哨兵模式
server.sentinel_mode = checkForSentinelMode(argc,argv);
// 初始服务端的默认配置
initServerConfig();
//ACL子系统必须尽快初始化,因为基本的网络代码和客户端创建都依赖于它
ACLInit();
// 初始化模块系统
moduleInitModulesSystem();
tlsInit();
// 将可执行路径和参数存储在一个安全的地方,以便以后能够重新启动服务器
server.executable = getAbsolutePath(argv[0]);
//保存执行的参数分配内存
server.exec_argv = zmalloc(sizeof(char*)*(argc+1));
server.exec_argv[argc] = NULL;
// 保存执行的参数
for (j = 0; j < argc; j++) server.exec_argv[j] = zstrdup(argv[j]);
// 如果是哨兵模式,就初始化哨兵的配置以及哨兵模式的参数
if (server.sentinel_mode) {
initSentinelConfig();
initSentinel();
}
/*
* 检查是否要执行 RDB 检测或 AOF 检查,这对应了实际运行的程序是 redis-check-rdb 或 redis-check-aof
* */
// 如果运行的是redis-check-rdb程序 调用redis_check_rdb_main
if (strstr(argv[0],"redis-check-rdb") != NULL)
redis_check_rdb_main(argc,argv,NULL);
// 如果运行的是redis-check-aof程序 调用redis_check_aof_main
else if (strstr(argv[0],"redis-check-aof") != NULL)
redis_check_aof_main(argc,argv);
if (argc >= 2) {
/* 解析命令行的选项 */
// 解析命令行参数 解析配置文件
loadServerConfig(server.configfile, config_from_stdin, options);
if (server.sentinel_mode) loadSentinelConfigFromQueue();
//释放一个sds字符串
sdsfree(options);
}
// 哨兵模式,检查配置文件
if (server.sentinel_mode) sentinelCheckConfigFile();
// 守护进程后台运行
server.supervised = redisIsSupervised(server.supervised_mode);
int background = server.daemonize && !server.supervised;
if (background) daemonize();
// 初始化服务端
initServer();
serverLog(LL_WARNING,"初始化");
if (background || server.pidfile) createPidFile();
if (server.set_proc_title) redisSetProcTitle(NULL);
redisAsciiArt();
checkTcpBacklogSettings();
// 如果不是哨兵模式
if (!server.sentinel_mode) {
moduleInitModulesSystemLast();
moduleLoadFromQueue();
ACLLoadUsersAtStartup();
InitServerLast();
// 从磁盘上load AOF 或者是 RDB 文件,以便恢复之前的数据。
loadDataFromDisk();
}
/* 警告可疑的max-memory设置. */
if (server.maxmemory > 0 && server.maxmemory < 1024*1024) {
serverLog(LL_WARNING,"WARNING: You specified a maxmemory value that is less than 1MB (current value is %llu bytes). Are you sure this is what you really want?", server.maxmemory);
}
redisSetCpuAffinity(server.server_cpulist);
setOOMScoreAdj(-1);
// 进入事件驱动框架,开始循环处理各种事件
aeMain(server.el);
aeDeleteEventLoop(server.el);
return 0;
}
关键的代码
- 初始服务端的默认配置 initServerConfig();
- 初始化服务端 initServer();
- 进入事件驱动框架,开始循环处理各种触发的事件 aeMain(server.el);
重点分析initServer函数
void initServer(void) {
int j;
//开启了 Unix 系统日志,则调用 openlog()与 Unix 系统日志建立输出连接,以便输出系统日志
if (server.syslog_enabled) {
openlog(server.syslog_ident, LOG_PID | LOG_NDELAY | LOG_NOWAIT,
server.syslog_facility);
}
// 创建共享对象集合,这些数据可在各场景中共享使用,
// 如小数字 0~9999、常用字符串+OK\r\n(命令处理成功响应字符串)、+PONG\r\n(ping 命令响应字符串)
createSharedObjects();
// 尝试修改环境变量,提高系统允许打开的文件描述符上限,避免由于大量客户端连接(Socket 文件描述符)导致错误。
adjustOpenFilesLimit();
const char *clk_msg = monotonicInit();
serverLog(LL_NOTICE, "monotonic clock: %s", clk_msg);
// 创建事件驱动框架
server.el = aeCreateEventLoop(server.maxclients+CONFIG_FDSET_INCR);
if (server.el == NULL) {
serverLog(LL_WARNING,
"Failed creating the event loop. Error message: '%s'",
strerror(errno));
exit(1);
}
// 分配db内存
server.db = zmalloc(sizeof(redisDb)*server.dbnum);
/* 监听端口 */
if (server.port != 0 &&
listenToPort(server.port,&server.ipfd) == C_ERR) {
serverLog(LL_WARNING, "Failed listening on port %u (TCP), aborting.", server.port);
exit(1);
}
/* 配置了 server.tls_ port,则开启 TLS Socket 服务,Redis 6.0 开始支持 TLS 连接. */
if (server.tls_port != 0 &&
listenToPort(server.tls_port,&server.tlsfd) == C_ERR) {
serverLog(LL_WARNING, "Failed listening on port %u (TLS), aborting.", server.tls_port);
exit(1);
}
/* 配置了 server.unixsocket,则开启 UNIX Socket 服务. */
if (server.unixsocket != NULL) {
unlink(server.unixsocket); /* don't care if this fails */
server.sofd = anetUnixServer(server.neterr,server.unixsocket,
server.unixsocketperm, server.tcp_backlog);
if (server.sofd == ANET_ERR) {
serverLog(LL_WARNING, "Opening Unix socket: %s", server.neterr);
exit(1);
}
anetNonBlock(NULL,server.sofd);
anetCloexec(server.sofd);
}
/* 如果根本没有监听套接字,则中止. */
if (server.ipfd.count == 0 && server.tlsfd.count == 0 && server.sofd < 0) {
serverLog(LL_WARNING, "Configured to not listen anywhere, exiting.");
exit(1);
}
/* 创建Redis数据库,初始化其他内部状态。 */
for (j = 0; j < server.dbnum; j++) {
// 创建全局哈希表
server.db[j].dict = dictCreate(&dbDictType,NULL);
//创建过期key的信息表
server.db[j].expires = dictCreate(&dbExpiresDictType,NULL);
//为被BLPOP阻塞的key创建信息表
server.db[j].expires_cursor = 0;
//为被BLPOP阻塞的key创建信息表
server.db[j].blocking_keys = dictCreate(&keylistDictType,NULL);
//为将执行PUSH的阻塞key创建信息表
server.db[j].ready_keys = dictCreate(&objectKeyPointerValueDictType,NULL);
//为被MULTI/WATCH操作监听的key创建信息表
server.db[j].watched_keys = dictCreate(&keylistDictType,NULL);
server.db[j].id = j;
server.db[j].avg_ttl = 0;
server.db[j].defrag_later = listCreate();
listSetFreeMethod(server.db[j].defrag_later,(void (*)(void*))sdsfree);
}
//初始化LRU 池
evictionPoolAlloc(); /* Initialize the LRU keys pool. */
/* 创建一个时间事件,执行函数为 serverCron,
* 这是我们增量处理许多后台操作的方法,比如客户端超时,清除未访问的过期键等等. */
if (aeCreateTimeEvent(server.el, 1, serverCron, NULL, NULL) == AE_ERR) {
serverPanic("Can't create event loop timers.");
exit(1);
}
/* 创建一个事件处理程序,用于接受TCP和Unix域套接字中的新连接. */
if (createSocketAcceptHandler(&server.ipfd, acceptTcpHandler) != C_OK) {
serverPanic("Unrecoverable error creating TCP socket accept handler.");
}
if (createSocketAcceptHandler(&server.tlsfd, acceptTLSHandler) != C_OK) {
serverPanic("Unrecoverable error creating TLS socket accept handler.");
}
//创建文件事件,并注册相应的事件处理函数
if (server.sofd > 0 && aeCreateFileEvent(server.el,server.sofd,AE_READABLE,
acceptUnixHandler,NULL) == AE_ERR) serverPanic("Unrecoverable error creating server.sofd file event.");
/* 注册一个可读事件,用于在模块中阻塞的客户端需要注意时唤醒事件循环。*/
if (aeCreateFileEvent(server.el, server.module_blocked_pipe[0], AE_READABLE,
moduleBlockedClientPipeReadable,NULL) == AE_ERR) {
serverPanic(
"Error registering the readable event for the module "
"blocked clients subsystem.");
}
/* 注册事件驱动框架的钩子函数,事件循环器在每次阻塞前后都会调用钩子函数*/
aeSetBeforeSleepProc(server.el,beforeSleep);
aeSetAfterSleepProc(server.el,afterSleep);
/* 如果需要,打开AOF文件. */
if (server.aof_state == AOF_ON) {
server.aof_fd = open(server.aof_filename,
O_WRONLY|O_APPEND|O_CREAT,0644);
if (server.aof_fd == -1) {
exit(1);
}
}
/* 如果 Redis 运行在 32 位操作系统上,由于 32 位操作系统内存空间限制为 4GB,所以将 Redis 使用内存限制为 3GB,避免 Redis 服务器因内存不足而崩溃。. */
if (server.arch_bits == 32 && server.maxmemory == 0) {
serverLog(LL_WARNING,"Warning: 32 bit instance detected but no memory limit set. Setting 3 GB maxmemory limit with 'noeviction' policy now.");
server.maxmemory = 3072LL*(1024*1024); /* 3 GB */
server.maxmemory_policy = MAXMEMORY_NO_EVICTION;
}
// 如果是Cluster 模式启动则初始化集群相关的
if (server.cluster_enabled) clusterInit();
replicationScriptCacheInit();
// 初始化LUA机制
scriptingInit(1);
// 初始化慢日志机制
slowlogInit();
//初始化延迟监控机制
latencyMonitorInit();
ACLUpdateDefaultUserPassword(server.requirepass);
}
总结
- RedisServer的整体启动流程:初始化默认配置解析启动命令初始化server启动事件驱动框架循环处理各种事件
- RedisServer结构体存储服务端配置项、运行时数据
参考文献
- 极客时间-Redis源码剖析与实战
- Redis启动过程源码分析
相关推荐
- 为何越来越多的编程语言使用JSON(为什么编程)
-
JSON是JavascriptObjectNotation的缩写,意思是Javascript对象表示法,是一种易于人类阅读和对编程友好的文本数据传递方法,是JavaScript语言规范定义的一个子...
- 何时在数据库中使用 JSON(数据库用json格式存储)
-
在本文中,您将了解何时应考虑将JSON数据类型添加到表中以及何时应避免使用它们。每天?分享?最新?软件?开发?,Devops,敏捷?,测试?以及?项目?管理?最新?,最热门?的?文章?,每天?花?...
- MySQL 从零开始:05 数据类型(mysql数据类型有哪些,并举例)
-
前面的讲解中已经接触到了表的创建,表的创建是对字段的声明,比如:上述语句声明了字段的名称、类型、所占空间、默认值和是否可以为空等信息。其中的int、varchar、char和decimal都...
- JSON对象花样进阶(json格式对象)
-
一、引言在现代Web开发中,JSON(JavaScriptObjectNotation)已经成为数据交换的标准格式。无论是从前端向后端发送数据,还是从后端接收数据,JSON都是不可或缺的一部分。...
- 深入理解 JSON 和 Form-data(json和formdata提交区别)
-
在讨论现代网络开发与API设计的语境下,理解客户端和服务器间如何有效且可靠地交换数据变得尤为关键。这里,特别值得关注的是两种主流数据格式:...
- JSON 语法(json 语法 priority)
-
JSON语法是JavaScript语法的子集。JSON语法规则JSON语法是JavaScript对象表示法语法的子集。数据在名称/值对中数据由逗号分隔花括号保存对象方括号保存数组JS...
- JSON语法详解(json的语法规则)
-
JSON语法规则JSON语法是JavaScript对象表示法语法的子集。数据在名称/值对中数据由逗号分隔大括号保存对象中括号保存数组注意:json的key是字符串,且必须是双引号,不能是单引号...
- MySQL JSON数据类型操作(mysql的json)
-
概述mysql自5.7.8版本开始,就支持了json结构的数据存储和查询,这表明了mysql也在不断的学习和增加nosql数据库的有点。但mysql毕竟是关系型数据库,在处理json这种非结构化的数据...
- JSON的数据模式(json数据格式示例)
-
像XML模式一样,JSON数据格式也有Schema,这是一个基于JSON格式的规范。JSON模式也以JSON格式编写。它用于验证JSON数据。JSON模式示例以下代码显示了基本的JSON模式。{"...
- 前端学习——JSON格式详解(后端json格式)
-
JSON(JavaScriptObjectNotation)是一种轻量级的数据交换格式。易于人阅读和编写。同时也易于机器解析和生成。它基于JavaScriptProgrammingLa...
- 什么是 JSON:详解 JSON 及其优势(什么叫json)
-
现在程序员还有谁不知道JSON吗?无论对于前端还是后端,JSON都是一种常见的数据格式。那么JSON到底是什么呢?JSON的定义...
- PostgreSQL JSON 类型:处理结构化数据
-
PostgreSQL提供JSON类型,以存储结构化数据。JSON是一种开放的数据格式,可用于存储各种类型的值。什么是JSON类型?JSON类型表示JSON(JavaScriptO...
- JavaScript:JSON、三种包装类(javascript 包)
-
JOSN:我们希望可以将一个对象在不同的语言中进行传递,以达到通信的目的,最佳方式就是将一个对象转换为字符串的形式JSON(JavaScriptObjectNotation)-JS的对象表示法...
- Python数据分析 只要1分钟 教你玩转JSON 全程干货
-
Json简介:Json,全名JavaScriptObjectNotation,JSON(JavaScriptObjectNotation(记号、标记))是一种轻量级的数据交换格式。它基于J...
- 比较一下JSON与XML两种数据格式?(json和xml哪个好)
-
JSON(JavaScriptObjectNotation)和XML(eXtensibleMarkupLanguage)是在日常开发中比较常用的两种数据格式,它们主要的作用就是用来进行数据的传...
你 发表评论:
欢迎- 一周热门
- 最近发表
- 标签列表
-
- r语言矩阵 (127)
- browsererror (114)
- exportexcel (119)
- cv2.bitwise_not (137)
- dump命令 (128)
- es6concat (126)
- heapify (127)
- java.security.egd (130)
- javax.annotation (117)
- jsstringsplit (117)
- js数字 (115)
- maven编译 (132)
- mysqlleft (128)
- nodejsbuffer (149)
- org.apache.commons.httpclient (126)
- org.jsoup (141)
- org.springframework.web (128)
- robotframework-ride (115)
- setnocounton (141)
- socket.gethostbyname (122)
- sqlmid (121)
- time.strptime (133)
- vscode格式化 (125)
- win32con (129)
- window.localstorage (126)