Pika 4.0(PikiwiDB) 代码分析

[AlexStocks]

1 PikiwiDB 特点

• 跨平台，几乎 100% 兼容 Redis 2.8
• 100% 支持原生 Sentinel 指令
• 支持事务和锁
• 数据异步落盘，数据安全性有问题，需要添加 binlog
• 主从同步也依赖 sndThread，在 200 GiB 的场景下，主从同步有性能问题
• LevelDB 支持不完整，需要一直 Pika 的 Blackwidow
• 网络和上层逻辑隔离的比较好，写逻辑比较简单，这是最大的优点

2 主体流程

2.1 请求处理

总体流程：

• 1 分析请求参数；
• 2 获取参数列表；
• 3 select db；
• 4 从 CommandTable 中获取命令处理函数；
• 5 执行命令；
• 6 给 clinet 做 reply 回复；
• 7 通过 Propogate(params) 函数把命令实时发送给 slaves；

下面以 ”set a b" 为例子，说明命令解析后的数据物化流程。

1 PCommandTable::ExecuteCmd

到函数 ExecuteCmd 的时候，params 是参数列表，info 则是 command 相关，info->handler 记录了 command 的处理函数。
函数调用路径： main -> Server::MainLoop() -> PikiwiDB::run() -> Server::run() -> Internal::TaskManager::loopParseStream() -> StreamSocket::loopParseStream() -> PClient::handlePacket() -> PCommandTable::ExecuteCmd() -> pstring.cc::set()

2 pstring.cc set()

函数调用路径： main -> Server::MainLoop() -> PikiwiDB::run() -> Server::run() -> Internal::TaskManager::loopParseStream() -> StreamSocket::loopParseStream() -> PClient::handlePacket() -> PCommandTable::ExecuteCmd() -> pstring.cc::set()

3 SetValue() 进一步调用 pstring.cc PSTORE::SetValue()

1 根据 db 号找到 db；2 把参数放入 waitSyncKeys_，由 pikiwiDB 异步写入内存和磁盘；3 返回

4 把指令同步给 slaves

2.2 数据落盘过程

落盘缓冲区：PStore.waitSyncKeys_

PStore 中 backends_ 定义为：std::vector<std::unique_ptr > backends_;

PStore::DumpToBackends(int dbno) 的作用是把 PStore.waitSyncKeys_[@dbno] 中的内容写入 PStore::backends_[@dbno]，如果 key 没有超时则调用的是 Put，超时则调用的是 Delete()，写完之后淘汰 waitSyncKeys_[dbno] 中的数据。

2.3 删除过时数据

查找 key 是否超时，如果超时则调用 PSTORE.DeleteKey() 删除。