This project demonstrates how to build very simple distributed key-value store on top of MicroRaft. Please note that this is not production-ready code.

afloatdb-server directory contains the server code and afloatdb-client directory contains the client code.

Each AfloatDB server runs a RaftNode and the communication between servers and the client-server communication happens through gRPC.

afloatdb-server/src/main/proto/AfloatDBRaft.proto contains the Protobufs definitions for MicroRaft's model and network abstractions, and the key-value operations of AfloatDB's key-value API. AfloatDB servers talk to each other via the RaftService defined in this file. This service is implemented at afloatdb-server/src/main/java/io/afloatdb/internal/rpc/impl/RaftRpcServiceImpl.java.

afloatdb-server/src/main/java/io/afloatdb/internal/raft/model package contains implementing MicroRaft's model abstractions using the Protobufs definitions defined in the above file.

afloatdb-server/src/main/java/io/afloatdb/internal/rpc/RaftRpcService.java implements MicroRaft's Transport abstraction and makes AfloatDB servers talk to each other with gRPC.

afloatdb-server/src/main/java/io/afloatdb/internal/raft/impl/KVStoreStateMachine.java contains the state machine implementation of AfloatDB's key-value API and it implements MicroRaft's StateMachine interface.

afloatdb-commons/src/main/proto/KV.proto defines the protocol between AfloatDB clients and servers. The server side counterpart is at afloatdb-server/src/main/java/io/afloatdb/internal/rpc/impl/KVService.java. It handles requests sent by clients and passes them to RaftNode.

afloatdb-server/src/main/proto/AfloatDBAdmin.proto contains the Protobufs definitions for management operations on AfloatDB clusters, such as adding / removing servers, querying RaftNode reports. Operators can manage AfloatDB clusters by making gRPC calls to the AdminService service defined in this file. Its server side counter part is at afloatdb-server/src/main/java/io/afloatdb/internal/rpc/impl/AdminService.java. It handles requests sent by clients and passes them to RaftNode.

That is enough pointers for curious readers.

MicroRaft provides a SQLite-based RaftStore implementation. AfloatDB injects its SerDe class to persist its Protocol Buffers based implementations of the RaftModel interfaces.

Configuration is built with the Typesafe Config library. You can also create config programmatically. Please see afloatdb-server/src/main/java/io/afloatdb/config/AfloatDBConfig.java.

You need to pass a config to start an AfloatDB server. The config should provide the Raft endpoint (id and address) and the initial member list of the cluster. afloatdb-server/src/test/resources contains example config files to start a 3 node AfloatDB cluster.

mvn clean package

java -jar afloatdb-server/target/afloatdb-server-fat.jar afloatdb-server/src/test/resources/node1.conf &

java -jar afloatdb-server/target/afloatdb-server-fat.jar afloatdb-server/src/test/resources/node2.conf &

java -jar afloatdb-server/target/afloatdb-server-fat.jar afloatdb-server/src/test/resources/node3.conf &

Once you start your AfloatDB cluster, you can add new servers at runtime. For this, you need to provide address of one of the running servers via the "join-to" config field for the new server.

java -jar afloatdb-server/target/afloatdb-server-fat.jar afloatdb-server/src/test/resources/node4.conf &

afloatdb-client/src/main/java/io/afloatdb/client/kv/KV.java contains the key-value interface. Keys have String type and values can be one of String, long, or byte[].

You can start a client with AfloatDBClient.newInstance(config) to write and read key-value pairs on the cluster. Please see afloatdb-client/src/main/java/io/afloatdb/client/AfloatDBClientConfig.java for configuration options. You need to pass a server address. If singleConnection is false, which is the default value, the client will discover all servers and connect to them.

java -jar afloatdb-client-cli/target/afloatdb-client-cli-fat.jar --server localhost:6701 --key name --value basri set

Output: Ordered{commitIndex=2, value=null}

java -jar afloatdb-client-cli/target/afloatdb-client-cli-fat.jar --server localhost:6701 --key name get

Output: Ordered{commitIndex=2, value=basri}

See afloatdb-client-cli/src/main/java/io/afloatdb/client/AfloatDBClientCliRunner.java for more options.