Etcd 是一个高可用的键值对存储系统，可以用它实现服务配置；服务发现 Etcd 使用 raft 一致性协议保证数据、服务的高可用 Etcd 提供了 rest 方法进行 api 的操作
Etcd 参数说明
--name方便理解的节点名称，默认为 default，在集群中应该保持唯一，可以使用 hostname--data-dir服务运行数据保存的路径，默认为 ${name}.etcd--snapshot-count指定有多少事务（transaction）被提交时，触发截取快照保存到磁盘--heartbeat-intervalleader 多久发送一次心跳到 followers。默认值是 100ms--eletion-timeout重新投票的超时时间，如果 follow 在该时间间隔没有收到心跳包，会触发重新投票，默认为 1000 ms--listen-peer-urls和同伴通信的地址，比如 http://ip:2380，如果有多个，使用逗号分隔。需要所有节点都能够访问，所以不要使用 localhost！--listen-client-urls对外提供服务的地址：比如 http://ip:2379,http://127.0.0.1:2379，客户端会连接到这里和 etcd 交互--advertise-client-urls对外公告的该节点客户端监听地址，这个值会告诉集群中其他节点--initial-advertise-peer-urls该节点同伴监听地址，这个值会告诉集群中其他节点--initial-cluster集群中所有节点的信息，格式为 node1=http://ip1:2380,node2=http://ip2:2380,…。注意：这里的 node1 是节点的 –name 指定的名字；后面的 ip1:2380 是 –initial-advertise-peer-urls 指定的值--initial-cluster-state新建集群的时候，这个值为 new；假如已经存在的集群，这个值为 existing--initial-cluster-token创建集群的 token，这个值每个集群保持唯一。这样的话，如果你要重新创建集群，即使配置和之前一样，也会再次生成新的集群和节点 uuid；否则会导致多个集群之间的冲突，造成未知的错误
Etcd restful 接口
启动一个单机的 etcd 直接执行
etcd
练习使用
restful接口调用
Golang 调用 Etcd Api
package main
import (
"fmt"
"os"
"os/signal"
"syscall"
"time"
"github.com/coreos/etcd/clientv3"
"golang.org/x/net/context"
"google.golang.org/grpc/grpclog"
)
func main() {
clientv3.SetLogger(grpclog.NewLoggerV2(os.Stderr, os.Stderr, os.Stderr))
cli, err := clientv3.New(clientv3.Config{
Endpoints: []string{"localhost:2379", "localhost:2389", "localhost:2399", "localhost:2409"},
DialTimeout: 5 * time.Second,
Username: "root",
Password: "123456",
})
if err != nil {
panic(err.Error())
}
defer cli.Close()
//fmt.Printf("%#v\n", cli)
cli.Put(context.TODO(), "/foo1", "go-key1-val")
resp, err := cli.Get(context.TODO(), "/foo1")
//fmt.Println(resp, err)
for k, v := range resp.Kvs {
fmt.Printf("--- %#v, %v %v\n", k, string(v.Key), string(v.Value))
}
go func() {
fmt.Println("in change watcher data")
timer := time.NewTicker(time.Second * 2)
defer timer.Stop()
for {
select {
case <-timer.C:
fmt.Println("get timer")
cli.Put(context.TODO(), "/foo1", fmt.Sprintf("go-timer-%d", time.Now().Unix()))
}
}
}()
go func() {
fmt.Println("in watcher.......")
wch := cli.Watch(context.TODO(), "/foo1")
for {
dwch := <-wch
fmt.Printf("get new watch data =>%#v\n", dwch)
}
}()
sn := make(chan os.Signal)
signal.Notify(sn, syscall.SIGKILL)
<-sn
}
集群配置
单机配置
- 服务一
- 数据提供地址
127.0.0.1:2379 - 集群同伴请求地址
127.0.0.1:2380
- 数据提供地址
- 服务二
- 数据提供地址
127.0.0.1:2389 - 集群同伴请求地址
127.0.0.1:2390
- 数据提供地址
- 服务三
- 数据提供地址
127.0.0.1:2399 - 集群同伴请求地址
127.0.0.1:2400
- 数据提供地址
服务一配置信息
etcd --name infra0 --initial-advertise-peer-urls http://127.0.0.1:2380 \
--listen-peer-urls http://127.0.0.1:2380 \
--listen-client-urls http://127.0.0.1:2379 \
--advertise-client-urls http://127.0.0.1:2379 \
--initial-cluster-token etcd-cluster-1 \
--initial-cluster infra0=http://127.0.0.1:2380,infra1=http://127.0.0.1:2390,infra2=http://127.0.0.1:2400 \
--initial-cluster-state new
服务二配置信息
etcd --name infra1 --initial-advertise-peer-urls http://127.0.0.1:2390 \
--listen-peer-urls http://127.0.0.1:2390 \
--listen-client-urls http://127.0.0.1:2389 \
--advertise-client-urls http://127.0.0.1:2389 \
--initial-cluster-token etcd-cluster-1 \
--initial-cluster infra0=http://127.0.0.1:2380,infra1=http://127.0.0.1:2390,infra2=http://127.0.0.1:2400 \
--initial-cluster-state new
服务三配置信息
etcd --name infra2 --initial-advertise-peer-urls http://127.0.0.1:2400 \
--listen-peer-urls http://127.0.0.1:2400 \
--listen-client-urls http://127.0.0.1:2399 \
--advertise-client-urls http://127.0.0.1:2399 \
--initial-cluster-token etcd-cluster-1 \
--initial-cluster infra0=http://127.0.0.1:2380,infra1=http://127.0.0.1:2390,infra2=http://127.0.0.1:2400 \
--initial-cluster-state new
送上一个简单的启动脚本