浅谈云原生技术组件—etcd

浅谈云原生技术组件—etcd

浅谈云原生技术组件—etcd

技术官网：什么是etcd？

etcd是一种强一致性的分布式键值存储组件，使用Raft算法，利用Go语言编写，它提供了一种可靠的方式来存储需要由分布式系统或机器集群访问的数据。它在网络分区期间优雅地处理领导者选举，并且可以容忍机器故障，即使在领导者节点中也是如此。

特点：

操作简单整洁，使用HTTP协议和JSON文件格式进行存取键值对键值对存储，类似于Zookeeper更够根据值的变化快速相应可以利用TLS增强安全性

2 动手运行etcd

2.1 安装要求

支持平台：下载并测试

下载页面：wget 14:20:34 (1.45 MB/s) - 已保存 “etcd-v3.5.4-linux-amd64.tar.gz” [19432359/19432359])root@ymx-ubuntu:/usr/local# lsetcd-v3.5.4-linux-amd64.tar.gz ......root@ymx-ubuntu:/usr/local# tar -zxvf etcd-v3.5.4-linux-amd64.tar.gz ......root@ymx-ubuntu:/usr/local# cd etcd-v3.5.4-linux-amd64/root@ymx-ubuntu:/usr/local/etcd-v3.5.4-linux-amd64# ls -al总用量 56300drwxr-xr-x 3 528287 89939 4096 4月 24 18:45 .drwxr-xr-x 14 root root 4096 5月 15 14:20 ..drwxr-xr-x 3 528287 89939 4096 4月 24 18:45 Documentation-rwxr-xr-x 1 528287 89939 23564288 4月 24 18:45 etcd-rwxr-xr-x 1 528287 89939 17960960 4月 24 18:45 etcdctl-rwxr-xr-x 1 528287 89939 16039936 4月 24 18:45 etcdutl-rw-r--r-- 1 528287 89939 42066 4月 24 18:45 README-etcdctl.md-rw-r--r-- 1 528287 89939 7359 4月 24 18:45 README-etcdutl.md-rw-r--r-- 1 528287 89939 9394 4月 24 18:45 README.md-rw-r--r-- 1 528287 89939 7896 4月 24 18:45 READMEv2-etcdctl.mdroot@ymx-ubuntu:/usr/local/etcd-v3.5.4-linux-amd64# ./etcd -versionetcd Version: 3.5.4Git SHA: 0xxxxxxGo Version: go1.16.15Go OS/Arch: linux/amd64

​​etcd​​：etcd服务​​etcdctl​​ ：etcd的命令行客户端​​etcdutl​​ ：etcd的命令行管理工具

2.3 运行并初步使用etcd

2.3.1 设置环境变量

root@ymx-ubuntu:/usr/local/etcd-v3.5.4-linux-amd64# vim /etc/profile#### 在文件末尾加入以下内容export ETCD_HOME=/usr/local/etcd-v3.5.4-linux-amd64export PATH=$PATH:$ETCD_HOME

2.3.1 启动etcd(单节点)

TOKEN=my_etcdCLUSTER_STATE=newNAME_1=my_etcd_nameHOST_1=127.0.0.1CLUSTER=${NAME_1}=--data-dir=data.etcd --name ${THIS_NAME} \ --initial-advertise-peer-urls --listen-peer-urls \ --advertise-client-urls --listen-client-urls \ --initial-cluster ${CLUSTER} \ --initial-cluster-state ${CLUSTER_STATE} --initial-cluster-token ${TOKEN}

2.3.2 使用 etcdctl 连接到 etcd

etcdctl --endpoints=127.0.0.1:2379 member list

演示：

root@ymx-ubuntu:/usr/local/etcd-v3.5.4-linux-amd64# ./etcdctl --endpoints=127.0.0.1:2379 member listxxxxxxxx, started, my_etcd_name, false

2.3.3 使用etcd的Hello World

ENDPOINTS=127.0.0.1:2379etcdctl --endpoints=$ENDPOINTS put foo "Hello World!"etcdctl --endpoints=$ENDPOINTS get fooetcdctl --endpoints=$ENDPOINTS --write-out="json" get foo

演示：

root@ymx-ubuntu:/usr/local/etcd-v3.5.4-linux-amd64# ./etcdctl --endpoints=$ENDPOINTS put foo "Hello World!"OKroot@ymx-ubuntu:/usr/local/etcd-v3.5.4-linux-amd64# ./etcdctl --endpoints=$ENDPOINTS get foofooHello World!root@ymx-ubuntu:/usr/local/etcd-v3.5.4-linux-amd64# ./etcdctl --endpoints=$ENDPOINTS --write-out="json" get foo{"header":{"cluster_id":87772999870000089,"member_id":10756500090258089453,"revision":3,"raft_term":2},"kvs":[{"key":"Zm9v","create_revision":2,"mod_revision":3,"version":2,"value":"SGV00000ybGQh"}],"count":1}

2.3.4 将etcd数据进行持久化

ENDPOINTS=127.0.0.1:2379etcdctl --endpoints=$ENDPOINTS snapshot save my.dbetcdctl --write-out=table --endpoints=$ENDPOINTS snapshot status my.db

演示：

root@ymx-ubuntu:/usr/local/etcd-v3.5.4-linux-amd64# ./etcdctl --endpoints=$ENDPOINTS snapshot save my.db......Snapshot saved at my.dbroot@ymx-ubuntu:/usr/local/etcd-v3.5.4-linux-amd64# ./etcdctl --write-out=table --endpoints=$ENDPOINTS snapshot status my.dbDeprecated: Use `etcdutl snapshot status` instead.+----------+----------+------------+------------+| HASH | REVISION | TOTAL KEYS | TOTAL SIZE |+----------+----------+------------+------------+| ebfb411d | 3 | 8 | 20 kB |+----------+----------+------------+------------+

3 使用客户端连接etcd

etcd支持以下客户端：

GoJavaScalaPerlPythonNodeRubyCC++…

因为作者本人目前只能够熟练的使用Java和Go，因此只那这两个做演示哈~

3.1 使用Go操作etcd

3.1.1 Go官方推荐的etcd连接工具（3.x版本以上）

get go.etcd.io/etcd/client/v3​​

3.1.2 代码

func main() { cli, err := clientv3.New(clientv3.Config{ Endpoints: []string{"127.0.0.1:2379"}, DialTimeout: 5 * time.Second, }) if err != nil { panic(err) } resp, err := cli.Put(context.TODO(), "sample_key", "sample_value") fmt.Println(resp) response, err := cli.Get(context.TODO(), "sample_key") fmt.Println(response) defer cli.Close()}

3.2 使用Java连接etcd

3.2.1 使用jetcd进行连接

io.etcd jetcd-core 0.5.0

3.2.2 代码

@Testvoid TestEtcd() throws Exception { //集群模式下可以使用逗号分隔 Client client = Client.builder().endpoints(" KV kvClient = client.getKVClient(); ByteSequence key = ByteSequence.from("test_key".getBytes()); ByteSequence value = ByteSequence.from("test_value".getBytes()); // put值 kvClient.put(key, value).get(); // get值 CompletableFuture getFuture = kvClient.get(key); GetResponse response = getFuture.get(); System.out.println(response); // 删除值 kvClient.delete(key).get();}

4 小总结下

etcd作为Kubernetes集群默认的服务配置中心，可以说是最贴近云原生的，相比Zookeeper，虽说有几分相似，但是他们所使用的分布式一致性算法颇有些不同，etcd使用Raft协议， Zookeeper使用ZAB协议，而且etcd支持使用http和https进行访问，使用上更加方便。

参考：

https://github.com/etcd-io/jetcd

https://github.com/etcd-io/etcd/tree/main/client/v3

https://github.com/etcd-io/etcd

https://etcd.io/docs/v3.5/integrations/

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。