Raft Java implementation which is simple and easy to understand.
Raft Java implementation which is simple and easy to understand.
Raft implementation library for Java.
参考自Raft论文和Raft作者的开源实现LogCabin。
在本地单机上部署一套3实例的raft集群，执行如下脚本：
cd raft-java-example && sh deploy.sh
该脚本会在raft-java-example/env目录部署三个实例example1、example2、example3；
同时会创建一个client目录，用于测试raft集群读写功能。
部署成功后，测试写操作，通过如下脚本： cd env/client
./bin/run_client.sh "list://127.0.0.1:8051,127.0.0.1:8052,127.0.0.1:8053" hello world
测试读操作命令：
./bin/run_client.sh "list://127.0.0.1:8051,127.0.0.1:8052,127.0.0.1:8053" hello
下面介绍如何在代码中使用raft-java依赖库来实现一套分布式存储系统。
com.github.wenweihu86.raft
raft-java-core
1.9.0
message SetRequest {
string key = 1;
string value = 2;
}
message SetResponse {
bool success = 1;
}
message GetRequest {
string key = 1;
}
message GetResponse {
string value = 1;
}public interface ExampleService {
Example.SetResponse set(Example.SetRequest request);
Example.GetResponse get(Example.GetRequest request);
}// 该接口三个方法主要是给Raft内部调用
public interface StateMachine {
/**
* 对状态机中数据进行snapshot，每个节点本地定时调用
* @param snapshotDir snapshot数据输出目录
*/
void writeSnapshot(String snapshotDir);
/**
* 读取snapshot到状态机，节点启动时调用
* @param snapshotDir snapshot数据目录
*/
void readSnapshot(String snapshotDir);
/**
* 将数据应用到状态机
* @param dataBytes 数据二进制
*/
void apply(byte[] dataBytes);
}// ExampleService实现类中需要包含以下成员
private RaftNode raftNode;
private ExampleStateMachine stateMachine;// 数据写入主要逻辑
byte[] data = request.toByteArray();
// 数据同步写入raft集群
boolean success = raftNode.replicate(data, Raft.EntryType.ENTRY_TYPE_DATA);
Example.SetResponse response = Example.SetResponse.newBuilder().setSuccess(success).build();// 数据读取主要逻辑，由具体应用状态机实现
Example.GetResponse response = stateMachine.get(request);…No open issues yet, or sync has not completed.