Fix: Same address cannot distinguish different registry center (#2784)

* fix: Same address cannot distinguish different registry center

* fix: Same address cannot distinguish different registry center

* registry.namespace is set to a constant,

Author: 1kasa

registry/protocol/protocol.go

@@ -80,14 +80,20 @@ func newRegistryProtocol() *registryProtocol {
 
 func (proto *registryProtocol) getRegistry(registryUrl *common.URL) registry.Registry {
 	var err error
-	reg, loaded := proto.registries.Load(registryUrl.PrimitiveURL)
+
+	namespace := registryUrl.GetParam(constant.RegistryNamespaceKey, "")
+	cacheKey := registryUrl.PrimitiveURL
+	if namespace != "" {
+		cacheKey = cacheKey + "?" + constant.NacosNamespaceID + "=" + namespace
+	}
+	reg, loaded := proto.registries.Load(cacheKey)
 	if !loaded {
 		reg, err = extension.GetRegistry(registryUrl.Protocol, registryUrl)
 		if err != nil {
 			logger.Errorf("Registry can not connect success, program is going to panic.Error message is %s", err.Error())
 			panic(err)
 		}
-		proto.registries.Store(registryUrl.PrimitiveURL, reg)
+		proto.registries.Store(cacheKey, reg)
 	}
 	return reg.(registry.Registry)
 }

remoting/nacos/builder.go

@@ -122,5 +122,9 @@ func NewNacosClientByURL(url *common.URL) (*nacosClient.NacosNamingClient, error
 		return nil, perrors.New("nacos client name must set")
 	}
 	logger.Infof("[Nacos Client] New nacos client with config = %+v", scs)
+	namespaceID := url.GetParam(constant.NacosNamespaceID, "")
+	if len(namespaceID) > 0 {
+		clientName += namespaceID
+	}
 	return nacosClient.NewNacosNamingClient(clientName, true, scs, cc)
 }