34 lines
709 B
Go
34 lines
709 B
Go
package goroutine
|
||
|
||
import (
|
||
"context"
|
||
"fmt"
|
||
clientv3 "go.etcd.io/etcd/client/v3"
|
||
"goLearn/model"
|
||
"time"
|
||
)
|
||
|
||
func Runtask(ctx context.Context) {
|
||
ctx2 := ctx.Value("value").(model.Task)
|
||
fmt.Println(ctx2.Id)
|
||
|
||
config := clientv3.Config{
|
||
Endpoints: []string{"127.0.0.1:2379"}, // etcd节点地址，集群模式可填多个
|
||
DialTimeout: 5 * time.Second, // 连接超时时间
|
||
// 如需认证，添加以下配置
|
||
// Username: "root",
|
||
// Password: "123456",
|
||
}
|
||
|
||
// 2. 建立连接
|
||
client, err := clientv3.New(config)
|
||
if err != nil {
|
||
fmt.Printf("连接etcd失败: %v\n", err)
|
||
return
|
||
}
|
||
defer client.Close() // 程序退出时关闭连接
|
||
|
||
fmt.Println("成功连接到etcd")
|
||
|
||
}
|