1. Redis 数据库
-
redisServer{ redisDb *db, int dbnum}
- 客户端使用
select num
来切换使用的数据库.
- 客户端使用
redisClient{ resided *db}
-
redisDb{ dict *dict, dict *expires}
.- expires 记录着key 和其过期时间.
- 数据库通知.
- 让客户端获取key的变化, 及命令的执行情况.
- key-space notification. 关注某个键执行了什么命令.
- key-event notification. 关注某个命令在什么键上被执行了.
2. RDB持久化
RDB文件是压缩过的二进制文件, 通过该文件可以还原生成文件时的数据库状态.
-
RDB文件的创建与载入.
- 使用save/bgsave 来同步/异步地创建.
- �自动进行载入, 且载入期间Redis 会处于阻塞状态.
- 由于AOF文件的更新频率高于RDB,所以优先使用AOF进行还原数据库状态.
-
自动间隔性保存.
-
redisServer{ saveparam *saveparams, dirty, lastSave}.
- dirty 为修改计数器.
- lastSave 记录着上次保存的时间.
-saveparam{ time_t seconds, changes}.
- 服务器的周期性函数
serverCron
每隔100毫秒运行一次, 其会检查是否有满足的保存条件.
-
-
RDB文件结构.
REDIS | db_version | databases | EOF | check_sum
database = SELECT | db_number | key_value_pairs.
- EOF 为一个字节的常量, 用来标示文件正文内容的结束.
- checksum 用于载入时验证损坏或出错.
- value的编码.
- �普通的字符串:
Encoding | int, len | string.
- 当长度大于20时:
Redis_RDB_ENC_LZF | compressed_len | origin_len | compressed string.
- �普通的字符串:
3. AOF持久化
Append Only File. 保存服务器所执行的写命令来记录数据库状态.
- 持久化的实现
- 命令追加.
- 在执行完写命令后, 将写命令追加到
redisServer { sds aof_buf }
缓存区的结尾.
- 在执行完写命令后, 将写命令追加到
- 文件的写入与同步.
- 服务器在结束一个事件循环前, 考虑是否将aof_buf的内容保存到AOF文件中.
- 命令追加.
- 文件的载入与数据还原.
- 由于Redis命令只能在客户端执行, 所以会创建一个不带网络链接的 fake client 来逐条执行命令.
- AOF重写(BGRewriteAOF): 为了解决文件体积膨胀问题.
- 创建新的AOF 文件来替代现有的AOF, 新文件不包含任何浪费空间的冗余命令.
- 通过读取服务器当前的数据库状态来实现, 而并不需要对现有AOF 文件进行任何读取, 分析或写入操作.
- 过程: 读取key 现有的value, 然后用一条命令去记录键值对, 代替之前记录该键值对的多条命令.
- 重写是放入子进程中进行.
- 为了解决重写过程中新增的写入命令, 设置AOF重写缓存区.
4. 事件
- 文件事件.
- 对TCP 操作的抽象.
- 组成: Socket + I/O多路复用(multiplexing) 程序 + 文件事件分派器 + 事件处理器.
- 使用I/O 多路复用来同时监听多个�TCP.
- 文件事件分派器�使用队列实现.
- 事件处理器用来处理命令请求,命令回复,连接应答.
- 时间事件.
- 分为: 定时事件和周期性事件.
- serverCron为时间事件.
- 组成 : id + when + timeProc.
- 实现: 将所有时间事件放在一个无序链表中.
- 每次执行时遍历整个链表.
- 时间事件的实际处理通常比设定的到达时间晚一点.
- 分为: 定时事件和周期性事件.
- 两者都是同步有序原子地执行的, 不会被中断.
- 所以应当减少时间阻塞时间, 来降低造成事件饥饿的可能性.
5. 客户端
- Redis 服务器为一对多的服务器
redisServer{ list *clients}.
- 使用由I/O 多路复用实现的文件时间处理器.
- 使用单线程的方式处理命令请求, 并与多个客户端进行通信.
- RedisClient
- fd. 客户端的socket描述符.
- fake client =-1, 用于还原时的载入AOF, 和执行Lua脚本时.
- robj *name. 默认为null,有名字使得身份更加清晰.
- int flags. 角色和目前所处的状态.
- sds querybuf. 输入缓存区用于保存发送的命令请求.
- robj **argv + int argc. 命令的参数以及参数个数. argv[0]是要执行的命令,其余是命令的参数.
- redisCommand *cmd. 命令的实现函数. 通过命令表查找出命令所对应的实现函数.
- buf[REDIS_REPLY_CHUNK_BYTES] + bufpos. 固定的缓存区. 用于命令的回复.
- list *reply. 可变大小缓冲区.
- int authenticated. 是否通过了身份验证.
网友评论