WriteBatch - KV存储-LevelDB/RocksDB源码剖析和中文注释

通过Batch Write来实现Concurrent Write


Overview

Put与Delete操作

Status DB::Put(constWriteOptions& opt,constSlice& key,constSlice&value) {

WriteBatch batch;

batch.Put(key,value);returnWrite(opt, &batch);

}

Status DB::Delete(constWriteOptions& opt,constSlice& key) {

WriteBatch batch;

batch.Delete(key);returnWrite(opt, &batch);

}

LevelDB对外暴露的写接口包括Put,Delete和Write,其中Write需要WriteBatch作为参数,而Put和Delete首先就是将当前的操作封装到一个WriteBatch对象,并调用Write接口。

opt是写选项,从上面代码并没有看出处理并发的逻辑,其实对于多线程的处理是在DBImpl::Write函数中完成

WriteBatch

每一个WriteBatch都是以一个固定长度的头部开始,然后后面接着许多连续的记录(插入或删除操作)

固定头部格式:

固定头部共12字节,其中前8字节为WriteBatch的序列号(也就是每个操作对应的全局序列号),对应rep_[0]到rep_[7],每次处理Batch中的记录时才会更新,后四字节为当前Batch中的记录数,对应rep_[8]到rep_[11];

后面的记录结构为:

插入数据时:type(kTypeValue、kTypeDeletion),Key_size,Key,Value_size,Value

删除数据时:type(kTypeValue、kTypeDeletion),Key_size,Key

WriteBatchInternal提供了一系列的静态操作接口来对WriteBatch的接口进行封装,而不是直接操作WriteBatch的接口。

Design


Writer封装WriteBatch

/*struct DBImpl::Writer {

*  WriteBatch* batch;

*  bool sync;

*  bool done;//该batch是否完成的标志done

* port::CondVar cv;//信号量cv用于多线程的同步

*};

*

*/

Source Code Chinese Comments

https://github.com/cld378632668/leveldb_chinese_comments

Referrence

http://blog.csdn.net/weixin_36145588/article/details/78133260

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 136,322评论 19 139
  • # rocksdb engine 写逻辑 ## 执行路径 DB::Put(key, value)是一个写操作简单封...
    kenry阅读 2,661评论 0 1
  • 1. Java基础部分 基础部分的顺序:基本语法,类相关的语法,内部类的语法,继承相关的语法,异常的语法,线程的语...
    子非鱼_t_阅读 33,870评论 18 399
  • 前面已经写了几篇文章介绍一些和 LevelDB 相关的内容: LSM 简介 LevelDB:整体架构 LevelD...
    linjinhe阅读 2,543评论 0 3
  • 1.import static是Java 5增加的功能,就是将Import类中的静态方法,可以作为本类的静态方法来...
    XLsn0w阅读 1,395评论 0 2

友情链接更多精彩内容