copy from 1.5

common/constant/key.go

@@ -138,6 +138,7 @@ const (
 	REGISTRY_TTL_KEY          = "registry.ttl"
 	SIMPLIFIED_KEY            = "simplified"
 	NAMESPACE_KEY             = "namespace"
+	REGISTRY_GROUP_KEY        = "registry.group"
 )
 
 const (

registry/directory/directory.go

@@ -93,11 +93,6 @@ func NewRegistryDirectory(url *common.URL, registry registry.Registry) (director
 
 	dir.consumerConfigurationListener = newConsumerConfigurationListener(dir)
 
-	// exchange data
-	subUrl := url.Clone()
-	subUrl.SubURL = nil
-	url.SubURL.SubURL = subUrl
-
 	go dir.subscribe(url.SubURL)
 	return dir, nil
 }

registry/nacos/listener.go

@@ -185,23 +185,16 @@ func getSubscribeName(url *common.URL) string {
 	return buffer.String()
 }
 
-func getSubscribeGroupName(url *common.URL) string {
-	if url.SubURL != nil {
-		return url.SubURL.GetParam(constant.GROUP_KEY, defaultGroup)
-	}
-	return defaultGroup
-}
-
 func (nl *nacosListener) startListen() error {
 	if nl.namingClient == nil {
 		return perrors.New("nacos naming namingClient stopped")
 	}
 	serviceName := getSubscribeName(nl.listenUrl)
-	groupName := getSubscribeGroupName(nl.listenUrl)
+	groupName := nl.listenUrl.GetParam(constant.REGISTRY_GROUP_KEY, defaultGroup)
 	nl.subscribeParam = &vo.SubscribeParam{
 		ServiceName:       serviceName,
-		GroupName:         groupName,
 		SubscribeCallback: nl.Callback,
+		GroupName:         groupName,
 	}
 	go func() {
 		_ = nl.namingClient.Client().Subscribe(nl.subscribeParam)

registry/nacos/registry.go

@@ -132,7 +132,7 @@ func (nr *nacosRegistry) Register(url *common.URL) error {
 	return nil
 }
 
-func createDeregisterParam(url *common.URL, serviceName string) vo.DeregisterInstanceParam {
+func createDeregisterParam(url *common.URL, serviceName string, groupName string) vo.DeregisterInstanceParam {
 	if len(url.Ip) == 0 {
 		url.Ip = localIP
 	}
@@ -144,13 +144,15 @@ func createDeregisterParam(url *common.URL, serviceName string) vo.DeregisterIns
 		Ip:          url.Ip,
 		Port:        uint64(port),
 		ServiceName: serviceName,
+		GroupName:   groupName,
 		Ephemeral:   true,
 	}
 }
 
 func (nr *nacosRegistry) DeRegister(url *common.URL) error {
 	serviceName := getServiceName(url)
-	param := createDeregisterParam(url, serviceName)
+	groupName := nr.URL.GetParam(constant.GROUP_KEY, defaultGroup)
+	param := createDeregisterParam(url, serviceName, groupName)
 	isDeRegistry, err := nr.namingClient.Client().DeregisterInstance(param)
 	if err != nil {
 		return err
@@ -185,6 +187,9 @@ func (nr *nacosRegistry) Subscribe(url *common.URL, notifyListener registry.Noti
 			return perrors.New("nacosRegistry is not available.")
 		}
 
+		groupName := nr.GetParam(constant.GROUP_KEY, defaultGroup)
+		url.SetParam(constant.REGISTRY_GROUP_KEY, groupName) // update to registry.group
+
 		listener, err := nr.subscribe(url)
 		if err != nil {
 			if !nr.IsAvailable() {

registry/nacos/service_discovery.go

@@ -169,6 +169,7 @@ func (n *nacosServiceDiscovery) GetInstances(serviceName string) []registry.Serv
 			Enable:      ins.Enable,
 			Healthy:     ins.Healthy,
 			Metadata:    metadata,
+			GroupName:   n.group,
 		})
 	}
 	return res
@@ -269,6 +270,7 @@ func (n *nacosServiceDiscovery) AddListener(listener registry.ServiceInstancesCh
 						Enable:      service.Enable,
 						Healthy:     true,
 						Metadata:    metadata,
+						GroupName:   n.group,
 					})
 				}
 

registry/service_instance.go

@@ -90,6 +90,7 @@ type DefaultServiceInstance struct {
 	Metadata        map[string]string
 	ServiceMetadata *common.MetadataInfo
 	Address         string
+	GroupName       string
 }
 
 // GetID will return this instance's id. It should be unique.