etcd 基础使用

news2025/1/10 10:09:34

etcd

Go 操作 Etcd 参考

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

  • 民间文档：http://www.topgoer.com/%E6%95%B0%E6%8D%AE%E5%BA%93%E6%93%8D%E4%BD%9C/go%E6%93%8D%E4%BD%9Cetcd/%E6%93%8D%E4%BD%9Cetcd.html

  • 官方文档：https://github.com/etcd-io/etcd/blob/main/client/v3/README.md

单机安装

下载地址 https://github.com/etcd-io/etcd/releases，解压后查看版本

etcd --version
etcdctl version

创建配置文件：conf.yaml

name: "hezebin-etcd"
data-dir: /usr/local/etcd/data
listen-client-urls: "http://127.0.0.1:2379"
advertise-client-urls: "http://127.0.0.1:2379"
initial-cluster-token: "hezebin-etcd-token"
initial-cluster: "hezebin-etcd=http://127.0.0.1:2380"
initial-advertise-peer-urls: "http://127.0.0.1:2380"
initial-cluster-state: "new"

启动 etcd 服务：

etcd --config-file=/usr/local/etcd/conf.yaml

打开终端，执行以下命令来检查 etcd 服务的健康状态：

etcdctl endpoint health

如果一切正常，您将看到类似以下的输出：

127.0.0.1:2379 is healthy: successfully committed proposal: took = 11.667µs

如果 etcd 服务正在运行且健康，您会收到健康状态的确认。

您还可以通过执行以下命令来查看 etcd 集群的成员状态：

etcdctl member list

这将列出 etcd 集群中的成员信息，包括成员的 ID、名称和状态。

设置键值对

etcdctl put name "hezebin"

etcdctl get name

# 查询Etcd所有的key
etcdctl get --prefix ""

# 只读取键 name 的值的命令
etcdctl get name --print-value-only

# 以 name 为前缀的所有键的命令，结果数量限制为2：
etcdctl get --prefix --limit=2 name

# 访问修订版本为 4 时的键的版本
etcdctl get --prefix --rev=4 name

# 假设 etcd 集群已经有下列键：
a = 123
b = 456
z = 789
# 读取大于等于键 b 的 byte 值的键的命令：
etcdctl get --from-key b

# 清空数据
etcdctl del name
# 删除所有 n 前缀的节点
etcdctl del n -- prefix
# 删除键 zoo 并返回被删除的键值对的命令：
etcdctl del --prev-kv zoo

watch操作

watch 监测一个键值的变化，一旦键值发生更新，就会输出最新的值并退出

etcdctl watch name

#更新键值
etcdctl put name "korbin"

# watch 阻塞处返回结果
PUT 
name
korbin

压缩修订版本

如我们提到的，etcd 保存修订版本以便应用可以读取键的过往版本。但是，为了避免积累无限数量的历史数据，压缩过往的修订版本就变得很重要。压缩之后，etcd 删除历史修订版本，释放资源来提供未来使用。所有修订版本在压缩修订版本之前的被替代的数据将不可访问。

这是压缩修订版本的命令：

$ etcdctl compact 5
compacted revision 5
# 在压缩修订版本之前的任何修订版本都不可访问
$ etcdctl get --rev=4 foo
Error:  rpc error: code = 11 desc = etcdserver: mvcc: required revision has been compacted

注意： etcd 服务器的当前修订版本可以在任何键(存在或者不存在)以json格式使用get命令来找到。下面展示的例子中 mykey 是在 etcd 服务器中不存在的：

$ etcdctl get mykey -w=json
{"header":{"cluster_id":14841639068965178418,"member_id":10276657743932975437,"revision":15,"raft_term":4}}

lease租约（过期机制）

应用可以为 etcd 集群里面的键授予租约。当键被附加到租约时，它的存活时间被绑定到租约的存活时间，而租约的存活时间相应的被 time-to-live (TTL)管理。在租约授予时每个租约的最小TTL值由应用指定。租约的实际 TTL 值是不低于最小 TTL，由 etcd 集群选择。一旦租约的 TTL 到期，租约就过期并且所有附带的键都将被删除。

授予租约

# 授予租约，TTL为10秒
$ etcdctl lease grant 10
lease 32695410dcc0ca06 granted with TTL(10s)
# 附加键 foo 到租约32695410dcc0ca06
$ etcdctl put --lease=32695410dcc0ca06 foo barOK

应用通过租约 id 可以撤销租约。撤销租约将删除所有它附带的 key。

撤销租约

$ etcdctl lease revoke 32695410dcc0ca06
lease 32695410dcc0ca06 revoked
$ etcdctl get foo
# 空应答，因为租约撤销导致foo被删除

keepAlive续约

应用可以通过刷新键的 TTL 来维持租约，以便租约不过期。维持同一个租约的命令：

$ etcdctl lease keep-alive 32695410dcc0ca06
lease 32695410dcc0ca06 keepalived with TTL(10)
lease 32695410dcc0ca06 keepalived with TTL(10)
lease 32695410dcc0ca06 keepalived with TTL(10)
...

获取租约信息

应用程序可能想知道租约信息，以便可以更新或检查租约是否仍然存在或已过期。应用程序也可能想知道有那些键附加到了特定租约。

获取租约信息的命令：

$ etcdctl lease timetolive 694d5765fc71500b
lease 694d5765fc71500b granted with TTL(500s), remaining(258s)

获取租约信息和租约附带的键的命令：

$ etcdctl lease timetolive --keys 694d5765fc71500b
lease 694d5765fc71500b granted with TTL(500s), remaining(132s), attached keys([zoo2 zoo1])
# 如果租约已经过期或者不存在，它将给出下面的应答:
Error:  etcdserver: requested lease not found

事务

etcd 的事务（Transaction）机制允许你在一个原子操作中执行一系列操作，这些操作要么全部成功，要么全部失败，确保数据的一致性和完整性。

etcdctl txn 并没有对事务提供过多的支持，执行事务最好通过 go 来实现：

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

package main

import (
	"context"
	"fmt"
	"log"
	"time"

	"go.etcd.io/etcd/clientv3"
)

func main() {
	// 创建 etcd 客户端
	cli, err := clientv3.New(clientv3.Config{
		Endpoints:   []string{"http://localhost:2379"}, // 替换为你的 etcd 地址
		DialTimeout: 5 * time.Second,
	})
	if err != nil {
		log.Fatal(err)
	}
	defer cli.Close()

	// 创建一个 etcd 事务
	etcdTxn := clientv3.NewKV(cli).Txn(context.Background())

	// 定义事务的比较和操作
	etcdTxn.If(
		clientv3.Compare(clientv3.Value("my_key"), "=", "10"),
	).
		Then(
			clientv3.OpPut("my_key", "20"),
		).
		Else(
			clientv3.OpPut("my_key", "30"),
		)

	// 提交事务
	txnResp, err := etcdTxn.Commit()
	if err != nil {
		log.Fatal(err)
	}

	// 检查事务是否成功
	if !txnResp.Succeeded {
		fmt.Println("Transaction failed")
	} else {
		fmt.Println("Transaction succeeded")
	}
}

注意：etcdTxn.If 中指定的条件是 clientv3.Compare(clientv3.Value("my_key"), "=", "10")，也就是检查键 “my_key” 的值是否等于 “10”。如果这个条件不满足（例如，键 “my_key” 的值为空），那么事务的 Else 分支会执行，而且整个事务会被标记为失败。

基于etcd实现分布式锁

原生实现

要在 etcd 中实现分布式锁，你可以利用 etcd 的事务特性和租约（Lease）机制。以下是一个使用 etcd 实现分布式锁的示例：

# 伪代码，etcdctl 并不支持下述命令，需要以 go 方式实现，api 更丰富
etcdctl txn -- \
  put my_lock some_value  --lease=0d7689bc575d6611  \
  if_not_exists

# if_not_exists: 这是一个条件，表示只有在键不存在时才执行上述的 put 操作。这个条件确保只有第一次创建节点的时候才会成功，从而实现锁的获取。

这个命令的目的是在一个 etcd 事务中，尝试创建一个指定键名的键值对，如果该键名在 etcd 中尚不存在（即尝试获取锁），则创建成功，否则操作失败。这个操作模式可以帮助实现分布式锁的基本机制。

Go 代码实现：

package main

import (
	"context"
	"fmt"
	"log"
	"time"

	"go.etcd.io/etcd/clientv3"
)

func main() {
	// 创建 etcd 客户端
	cli, err := clientv3.New(clientv3.Config{
		Endpoints:   []string{"http://localhost:2379"}, // 替换为你的 etcd 地址
		DialTimeout: 5 * time.Second,
	})
	if err != nil {
		log.Fatal(err)
	}
	defer cli.Close()

	// 创建租约
	leaseResp, err := cli.Grant(context.Background(), 10) // 10 秒的租约时间
	if err != nil {
		log.Fatal(err)
	}

	// 锁的键名
	lockKey := "my_lock"

	// 尝试获取锁
	txnResp, err := cli.Txn(context.Background()).
		If(clientv3.Compare(clientv3.CreateRevision(lockKey), "=", 0)).
		Then(clientv3.OpPut(lockKey, "lock_holder", clientv3.WithLease(leaseResp.ID))).
		Commit()
	if err != nil {
		log.Fatal(err)
	}

	// 检查是否成功获取锁
	if !txnResp.Succeeded {
		log.Println("Failed to acquire lock")
		return
	}

	log.Println("Lock acquired")

	// 续约循环（保持锁）
	keepAliveCh, err := cli.KeepAlive(context.Background(), leaseResp.ID)
	if err != nil {
		log.Fatal(err)
	}

	go func() {
		for range keepAliveCh {
			// 续约成功，执行你的逻辑，或者也可以不做任何处理
		}
	}()

	// 在这里执行需要保护的临界区代码

	// 释放锁（取消续约）
	_, err = cli.Revoke(context.Background(), leaseResp.ID)
	if err != nil {
		log.Fatal(err)
	}

	log.Println("Lock released")
}

Go 封装实现

cli, err := clientv3.New(clientv3.Config{Endpoints: endpoints})
if err != nil {
    log.Fatal(err)
}
defer cli.Close()

// 创建两个单独的会话用来演示锁竞争
s1, err := concurrency.NewSession(cli)
if err != nil {
    log.Fatal(err)
}
defer s1.Close()
m1 := concurrency.NewMutex(s1, "/my-lock/")

s2, err := concurrency.NewSession(cli)
if err != nil {
    log.Fatal(err)
}
defer s2.Close()
m2 := concurrency.NewMutex(s2, "/my-lock/")

// 会话s1获取锁
if err := m1.Lock(context.TODO()); err != nil {
    log.Fatal(err)
}
fmt.Println("acquired lock for s1")

m2Locked := make(chan struct{})
go func() {
    defer close(m2Locked)
    // 等待直到会话s1释放了/my-lock/的锁
    if err := m2.Lock(context.TODO()); err != nil {
        log.Fatal(err)
    }
}()

if err := m1.Unlock(context.TODO()); err != nil {
    log.Fatal(err)
}
fmt.Println("released lock for s1")

<-m2Locked
fmt.Println("acquired lock for s2")

通过源码可以发现concurrency包的实现原理为执行一个 key 的前缀，并在最终设置到 etcd key 的尾部拼接上 /lease_id，租约为 60 秒，且每隔 20 秒续租一次。

在 tryAcquire 函数中通过 put 上述的键值，判断版本号，若设置成功则拿到锁，否则阻塞等待锁：
在这里插入图片描述

阻塞期间先通过查询一次 key 是否存在判断是否阻塞，若不存在表示拿到锁，结束阻塞；存在则通过 watch 监听 key 的变更，仅允许DELETE类型，其他变更操作会报错，并做强制解锁。
在这里插入图片描述
在这里插入图片描述

服务注册与发现

当使用 etcd 实现服务注册与发现时，通常需要以下步骤：

  1. 引入 etcd 的 Go 客户端库
  2. 连接到 etcd 服务器
  3. 注册服务：将服务的信息写入 etcd 中
  4. 发现服务：从 etcd 中获取已注册的服务信息

以下是一个简单示例，演示如何使用 Go 语言操作 etcd 实现基本的服务注册与发现功能。请确保已经安装了 etcd 并启动了 etcd 服务器。

package main

import (
	"context"
	"fmt"
	"log"
	"time"

	"go.etcd.io/etcd/clientv3"
)

func main() {
	// 创建 etcd 客户端
	cli, err := clientv3.New(clientv3.Config{
		Endpoints:   []string{"localhost:2379"}, // etcd 服务器地址
		DialTimeout: 5 * time.Second,
	})
	if err != nil {
		log.Fatal(err)
	}
	defer cli.Close()

	// 注册服务
	serviceName := "my-service"
	serviceIP := "192.168.1.100"
	servicePort := "8080"

	serviceKey := fmt.Sprintf("/services/%s/%s:%s", serviceName, serviceIP, servicePort)
	serviceValue := "some-metadata-about-the-service"

	ctx := context.Background()
	_, err = cli.Put(ctx, serviceKey, serviceValue)
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("Service registered: %s\n", serviceKey)

	// 发现服务
	discoveryKey := fmt.Sprintf("/services/%s", serviceName)
	resp, err := cli.Get(ctx, discoveryKey, clientv3.WithPrefix())
	if err != nil {
		log.Fatal(err)
	}

	fmt.Println("Discovered services:")
	for _, kv := range resp.Kvs {
		fmt.Printf("Key: %s, Value: %s\n", kv.Key, kv.Value)
	}
}

可以结合 watch 机制优化更新服务变更。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/836099.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

如何把pdf转成cad版本？这种转换方法非常简单

如何把pdf转成cad版本？这种转换方法非常简单

将PDF转换成CAD格式的优势在于&#xff0c;CAD格式通常是用于工程设计和绘图的标准格式。这种格式的文件可以在计算机上进行编辑和修改&#xff0c;而不需要纸质副本。此外&#xff0c;CAD文件通常可以与其他CAD软件进行交互&#xff0c;从而使得工程设计和绘图过程更加高效和精…
阅读更多...
5款无广告的超实用软件，建议收藏！

5款无广告的超实用软件，建议收藏！

​ 大家好,我又来了,今天向大家推荐几款软件,它们有个共同的特点,就是无广告、超级实用,大家看完之后,可以自己去搜索下载试用。 1.重复文件清理——Duplicate Cleaner ​ Duplicate Cleaner是一款用于找出硬盘中重复文件并删除的工具。它可以通过内容或文件名查找重复文档、…
阅读更多...
面试必考精华版Leetcode104. 二叉树的最大深度

面试必考精华版Leetcode104. 二叉树的最大深度

题目&#xff1a; 代码&#xff08;首刷自解 day23&#xff09;&#xff1a; class Solution { public:int maxDepth(TreeNode* root) {if(rootnullptr) return 0;return max(maxDepth(root->left),maxDepth(root->right))1;} };
阅读更多...
安超云参与编制的《上云指导：云基础环境框架（Landing Zone）设计与应用》白皮书正式发布

安超云参与编制的《上云指导：云基础环境框架（Landing Zone）设计与应用》白皮书正式发布

近日&#xff0c;由中国信息通信研究院牵头&#xff0c;阿里云、中国移动、安超云等单位共同编制的业界首个第三方视角的《上云指导&#xff1a;云基础环境框架&#xff08;Landing Zone&#xff09;设计与应用》白皮书正式发布。 白皮书从云基础环境框架 Landing Zone 背景、内…
阅读更多...
反诈：吴明军、黄亮领导的WIN生活资金盘，大家警惕防范此类诈骗

反诈：吴明军、黄亮领导的WIN生活资金盘，大家警惕防范此类诈骗

消息已经证实&#xff01;“米粒”无法变现&#xff0c;数以万计的会员深套“315万民商城”&#xff0c;维权艰难&#xff0c;血汗钱无法讨回。 其实这一点笔者并不感到太意外&#xff0c;因为万民商城资金传销盘的定性之前就已经发文揭露过&#xff0c;并反复提醒大家小心警惕…
阅读更多...
制造型企业如何实现车间设备生产数据的实时采集？需要5G网络吗？

制造型企业如何实现车间设备生产数据的实时采集？需要5G网络吗？

引言 在制造业数字化转型的浪潮下&#xff0c;实时采集车间设备生产数据变得尤为重要。工业边缘网关HiWoo Box作为一款专为工业应用而设计的智能设备&#xff0c;具备工业级设计和多种联网方式&#xff0c;为制造型企业提供了高性能的车间设备数据实时采集解决方案。本文将重点…
阅读更多...
ChatGPT3.5——AI人工智能是个什么玩意？

ChatGPT3.5——AI人工智能是个什么玩意？

ChatGPT3.5——AI人工智能 AI人工智能什么是AI&#xff1f;AI有什么过人之处AI有什么缺点 AI的发展AI的发展史中国是如何发展AI的 AI六大要素感知理解推理学习交互 ChatCPT-3.5GPT-3.5的优势在哪里GPT-3.5的风险GPT-4骗人事件 AI人工智能 AI&#xff0c;就像是一位超级聪明的机…
阅读更多...
Spring Boot 配置多数据源【最简单的方式】

Spring Boot 配置多数据源【最简单的方式】

Druid连接池 Spring Boot 配置多数据源【最简单的方式】 文章目录 Druid连接池 Spring Boot 配置多数据源【最简单的方式】 0.前言1.基础介绍2.步骤2.1. 引入依赖2.2. 配置文件2.3. 核心源码Druid数据源创建器Druid配置项 DruidConfig 3.示例项目3.1. pom3.1.1. 依赖版本定义3.…
阅读更多...
【SpringBoot】86、SpringBoot中集成Quartz根据Cron表达式获取接下来5次执行时间

【SpringBoot】86、SpringBoot中集成Quartz根据Cron表达式获取接下来5次执行时间

本篇文章根据集成 Quartz 根据 Cron 表达式获取接下来的 5 次执行时间，在配置定时任务时，可以清晰地知道自己的 Cron 表达式是否正确，对于 Quartz 不熟悉的同学可以先看看我之前的文章 【SpringBoot】82、SpringBoot集成Quartz实现动态管理定时任务 【SpringBoot】83、Spri…
阅读更多...
马斯克收购AI.com域名巩固xAI公司地位；如何评估大型语言模型的性能

马斯克收购AI.com域名巩固xAI公司地位；如何评估大型语言模型的性能

&#x1f989; AI新闻 &#x1f680; AI拍照小程序妙鸭相机上线商业工作站并邀请摄影师进行内测 摘要&#xff1a;AI拍照小程序妙鸭相机将上线面向商业端的工作站&#xff0c;并邀请摄影师进行模板设计的内测。妙鸭相机希望为行业提供更多生态产品&#xff0c;扩大行业规模&a…
阅读更多...
peerDependency到底是什么

peerDependency到底是什么

peerDependency到底是什么 正常开发中&#xff0c;我们经常接触到的是 package.json 中的 dependencies 和 devDependencies, 本文不对上面两个进行细节分析&#xff0c;让我们来看看 peerDependencies 是什么&#xff1f; 在 NPM v7 中&#xff0c;默认安装 peerDependencies…
阅读更多...
java+springboot+mysql法律咨询网

java+springboot+mysql法律咨询网

项目介绍&#xff1a; 使用javassmmysql开发的法律咨询网&#xff0c;系统包含超级管理员&#xff0c;系统管理员、用户角色&#xff0c;功能如下&#xff1a; 用户&#xff1a;主要是前台功能使用&#xff0c;包括注册、登录&#xff1b;查看法律领域&#xff1b;法律法规&a…
阅读更多...
fetch-github-hosts间隔一年大更新v2.6发布，多端支持

fetch-github-hosts间隔一年大更新v2.6发布，多端支持

前言 fetch-github-hosts是一款同步 github hosts 的工具&#xff0c;用于帮助您解决github时而无法访问的问题。在间隔了一年之久的时间&#xff0c;最近抽空将fetch-github-hosts的依赖及UI进行了一波大更新&#xff0c;同时也增加了一些实用的功能。 主要更新 更新了基础依…
阅读更多...
C语言 用数组名作函数参数

C语言 用数组名作函数参数

当用数组名作函数参数时&#xff0c;如果形参数组中各元素的值发生变化&#xff0c;实参数组元素的值随之变化。 1.数组元素做实参的情况&#xff1a; 如果已经定义一个函数&#xff0c;其原型为 void swap(int x,int y);假设函数的作用是将两个形参&#xff08;x,y&#xf…
阅读更多...
云运维工具

云运维工具

企业通常寻找具有成本效益的方法来优化创收&#xff0c;维护物理基础架构以托管服务器和应用程序以提供服务交付需要巨大的空间和前期资金&#xff0c;最重要的是&#xff0c;物理基础设施会产生额外的运营支出以进行定期维护&#xff0c;这对收入造成了沉重的损失。 云使企业…
阅读更多...
降维 — PCA 真的能改善分类结果吗？

降维 — PCA 真的能改善分类结果吗？

一、说明 我遇到了一些关于降维技术的资源。这个主题绝对是最有趣的主题之一&#xff0c;很高兴认为有一些算法能够通过选择仍然代表整个数据集的最重要的特征来减少特征的数量。作者指出的优点之一是这些算法可以改善分类任务的结果。 在这篇文章中&#xff0c;我将使用主成分…
阅读更多...
在线免费做分班查询软件：这个制作分班查询系统的平台就可实现

在线免费做分班查询软件：这个制作分班查询系统的平台就可实现

在制作分班查询系统前&#xff0c;作为老师的我们可以先理清制作分班查询系统的意义&#xff01;这几个要点可能很多老师都没有留意过&#xff01; 提高工作效率&#xff1a; 学校每年都需要进行学生的分班工作&#xff0c;如果采用传统的手工方式进行分班查询&#xff0c;会…
阅读更多...
防火墙规则分析管理

防火墙规则分析管理

防火墙规则在高效的网络安全管理中起着至关重要的作用&#xff0c;在添加规则之前&#xff0c;确保提议的新规则不会对网络产生负面影响至关重要。 通过防火墙规则影响分析&#xff0c;安全管理员可以详细了解添加新规则的可能影响&#xff0c;防火墙规则影响分析的一个重要方…
阅读更多...
假日购物季已经打响？卖家要提前行动起来啦！

假日购物季已经打响？卖家要提前行动起来啦！

去年&#xff0c;假日购物季比以往任何时候都要早开启&#xff0c;这促使消费者对今年的购物季抱有更多的期待。 根据Optimove最新的消费者调查&#xff0c;有一半的消费者&#xff08;50%&#xff09;计划在11月之前开始他们的假日购物。 当被问及是什么促使他们提前购买时&…
阅读更多...
【已解决】安装win7系统，“Windows安装程序无法将Windows配置在此计算机的硬件上运行”

【已解决】安装win7系统，“Windows安装程序无法将Windows配置在此计算机的硬件上运行”

问题&#xff1a; 安装windows7时报错&#xff1a;“Windows安装程序无法将Windows配置在此计算机的硬件上运行” 解决办法&#xff1a; 方法一 shiftF10 调出命令提示行&#xff0c;输入cd oobe 然后再输入msoobe 回车&#xff0c;就可以继续进行下一步了。 如果方法一不…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023