add: tag route static config

cluster/router/tag/router.go

@@ -52,7 +52,8 @@ func (p *PriorityRouter) Route(invokers []protocol.Invoker, url *common.URL, inv
 		logger.Warnf("[tag router] invokers from previous router is empty")
 		return invokers
 	}
-	key := url.Service() + constant.TagRouterRuleSuffix
+	// tag is valid in application
+	key := url.GetParam(constant.ApplicationKey, "") + constant.TagRouterRuleSuffix
 	value, ok := p.routerConfigs.Load(key)
 	if !ok {
 		return staticTag(invokers, url, invocation)
@@ -76,7 +77,7 @@ func (p *PriorityRouter) Notify(invokers []protocol.Invoker) {
 	if len(invokers) == 0 {
 		return
 	}
-	service := invokers[0].GetURL().Service()
+	service := invokers[0].GetURL().GetParam(constant.ApplicationKey, "")
 	if service == "" {
 		logger.Error("url service is empty")
 		return

config/application_config.go

@@ -38,6 +38,7 @@ type ApplicationConfig struct {
 	Environment  string `yaml:"environment" json:"environment,omitempty" property:"environment"`
 	// the metadata type. remote or local
 	MetadataType string `default:"local" yaml:"metadata-type" json:"metadataType,omitempty" property:"metadataType"`
+	Tag          string `yaml:"tag" json:"tag,omitempty" property:"tag"`
 }
 
 // Prefix dubbo.application

config/config_loader.go

@@ -131,6 +131,7 @@ func createInstance(url *common.URL) (registry.ServiceInstance, error) {
 		Enable:      true,
 		Healthy:     true,
 		Metadata:    metadata,
+		Tag:         appConfig.Tag,
 	}
 
 	for _, cus := range extension.GetCustomizers() {

config_center/zookeeper/impl.go

@@ -103,6 +103,7 @@ func newZookeeperDynamicConfiguration(url *common.URL) (*zookeeperDynamicConfigu
 // AddListener add listener for key
 // TODO this method should has a parameter 'group', and it does not now, so we should concat group and key with '/' manually
 func (c *zookeeperDynamicConfiguration) AddListener(key string, listener config_center.ConfigurationListener, options ...config_center.Option) {
+	key = c.GetURL().GetParam(constant.ConfigNamespaceKey, config_center.DefaultGroup) + "/" + key
 	qualifiedKey := buildPath(c.rootPath, key)
 	c.cacheListener.AddListener(qualifiedKey, listener)
 }

imports/imports.go

@@ -34,6 +34,7 @@ import (
 	_ "dubbo.apache.org/dubbo-go/v3/cluster/loadbalance/roundrobin"
 	_ "dubbo.apache.org/dubbo-go/v3/cluster/router/meshrouter"
 	_ "dubbo.apache.org/dubbo-go/v3/cluster/router/polaris"
+	_ "dubbo.apache.org/dubbo-go/v3/cluster/router/tag"
 	_ "dubbo.apache.org/dubbo-go/v3/config_center/nacos"
 	_ "dubbo.apache.org/dubbo-go/v3/config_center/zookeeper"
 	_ "dubbo.apache.org/dubbo-go/v3/filter/accesslog"

registry/service_instance.go

@@ -19,6 +19,7 @@ package registry
 
 import (
 	"encoding/json"
+	url2 "net/url"
 	"strconv"
 )
 
@@ -70,6 +71,9 @@ type ServiceInstance interface {
 
 	// SetServiceMetadata saves metadata in instance
 	SetServiceMetadata(info *common.MetadataInfo)
+
+	// GetTag will return the tag of the instance
+	GetTag() string
 }
 
 // nolint
@@ -92,6 +96,7 @@ type DefaultServiceInstance struct {
 	Address         string
 	GroupName       string
 	endpoints       []*Endpoint `json:"-"`
+	Tag             string
 }
 
 // GetID will return this instance's id. It should be unique.
@@ -142,6 +147,10 @@ func (d *DefaultServiceInstance) SetServiceMetadata(m *common.MetadataInfo) {
 	d.ServiceMetadata = m
 }
 
+func (d *DefaultServiceInstance) GetTag() string {
+	return d.Tag
+}
+
 // ToURLs return a list of url.
 func (d *DefaultServiceInstance) ToURLs(service *common.ServiceInfo) []*common.URL {
 	urls := make([]*common.URL, 0, 8)
@@ -158,15 +167,17 @@ func (d *DefaultServiceInstance) ToURLs(service *common.ServiceInfo) []*common.U
 				url := common.NewURLWithOptions(common.WithProtocol(service.Protocol),
 					common.WithIp(d.Host), common.WithPort(strconv.Itoa(endpoint.Port)),
 					common.WithPath(service.Name), common.WithInterface(service.Name),
-					common.WithMethods(service.GetMethods()), common.WithParams(service.GetParams()))
+					common.WithMethods(service.GetMethods()), common.WithParams(service.GetParams()),
+					common.WithParams(url2.Values{constant.Tagkey: {d.Tag}}))
 				urls = append(urls, url)
 			}
 		}
 	} else {
 		url := common.NewURLWithOptions(common.WithProtocol(service.Protocol),
 			common.WithIp(d.Host), common.WithPort(strconv.Itoa(d.Port)),
 			common.WithPath(service.Name), common.WithInterface(service.Name),
-			common.WithMethods(service.GetMethods()), common.WithParams(service.GetParams()))
+			common.WithMethods(service.GetMethods()), common.WithParams(service.GetParams()),
+			common.WithParams(url2.Values{constant.Tagkey: {d.Tag}}))
 		urls = append(urls, url)
 	}
 	return urls
@@ -198,6 +209,7 @@ func (d *DefaultServiceInstance) Copy(endpoint *Endpoint) ServiceInstance {
 		Healthy:         d.Healthy,
 		Metadata:        d.Metadata,
 		ServiceMetadata: d.ServiceMetadata,
+		Tag:             d.Tag,
 	}
 	dn.ID = d.GetAddress()
 	return dn

registry/zookeeper/service_discovery.go

@@ -299,6 +299,7 @@ func (zksd *zookeeperServiceDiscovery) toCuratorInstance(instance registry.Servi
 		Port:                instance.GetPort(),
 		Payload:             pl,
 		RegistrationTimeUTC: 0,
+		Tag:                 instance.GetTag(),
 	}
 	return cuis
 }
@@ -327,5 +328,6 @@ func toZookeeperInstance(cris *curator_discovery.ServiceInstance) registry.Servi
 		Enable:      true,
 		Healthy:     true,
 		Metadata:    md,
+		Tag:         cris.Tag,
 	}
 }

remoting/zookeeper/curator_discovery/service_instance.go

@@ -26,4 +26,5 @@ type ServiceInstance struct {
 	Port                int         `json:"port,omitempty"`
 	Payload             interface{} `json:"payload,omitempty"`
 	RegistrationTimeUTC int64       `json:"registrationTimeUTC,omitempty"`
+	Tag                 string      `json:"tag,omitempty"`
 }