剔除非本node的服务初始化

This commit is contained in:
duanhf2012
2020-04-23 16:41:23 +08:00
parent cfec29714e
commit 753a2ac05c

View File

@@ -85,6 +85,10 @@ func initNode(id int){
//4.init service //4.init service
for _,s := range preSetupService { for _,s := range preSetupService {
//是否配置的service
if cluster.GetCluster().IsConfigService(s.GetName()) == false {
continue
}
pServiceCfg := cluster.GetCluster().GetServiceCfg(nodeId,s.GetName()) pServiceCfg := cluster.GetCluster().GetServiceCfg(nodeId,s.GetName())
s.Init(s,cluster.GetRpcClient,cluster.GetRpcServer,pServiceCfg) s.Init(s,cluster.GetRpcClient,cluster.GetRpcServer,pServiceCfg)
} }