IT 手制品

悠云闲语

极简 Raft 主节点选举组件(speedboat)

Speedboat

repo

极简 Raft 主节点选举组件

License
Java

特性

  • 极简 API：Speedboat.start(config) 一行启动
  • 集群视角配置：用户只需配置 datacenter + nodes
  • 自动匹配：系统自动检测本机 IP 并匹配节点
  • 自动模式：单机房扁平模式，跨机房级联模式
  • 两套超时：机房内/机房间独立配置
  • 零依赖配置：默认 Properties，可选实现 JSON/YAML

快速开始

1. 添加依赖

<dependency>
    <groupId>cn.itcraft</groupId>
    <artifactId>speedboat</artifactId>
    <version>1.0.0</version>
</dependency>

2. 创建配置文件

config.properties：

nodes.0.0=192.168.10.1:3000
nodes.0.1=192.168.10.2:3000
nodes.0.2=192.168.10.3:3000

3. 启动集群

SpeedboatConfigProvider config = new PropertiesConfigProvider("config.properties");
Speedboat.start(config);

if (Speedboat.isMain()) {
    System.out.println("I am the leader!");
}

// 关闭时
Speedboat.stop();

配置示例

单机房

nodes.0.0=192.168.10.1:3000
nodes.0.1=192.168.10.2:3000
nodes.0.2=192.168.10.3:3000

跨机房

datacenter=hangzhou001

# 杭州机房
nodes.0.0=192.168.10.1:3000
nodes.0.1=192.168.10.2:3000
nodes.0.2=192.168.10.3:3000

# 北京机房
nodes.1.0=10.3.1.1:3000
nodes.1.1=10.3.1.2:3000
nodes.1.2=10.3.1.3:3000

# 机房内选举超时
election.intra.timeout.min=1000
election.intra.timeout.max=2000

# 机房间选举超时
election.cross.timeout.min=3000
election.cross.timeout.max=5000

API

// 启动
Speedboat.start(config);

// 状态查询
Speedboat.isMain();           // 是否主节点
Speedboat.getLeaderId();      // 主节点ID
Speedboat.getTerm();          // 当前任期
Speedboat.getNodeId();        // 本节点ID
Speedboat.getDatacenterId();  // 机房ID
Speedboat.isRunning();        // 运行状态

// 停止
Speedboat.stop();

自动模式

nodes.size() 模式 说明
== 1 单机房扁平模式 所有节点平等选举
> 1 跨机房级联模式 本机房选举 + 跨机房级联

构建

mvn clean package

测试

mvn test

License

Apache 2.0

0%