diff --git a/cluster/router/chain/chain.go b/cluster/router/chain/chain.go index 71309472e1..cc4ea5fdb0 100644 --- a/cluster/router/chain/chain.go +++ b/cluster/router/chain/chain.go @@ -113,8 +113,10 @@ func NewRouterChain() (*RouterChain, error) { for key, routerFactory := range routerFactories { r, err := routerFactory().NewPriorityRouter() - if r == nil || err != nil { - logger.Warnf("router chain build router fail! routerFactories key:%s reason is :%v", key, err) + if err != nil { + logger.Errorf("Build router chain failed with routerFactories key:%s and error:%v", key, err) + continue + } else if r == nil { continue } routers = append(routers, r) diff --git a/cluster/router/v3router/router_chain.go b/cluster/router/v3router/router_chain.go index 973f98e5a6..427a053feb 100644 --- a/cluster/router/v3router/router_chain.go +++ b/cluster/router/v3router/router_chain.go @@ -48,10 +48,11 @@ func NewUniformRouterChain() (router.PriorityRouter, error) { // 1. add mesh route listener r := &RouterChain{} rootConfig := config.GetRootConfig() - dynamicConfiguration, err := rootConfig.ConfigCenter.GetDynamicConfiguration() - if err != nil { - return nil, err + if rootConfig.ConfigCenter.DynamicConfiguration == nil { + logger.Infof("Config center does not start, please check if the configuration center has been properly configured in dubbogo.yml") + return nil, nil } + dynamicConfiguration := rootConfig.ConfigCenter.DynamicConfiguration dynamicConfiguration.AddListener(rootConfig.Application.Name, r) // 2. try to get mesh route configuration, default key is "dubbo.io.MESHAPPRULE" with group "dubbo" diff --git a/config/config_center_config.go b/config/config_center_config.go index 708f1980d1..8a647721ab 100644 --- a/config/config_center_config.go +++ b/config/config_center_config.go @@ -18,6 +18,7 @@ package config import ( + "fmt" "net/url" "strings" ) @@ -155,7 +156,7 @@ func (c *CenterConfig) CreateDynamicConfiguration() (config_center.DynamicConfig } factory := extension.GetConfigCenterFactory(configCenterUrl.Protocol) if factory == nil { - return nil, errors.New("get config center factory failed") + return nil, errors.New(fmt.Sprintf("Get config center factory of %s failed", configCenterUrl.Protocol)) } return factory.GetDynamicConfiguration(configCenterUrl) } diff --git a/config/root_config.go b/config/root_config.go index 7db0a341da..c1f185cc16 100644 --- a/config/root_config.go +++ b/config/root_config.go @@ -137,7 +137,7 @@ func (rc *RootConfig) Init() error { return err } if err := rc.ConfigCenter.Init(rc); err != nil { - logger.Infof("config center doesn't start, because %s", err) + logger.Infof("Config center doesn't start,because %s", err) } else { if err := rc.Logger.Init(); err != nil { // init logger using config from config center again return err