golang-etcd系列(一)--初识

etcd 是一个 golang 编写的分布式、高可用的一致性键值存储系统，是目前容器编排领域火热的 Kubernetes(k8s) 内置的服务发现与节点一致性中间件，用于提供可靠的分布式键值（key-value）存储、配置共享和服务发现等功能。etcd 能够用于存储关键数据和实现分布式调度，在现代化的集群运行中可以起到关键性的做用。

etcd 基于 Raft 协议，经过复制日志文件的方式来保证数据的强一致性。在 etcd 以前，经常使用的是基于 Paxos 协议的 ZooKeeper。

etcd 主要特性有：

• 简单：基于 HTTP+JSON 的 API 让你用 curl 就能够轻松使用。
• 安全：可选 SSL 客户认证机制。
• 快速：每一个实例每秒支持一千次写操做。
• 可信：使用 Raft 算法充分实现了分布式。

1. 安装

1.1 下载可执行文件：https://github.com/etcd-io/et...

下载最新发行版打包文件、解压、执行便可运行：

$ tar zxvf etcd-v3.3.18-linux-amd64.tar.gz
$ cd etcd-v3.3.18-linux-amd64/
$ ./etcd # 运行 etcd 服务端
$ ./etcdctl # 运行 etcd 客户端

1.2 下载源代码编译

$ git clone https://github.com/etcd-io/etcd.git
$ cd etcd
$ ./build

1.3 查看运行状况

$ netstat -anp | grep etcd
tcp        0      0 127.0.0.1:2379          0.0.0.0:*               LISTEN      20537/etcd      
tcp        0      0 127.0.0.1:2380          0.0.0.0:*               LISTEN      20537/etcd      
tcp        0      0 127.0.0.1:2379          127.0.0.1:50902         ESTABLISHED 20537/etcd      
tcp        0      0 127.0.0.1:50902         127.0.0.1:2379          ESTABLISHED 20537/etcd      
unix  2      [ ]         数据报                220389   20537/etcd          @0002f
unix  2      [ ]         数据报                220388   20537/etcd

经过端口查看能够看出，本地的 etcd-server 集群内节点通讯端口 2380，etcd-client 服务端-客户端通讯端口 2379 都已创建、监听中，说明 etcd 守护进程已成功开启。

1.4 经常使用命令

kv 键值存储最经常使用命令是：put、get 和 del

./etcdctl put hello world # 设置 k-v
OK
$ ./etcdctl get hello # 获取 k-v
hello
world
$ ./etcdctl del hello # 删除 k-v
1
$ ./etcdctl get hello # 删除后获取为空
$

2. golang 使用 demo

新建 kv_demo.go 文件以下：

package main

import (
    "context"
    "fmt"
    "time"

    "github.com/coreos/etcd/clientv3"
)

func main() {

    cli, err := clientv3.New(clientv3.Config{
        Endpoints:   []string{"localhost:2379", "localhost:22379", "localhost:32379"},
        DialTimeout: 5 * time.Second,
    })
    if err != nil {
        fmt.Println("connect failed, err:", err)
        return
    }

    // 创建客户端成功
    fmt.Println("connect succ")
    defer cli.Close()
    
    // 设置1秒超时，访问 etcd 有超时控制
    ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    
    // 设置 key
    _, err = cli.Put(ctx, "hello", "world")
    
    //操做完毕，取消 etcd
    cancel()
    if err != nil {
        fmt.Println("put failed, err:", err)
        return
    }
    
    // 取值，设置超时为 1 秒
    ctx, cancel = context.WithTimeout(context.Background(), time.Second)
    resp, err := cli.Get(ctx, "hello")
    cancel()
    if err != nil {
        fmt.Println("get failed, err:", err)
        return
    }
    
    for _, ev := range resp.Kvs {
        fmt.Printf("%s : %s\n", ev.Key, ev.Value)
    }
}

运行 go run kv_demo.go：

$ go run kv_demo.go 
connect succ
hello : world

demo 源码： https://github.com/astraw99/etcd_go

能够看到，上面的 demo 成功进行 key-value 设置与获取。固然 etcd 的命令还有不少，今天初步使用就简单使用这个 kv 存储，其余后面慢慢解析。

3. 小结

本文对 etcd 进行了简单认识和了解，对其最经常使用的 key-value 分布式存储进行了 golang-demo 演示，能够看出 etcd 的部署、使用是很简单的，客户端命令也很明晰，下一步将深刻源码一步一步去探索 etcd 的实现细节。

ectd 做为分布式服务发现、一致性存储领域的后起之秀，在分布式集群、云部署、云应用方面具备举足轻重的做用，从其官方 GitHub 能够看到代码更新迭代快速、从版本 v2 => v3，随着 CoreOS 和 Kubernetes 等项目在开源社区日益火热，相信在不久的未来将会获得更为普遍的应用。