update nacos go sdk to 1.0.1

Author: tietang

.gitignore

@@ -22,4 +22,6 @@ etcd/temp/
 vendor/
 **/temp/
 _vendor-20180703123224/
-vendor/**
+vendor/**
+/nacos/
+/go.sum

go.mod

@@ -52,7 +52,7 @@ require (
 	github.com/hashicorp/serf v0.9.2 // indirect
 	github.com/mitchellh/go-testing-interface v1.14.1 // indirect
 	github.com/mitchellh/mapstructure v1.3.2 // indirect
-	github.com/nacos-group/nacos-sdk-go v0.3.2
+	github.com/nacos-group/nacos-sdk-go v1.0.1
 	github.com/prometheus/common v0.10.0
 	github.com/samuel/go-zookeeper v0.0.0-20180130194729-c4fab1ac1bec
 	github.com/satori/go.uuid v1.2.1-0.20181028125025-b2ce2384e17b
@@ -65,9 +65,6 @@ require (
 	github.com/valyala/fasttemplate v1.1.0
 	github.com/xiang90/probing v0.0.0-20190116061207-43a291ad63a2 // indirect
 	go.etcd.io/bbolt v1.3.2 // indirect
-	go.uber.org/atomic v1.4.0 // indirect
-	go.uber.org/multierr v1.1.0 // indirect
-	go.uber.org/zap v1.10.0 // indirect
 	golang.org/x/crypto v0.0.0-20191106202628-ed6320f186d4 // indirect
 	golang.org/x/sys v0.0.0-20200602225109-6fdc65e7d980 // indirect
 	golang.org/x/time v0.0.0-20190308202827-9d24e82272b4 // indirect

nacos/nacos_client_props_source.go

@@ -33,7 +33,7 @@ type NacosClientPropsConfigSource struct {
 	//
 	name          string
 	lastCt        uint32
-	ClientConfig  constant.ClientConfig
+	ClientConfig  *constant.ClientConfig
 	ServerConfigs []constant.ServerConfig
 	Client        config_client.IConfigClient
 }
@@ -45,15 +45,16 @@ func NewNacosClientPropsConfigSource(address, group, dataId, tenant string) *Nac
 	s.DataId = dataId
 	s.Group = group
 	s.Tenant = tenant
-	s.ClientConfig = constant.ClientConfig{
-		TimeoutMs:            10 * 1000,            //http请求超时时间，单位毫秒
-		ListenInterval:       30 * 1000,            //监听间隔时间，单位毫秒（仅在ConfigClient中有效）
-		BeatInterval:         5 * 1000,             //心跳间隔时间，单位毫秒（仅在ServiceClient中有效）
-		CacheDir:             "./data/nacos/cache", //缓存目录
-		LogDir:               "./data/nacos/log",   //日志目录
-		UpdateThreadNum:      20,                   //更新服务的线程数
-		NotLoadCacheAtStart:  true,                 //在启动时不读取本地缓存数据，true--不读取，false--读取
-		UpdateCacheWhenEmpty: true,                 //当服务列表为空时是否更新本地缓存，true--更新,false--不更新
+	s.ClientConfig = &constant.ClientConfig{
+		TimeoutMs:            10 * 1000,       //请求Nacos服务端的超时时间，默认是10000ms
+		BeatInterval:         5 * 1000,        //心跳间隔时间，单位毫秒（仅在ServiceClient中有效）
+		CacheDir:             "./nacos/cache", //缓存目录
+		LogDir:               "./nacos/log",   //日志目录
+		UpdateThreadNum:      20,              //更新服务的线程数
+		NotLoadCacheAtStart:  true,            //在启动时不读取本地缓存数据，true--不读取，false--读取
+		UpdateCacheWhenEmpty: false,           //当服务列表为空时是否更新本地缓存，true--更新,false--不更新,当service返回的实例列表为空时，不更新缓存，用于推空保护
+		RotateTime:           "1h",            // 日志轮转周期，比如：30m, 1h, 24h, 默认是24h
+		MaxAge:               3,               // 日志最大文件数，默认3
 	}
 	if len(tenant) > 0 {
 		s.ClientConfig.NamespaceId = tenant
@@ -85,7 +86,7 @@ func NewNacosClientPropsConfigSource(address, group, dataId, tenant string) *Nac
 	var err error
 	s.Client, err = clients.CreateConfigClient(map[string]interface{}{
 		constant.KEY_SERVER_CONFIGS: s.ServerConfigs,
-		constant.KEY_CLIENT_CONFIG:  s.ClientConfig,
+		constant.KEY_CLIENT_CONFIG:  *s.ClientConfig,
 	})
 	if err != nil {
 		log.Panic("error create ConfigClient: ", err)
@@ -116,11 +117,11 @@ func (s *NacosClientPropsConfigSource) watchContext() {
 		DataId: "dataId",
 		Group:  "group",
 	}
-	if len(s.AppName) > 0 {
-		cp.AppName = s.AppName
-	}
+	//if len(s.AppName) > 0 {
+	//	cp.AppName = s.AppName
+	//}
 	cp.OnChange = func(namespace, group, dataId, data string) {
-		s.parseAndregisterProps([]byte(data))
+		s.parseAndRegisterProps([]byte(data))
 		log.Info("changed config:", namespace, group, dataId)
 	}
 	s.Client.ListenConfig(cp)
@@ -137,11 +138,11 @@ func (s *NacosClientPropsConfigSource) findProperties() {
 		log.Error(err)
 		return
 	}
-	s.parseAndregisterProps(data)
+	s.parseAndRegisterProps(data)
 
 }
 
-func (s *NacosClientPropsConfigSource) parseAndregisterProps(data []byte) {
+func (s *NacosClientPropsConfigSource) parseAndRegisterProps(data []byte) {
 	sep := s.LineSeparator
 	if sep == "" {
 		sep = NACOS_LINE_SEPARATOR
@@ -179,9 +180,9 @@ func (h *NacosClientPropsConfigSource) get() (body []byte, err error) {
 		DataId: "dataId",
 		Group:  "group",
 	}
-	if len(h.AppName) > 0 {
-		cp.AppName = h.AppName
-	}
+	//if len(h.AppName) > 0 {
+	//	cp.AppName = h.AppName
+	//}
 	content, err := h.Client.GetConfig(cp)
 	if err != nil {
 		log.Error(err)

nacos/nacos_client_props_source_test.go

@@ -7,8 +7,11 @@ import (
 	"time"
 )
 
+//var address = "console.nacos.io"
+var address = "172.16.1.248:8848"
+
 func TestNacosClientIniConfigSource2(t *testing.T) {
-	address := "console.nacos.io"
+
 	//http://console.nacos.io/nacos/v1/cs/configs?
 	// show=all&dataId=xxx123&group=DEFAULT_GROUP&tenant=&namespaceId=
 	dataId := "xxx123"
@@ -22,7 +25,7 @@ func TestNacosClientIniConfigSource(t *testing.T) {
 	//address := "172.16.1.248:8848"
 	//http://console.nacos.io/nacos/v1/cs/configs?show=all&dataId=q123&group=DEFAULT_GROUP&tenant=&namespaceId=
 	//http://console.nacos.io/nacos/v1/cs/configs
-	address := "console.nacos.io"
+	//address := "console.nacos.io"
 
 	size := 10
 	inilen := 3

nacos/nacos_client_source.go

@@ -101,9 +101,9 @@ func (h *NacosClientConfigSource) get() (cr *ConfigRes, err error) {
 		DataId: "dataId",
 		Group:  "group",
 	}
-	if len(h.AppName) > 0 {
-		cp.AppName = h.AppName
-	}
+	//if len(h.AppName) > 0 {
+	//	cp.AppName = h.AppName
+	//}
 	content, err := h.Client.GetConfig(cp)
 	if err != nil {
 		log.Error(err)

nacos/nacos_data_test.go

@@ -36,7 +36,6 @@ func update(group, dataId, tenant string, size, len int) map[string]string {
 		DataId:  dataId,
 		Group:   group,
 		Content: "",
-		Tag:     "",
 	}
 	b, e := c.PublishConfig(vo)
 	fmt.Println(b, e)

nacos/nacos_props_source.go

@@ -9,7 +9,7 @@ import (
 	"fmt"
 	"github.com/nacos-group/nacos-sdk-go/common/constant"
 	"github.com/nacos-group/nacos-sdk-go/common/nacos_error"
-	"github.com/nacos-group/nacos-sdk-go/common/util"
+	"github.com/nacos-group/nacos-sdk-go/util"
 	uuid "github.com/satori/go.uuid"
 	log "github.com/sirupsen/logrus"
 	"github.com/tietang/props/v3/kvs"