做配置文件的热更

Author: hwholiday

micro_v2/client/main.go

@@ -22,8 +22,8 @@ func main() {
 	var opss client.CallOption = func(o *client.CallOptions) {
 		o.RequestTimeout = time.Second * 30
 		o.DialTimeout = time.Second * 30
+		o.Retries = 3
 	}
-
 	info, err := agent.RpcUserInfo(context.TODO(), &test_agent.ReqMsg{
 		UserName: "test user",
 	}, opss)

micro_v2/config/main.go

@@ -0,0 +1,39 @@
+package main
+
+import (
+	"fmt"
+	"github.com/micro/go-micro/v2/config"
+	"github.com/micro/go-micro/v2/config/encoder/toml"
+	"github.com/micro/go-micro/v2/config/source"
+	"github.com/micro/go-micro/v2/config/source/etcd"
+)
+
+func main() {
+	conf, err := config.NewConfig()
+	if err != nil {
+		panic(err)
+	}
+	t := toml.NewEncoder()
+	sou := etcd.NewSource(
+		etcd.WithAddress("192.168.1.86:2379"),
+		etcd.WithPrefix("/conf/"),
+		etcd.StripPrefix(true),
+		source.WithEncoder(t),
+	)
+	if err = conf.Load(sou); err != nil {
+		panic(err)
+	}
+	fmt.Println("读取到配置", string(conf.Get("test", "server").Bytes()))
+	wath, err := conf.Watch("test", "server")
+	if err != nil {
+		panic(err)
+	}
+	defer wath.Stop()
+	for {
+		val, err := wath.Next()
+		if err != nil {
+			panic(err)
+		}
+		fmt.Println(string(val.Bytes()))
+	}
+}