05-redis服务器

命令请求的执行过程

  • 客户端发送命令请求

  • 服务器读取命令请求

  • 命令执行器:查找命令实现

  • 命令执行器:执行预备操作

  • 命令执行器:调用命令的实现函数

  • 命令执行器:执行后续工作

  • 将命令回复发送给客户端

  • 客户端接收并打印回复

serverCron函数

更新服务器时间缓存

struct redisServer (
    ...;
    time_t unixtime;    // 保存了秒级精度的系统当前UNIX事件戳,serverCron函数每100毫秒更新一次
    long long mstime;   // 保存了毫秒级精度的系统当前UNIX事件戳,serverCron函数每100毫秒更新一次
    ...;
);

更新LRU时钟

struct redisServer (
    ...;
    unsigned lruclock:22;   // 默认每10秒更新一次时钟缓存,用于计算键的空转时长
    ...;
);

更新服务器每秒执行命令次数

struct redisServer (
    ...;
    long long ops_sec_last_sample_time; // 上一次进行抽样的时间
    long long ops_sec_last_sample_ops;  // 上一次抽样时,服务器已执行命令的数量
    
    // 数组默认是16的环形数组,数组中每一项记录了一次抽样结果
    long long ops_sec_samples[REDIS_OPS_SEC_SAMPLES];   
    
    // ops_sec_samples数组的索引,每次抽样后自增1,在值等于16时重置为0,让其构成一个环形数组
    int ops_sec_index;  
    ...;
);

更新服务器内存峰值记录

struct redisServer (
    ...;
    size_t stat_peak_memory;    // 已使用内存峰值,记录服务器的内存峰值大小
    ...;
);

处理SIGTERM信号

struct redisServer (
    ...;
    int shutdown_asap;  // 关闭服务器的标识,为1时关闭服务器,为0时不做动作
    ...;
);

管理客户端资源

管理数据库资源

执行被延迟的BGREWRITEAOF

struct redisServer (
    ...;
    int aof_rewrite_scheduled;  // 如果值为1,那么表示有BGREWRITEAOF命令被延迟了
    ...;
);

检查持久化操作的运行状态

struct redisServer (
    ...;
    pid_t rdb_child_pid;    // 记录执行BGSAVE命令的子进程ID, 如果没有执行该值为-1
    pid_t aof_child_pid;    // 记录执行BGREWRITEAOF命令的子进程ID, 如果没有执行该值为-1
    ...;
);

将AOF缓冲区中的内容写入AOF文件

关闭异步客户端

增加cronloops计数器的值

struct redisServer (
    ...;
    // 函数运行次数,每运行一次serverCron,该属性的值加1
    // 作用是复制时实现每次执行serverCron函数N次就执行一次指定代码
    int cronloops;  
    ...;
);

总结下来的结构如下:

struct redisServer (
    ...;
    time_t unixtime;    // 保存了秒级精度的系统当前UNIX事件戳,serverCron函数每100毫秒更新一次
    long long mstime;   // 保存了毫秒级精度的系统当前UNIX事件戳,serverCron函数每100毫秒更新一次
    
    unsigned lruclock:22;   // 默认每10秒更新一次时钟缓存,用于计算键的空转时长
    
    long long ops_sec_last_sample_time; // 上一次进行抽样的时间
    long long ops_sec_last_sample_ops;  // 上一次抽样时,服务器已执行命令的数量
    // 数组默认是16的环形数组,数组中每一项记录了一次抽样结果
    long long ops_sec_samples[REDIS_OPS_SEC_SAMPLES];   
    // ops_sec_samples数组的索引,每次抽样后自增1,在值等于16时重置为0,让其构成一个环形数组
    int ops_sec_index;  
    
    size_t stat_peak_memory;    // 已使用内存峰值,记录服务器的内存峰值大小
    
    int shutdown_asap;  // 关闭服务器的标识,为1时关闭服务器,为0时不做动作
    
    int aof_rewrite_scheduled;  // 如果值为1,那么表示有BGREWRITEAOF命令被延迟了
    
    pid_t rdb_child_pid;    // 记录执行BGSAVE命令的子进程ID, 如果没有执行该值为-1
    pid_t aof_child_pid;    // 记录执行BGREWRITEAOF命令的子进程ID, 如果没有执行该值为-1
    
    // 函数运行次数,每运行一次serverCron,该属性的值加1
    // 作用是复制时实现每次执行serverCron函数N次就执行一次指定代码
    int cronloops;  
    ...;
);

初始化服务器

初始化服务器状态结构

initServerConfig函数操作:
  • 设置服务器的运行ID
  • 设置服务器的默认运行频率
  • 设置服务器的默认配置文件路径
  • 设置服务器的运行架构
  • 设置服务器的默认端口号
  • 设置服务器默认RDB持久化条件和AOF持久化条件
  • 初始化服务器的LRU时钟
  • 创建命令表

载入配置选项

初始化服务器数据结构

创建的数据结构比如
  • 创建server.client链表
  • 创建server.db数组
  • 创建用于保存频道订阅信息的server.pubsub_channels字典以及用于保存模式订阅信息的server.pubsubtterns链表
  • 创建用于执行Lua脚本的Lua环境server.lua
  • 创建用于保存慢查询日志的server.slowlog属性
运行initServer函数
  • 为服务器设置进程信号处理器
  • 创建共享对象
  • 打开服务器的监听端口
  • 为ServerCron创建时间事件
  • 如果AOF持久化功能打开,则打开现有AOF文件,如果不存在,创建一个新的
  • 初始化服务器后台I/O模块

还原数据库状态

执行时间循环

参考
黄键宏老师的《redis设计与实现》,机械工业出版社

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 205,033评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 87,725评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,473评论 0 338
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,846评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,848评论 5 368
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,691评论 1 282
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,053评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,700评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 42,856评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,676评论 2 323
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,787评论 1 333
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,430评论 4 321
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,034评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,990评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,218评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,174评论 2 352
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,526评论 2 343

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,598评论 18 139
  • Lua 5.1 参考手册 by Roberto Ierusalimschy, Luiz Henrique de F...
    苏黎九歌阅读 13,733评论 0 38
  • 指令集 lua_capture_error_log lua_use_default_type lua_malloc...
    吃瓜的东阅读 11,970评论 0 2
  • 俗语说:“男大当婚,女大当嫁。”在我国的传统下,无论是男女,到了适当年龄就需要成家立室、结婚生子。纵观当下,却总有...
    洛漾熙_0d2a阅读 296评论 3 5
  • 很多朋友都看过这本《秘密》,或者视频(视频效果好于书)。这个视频可以说是我的灵性启蒙电影,它让人发现意念、心、情绪...
    梦想森林DreamForest阅读 379评论 0 3