Skip to content

【代码随想录知识星球】项目分享-基于Raft的k-v存储数据库🔥

Notifications You must be signed in to change notification settings

youngyangyang04/KVstorageBaseRaft-cpp

Repository files navigation

KVstorageBaseRaft-cpp

本项目为:【代码随想录知识星球】项目分享-基于Raft的k-v存储数据库。

notice:本项目的目的是学习Raft的原理,并实现一个简单的k-v存储数据库。因此并不适用于生产环境。

分支说明

  • main:最新内容,已经实现一个简单的clerk
  • rpc:基于muduo和rpc框架相关内容
  • raft_DB:基于Raft的k-v存储数据库,主要用于观察选举过程

使用方法

1.库准备

  • muduo
  • boost
  • protoc
  • clang-format(可选)

安装说明

  • clang-format,如果你不设计提交pr,那么不用安装,这里也给出安装命令:sudo apt-get install clang-format
  • protoc,本地版本为3.12.4,ubuntu22使用sudo apt-get install protobuf-compiler libprotobuf-dev安装默认就是这个版本
  • boost,sudo apt-get install libboost-dev libboost-test-dev libboost-all-dev
  • muduo,https://blog.csdn.net/QIANGWEIYUAN/article/details/89023980

如果库安装编译本仓库的时候有错误或者需要确认版本信息,可以在issue页面查看其他人遇到的问题和分享: 链接

2.编译启动

使用rpc

mkdir cmake-build-debug
cd cmake-build-debug
cmake ..
make

之后在目录bin就有对应的可执行文件生成:

  • consumer
  • provider 运行即可,注意先运行provider,再运行consumer,原因很简单:需要先提供rpc服务,才能去调用。

使用raft集群

mkdir cmake-build-debug
cd cmake-build-debug
cmake..
make

之后在目录bin就有对应的可执行文件生成,

// make sure you in bin directory ,and this has a test.conf file
raftCoreRun -n 3 -f test.conf

这里更推荐一键运行,使用clion/clion nova,点击这个按钮即可: img.png

正常运行后,命令行应该有如下raft的运行输出:

20231228 13:04:40.570744Z 615779 INFO  TcpServer::newConnection [RpcProvider] - new connection [RpcProvider-127.0.1.1:16753#2] from 127.0.0.1:37234 - TcpServer.cc:80
[2023-12-28-21-4-41] [Init&ReInit] Sever 0, term 0, lastSnapshotIncludeIndex {0} , lastSnapshotIncludeTerm {0}
[2023-12-28-21-4-41] [Init&ReInit] Sever 1, term 0, lastSnapshotIncludeIndex {0} , lastSnapshotIncludeTerm {0}
[2023-12-28-21-4-41] [Init&ReInit] Sever 2, term 0, lastSnapshotIncludeIndex {0} , lastSnapshotIncludeTerm {0}
[2023-12-28-21-4-41] [       ticker-func-rf(1)              ]  选举定时器到期且不是leader,开始选举

[2023-12-28-21-4-41] [func-sendRequestVote rf{1}] 向server{1} 發送 RequestVote 開始
[2023-12-28-21-4-41] [func-sendRequestVote rf{1}] 向server{1} 發送 RequestVote 開始
[2023-12-28-21-4-41] [func-sendRequestVote rf{1}] 向server{1} 發送 RequestVote 完畢,耗時:{0} ms
[2023-12-28-21-4-41] [func-sendRequestVote rf{1}] elect success  ,current term:{1} ,lastLogIndex:{0}

[2023-12-28-21-4-41] [func-sendRequestVote rf{1}] 向server{1} 發送 RequestVote 完畢,耗時:{0} ms
[2023-12-28-21-4-41] [func-Raft::doHeartBeat()-Leader: {1}] Leader的心跳定时器触发了

[2023-12-28-21-4-41] [func-Raft::doHeartBeat()-Leader: {1}] Leader的心跳定时器触发了 index:{0}

[2023-12-28-21-4-41] [func-Raft::doHeartBeat()-Leader: {1}] Leader的心跳定时器触发了 index:{2}

[2023-12-28-21-4-41] [func-Raft::sendAppendEntries-raft{1}] leader 向节点{0}发送AE rpc開始 , args->entries_size():{0}
[2023-12-28-21-4-41] [func-Raft::sendAppendEntries-raft{1}] leader 向节点{2}发送AE rpc開始 , args->entries_size():{0}
[2023-12-28-21-4-41] [func-Raft::doHeartBeat()-Leader: {1}] Leader的心跳定时器触发了

使用kv

在启动raft集群之后启动callerMain即可。

Docs

  • 如果你想创建自己的rpc,请参考example中rpc的md文件和friendRPC相关代码.此外可以见rpc分支
  • 各个文件夹文件内容说明:这里

notice:在代码编写过程中可能有一些bug改进,其他分支可能并没有修复这些bug以及相应的改进。注意甄别 同时欢迎issue提出这些bug或者pr改进。

todoList

  • 完成raft节点的集群功能
  • 去除冗余的库:muduo、boost
  • 代码精简优化
  • code format
  • 代码解读 maybe

贡献者列表

Star History

Star History Chart

About

【代码随想录知识星球】项目分享-基于Raft的k-v存储数据库🔥

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages