4.4 节 服务器连接成功,put写入kv的时候,一直阻塞不返回

来源:4-4 put写入kv

月亮和西多士

2019-08-04

连接服务器应该是成功的,因为没有返回错误
但是put一直阻塞
服务器主机系统CentOS7.6

package main

import (
	"context"
	"fmt"
	"time"
	"github.com/coreos/etcd/clientv3"
)


func main(){

	var(
		config clientv3.Config
		client *clientv3.Client
		err error
		kv clientv3.KV
		//ctx context.Context
		putResp *clientv3.PutResponse
	)

	config = clientv3.Config{
		Endpoints:[]string{"192.168.80.129:2379"},
		DialTimeout:5 * time.Second,
	}

	//建立一个客户端
	if client,err = clientv3.New(config);err != nil{
		fmt.Println(err)
		return 
	}

	//用于读写etcd的键值对
	kv = clientv3.NewKV(client)


	fmt.Println(".....")  //kv.Put(...) 一直阻塞不返回结果
	if putResp,err = kv.Put(context.TODO(), "/cron/jobs/job1", "hello");err !=nil{
		fmt.Println(err)
	}else{
		fmt.Println("Revision",putResp.Header.Revision)
	}
}
写回答

1回答

月亮和西多士

提问者

2019-08-04

怎么取消提问,问题自己解决了。

我关闭了防火墙就没问题了。。

0
0

Go语言开发分布式任务调度 轻松搞定高性能Crontab

分布式系统设计+高并发细节处理,一次性让你“晋级”到位

1136 学习 · 177 问题

查看课程