Skip to content

Latest commit

 

History

History
169 lines (127 loc) · 6.08 KB

README-CN.md

File metadata and controls

169 lines (127 loc) · 6.08 KB
Raw

ROSEDB 是什么？

RoseDB 是一个基于 Bitcask 存储模型，轻量、快速、可靠的 KV 存储引擎。

Bitcask 存储模型的设计主要受到日志结构化的文件系统和日志文件合并的启发。

状态

RoseDB 经过充分测试，可放心在生产环境使用。目前有一些用户已经在生产环境中使用 RoseDB 作为存储引擎。

没有找到您想要的功能？ 请提出 issue 或 PR，项目目前处于积极维护状态，将会以最快的速度响应你的需求

设计概述

RoseDB 存储数据的文件使用预写日志（Write Ahead Log），这些日志文件是具有 block 缓存的只追加写入（append-only）文件。

wal: https://github.com/rosedblabs/wal

主要特点

优势

读写低延迟 这是由于 Bitcask 存储模型文件的追加写入特性，充分利用顺序 IO 的优势。
高吞吐量，即使数据完全无序 写入 RoseDB 的数据不需要在磁盘上排序，Bitcask 的日志结构文件设计在写入过程中减少了磁盘磁头的移动。
能够处理大于内存的数据集，性能稳定 RoseDB 的数据访问涉及对内存中的索引数据结构进行直接查找，这使得即使数据集非常大，查找数据也非常高效。
一次磁盘 IO 可以获取任意键值对 RoseDB 的内存索引数据结构直接指向数据所在的磁盘位置，不需要多次磁盘寻址来读取一个值，有时甚至不需要寻址，这归功于操作系统的文件系统缓存以及 WAL 的 block 缓存。
性能快速稳定 RoseDB 写入操作最多需要一次对当前打开文件的尾部的寻址，然后进行追加写入，写入后会更新内存。这个流程不会受到数据库数据量大小的影响，因此性能稳定。
崩溃恢复快速 使用 RoseDB 的崩溃恢复很容易也很快，因为 RoseDB 文件是只追加写入一次的。恢复操作需要检查记录并验证CRC数据，以确保数据一致。
备份简单 在大多数系统中，备份可能非常复杂。RoseDB 通过其只追加写入一次的磁盘格式简化了此过程。任何按磁盘块顺序存档或复制文件的工具都将正确备份或复制 RoseDB 数据库。
批处理操作可以保证原子性、一致性和持久性 RoseDB 支持批处理操作，这些操作是原子、一致和持久的。批处理中的新写入操作在提交之前被缓存在内存中。如果批处理成功提交，批处理中的所有写入操作将持久保存到磁盘。如果批处理失败，批处理中的所有写入操作将被丢弃。 即一个批处理操作中的所有写入操作要么全部成功，要么全部失败。
支持可以反向和正向迭代的迭代器 RoseDB 支持正向和反向迭代器，这些迭代器可以在数据库中的任何位置开始迭代。迭代器可以用于扫描数据库中的所有键值对，也可以用于扫描数据库中的某个范围的键值对，迭代器从索引中获取位置信息，然后直接从磁盘中读取数据，因此迭代器的性能非常高。
支持 Watch 功能 RoseDB 支持 Watch 功能，DB 中的 key 发生变化时你可以得到一个事件通知。
支持 Key 的过期时间 RoseDB 支持为 key 设置过期时间，过期后 key 将被自动删除。

缺点

所有的 key 必须在内存中维护 RoseDB 始终将所有 key 保留在内存中，这意味着您的系统必须具有足够的内存来容纳所有的 key。

快速上手

基本操作

package main

import "github.com/rosedblabs/rosedb/v2"

func main() {
	// 指定选项
	options := rosedb.DefaultOptions
	options.DirPath = "/tmp/rosedb_basic"

	// 打开数据库
	db, err := rosedb.Open(options)
	if err != nil {
		panic(err)
	}
	defer func() {
		_ = db.Close()
	}()

	// 设置键值对
	err = db.Put([]byte("name"), []byte("rosedb"))
	if err != nil {
		panic(err)
	}

	// 获取键值对
	val, err := db.Get([]byte("name"))
	if err != nil {
		panic(err)
	}
	println(string(val))

	// 删除键值对
	err = db.Delete([]byte("name"))
	if err != nil {
		panic(err)
	}
}

批处理操作

	// 创建批处理
	batch := db.NewBatch(rosedb.DefaultBatchOptions)

	// 设置键值对
	_ = batch.Put([]byte("name"), []byte("rosedb"))

	// 获取键值对
	val, _ := batch.Get([]byte("name"))
	println(string(val))

	// 删除键值对
	_ = batch.Delete([]byte("name"))

	// 提交批处理
	_ = batch.Commit()

完整代码可查看 examples 示例代码。

社区

欢迎加入 Slack 频道和 Discussions 和其他 RoseDB 开发者和使用者进行交流。

微信群：

可扫描下方二维码，邀请你加入 RoseDB 社区交流群，请备注 rosedb

贡献者