raft-java
RaftimplemetatiolibraryforJava.参考自Raft论文和Raft作者的开源实现LogCabi。
支持的功能leader选举
日志复制
sapshot
集群成员动态更变
QuickStart在本地单机上部署一套3实例的raft集群，执行如下脚本：cdraft-java-example&&shdeploy.sh 该脚本会在raft-java-example/ev目录部署三个实例example1、example2、example3；同时会创建一个cliet目录，用于测试raft集群读写功能。部署成功后，测试写操作，通过如下脚本：cdev/cliet ./bi/ru_cliet.sh"127.0.0.1:8051,127.0.0.1:8052,127.0.0.1:8053"helloworld 测试读操作命令：./bi/ru_cliet.sh"127.0.0.1:8051,127.0.0.1:8052,127.0.0.1:8053"hello
使用方法下面介绍如何在代码中使用raft-java依赖库来实现一套分布式存储系统。
配置依赖<depedecy> <groupId>com.github.weweihu86.raft</groupId> <artifactId>raft-java-core</artifactId> <versio>1.8.0</versio></depedecy>定义数据写入和读取接口message SetRequest { strig key = 1; strig value = 2;}message SetRespose { bool success = 1;}message GetRequest { strig key = 1;}message GetRespose { strig value = 1;}public iterface ExampleService { Example.SetRespose set(Example.SetRequest request); Example.GetRespose get(Example.GetRequest request);}服务端使用方法实现状态机StateMachie接口实现类
// 该接口三个方法主要是给Raft内部调用public iterface StateMachie { /** * 对状态机中数据进行sapshot，每个节点本地定时调用 * @param sapshotDir sapshot数据输出目录 */ void writeSapshot(Strig sapshotDir); /** * 读取sapshot到状态机，节点启动时调用 * @param sapshotDir sapshot数据目录 */ void readSapshot(Strig sapshotDir); /** * 将数据应用到状态机 * @param dataBytes 数据二进制 */ void apply(byte[] dataBytes);}实现数据写入和读取接口
// ExampleService实现类中需要包含以下成员private RaftNode raftNode;private ExampleStateMachie stateMachie;// 数据写入主要逻辑byte[] data = request.toByteArray();// 数据同步写入raft集群boolea success = raftNode.replicate(data, Raft.EtryType.ENTRY_TYPE_DATA);Example.SetRespose respose = Example.SetRespose.ewBuilder().setSuccess(success).build();// 数据读取主要逻辑，由具体应用状态机实现Example.GetRespose respose = stateMachie.get(request);服务端启动逻辑
// 初始化RPCServerRPCServer server = ew RPCServer(localServer.getEdPoit().getPort());// 应用状态机ExampleStateMachie stateMachie = ew ExampleStateMachie();// 设置Raft选项，比如：RaftOptios.sapshotMiLogSize = 10 * 1024;RaftOptios.sapshotPeriodSecods = 30;RaftOptios.maxSegmetFileSize = 1024 * 1024;// 初始化RaftNodeRaftNode raftNode = ew RaftNode(serverList, localServer, stateMachie);// 注册Raft节点之间相互调用的服务RaftCosesusService raftCosesusService = ew RaftCosesusServiceImpl(raftNode);server.registerService(raftCosesusService);// 注册给Cliet调用的Raft服务RaftClietService raftClietService = ew RaftClietServiceImpl(raftNode);server.registerService(raftClietService);// 注册应用自己提供的服务ExampleService exampleService = ew ExampleServiceImpl(raftNode, stateMachie);server.registerService(exampleService);// 启动RPCServer，初始化Raft节点server.start();raftNode.iit();
评论