Raft是一种通过复制日志实现的一致性算法。
一致性算法可以让由多个机器组成的集群像一台机器一样工作，即使其中部分成员出现错误，整个集群仍然可以正常工作。
关于Raft的理论可以参考，
该项目是从nats-io/graft中fork而来，主要的目标是，
- 中文化。
- 完善文档。
- 完善实例。我在运行实例时，发现无法运行起来。
- 修复代码中的问题。
对于graft，由于是nats.io维护，所以该工程的实例rpc是基于nats消息系统实现，其中数据序列化是由protobuf处理。
-
运行nats server
下载并运行nats server二进制。具体的下载地址：nats server下载
# 以macos为例 # 下载 wget https://github.com/nats-io/nats-server/releases/download/v2.1.7/nats-server-v2.1.7-darwin-amd64.zip unzip ./nats-server-v2.1.7-darwin-amd64.zip cd nats-server-v2.1.7-darwin-amd64 # -D: debug模式 ./nats-server -D
nats server启动后，会监听
0.0.0.0:4222端口 -
运行示例
示例源码仓库：graft-example
func main() { ci := graft.ClusterInfo{Name: "zy_cluster", Size: 3} opts := &nats.DefaultOptions opts.Servers = []string{"localhost:4222"} rpc, err := graft.NewNatsRpc(opts) panicError(err) errChan := make(chan error) stateChangeChan := make(chan graft.StateChange) handler := graft.NewChanHandler(stateChangeChan, errChan) logfile := fmt.Sprintf("/tmp/graft-%d.log", rand.Int31n(100)) node, err := graft.New(ci, handler, rpc, logfile) panicError(err) defer node.Close() for { if node.State() == graft.LEADER { // Process as a LEADER logrus.Infof("node(%v) is leader", node.Id()) } select { case sc := <-stateChangeChan: // Process a state change logrus.Warnf("node(%v) state changed: %v", node.Id(), sc) case err := <-errChan: // Process an error, log etc. logrus.Errorf("node(%v) got error: %v", node.Id(), err) default: } logrus.Infof("node(%s) - current leader:%s - current_term:%v", node.Id(), node.Leader(), node.CurrentTerm()) time.Sleep(1 * time.Second) } }
示例说明：
- 启动一个raft集群，命名为：zy_cluster，其中集群节点数量为3。
- RPC通信是通过nats server。server的启动参考第1步。
- raft的日志文件会保存在
/tmp/graft-%d.log，其中%d为一个随机数。
-
运行示例
在第2步中，我们指定该集群有3个节点，所以可以启动3个进程。
# 运行3次 go run main.go截图如下，
原有仓库的pb文件中，会报错，需要使用golang/protobuf重新生成。
使用下列语句生成新的pb文件。
-
安装protoc的Go语言插件
go get github.com/golang/protobuf/protoc-gen-go
-
进入pb文件夹，运行命令生成pb.go
protoc --go_out=. *.proto
Unless otherwise noted, the NATS source files are distributed under the Apache Version 2.0 license found in the LICENSE file.