calvin 系统实现
- Calvin: Fast Distributed Transactions for Partitioned Database Systems
- The Case for Determinism in Database Systems
- 客户端兼容 redis-cli ledis-cli
- 使用raft 支持 多副本
- 支持Calvin 确定化调度
- 支持多条数据的更新、查询（mget mset 命令）
- 支持数据分片，实现分布式的Calvin 系统
##Client tool 客户端使用ledisdb的客户端工具 ledis-cli,使用方法如下：
Usage of ledis-cli:
-h string
dataserver ip (default 127.0.0.1) (default "127.0.0.1")
-p int
dataserver port (default 56000)
##Build and install
mkdir $WORKSPACE
cd $WORKSPACE
git clone [email protected]:shili1992/Orangedb.git
cd src/github.com/shili1992/Orangedb/cmd/dataserver
go build##Running servers
- 开启一个dataserver
cd src/github.com/shili1992/Orangedb/cmd/dataserver
./dataserver node0 log0 &- 开启集群(只有副本，没有分片)
nohup ./dataserver -haddr 127.0.0.1:11000 -raddr 127.0.0.1:12000 -respaddr 127.0.0.1:56000 -tranaddr 127.0.0.1:37000 node0 log0 >log/0.log &
sleep 1
nohup ./dataserver -haddr 127.0.0.1:11001 -raddr 127.0.0.1:12001 -respaddr 127.0.0.1:56001 -tranaddr 127.0.0.1:37001 -join 127.0.0.1:11000 node1 log1 >log/1.log &
sleep 1
nohup ./dataserver -haddr 127.0.0.1:11002 -raddr 127.0.0.1:12002 -respaddr 127.0.0.1:56002 -tranaddr 127.0.0.1:37002 -join 127.0.0.1:11000 node2 log2 >log/2.log &- 开启集群(2Partition,2 cluster)
nohup ./dataserver -haddr 127.0.0.1:11000 -raddr 127.0.0.1:12000 -respaddr 127.0.0.1:56000 -tranaddr 127.0.0.1:37000 -conf 2part_2cluster.conf -C 0 -G 2 -g 0 node0 log0 >log/0.log &
sleep 1
nohup ./dataserver -haddr 127.0.0.1:11001 -raddr 127.0.0.1:12001 -respaddr 127.0.0.1:56001 -tranaddr 127.0.0.1:37001 -conf 2part_2cluster.conf -C 0 -G 2 -g 1 node1 log1 >log/1.log &
sleep 1
nohup ./dataserver -haddr 127.0.0.1:11002 -raddr 127.0.0.1:12002 -respaddr 127.0.0.1:56002 -tranaddr 127.0.0.1:37002 -conf 2part_2cluster.conf -join 127.0.0.1:11000 -C 1 -G 2 -g 0 node2 log2 >log/2.log &
sleep 1
nohup ./dataserver -haddr 127.0.0.1:11003 -raddr 127.0.0.1:12003 -respaddr 127.0.0.1:56003 -tranaddr 127.0.0.1:37003 -conf 2part_2cluster.conf -join 127.0.0.1:11001 -C 1 -G 2 -g 1 node3 log3 >log/3.log &
##Todo
- 提供事务（MULTI、DISCARD、EXEC ）的支持
- 提供读写事务支持
- 提供事务支持（rc 隔离级别）
- 设计一个高效率的sequencer层
- 实现快照或者可串行化隔离级别
- 实现 MVCC架构的存储层
- 提供多种数据结构支持