4.etcd监听Watch
最后更新于：2022-04-02 04:51:55
~~~
package main
import (
"context"
"fmt"
"time"
"github.com/coreos/etcd/clientv3"
)
func main() {
cli, err := clientv3.New(clientv3.Config{
Endpoints: []string{"localhost:2379", "localhost:22379", "localhost:32379"},
DialTimeout: 5 * time.Second,
})
if err != nil {
fmt.Println("connect failed, err:", err)
return
}
fmt.Println("connect succ")
defer cli.Close()
cli.Put(context.Background(), "/logagent/conf/", "8888888")
for {
// watch key 监听节点
rch := cli.Watch(context.Background(), "/logagent/conf/")
for wresp := range rch {
for _, ev := range wresp.Events {
fmt.Printf("%s %q : %q\n", ev.Type, ev.Kv.Key, ev.Kv.Value)
}
}
}
}
~~~
开启窗口1：
~~~
go run main.go
~~~
返回结果：
~~~
connect succ
~~~
开启窗口2：
~~~
go run main.go
~~~
返回结果：
~~~
connect succ
同时窗口1 返回：
PUT "/logagent/conf/" : "8888888"
~~~
';