当前位置：首页 > news >正文

【GoLang】etcd初始化客户端时不会返回错误怎么办

news 来源：原创 2025/6/25 21:39:35

问题描述

今天遇到一个奇怪问题，我在初始化一个etcd客户端时，传入了一个错误的端点，然后就水灵灵的初始化成功了，没有触发err。

这直接导致后续的etcd操作永久阻塞，而且不利于错误排查。。。。

package main

import (
	"context"
	"fmt"
	clientv3 "go.etcd.io/etcd/client/v3"
	"go.uber.org/zap"
	"time"
)

func main() {
	cli, err := clientv3.New(clientv3.Config{
		Endpoints:   []string{"127.0.0.1:2378"},	// 传入一个错误端口2378
		DialTimeout: 5 * time.Second,
	})
	if err != nil {    // err为 nil
		fmt.Printf("clientv3.New() err: %v", err)
		return
	}

}

后来我查了一下，原因如下：

clientv3.New 在创建客户端时，不会立即验证端点的有效性或是否可连接，而是将验证推迟到实际使用客户端（比如执行 Put、Get 等操作）时。

err 为 nil 并不一定意味着端点是正确的，而是说明 clientv3.New 在初始化时没有检测到明显的配置错误。真正的连接问题可能在后续操作中暴露出来。

解决方式

我们在初始化完成之后，直接验证该端点的有效性。（类似于ping），如果验证出错就 return，验证正确就继续执行。

package main

import (
	"context"
	"fmt"
	clientv3 "go.etcd.io/etcd/client/v3"
	"go.uber.org/zap"
	"time"
)

func main() {
	cli, err := clientv3.New(clientv3.Config{
		Endpoints:   []string{"127.0.0.1:2378"}, // 传入一个错误端口2378
		DialTimeout: 5 * time.Second,
	})
	if err != nil {
		fmt.Printf("clientv3.New() err: %v", err)
		return
	}

	// 验证端点有效性
	ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
	defer cancel()
	_, err = cli.Status(ctx, "127.0.0.1:2378")
	if err != nil {
		fmt.Printf("验证端点有效性失败 cli.Status() %v\n", err)
		cli.Close() // 记得关
		return
	}

}

实际跑一下，输出如下：

{"level":"warn","ts":"2025-04-03T15:16:38.336886+0800","logger":"etcd-client","caller":"v3@v3.5.12/retry_interceptor.go:62","msg":"retrying of unary invoker failed","target":"etcd-endpoints://0xc0000f61c0/127.0.0.1:2378","attempt":0,"error":"rpc error: code = DeadlineExceeded desc = latest balancer error: connection error: desc = \"transport: Error while dialing: dial tcp 127.0.0.1:2378: connectex: No connection could be made because the target machine actively refused it.\""}
验证端点有效性失败 cli.Status() context deadline exceeded

第一行是clientv3内部自动输出的一条日志，其中描述了错误原因：Error while dialing: dial tcp 127.0.0.1:2378: connectex: No connection could be made because the target machine actively refused it

第二行则是我们手动输出的err，只描述了上下文超时错误。

这样一来，错误的端点就会在此被检查出来，我们就成功实现了验证。

但是，描述了错误原因的这条日志，他只是自动打印在控制台了，并不是打印在日志文件中，这样我们日后还是不方便排查问题，那我们如何将其打印在日志文件中呢？有需求的小伙伴可以继续往下看。