add:nacos client

upadd:添加nacos-sdk-go

upup:è·调整import顺序

up

database/kv/nacos/client.go

+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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 nacos
+
+import (
+	"sync"
+)
+
+import (
+	"github.com/nacos-group/nacos-sdk-go/clients"
+	"github.com/nacos-group/nacos-sdk-go/clients/naming_client"
+	"github.com/nacos-group/nacos-sdk-go/common/constant"
+)
+
+var (
+	clientPool     nacosClientPool
+	clientPoolOnce sync.Once
+)
+
+type nacosClientPool struct {
+	sync.Mutex
+	namingClient map[string]naming_client.INamingClient
+}
+
+func initNacosClientPool() {
+	clientPool.namingClient = make(map[string]naming_client.INamingClient)
+}
+
+// NewNamingClient create nacos client
+func NewNamingClient(name string, share bool, sc []constant.ServerConfig, cc constant.ClientConfig) (naming_client.INamingClient, error) {
+	if share {
+		clientPoolOnce.Do(initNacosClientPool)
+		clientPool.Lock()
+		defer clientPool.Unlock()
+		if client, ok := clientPool.namingClient[name]; ok {
+			return client, nil
+		}
+	}
+	configMap := make(map[string]interface{}, 2)
+	configMap["serverConfigs"] = sc
+	configMap["clientConfig"] = cc
+	client, err := clients.CreateNamingClient(configMap)
+	if share {
+		clientPool.namingClient[name] = client
+	}
+	return client, err
+}

database/kv/nacos/client_test.go

+package nacos
+
+import "testing"
+
+import (
+	"github.com/nacos-group/nacos-sdk-go/common/constant"
+	"github.com/stretchr/testify/assert"
+)
+
+func TestNewNamingClient(t *testing.T) {
+	scs := make([]constant.ServerConfig, 0, 1)
+	scs = append(scs, constant.ServerConfig{IpAddr: "console.nacos.io", Port: 80})
+
+	cc := constant.ClientConfig{
+		TimeoutMs:           5 * 1000,
+		NotLoadCacheAtStart: true,
+	}
+
+	client1, err := NewNamingClient("nacos", true, scs, cc)
+	client2, err := NewNamingClient("nacos", true, scs, cc)
+	client3, err := NewNamingClient("nacos", false, scs, cc)
+	client4, err := NewNamingClient("test", true, scs, cc)
+
+	assert.Nil(t, err)
+	assert.Equal(t, client1, client2)
+	assert.NotEqual(t, client1, client3)
+	assert.NotEqual(t, client1, client4)
+}

go.mod

@@ -11,6 +11,7 @@ require (
 	github.com/k0kubun/pp v3.0.1+incompatible
 	github.com/mattn/go-colorable v0.1.7 // indirect
 	github.com/mattn/go-isatty v0.0.12
+	github.com/nacos-group/nacos-sdk-go v1.0.7
 	github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e // indirect
 	github.com/pkg/errors v0.9.1
 	github.com/prometheus/client_golang v1.9.0 // indirect