在线时间:8:00-16:00
迪恩网络APP
随时随地掌握行业动态
扫描二维码
关注迪恩网络微信公众号
开源软件名称:raft-java开源软件地址:https://gitee.com/wenweihu86/raft-java开源软件介绍:raft-javaRaft implementation library for Java. 支持的功能
Quick Start在本地单机上部署一套3实例的raft集群,执行如下脚本: 使用方法下面介绍如何在代码中使用raft-java依赖库来实现一套分布式存储系统。 配置依赖<dependency> <groupId>com.github.wenweihu86.raft</groupId> <artifactId>raft-java-core</artifactId> <version>1.8.0</version></dependency> 定义数据写入和读取接口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);
// 初始化RPCServerRPCServer server = new RPCServer(localServer.getEndPoint().getPort());// 应用状态机ExampleStateMachine stateMachine = new ExampleStateMachine();// 设置Raft选项,比如:RaftOptions.snapshotMinLogSize = 10 * 1024;RaftOptions.snapshotPeriodSeconds = 30;RaftOptions.maxSegmentFileSize = 1024 * 1024;// 初始化RaftNodeRaftNode raftNode = new RaftNode(serverList, localServer, stateMachine);// 注册Raft节点之间相互调用的服务RaftConsensusService raftConsensusService = new RaftConsensusServiceImpl(raftNode);server.registerService(raftConsensusService);// 注册给Client调用的Raft服务RaftClientService raftClientService = new RaftClientServiceImpl(raftNode);server.registerService(raftClientService);// 注册应用自己提供的服务ExampleService exampleService = new ExampleServiceImpl(raftNode, stateMachine);server.registerService(exampleService);// 启动RPCServer,初始化Raft节点server.start();raftNode.init(); |
请发表评论