Graft

Raft是一种通过复制日志实现的一致性算法。

一致性算法可以让由多个机器组成的集群像一台机器一样工作，即使其中部分成员出现错误，整个集群仍然可以正常工作。

关于Raft的理论可以参考，

简介

该项目是从nats-io/graft中fork而来，主要的目标是，

中文化。
完善文档。
完善实例。我在运行实例时，发现无法运行起来。
修复代码中的问题。

graft

对于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文件

原有仓库的pb文件中，会报错，需要使用golang/protobuf重新生成。

使用下列语句生成新的pb文件。

安装protoc的Go语言插件

go get github.com/golang/protobuf/protoc-gen-go

进入pb文件夹，运行命令生成pb.go
```
protoc --go_out=. *.proto
```

License

Unless otherwise noted, the NATS source files are distributed under the Apache Version 2.0 license found in the LICENSE file.

License

xpzouying/graft

ErrorLooks like something went wrong!

About

Resources

License

Uh oh!

Stars

Watchers

Forks

Releases

Packages 0

Languages

Error
Looks like something went wrong!

Packages