go 访问 etcd 时,数据与后台不一致
使用 go 访问 etcd 时,开发者遇到了以下问题:
- etcd 已启动,且 etcdctl 命令可以使用。
- 代码可以获取 etcd 中的值,但 etcdctl 无法查找该值。
代码如下:
package main
import (
"context"
"fmt"
"log"
"sync"
"time"
clientv3 "go.etcd.io/etcd/client/v3"
)
func main() {
cli, err := clientv3.New(clientv3.Config{
Endpoints: []string{"localhost:2379"},
DialTimeout: 5 * time.Second,
})
if err != nil {
log.Fatal(err)
}
defer cli.Close()
var wg sync.WaitGroup
wg.Add(1)
go func() {
defer wg.Done()
resp, err := cli.Get(context.Background(), "/test")
if err != nil {
log.Fatal(err)
}
fmt.Println(resp.Kvs)
}()
time.Sleep(2 * time.Second)
ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
_, err = cli.Put(ctx, "/test", "bar")
cancel()
if err != nil {
log.Fatal(err)
}
wg.Wait()
}解决方案
这个问题的根源在于 etcd 的不同版本。代码使用的是 etcd v3 接口,但问题中使用的 etcdctl 命令可能是针对 etcd v2。确保使用与代码相匹配的 etcdctl 版本。对于 v3 接口,应使用 etcdctl --version=3 命令。










