diff --git a/cluster/directory/base_directory.go b/cluster/directory/base_directory.go index 2bcb3955875f59c748f71d4b929e3ae067d30da9..eeeb8a741bda64211b64c4b999578a460c9d59b7 100644 --- a/cluster/directory/base_directory.go +++ b/cluster/directory/base_directory.go @@ -17,19 +17,21 @@ package directory +import ( + "sync" +) import ( "github.com/apache/dubbo-go/cluster" "github.com/apache/dubbo-go/common/constant" "github.com/apache/dubbo-go/common/extension" - "github.com/dubbogo/gost/container" + "github.com/dubbogo/gost/container/gxset" "go.uber.org/atomic" - "sync" ) import ( "github.com/apache/dubbo-go/common" ) -var RouterUrlSet = container.NewSet() +var RouterUrlSet = gxset.NewSet() type BaseDirectory struct { url *common.URL diff --git a/cluster/directory/static_directory.go b/cluster/directory/static_directory.go index 1f2acdff8a56dd225f53a089c87de4b7d48c4f26..28683b60baa8e628198332dc584b4c11297776d9 100644 --- a/cluster/directory/static_directory.go +++ b/cluster/directory/static_directory.go @@ -19,10 +19,13 @@ package directory import ( "fmt" + "reflect" +) +import ( "github.com/apache/dubbo-go/common" "github.com/apache/dubbo-go/common/constant" + "github.com/apache/dubbo-go/common/logger" "github.com/apache/dubbo-go/protocol" - "reflect" ) type staticDirectory struct { @@ -58,7 +61,7 @@ func (dir *staticDirectory) IsAvailable() bool { func (dir *staticDirectory) List(invocation protocol.Invocation) []protocol.Invoker { invokers := dir.invokers localRouters := dir.routers - fmt.Println("========", len(localRouters)) + logger.Debug("========", len(localRouters)) if len(localRouters) > 0 { for _, router := range localRouters { diff --git a/config/condition_router_config.go b/config/condition_router_config.go index 95df299213841f42b70fd1a814b15e88bbf54c2a..77ab227cecb37b2d37434b8b0db294b1f8735751 100644 --- a/config/condition_router_config.go +++ b/config/condition_router_config.go @@ -84,7 +84,7 @@ func RouterInit(confRouterFile string) error { logger.Debugf("provider config{%#v}\n", routerConfig) directory.RouterUrlSet.Add(initRouterUrl()) - fmt.Println("=====", directory.RouterUrlSet.Size()) + logger.Debug("=====", directory.RouterUrlSet.Size()) return nil }