docs(example): add more example

README.md

@@ -88,11 +88,9 @@ func main() {
         NotLoadCacheAtStart: true,
         LogDir:              "/tmp/nacos/log",
         CacheDir:            "/tmp/nacos/cache",
-        RotateTime:          "1h",
-        MaxAge:              3,
         LogLevel:            "info",
-        Username:            "test",
-        Password:            "test"
+        Username:            "your-name",
+        Password:            "your-password"
     }
 
     cli, err := clients.NewNamingClient(
@@ -137,11 +135,9 @@ func main() {
             NotLoadCacheAtStart: true,
             LogDir:              "/tmp/nacos/log",
             CacheDir:            "/tmp/nacos/cache",
-            RotateTime:          "1h",
-            MaxAge:              3,
             LogLevel:            "info",
-            Username:            "test",
-            Password:            "test"
+            Username:            "your-name",
+            Password:            "your-password"
     }
 
     cli,err := clients.NewNamingClient(

README_CN.md

@@ -98,11 +98,9 @@ func main() {
         NotLoadCacheAtStart: true,
         LogDir:              "/tmp/nacos/log",
         CacheDir:            "/tmp/nacos/cache",
-        RotateTime:          "1h",
-        MaxAge:              3,
         LogLevel:            "info",
-        Username:            "test",
-        Password:            "test"
+        Username:            "your-name",
+        Password:            "your-password"
     }
 
     cli, err := clients.NewNamingClient(
@@ -147,11 +145,9 @@ func main() {
             NotLoadCacheAtStart: true,
             LogDir:              "/tmp/nacos/log",
             CacheDir:            "/tmp/nacos/cache",
-            RotateTime:          "1h",
-            MaxAge:              3,
             LogLevel:            "info",
-            Username:            "test",
-            Password:            "test"
+            Username:            "your-name",
+            Password:            "your-password"
     }
 
     cli,err := clients.NewNamingClient(

example/custom-config/client/main.go

@@ -0,0 +1,70 @@
+// Copyright 2021 CloudWeGo Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package main
+
+import (
+	"context"
+	"log"
+	"time"
+
+	"github.com/cloudwego/kitex-examples/hello/kitex_gen/api"
+	"github.com/cloudwego/kitex-examples/hello/kitex_gen/api/hello"
+	"github.com/cloudwego/kitex/client"
+	"github.com/kitex-contrib/registry-nacos/resolver"
+	"github.com/nacos-group/nacos-sdk-go/clients"
+	"github.com/nacos-group/nacos-sdk-go/common/constant"
+	"github.com/nacos-group/nacos-sdk-go/vo"
+)
+
+func main() {
+	// the nacos server config
+	sc := []constant.ServerConfig{
+		*constant.NewServerConfig("127.0.0.1", 8848),
+	}
+
+	// the nacos client config
+	cc := constant.ClientConfig{
+		NamespaceId:         "public",
+		TimeoutMs:           5000,
+		NotLoadCacheAtStart: true,
+		LogDir:              "/tmp/nacos/log",
+		CacheDir:            "/tmp/nacos/cache",
+		LogLevel:            "info",
+		// more ...
+	}
+
+	cli, err := clients.NewNamingClient(
+		vo.NacosClientParam{
+			ClientConfig:  &cc,
+			ServerConfigs: sc,
+		},
+	)
+	if err != nil {
+		panic(err)
+	}
+	newClient := hello.MustNewClient(
+		"Hello",
+		client.WithResolver(resolver.NewNacosResolver(cli)),
+		client.WithRPCTimeout(time.Second*3),
+	)
+	for {
+		resp, err := newClient.Echo(context.Background(), &api.Request{Message: "Hello"})
+		if err != nil {
+			log.Fatal(err)
+		}
+		log.Println(resp)
+		time.Sleep(time.Second)
+	}
+}

example/custom-config/server/main.go

@@ -0,0 +1,77 @@
+// Copyright 2021 CloudWeGo Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package main
+
+import (
+	"context"
+	"log"
+
+	"github.com/cloudwego/kitex-examples/hello/kitex_gen/api"
+	"github.com/cloudwego/kitex-examples/hello/kitex_gen/api/hello"
+	kitexregistry "github.com/cloudwego/kitex/pkg/registry"
+	"github.com/cloudwego/kitex/server"
+	"github.com/kitex-contrib/registry-nacos/registry"
+	"github.com/nacos-group/nacos-sdk-go/clients"
+	"github.com/nacos-group/nacos-sdk-go/common/constant"
+	"github.com/nacos-group/nacos-sdk-go/vo"
+)
+
+type HelloImpl struct{}
+
+func (h *HelloImpl) Echo(_ context.Context, req *api.Request) (resp *api.Response, err error) {
+	resp = &api.Response{
+		Message: req.Message,
+	}
+	return
+}
+
+func main() {
+	// the nacos server config
+	sc := []constant.ServerConfig{
+		*constant.NewServerConfig("127.0.0.1", 8848),
+	}
+
+	// the nacos client config
+	cc := constant.ClientConfig{
+		NamespaceId:         "public",
+		TimeoutMs:           5000,
+		NotLoadCacheAtStart: true,
+		LogDir:              "/tmp/nacos/log",
+		CacheDir:            "/tmp/nacos/cache",
+		LogLevel:            "info",
+		// more ...
+	}
+
+	cli, err := clients.NewNamingClient(
+		vo.NacosClientParam{
+			ClientConfig:  &cc,
+			ServerConfigs: sc,
+		},
+	)
+	if err != nil {
+		panic(err)
+	}
+
+	svr := hello.NewServer(
+		new(HelloImpl),
+		server.WithRegistryInfo(&kitexregistry.Info{ServiceName: "Hello"}),
+		server.WithRegistry(registry.NewNacosRegistry(cli)),
+	)
+	if err := svr.Run(); err != nil {
+		log.Println("server stopped with error:", err)
+	} else {
+		log.Println("server stopped")
+	}
+}

example/custom-logger/main.go

@@ -0,0 +1,78 @@
+// Copyright 2021 CloudWeGo Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package main
+
+import (
+	"context"
+	"log"
+
+	"github.com/cloudwego/kitex-examples/hello/kitex_gen/api"
+	"github.com/cloudwego/kitex-examples/hello/kitex_gen/api/hello"
+	kitexregistry "github.com/cloudwego/kitex/pkg/registry"
+	"github.com/cloudwego/kitex/server"
+	"github.com/kitex-contrib/registry-nacos/nacos"
+	"github.com/kitex-contrib/registry-nacos/registry"
+	"github.com/nacos-group/nacos-sdk-go/clients"
+	"github.com/nacos-group/nacos-sdk-go/common/constant"
+	"github.com/nacos-group/nacos-sdk-go/vo"
+)
+
+type HelloImpl struct{}
+
+func (h *HelloImpl) Echo(_ context.Context, req *api.Request) (resp *api.Response, err error) {
+	resp = &api.Response{
+		Message: req.Message,
+	}
+	return
+}
+
+func main() {
+	// the nacos server config
+	sc := []constant.ServerConfig{
+		*constant.NewServerConfig("127.0.0.1", 8848),
+	}
+
+	// the nacos client config
+	cc := constant.ClientConfig{
+		NamespaceId:         "public",
+		TimeoutMs:           5000,
+		NotLoadCacheAtStart: true,
+		LogDir:              "/tmp/nacos/log",
+		CacheDir:            "/tmp/nacos/cache",
+		LogLevel:            "info",
+		CustomLogger:        nacos.NewCustomNacosLogger(), // With a custom Logger，you can use kitex `klog` or other.
+	}
+
+	cli, err := clients.NewNamingClient(
+		vo.NacosClientParam{
+			ClientConfig:  &cc,
+			ServerConfigs: sc,
+		},
+	)
+	if err != nil {
+		panic(err)
+	}
+
+	svr := hello.NewServer(
+		new(HelloImpl),
+		server.WithRegistryInfo(&kitexregistry.Info{ServiceName: "Hello"}),
+		server.WithRegistry(registry.NewNacosRegistry(cli)),
+	)
+	if err := svr.Run(); err != nil {
+		log.Println("server stopped with error:", err)
+	} else {
+		log.Println("server stopped")
+	}
+}

go.mod

@@ -3,8 +3,9 @@ module github.com/kitex-contrib/registry-nacos
 go 1.16
 
 require (
-	github.com/cloudwego/kitex v0.1.4
+	github.com/cloudwego/kitex v0.3.2
 	github.com/cloudwego/kitex-examples v0.0.0-20220119031419-496e8f89fe75
 	github.com/nacos-group/nacos-sdk-go v1.1.2-0.20220407143335-bff55a2174fc
 	github.com/stretchr/testify v1.7.0
+	gopkg.in/yaml.v2 v2.2.8 // indirect
 )